Java DbUtils 操作數據庫

 

示例

1、新建項目，把數據庫驅動、DbUtils的jar包添加到項目中

 

2、新建文件夾resource，標識為資源根目錄，下面新建數據庫連接的配置文件mysql.properties

driver=com.mysql.cj.jdbc.Driver
url=jdbc:mysql://localhost:3306/my_db?serverTimezone=GMT
user=chy
password=abcd

?serverTimezone=GMT是為了解決時區問題，GMT、UTC均可。

 

3、新建實體類bean.Student

package bean;

public class Student {
    private int id;
    private String name;
    private int age;
    private int score;

    public Student() {
    }

    public Student(int id, String name, int age, int score) {
        this.id = id;
        this.name = name;
        this.age = age;
        this.score = score;
    }

    public int getId() {
        return id;
    }

    public void setId(int id) {
        this.id = id;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public int getAge() {
        return age;
    }

    public void setAge(int age) {
        this.age = age;
    }

    public int getScore() {
        return score;
    }

    public void setScore(int score) {
        this.score = score;
    }

    @Override
    public String toString() {
        return "Student{" +
                "id=" + id +
                ", name='" + name + '\'' +
                ", age=" + age +
                ", score=" + score +
                '}';
    }
}

DbUtils將結果集中的記錄映射到JavaBean中時，采用的方式和Spring的設值注入一樣：先調用空參的構造器，再調用setter()方法進行初始化。

所以一定要有空參的構造器、setter()方法，要么不寫構造器，調用默認的空參構造器；如果寫了帶參的構造器，就必須顯示寫空參的構造器。

 

4、新建測試類test.Test

public class Test {
    public static void main(String[] args) throws ClassNotFoundException, IOException, SQLException {
        //從properties文件中加載數據庫配置
        Properties properties = new Properties();
        InputStream fis = Class.forName("test.Test").getResourceAsStream("/mysql.properties");
        properties.load(fis);
        String driver = properties.getProperty("driver");
        String url = properties.getProperty("url");
        String user = properties.getProperty("user");
        String password = properties.getProperty("password");

        DbUtils.loadDriver(driver);   //靜態方法加載驅動
        Connection connection = DriverManager.getConnection(url, user, password);  //獲取連接
        QueryRunner queryRunner = new QueryRunner();  //創建QueryRunner對象，增刪查改都要通過QueryRunner對象來完成

        //查詢
        String sql = "select * from student_tb where id=?";
        BeanHandler<Student> studentBeanHandler = new BeanHandler<>(Student.class); //結果集處理器，將結果集中的記錄映射到指定的類中
        Student student = queryRunner.query(connection, sql, studentBeanHandler, 1);  //執行查詢，將結果集中的記錄映射到JavaBean中，返回的就是目標類型，不必強轉
        System.out.println(student);   //可通過getter()方法獲取屬性值（對應表中的字段值）

        DbUtils.close(connection);  //靜態方法關閉連接
    }
}

 

 

 

ResultSetHandler

結果集處理器ResultSetHandler是一個接口，不能直接使用。

（1）使用ResultSetHandler的實現類ScalarHandler

ScalarHandler適合只有一條記錄的結果集，獲取的是該條記錄某個字段的值。

 

（2）ResultSetHandler有一個抽象子類BaseResultSetHandler，BaseResultSetHandler有3個實現類

• BeanHandler   將結果集中的記錄映射為一個JavaBean，適合結果集中只有一條記錄的情況
• BeanListHandler   將結果集中的所有記錄映射為一個JavaBean的List集合，一條記錄就是一個元素，就是一個JavaBean。
• BeanMapHandler  將結果集映射為JavaBean的Map集合

 

增刪查改都是通過QueryRunner對象來實現的：

• 查：QueryRunner對象.query(數據庫連接，sql語句，結果集處理器，sql語句中的？部分的參數值）
• 增、刪、改：QueryRunner對象.update(數據庫連接，sql語句，sql語句中？部分的參數值）

說明：

• 最后一個是個數不確定的參數，可以沒有，也可以有多個，有多個時逗號隔開即可，也可以寫成數組的形式。
• 如果使用了數據源，可缺省第一個參數數據庫連接。
• QueryRunner並非像名字中的query一樣只能用於查詢，QueryRunner提供的insert()方法不常用、不方便，插入也要用update()。

 

 

 

查詢

//查詢，結果集中只有一條記錄的情況
        String sql = "select * from student_tb where id=?";
        BeanHandler<Student> studentBeanHandler = new BeanHandler<>(Student.class); //<>中指定目標類型，（）中指定目標類型的class
        Student student = queryRunner.query(connection, sql, studentBeanHandler,1);  //執行查詢，，返回的就是目標類型，不必強轉
        System.out.println(student);   //可通過getter()方法獲取屬性值（對應表中的字段值）

 

 

//查詢，結果集中只有一條記錄，直接獲取某個字段的值
        String sql = "select name from student_tb where id=?";
        ScalarHandler<String> scalarHandler = new ScalarHandler<>();
        String name = queryRunner.query(connection, sql, scalarHandler,1);  //獲取的是某個字段的值
        System.out.println(name);

使用BeanHandler封裝為Bean，再使用getter()獲取也行。

 

 

//查詢，結果集中有多條記錄的情況
        String sql = "select * from student_tb";
        BeanListHandler<Student> studentBeanListHandler = new BeanListHandler<>(Student.class); //要用List
        List<Student> list = queryRunner.query(connection, sql, studentBeanListHandler);  //返回值的類型是List<目標JavaBean>
        //遍歷這個list就是遍歷結果集

 

 

 

增、刪、改

　　//插入
        String sql = "insert into student_tb (name,age,score) values (?,?,?)";
        //queryRunner.update(connection, sql, "曹操",20,90);  //返回值是int，受影響的記錄數
        Object[] values = {"曹操",20,90};
        queryRunner.update(connection, sql,values );  //?部分的參數值也可以寫成數組形式

增、刪、改的用法都差不多，不再一一列舉。

 

 

 

批量操作

語法：QueryRunner對象.batch(數據庫連接，sql語句，Object[][]) ;

最后一個參數是二維數組，一行對應一個sql語句？部分的參數值。

如果使用的是連接池，可缺省第一個參數數據庫連接。

//批量插入
        String sql = "insert into student_tb (name,age,score) values (?,?,?)";
        Object[][] values = {{"曹操", 20, 90}, {"劉備", 20, 90}, {"孫權", 18, 88}};
        queryRunner.batch(connection, sql,values);  //批量執行，返回的是int[],一個值對應一個sql語句影響的記錄數

DbUtils的批量操作是批量執行相似的sql語句（只有？部分的值不同）。

 

 

 

使用數據源

//從properties文件中加載數據源配置
        Properties properties = new Properties();
        InputStream fis = Class.forName("test.Test").getResourceAsStream("/mysqlDataSource.properties");
        properties.load(fis);
        //String driver = properties.getProperty("driver");  //不必使用driver
        String url = properties.getProperty("url");
        String user = properties.getProperty("user");
        String password = properties.getProperty("password");

        //配置數據源
        MysqlDataSource dataSource=new MysqlDataSource();
        dataSource.setURL(url);
        dataSource.setUser(user);
        dataSource.setPassword(password);

        //DbUtils.loadDriver(driver);   //數據庫驅動提供的數據源自帶驅動，不用再加載驅動
        QueryRunner queryRunner = new QueryRunner(dataSource);  //需傳入一個數據源，操作數據庫時會自動獲取連接，不必手動獲取連接
        String sql = "insert into student_tb (name,age,score) values (?,?,?)";
        queryRunner.update(sql,"曹操", 20, 90);  //不必傳入連接，會自動從數據源獲取連接

不必手動獲取連接、關閉連接，很方便。

數據庫驅動自帶的數據源、C3P0、DBCP的操作方式差不多，此處不再一一寫出。

 

 

 

Hibernate也是將結果集中的記錄映射為實體對象，相比之下，DbUtils體積極小（只有一個jar包），沒有hql一樣復雜的操作，操作十分簡便。