JDBC操作

短命女 2023-10-04 07:53 22阅读 0赞

#### 文章目录 ####

*  JDBC的创建流程
 *   *  注册驱动
     *  创建链接
     *  执行SQL语句
     *  获取结果集
     *  释放资源
 *  JDBC工具类的抽取

JDBC全称为Java Database Connectivity，即Java与数据库的链接方式。针对于不同的数据库，可以调用不同的驱动包，通过JDBC来完成Java程序同数据库的交互。

## JDBC的创建流程 ##

### 注册驱动 ###

调用DriverManager的registerDriver方法注册驱动。

DriverManager.registerDriver(new Driver());

如果查看Driver的源代码，可以看到该类中存在一个静态代码块，在静态代码块中会调用registerDriver注册驱动，所以一般使用`Class.forname("com.mysql.cj.jdbc.Driver")`来注册驱动

public class Driver extends NonRegisteringDriver implements java.sql.Driver {
        
        public Driver() throws SQLException {
        
        }
    
        static {
        
            try {
        
                DriverManager.registerDriver(new Driver());
            } catch (SQLException var1) {
        
                throw new RuntimeException("Can't register driver!");
            }
        }
    }

### 创建链接 ###

使用DriverManager的getConnection(String url, String user, String password)方法创建数据的链接，其中方法中的url参数是JDBC的协议描述，主要由一下几个部分组成

*  jdbc ： 协议
 *  mysql ：子协议
 *  localhost ： 数据库IP
 *  3306 ： 数据库端口
 *  mysqltest ： 需要链接的数据库

如果数据库在本地，则可以使用简写的方式`jdbc:mysql:///mysqltest`

另外两个参数就是数据库的用户名和密码，最后会返回一个Connection对象

Connection connection = DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/mysqltest", "root", "root");

### 执行SQL语句 ###

通过创建链接的返回的Connection对象，创建执行SQL的对象，这里主要包含3种：

*  createStatement() ：创建执行SQL的对象，返回Statement对象，但是存在SQL注入漏洞
 *  preparedStatement(String sql) ：预处理SQL语句，返回PreparedStatement对象，可以有效的避免SQL注入漏洞
 *  prepareCall(String sql) ：执行存储过程，返回CallableStatement对象

> PreparedStatement与CallableStatement都是Statement对象的子类接口，继承了父类的方法

Connection对象除了能够创建执行SQL的对象，还可以对事务进行管理：

*  setAutoCommit(boolean autoCommit) ：设置事务是否自动提交，当autoCommit为false时执行的SQL将不会自动提交，需要手动提交
 *  commit() ：提交事务
 *  rollback() ：回滚事务

通过Connection创建执行对象Statement后，就需要去执行SQL语句，Statement对象存在3种执行方法

*  execute(String sql) ：执行任意形式的SQL语句，返回布尔值，如果是查询结果就返回true，如果是操作语句就返回false
 *  executeQuery(String sql) ：执行查询语句，将查询结果放入ResultSet对象中，并将其返回
 *  executeUpdate(String sql) ：执行update/insert/delete语句，返回int类型的值，记录SQL语句最后操作了多少条数据

除了可以执行SQL还可以执行批处理，主要操作也是3种：

*  addBatch() ：添加批处理
 *  executeBatch() ：执行批处理
 *  clearBatch() ：清除批处理

### 获取结果集 ###

执行完成查询语句之后，会将数据结果存在ResultSet中，ResultSet类提供了next()方法，用于逐行读取ResultSet中的数据，同时可以通过getXXX()方法对字段的值进行，如果字段属性为String就可以使用getString(String columnLabel)参数填写字段名称就可以获取字段的值。

> ResultSet对象类似于一个表格，ResultSet对象初始是在第一行前面，通过调用next()方法可以使其指向下一行数据

这里要单独说一下对于时间类型的字段，ResultSet提供了三个方法用于获取时间类型字段的值

*  getDate()/setDate() ：获取/设置时间的年月日，返回java.sql.Date对象
 *  getTime()/setTime() ：获取/设置时间的时分秒，返回java.sql.Time对象
 *  getTimestamp()/setTimestamp() ：获取/设置时间的年月日时分秒毫秒，返回java.sql.Timestamp对象

JDBC提供的三种时间类都是java.util.Date的子类，所以JDBC的类可以直接赋值给java.util.Date类，但如果反过来将java.util.Date赋值给java.sql.Timestamp类就需要用到类的构造方法`public Timestamp(long time)`，参数为时间的毫秒数。

### 释放资源 ###

对数据库操作完成后，要对创建的资源进行释放，例如：Connection, Statement, ResultSet对象。尤其是Connection对象，用完之后要及时释放，若不能及时关闭、释放极易造成服务器宕机，所以Connection要做到晚创建，早释放。由于注册驱动必然需要捕获异常，所以释放资源一般要放在finally中进行执行。

