项目连接数据库
右侧导航栏找到databsae
如果没有驱动，先下载驱动
填写数据库用户名密码
勾选对应的表即可
JDBC代码流程
1,配置信息
2,加载驱动 从MySQL Connector/J 5.1版本开始，推荐使用com.mysql.cj.jdbc.Driver这个新的驱动类。
3,链接数据库
4,向数据库发送SQL的对象statement:CURD
5,编写sql
6,执行查询SQL,返回一个ResultSet 结果集
7，关闭链接，释放资源 一定要做，先开的后关
代码流程如下:
public class TestIdbc {
public static void main(String[] args) throws ClassNotFoundException, SQLException {
//配置信息
//useUnicode=ture&characterEncoding=utf-8解决中文乱码问题
String url="jdbc:mysql://localhost:3306/jdbc?useUnicode=ture&characterEncoding=utf-8";
String username="root";
String password="123456";
//1,加载驱动 从MySQL Connector/J 5.1版本开始，推荐使用com.mysql.cj.jdbc.Driver这个新的驱动类。
Class.forName("com.mysql.cj.jdbc.Driver");
//2,链接数据库
Connection cnno= DriverManager.getConnection(url,username,password);
//3,向数据库发送SQL的对象statement:CURD
Statement sta=cnno.createStatement();
//4，编写sql
String sql="select * from user";
//5,执行查询SQL,返回一个ResultSet 结果集
ResultSet rs=sta.executeQuery(sql);
//4，编写sql
// String sql="update user set name='张三' where id=1";
//5,执行查询SQL,返回一个int 修改的数据条数
// int rs=sta.executeUpdate(sql);
while (rs.next()){
System.out.println("id="+rs.getObject("id"));
System.out.println("name="+rs.getObject("name"));
System.out.println("password="+rs.getObject("password"));
System.out.println("age="+rs.getObject("age"));
System.out.println("address="+rs.getObject("address"));
}
//6，关闭链接，释放资源 一定要做，先开的后关
rs.close();
sta.close();
cnno.close();
}预编译sql
public class TestIdbc2 {
public static void main(String[] args) throws ClassNotFoundException, SQLException {
//配置信息
//useUnicode=ture&characterEncoding=utf-8解决中文乱码问题
String url="jdbc:mysql://localhost:3306/jdbc?useUnicode=ture&characterEncoding=utf-8";
String username="root";
String password="123456";
//1,加载驱动 从MySQL Connector/J 5.1版本开始，推荐使用com.mysql.cj.jdbc.Driver这个新的驱动类。
Class.forName("com.mysql.cj.jdbc.Driver");
//2,链接数据库
Connection cnno= DriverManager.getConnection(url,username,password);
//3，编写sql
String sql="insert into user(id,name,password,address,age,eamil) values (?,?,?,?,?,?)";
//4,预编译
PreparedStatement preparedStatement= cnno.prepareStatement(sql);
preparedStatement.setInt(1,3);//给第一个占位符？的赋值为1
preparedStatement.setString(2,"我们");//给第二一个占位符？的赋值为1
preparedStatement.setString(3,"12345");
preparedStatement.setString(4,"成都");
preparedStatement.setString(5,"18");
preparedStatement.setString(6,"11.qq.com");
//5,执行sql
int i=preparedStatement.executeUpdate();
if(i > 0){
System.out.println("成功");
}
//6，关闭链接，释放资源 一定要做，先开的后关
preparedStatement.close();
cnno.close();
}
}
JDBC事务
ACID原则：保证数据的安全性,要么都成功，要么都不成功
开启事务 start transaction;
事务提交 commit()
事务回滚 rollback()
关闭事务
单元测试依赖junit
<!--单元测试 方法上加@Test即可运行测试-->
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>4.13.2</version>
<scope>test</scope>
</dependency>事务案例
public class TestIdbc3 {
public static void main(String[] args){
//配置信息
//useUnicode=ture&characterEncoding=utf-8解决中文乱码问题
String url="jdbc:mysql://localhost:3306/jdbc?useUnicode=ture&characterEncoding=utf-8";
String username="root";
String password="123456";
Connection cnno = null;
try {
//1,加载驱动 从MySQL Connector/J 5.1版本开始，推荐使用com.mysql.cj.jdbc.Driver这个新的驱动类。
Class.forName("com.mysql.cj.jdbc.Driver");
//2,链接数据库
cnno= DriverManager.getConnection(url,username,password);
//通知数据库开启是事务
cnno.setAutoCommit(false);
//3，编写sql
String sql="update account set money = money-100 where name='A'";
// 执行sql
cnno.prepareStatement(sql).executeUpdate();
//制造错误
int i=1/0;
String sql2="update account set money = money+100 where name='B'";
// 执行sql
cnno.prepareStatement(sql2).executeUpdate();
cnno.commit();
} catch (Exception e) {
try {
//如果出现异常，通知数据库回滚
cnno.rollback();
} catch (SQLException throwables) {
throwables.printStackTrace();
}
e.printStackTrace();
}finally {
//6，关闭链接，释放资源 一定要做，先开的后关
try {
cnno.close();
} catch (SQLException throwables) {
throwables.printStackTrace();
}
}
}
}
