我要评论JDBC的简单介绍
概念
- JDBC ： Java Database Connectivity，java连接数据库，使用Java操作数据库的技术。
- 本质 ： 其实就是sun公司定义的一套操作所有关系型数据库的规则，即接口。
各个数据库厂商去实现这套接口，提供数据库操作驱动jar包，我们可以使用这套
接口进行（JDBC）编程，真正执行的代码是驱动jar包的实现类。
快速入门
本人使用的是jdk10和mysql-connector-java-5.1.45-bin.jar。
步骤：
- 导入驱动jar包
- 项目根目录创建文件夹libs。
- 将mysql-connector-java-5.1.45-bin.jar复制到libs目录下
- 右击libs下，Add as Library将jar包导入项目中
- 注册驱动
- 获取数据库连接对象（Collection）
- 定义sql
- 获取执行sql语句的对象 Statement
- 执行sql，接受返回结果（ResultSet）
- 处理结果
释放资源
// 2. 注册驱动 Class.forName("com.mysql.jdbc.Driver"); // 3. 获取连接对象Collection Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/db1", "root", "nrblwbb7"); // 4. 定义sql String sql = "UPDATE STUDENT SET AGE = 23 WHERE NAME = '王智'"; // 5. 获取执行sql语句的对象 Statement Statement statement = conn.createStatement(); // 6. 执行sql，接受返回结果（ResultSet） int result = statement.executeUpdate(sql); // 7. 处理结果 System.out.println(result); // 8. 释放资源 statement.close(); conn.close();
详解各个对象
- DriverManager：驱动管理对象
- Connection：数据库连接对象
- Statement：执行sql对象
- ResultSet：结果集对象
- PreparedStatement ：执行sql对象
DriverManager
功能：
- 注册驱动：告诉程序该使用哪一个数据库驱动jar
- 使用的方法：static void registerDriver(Driver driver) :注册与给定的驱动程序 DriverManager 。
- 写代码使用：Class.forName("com.mysql.jdbc.Driver");
通过查看源码发现：在com.mysql.jdbc.Driver类中存在静态代码块
static { try { java.sql.DriverManager.registerDriver(new Driver()); } catch (SQLException E) { throw new RuntimeException("Can't register driver!"); } }注意：mysql5之后的驱动jar包可以省略注册驱动的步骤。
- 获取数据库连接
- 方法：static Connection getConnection(String url, String user, String password)
- 参数：
- url：指定连接的路径
- 语法：jdbc:mysql://ip地址(域名):端口号/数据库名称
- 例子：jdbc:mysql://localhost:3306/db
- 细节：如果连接的是本机mysql服务器，并且mysql服务默认端口是3306，则url可以简写为：jdbc:mysql:///数据库名称
- jdbc是连接数据库的协议，mysql是连接mysql数据库的子协议
- user：用户名
- password：密码
- url：指定连接的路径
Collection连接对象
功能：
- 获取执行sql的对象
- Statement createStatement()
- PreparedStatement prepareStatement(String sql)
- 管理事务
- 开启事务：setAutoCommit(boolean autoCommit) ：调用该方法设置参数为false，即开启事务
- 提交事务：commit()
- 回滚事务：rollback()
Statement执行静态sql对象
功能：
- 执行sql
- boolean execute(String sql) ：可以执行任意的sql （了解）
- int executeUpdate(String sql) ：执行DML（insert、update、delete）语句、DDL(create，alter、drop)语句
- 返回值：影响的行数，可以通过这个影响的行数判断DML语句是否执行成功 返回值>0的则执行成功，反之，则失败。
- ResultSet executeQuery(String sql) ：执行DQL（select)语句
插入举例：
public static void main(String[] args) {
Connection conn = null;
Statement stmt = null;
try {
// 1. 加载驱动
Class.forName("com.mysql.jdbc.Driver");
// 2. 获取连接对象
conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/db3?useSSL=true", "root", "nrblwbb7");
// 3. 创建sql
String sql = "INSERT INTO ACCOUNT VALUES (NULL,'网址',2000)";
// 4. 获取执行sql对象
stmt = conn.createStatement();
// 5. 执行sql
int count = stmt.executeUpdate(sql);
// 6. 处理结果
System.out.println("影响的行数为：" + count);
if(count > 0){
System.out.println("插入成功");
}else{
System.out.println("操作失败");
}
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (SQLException e) {
e.printStackTrace();
} finally {
// 7. 释放资源
if(stmt != null){
try {
stmt.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
if(conn != null){
try {
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
｝
修改举例：
public static void main(String[] args) {
/**
* 由于Connection和Statement实现了AutoCloseable接口，所以可以使用自动关闭
*/
try(
// 2.获取Connection对象
Connection conn = DriverManager.getConnection(
"jdbc:mysql://localhost:3306/db3?useSSL=true",
"root",
"nrblwbb7") ;
// 3. 获取Statement对象
Statement stmt = conn.createStatement()
){
// 1.加载驱动
Class.forName("com.mysql.jdbc.Driver");
// 4. 创建sql
String sql = "UPDATE ACCOUNT SET BALANCE = 1500 WHERE NAME = '网址'";
// 5. 执行sql
int count = stmt.executeUpdate(sql);
// 6. 处理结果
System.out.println(count);
if(count > 0){
System.out.println("修改成功");
}else{
System.out.println("操作失败或者记录未更改");
}
// 7. 关闭连接，由于try..with..resource会自动关闭，所以无须担心
} catch (SQLException e) {
e.printStackTrace();
} catch (ClassNotFoundException e) {
e.printStackTrace();
}
}
删除举例：
public static void main(String[] args) {
/**
* 由于Connection和Statement实现了AutoCloseable接口，所以可以使用自动关闭
*/
try(
// 2.获取Connection对象
Connection conn = DriverManager.getConnection(
"jdbc:mysql://localhost:3306/db3?useSSL=true",
"root",
"nrblwbb7") ;
// 3. 获取Statement对象
Statement stmt = conn.createStatement()
){
// 1.加载驱动
Class.forName("com.mysql.jdbc.Driver");
// 4. 创建sql
String sql = "DELETE FROM ACCOUNT WHERE NAME = '网址'";
// 5. 执行sql
int count = stmt.executeUpdate(sql);
// 6. 处理结果
System.out.println(count);
if(count > 0){
System.out.println("删除成功");
}else{
System.out.println("删除失败");
}
// 7. 关闭连接，由于try..with..resource会自动关闭，所以无须担心
} catch (SQLException e) {
e.printStackTrace();
} catch (ClassNotFoundException e) {
e.printStackTrace();
}
}
ResultSet:结果及对象，封装查询结果
功能：
- 封装查询结果：
- boolean next(): 游标向下移动一行，判断当前行是否是最后一行末尾(是否有数据)，如果是，则返回false，如果不是则返回true
- getXxx(参数):获取数据
- Xxx：代表数据类型 如： int getInt() , String getString()
- 参数：
- int：代表列的编号,从1开始 如： getString(1)
- String：代表列名称。 如： getDouble("balance")
- 注意：
- 使用步骤：
- 游标向下移动一行
- 判断是否有数据
- 获取数据
- 使用步骤：
举个简单例子：
@Test
public void selectDemo(){
try {
// 1.加载驱动
Class.forName("com.mysql.jdbc.Driver");
// 2.创建sql语句
String sql = "select * from account";
try(
// 3.获取连接对象
Connection conn = DriverManager.getConnection(
"jdbc:mysql://localhost:3306/db3?useSSL=true",
"root",
"root");
// 4.获取执行sql语句对象
Statement stmt = conn.createStatement()
){
// 5.执行sql
ResultSet rs = stmt.executeQuery(sql);
// 6.处理结果集
while(rs.next()){
// 获取id
int id = rs.getInt("id");
// 获取姓名
String name = rs.getString("name");
// 获取账户余额
double balance = rs.getDouble("balance");
// 正确的处理应该是封装为对象，进行处理，这就简单展示下
System.out.println("id = " + id + ", name = " + name + ", balance = " + balance);
}
} catch (SQLException e) {
e.printStackTrace();
}
} catch (ClassNotFoundException e) {
e.printStackTrace();
}
}
PreparedStatement：执行动态sql的对象
功能：
- 执行动态的sql
- SQL注入问题：在拼接sql时，有一些sql的特殊关键字参与字符串的拼接。会造成安全性问题
- 输入用户随便，输入密码：a' or 'a' = 'a
- sql：select * from user where username = 'fhdsjkf' and password = 'a' or 'a' = 'a'
- 解决sql注入问题：使用PreparedStatement对象来解决
- 预编译的SQL：参数使用?作为占位符
- 步骤：
- 导入驱动jar包 mysql-connector-java-5.1.45-bin.jar
- 注册驱动
- 获取数据库连接对象 Connection
- 定义sql
- 注意：sql的参数使用？作为占位符。 如：select * from user where username = ? and password = ?;
- 获取执行sql语句的对象 PreparedStatement Connection.prepareStatement(String sql)
- 给？赋值：
- 方法： setXxx(参数1,参数2)
- 参数1：？的位置编号 从1 开始
- 参数2：？的值
- 方法： setXxx(参数1,参数2)
- 执行sql，接受返回结果，不需要传递sql语句
- 处理结果
- 释放资源
- 注意：后期都会使用PreparedStatement来完成增删改查的所有操作
- 可以防止SQL注入
- 效率更高
- SQL注入问题：在拼接sql时，有一些sql的特殊关键字参与字符串的拼接。会造成安全性问题
封装工具类
src下db.properties的信息：
# 驱动 driver=com.mysql.jdbc.Driver # url url=jdbc:mysql://127.0.0.1:3306/db3?useSSL=true # 用户 username=root # 密码 password=root
封装的工具类如下：
public class JDBCUtils {
private static String driver;
private static String url;
private static String username;
private static String password;
static{
try {
// 读取配置文件
InputStream inputStream = JDBCUtils.class.getClassLoader().getResourceAsStream("db.properties");
Properties pro = new Properties();
pro.load(inputStream);
// 静态变量赋值
driver = pro.getProperty("driver");
url = pro.getProperty("url");
username = pro.getProperty("username");
password = pro.getProperty("password");
// 注册驱动
Class.forName(driver);
} catch (IOException e) {
e.printStackTrace();
} catch (ClassNotFoundException e) {
e.printStackTrace();
}
}
/**
* 获取连接对象
* @return 返回连接对象
*/
public static Connection getConn() throws SQLException {
return DriverManager.getConnection(url,username,password);
}
/**
* 关闭资源
* @param stmt
* @param conn
*/
public static void close(Statement stmt,Connection conn){
if(stmt != null){
try {
stmt.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
if(conn != null){
try {
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
/**
* 关闭资源
* @param rs
* @param stmt
* @param conn
*/
public static void close(ResultSet rs, Statement stmt, Connection conn){
if(rs != null){
try {
rs.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
if(stmt != null){
try {
stmt.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
if(conn != null){
try {
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
}
事务管理
- 事务：一个包含多个步骤的业务操作。如果这个业务操作被事务管理，则这多个步骤要么同时成功，要么同时失败。
- 操作：
- 开启事务
- 提交事务
- 回滚事务
- 使用Connection对象来管理事务
- 开启事务：setAutoCommit(boolean autoCommit) ：调用该方法设置参数为false，即开启事务
- 在执行sql之前开启事务
- 提交事务：commit()
- 当所有sql都执行完提交事务
- 回滚事务：rollback()
- 在catch中回滚事务
测试：
public static void main(String[] args) { Connection conn = null; PreparedStatement pstmt1 = null; PreparedStatement pstmt2 = null; try { // 1.创建sql，转账的sql String sql1 = "UPDATE ACCOUNT SET BALANCE = BALANCE - ? WHERE ID = ?"; String sql2 = "UPDATE ACCOUNT SET BALANCE = BALANCE + ? WHERE ID = ?"; // 2.获取连接对象 conn = JDBCUtils.getConn(); // 开启事务 conn.setAutoCommit(false); // 3.获取执行sql对象，进行预编译 pstmt1 = conn.prepareStatement(sql1); pstmt2 = conn.prepareStatement(sql2); // 4.替换占位符 pstmt1.setDouble(1,500); pstmt1.setInt(2,1); pstmt2.setDouble(1,500); pstmt2.setInt(2,2); // 5.执行sql pstmt1.executeUpdate(); // int i = 3 / 0; pstmt2.executeUpdate(); // 提交事务 conn.commit(); } catch (Exception e) { if(conn != null) { try { // 事务回滚 conn.rollback(); } catch (SQLException e1) { e1.printStackTrace(); } } e.printStackTrace(); } finally { JDBCUtils.close(pstmt1,conn); JDBCUtils.close(pstmt2,null); } } - 开启事务：setAutoCommit(boolean autoCommit) ：调用该方法设置参数为false，即开启事务
您可能感兴趣的文章:
如您对本文有疑问或者有任何想说的，请 点击进行留言回复，万千网友为您解惑！
网友评论