Connection（数据库连接对象）

简介&＃xff1a;通过代码来讲解Connection的含义。
推荐学习路线&＃xff1a;JDBC数据库的连接->Connection&＃xff08;数据库连接对象&＃xff09;->Statement->ResultSet->通过PreparedStatement预防SQL注入->通过PreparedStatement预防SQL注入->JDBC增删改查案例讲解 大家跟着敲完基本就可以JDBC基础毕业了。

演示代码

/**
* JDBC API 详解&＃xff1a;Connection
*/
public class JDBCDemo_Connection {
public static void main(String[] args) throws Exception {
//1. 注册驱动
Class.forName("com.mysql.cj.jdbc.Driver");
//2. 获取连接
// String url &＃61; "jdbc:mysql://127.0.0.1:3306/books"; // 如果是mysql5这样写
String url &＃61; "jdbc:mysql://localhost:3306/books?serverTimezone&＃61;GMT%2B8&useOldAliasMetadataBehavior&＃61;true"; // 如果是mysql8这样写
String username &＃61; "root";
String password &＃61; "1234";
Connection conn &＃61; DriverManager.getConnection(url, username, password);
//3. 定义sql
String sql1 &＃61; "update book set price &＃61; price - 8 where reclD &＃61; 1";
String sql2 &＃61; "update book set price &＃61; price - 8 where reclD &＃61; 2";
String sql3 &＃61; "update book set price &＃61; price - 8 where reclD &＃61; 3";
//4. 获取执行sql的对象 Statement
Statement stmt &＃61; conn.createStatement();
try {
// &＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;开启事务&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;
conn.setAutoCommit(false); // 加上这几句之后 如果发生异常就会回滚 然后数据不会发生改变
// 如果没有发生异常 但是发现数据库里面的数据没有改变
// 可以把这里改成true 不改的话内存里面的数据改了 但是显示的没有改
//5. 执行sql
int count1 &＃61; stmt.executeUpdate(sql1);//受影响的行数
//6. 处理结果
System.out.println(count1);
//5. 执行sql
int count2 &＃61; stmt.executeUpdate(sql2);//受影响的行数
//6. 处理结果
System.out.println(count2);
// &＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;提交事务&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;
//程序运行到此处&＃xff0c;说明没有出现任何问题&＃xff0c;则需求提交事务
conn.commit();
} catch (Exception e) {
// &＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;回滚事务&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;
//程序在出现异常时会执行到这个地方&＃xff0c;此时就需要回滚事务
conn.rollback();
e.printStackTrace();
}
//7. 释放资源
stmt.close();
conn.close();
}
}


运行结果&＃xff1a;

代码分析

使用Connection的步骤

导入自己的各种信息

//1. 注册驱动
Class.forName("com.mysql.cj.jdbc.Driver");
//2. 获取连接
// String url &＃61; "jdbc:mysql://127.0.0.1:3306/books"; // 如果是mysql5这样写
String url &＃61; "jdbc:mysql://localhost:3306/books?serverTimezone&＃61;GMT%2B8&useOldAliasMetadataBehavior&＃61;true"; // 如果是mysql8这样写
String username &＃61; "root";
String password &＃61; "wtc2002516ssst1";


创建Connection对象

Connection conn &＃61; DriverManager.getConnection(url, username, password);


定义sql语句

//3. 定义sql
String sql1 &＃61; "update book set price &＃61; price - 8 where reclD &＃61; 1";
String sql2 &＃61; "update book set price &＃61; price - 8 where reclD &＃61; 2";
String sql3 &＃61; "update book set price &＃61; price - 8 where reclD &＃61; 3";


调用creatStatement()方法

//4. 获取执行sql的对象 Statement
Statement stmt &＃61; conn.createStatement();


Connection的理解

这就是Connection(数据库连接对象) 的在代码中的涉及部分&＃xff0c;那么Connection到底是什么了&＃xff0c;就跟它的名字一样&＃xff0c;数据库连接对象&＃xff0c;从面相对象的角度理解&＃xff0c;这个对象就是封装了去连接整个数据库信息的用户的各种信息&＃xff0c;比如url,password,username&＃xff0c;这些信息&＃xff0c;把这些信息封装打包&＃xff0c;成为一个Connection&＃xff08;数据库连接对象&＃xff09;,然后就可以通过这个封装好的对象去进行一系列操作了。

其他信息

Connection&＃xff08;数据库连接对象&＃xff09;作用&＃xff1a;

• 获取执行 SQL 的对象
• 管理事务