【web】JDBC
项目连接数据库
右侧导航栏找到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:CURDStatement sta=cnno.createStatement();//4，编写sqlString 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，编写sqlString sql="insert into user(id,name,password,address,age,eamil) values (?,?,?,?,?,?)";//4,预编译PreparedStatement preparedStatement= cnno.prepareStatement(sql);preparedStatement.setInt(1,3);//给第一个占位符？的赋值为1preparedStatement.setString(2,"我们");//给第二一个占位符？的赋值为1preparedStatement.setString(3,"12345");preparedStatement.setString(4,"成都");preparedStatement.setString(5,"18");preparedStatement.setString(6,"11.qq.com");//5,执行sqlint 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，编写sqlString sql="update account set money = money-100 where name='A'";// 执行sqlcnno.prepareStatement(sql).executeUpdate();//制造错误int i=1/0;String sql2="update account set money = money+100 where name='B'";// 执行sqlcnno.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();}}}
}