JDBC

JDBC

JDBC

概念

Java DataBase Connectivity Java 数据库连接， Java语言操作数据库。

JDBC本质：其实是官方（sun公司）定义的一套操作所有关系型数据库的规则，即接口。各个数据库厂商去实现这套接口，提供数据库驱动jar包。我们可以使用这套接口（JDBC）编程，真正执行的代码是驱动jar包中的实现类。

步骤

1. 导入驱动jar包 mysql-connector-java-5.1.37-bin.jar

   1. 复制mysql-connector-java-5.1.37-bin.jar到项目的libs目录下

   2. 右键-->Add As Library

2. 注册驱动

3. 获取数据库连接对象 Connection

4. 定义sql

5. 获取执行sql语句的对象 Statement

6. 执行sql，接受返回结果

7. 处理结果

8. 释放资源

代码实现

public class Demo01 {
    public static void main(String[] args) throws Exception {
        // 注册驱动
        Class.forName("com.mysql.jdbc.Driver");
        // 获取数据库连接对象
        Connection coon = DriverManager.getConnection("jdbc:mysql://localhost:3306/db3", "root", "root");
        // 定义sql语句
        String sql = "update student set age=55 where id = 1";
        // 获取执行sql的对象 Statement
        Statement stem = coon.createStatement();
        // 执行sql
        int i = stem.executeUpdate(sql);
        // 处理结果
        System.out.println(i);
        // 释放资源
        stem.close();
        coon.close();
    }
}

详解各个对象

DriverManager：驱动管理对象

功能

• 注册驱动：告诉程序该使用哪一个数据库驱动jar

  static void registerDriver(Driver driver) :注册与给定的驱动程序 DriverManager 。

  写代码使用： Class.forName("com.mysql.jdbc.Driver");

  通过查看源码发现：在com.mysql.jdbc.Driver类中存在静态代码块

static {
    try {
        DriverManager.registerDriver(new Driver());
    } catch (SQLException var1) {
        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/db3

  • 细节：如果连接的是本机mysql服务器，并且mysql服务默认端口是3306，则url可以简写为：jdbc:mysql:///数据库名称

• user：用户名

• password：密码

---

Connection：数据库连接对象

功能

• 获取执行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)语句

---

ResultSet：结果集对象,封装查询结果

boolean next(): 游标向下移动一行，判断当前行是否是最后一行末尾(是否有数据)，如果是，则返回false，如果不是则返回true

getXxx(参数):获取数据

• Xxx：代表数据类型 如： int getInt() , String getString()

参数：

• int：代表列的编号,从1开始 如： getString(1)

• String：代表列名称。 如： getDouble("balance")

注意：

1. 游标向下移动一行

2. 判断是否有数据

3. 获取数据

//循环判断游标是否是最后一行末尾。

while(rs.next()){
    //获取数据
    int id = rs.getInt(1);
    String name = rs.getString("name");
    double balance = rs.getDouble(3);
​
    System.out.println(id + "---" + name + "---" + balance);
}

抽取JDBC工具类 ： JDBCUtils

目的：简化书写

分析：

1. 注册驱动也抽取

2. 抽取一个方法获取连接对象

   • 需求：不想传递参数（麻烦），还得保证工具类的通用性。

   • 解决：配置文件

   url=
   user=
   password=

3. 抽取一个方法释放资源

   public class JdbcUtils {
       // 定义静态成员变量
       private static String url;
       private static String user;
       private static String password;
       private static String driver;
   ​
       static {
           // 读取资源文件，获取值
           try {
               // 创建Properties集合类
               Properties pro = new Properties();
               // 加载文件
               ClassLoader classLoader = JdbcUtils.class.getClassLoader();
               URL resource = classLoader.getResource("jdbc.properties");
               String path = resource.getPath();
               // System.out.println(path);
   ​
               pro.load(new FileReader(path));
               // pro.load(new FileReader("src/jdbc.properties"));
               // 获取数据，赋值
               url = pro.getProperty("url");
               user = pro.getProperty("user");
               password = pro.getProperty("password");
               driver = pro.getProperty("driver");
               // 注册驱动
               Class.forName(driver);
   ​
           } catch (IOException e) {
               e.printStackTrace();
           } catch (ClassNotFoundException e) {
               e.printStackTrace();
           }
   ​
       }
   ​
   ​
       public static Connection getConnection() throws SQLException {
           return DriverManager.getConnection(url, user, password);
       }
   ​
       public static void close(Statement statement, Connection connection) {
           if (statement != null) {
               try {
                   statement.close();
               } catch (SQLException e) {
                   e.printStackTrace();
               }
           }
           if (connection != null) {
               try {
                   connection.close();
               } catch (SQLException e) {
                   e.printStackTrace();
               }
           }
       }
   ​
       public static void close(ResultSet resultSet, Statement statement, Connection connection) {
           if (resultSet != null) {
               try {
                   resultSet.close();
               } catch (SQLException e) {
                   e.printStackTrace();
               }
           }
           if (statement != null) {
               try {
                   statement.close();
               } catch (SQLException e) {
                   e.printStackTrace();
               }
           }
           if (connection != null) {
               try {
                   connection.close();
               } catch (SQLException e) {
                   e.printStackTrace();
               }
           }
       }
   }

JDBC控制事务：

1. 事务：一个包含多个步骤的业务操作。如果这个业务操作被事务管理，则这多个步骤要么同时成功，要么同时失败。

2. 操作：

   • 开启事务

   • 提交事务

   • 回滚事务

3. 使用Connection对象来管理事务

   • 开启事务：setAutoCommit(boolean autoCommit) ：调用该方法设置参数为false，即开启事务

     • 在执行sql之前开启事务

   • 提交事务：commit()

     • 当所有sql都执行完提交事务

   • 回滚事务：rollback()

     • 在catch中回滚事务

public class JDBCDemo10 {
​
    public static void main(String[] args) {
        Connection conn = null;
        PreparedStatement pstmt1 = null;
        PreparedStatement pstmt2 = null;
​
        try {
            //1.获取连接
            conn = JDBCUtils.getConnection();
            //开启事务
            conn.setAutoCommit(false);
​
            //2.定义sql
            //2.1 张三 - 500
            String sql1 = "update account set balance = balance - ? where id = ?";
            //2.2 李四 + 500
            String sql2 = "update account set balance = balance + ? where id = ?";
            //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) {
            //事务回滚
            try {
                if (conn != null) {
                    conn.rollback();
                }
            } catch (SQLException e1) {
                e1.printStackTrace();
            }
            e.printStackTrace();
        } finally {
            JDBCUtils.close(pstmt1, conn);
            JDBCUtils.close(pstmt2, null);
        }
    }
​
}