package com.jdbc;
    
    import org.junit.Test;
    import java.sql.*;
    
    public class JDBCTest {
        
        @Test
        public void test() {
        
            Connection connection = null;
            Statement statement = null;
            ResultSet resultSet = null;
            try {
        
                // 1.注册驱动
                Class.forName("com.mysql.cj.jdbc.Driver");
                // 2.创建链接
                String jdbc = "jdbc:mysql://127.0.0.1:3306/mysqltest";
                connection = DriverManager.getConnection(jdbc, "root", "root");
    
                // 3.执行SQL语句，获取结果
                String sql = "SELECT * FROM tb_employee";
                // 创建SQL对象
                statement = connection.createStatement();
                resultSet = statement.executeQuery(sql);
    
                // 获取结果
                while (resultSet.next()) {
        
                    String empId = resultSet.getString("empId");
                    String name = resultSet.getString("name");
                    Integer depId = resultSet.getInt("depId");
    
                    System.out.println("empId:" + empId + "; name:" + name + "; depId:" + depId);
                }
    
                // 释放资源
                resultSet.close();
                statement.close();
                connection.close();
    
            } catch (Exception e) {
        
                e.printStackTrace();
            } finally {
        
                if (resultSet != null) {
        
                    try {
        
                        resultSet.close();
                    } catch (SQLException e) {
        
                        e.printStackTrace();
                    }
                    
                    resultSet = null;
                }
                
                if (statement != null) {
        
                    try {
        
                        statement.close();
                    } catch (SQLException e) {
        
                        e.printStackTrace();
                    }
                    
                    statement = null;
                }
                
                if (connection != null) {
        
                    try {
        
                        connection.close();
                    } catch (SQLException e) {
        
                        e.printStackTrace();
                    }
                    
                    // Java中垃圾回收机制会将为null的对象进行回收
                    connection = null;
                }
            }
        }
    
    }

## JDBC工具类的抽取 ##

如果每实现一个功能都要去重复书写JDBC的创建流程，会显得十分臃肿，所以我们可以对注册驱动、创建数据库链接对象和销毁资源进行封装，将其封装为工具类。

其中引入了资源文件的用法，将.properties文件作为配置文件，将数据库的驱动包路径，链接协议，数据库用户名和密码存放在配置文件中，通过创建Properties对象来解析配置文件。

这里要注意资源文件输入流的创建，不推荐使用常规的相对路径来寻找文件，因为在Java Web中是无法识别相对路径，所以要使用类的加载器的方式获取文件输入流。

package com.jdbc.utils;
    
    import java.io.IOException;
    import java.io.InputStream;
    import java.sql.*;
    import java.util.Properties;
    
    public class JDBCUtils {
        
        private static final String jdbcDriver;
        private static final String url;
        private static final String username;
        private static final String password;
    
        static {
        
            // 创建资源对象
            Properties properties = new Properties();
    
            // 获取资源文件的输入流
            InputStream inputStream = JDBCUtils.class.getClassLoader().getResourceAsStream("jdbc.properties");
            try {
        
                // 解析资源文件
                properties.load(inputStream);
            } catch (IOException e) {
        
                e.printStackTrace();
            }
    
            jdbcDriver = properties.getProperty("jdbcDriver");
            url = properties.getProperty("url");
            username = properties.getProperty("username");
            password = properties.getProperty("password");
        }
    
        /**
         * 注册JDBC驱动
         * @throws ClassNotFoundException
         */
        public static void loadDriver() throws ClassNotFoundException {
        
            Class.forName(jdbcDriver);
        }
    
        /**
         * 创建数据库链接
         * @return
         */
        public static Connection getConnection() throws Exception {
        
            loadDriver();
            return DriverManager.getConnection(url, username, password);
        }
    
        /**
         * 释放资源
         * @param connection
         * @param statement
         */
        public static void release(Connection connection, Statement statement) {
        
            if (statement != null) {
        
                try {
        
                    statement.close();
                } catch (SQLException e) {
        
                    e.printStackTrace();
                }
    
                statement = null;
            }
    
            if (connection != null) {
        
                try {
        
                    connection.close();
                } catch (SQLException e) {
        
                    e.printStackTrace();
                }
    
                connection = null;
            }
        }
    
        /**
         * 释放资源
         * @param connection
         * @param statement
         * @param resultSet
         */
        public static void release(Connection connection, Statement statement, ResultSet resultSet) {
        
            if (resultSet != null) {
        
                try {
        
                    resultSet.close();
                } catch (SQLException e) {
        
                    e.printStackTrace();
                }
    
                resultSet = null;
            }
    
            if (statement != null) {
        
                try {
        
                    statement.close();
                } catch (SQLException e) {
        
                    e.printStackTrace();
                }
    
                statement = null;
            }
    
            if (connection != null) {
        
                try {
        
                    connection.close();
                } catch (SQLException e) {
        
                    e.printStackTrace();
                }
    
                connection = null;
            }
        }
    }