JDBC和連接池04-2
10.資料庫連接池
10.5Apache-DBUtils
10.5.1resultSet問題
先分析一個問題
在之前的程式中，執行sql陳述句后回傳的結果集存在如下問題：
-
關閉connection后，resultSet結果集無法使用
如果要使用結果集，就不能關閉連接，不能關閉連接，就會反過來影響別的程式去連接資料庫，就會對多并發程式造成很大的影響
-
resultSet不利于資料的管理
如果其它的方法或者程式想要使用結果集，也需要一直保持連接，影響其他程式對資料庫的連接
-
使用回傳資訊也不方便
解決方法：
定義一個類，該類的屬性和表的欄位是對應關系/映射關系，即用類的屬性和表的欄位(列)關聯起來
我們把這種類叫做JavaBean，或者POJO，Domain，
一個Actor物件就對應一條actor表的記錄，將Actor物件放入到ArrayList集合中（將結果集的記錄封裝到ArrayList中）
10.5.2土方法完成封裝
Actor類（JavaBean）：
package li.jdbc.datasource;
import java.util.Date;
/**
* Actor物件和actor表的記錄對應
*/
public class Actor {//JavaBean/POJO/Domain
private Integer id;
private String name;
private String sex;
private Date borndate;
private String phone;
public Actor() {//一定要給一個無參構造器[反射需要]
}
public Actor(Integer id, String name, String sex, Date borndate, String phone) {
this.id = id;
this.name = name;
this.sex = sex;
this.borndate = borndate;
this.phone = phone;
}
public Integer getId() {
return id;
}
public void setId(Integer id) {
this.id = id;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public String getSex() {
return sex;
}
public void setSex(String sex) {
this.sex = sex;
}
public Date getBorndate() {
return borndate;
}
public void setBorndate(Date borndate) {
this.borndate = borndate;
}
public String getPhone() {
return phone;
}
public void setPhone(String phone) {
this.phone = phone;
}
@Override
public String toString() {
return "\nActor{" +
"id=" + id +
", name='" + name + '\'' +
", sex='" + sex + '\'' +
", borndate=" + borndate +
", phone='" + phone + '\'' +
'}';
}
}
測驗程式：
package li.jdbc.datasource;
import org.junit.Test;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.Date;
public class JDBCUtilsByDruid_Use {
//使用土方法嘗試解決ResultSet問題==封裝=>ArrayList
@Test
public void testSelectToArrayList() {//也可以設定回傳值
System.out.println("使用druid方式完成");
//1.得到連接
Connection connection = null;
//2.組織一個sql陳述句
String sql = "Select * from actor where id >=?";
//3.創建PreparedStatement物件
PreparedStatement preparedStatement = null;
ResultSet set = null;
ArrayList<Actor> list = new ArrayList<>();//創建ArrayList物件，存放actor物件
try {
connection = JDBCUtilsByDruid.getConnection();
preparedStatement = connection.prepareStatement(sql);
preparedStatement.setInt(1, 1);//給?號賦值
//執行sql,得到結果集
set = preparedStatement.executeQuery();
//遍歷該結果集
while (set.next()) {
int id = set.getInt("id");
String name = set.getString("name");
String sex = set.getString("sex");
Date borndate = set.getDate("borndate");
String phone = set.getString("phone");
//把得到的當前 resultSet的一條記錄，封裝到一個Actor物件中，并放入arraylist集合
list.add(new Actor(id,name,sex,borndate,phone));
}
System.out.println("list集合資料="+list);
//or
for (Actor actor:list) {
System.out.println("id="+actor.getId()+"\t"+"name="+actor.getName());
}
} catch (SQLException e) {
e.printStackTrace();
} finally {
//關閉資源（不是真的關閉連接，而是將Connection物件放回連接池中）
JDBCUtilsByDruid.close(set, preparedStatement, connection);
}
//因為ArrayList 和 connection 沒有任何關聯，所以該集合可以復用
//return list;
}
}
10.5.3Apache-DBUtils
-
基本介紹
commons-dbutils是Apache組織提供的一個開源 JDBC工具類別庫，它是對 JDBC的封裝，使用dbutils能極大簡化 JDBC編碼的作業量，
-
DbUtils類
- QueryRunner類：該類封裝了SQL的執行，是執行緒安全的，可以實作增、刪、改、查、批處理
- 使用QueryRunner類實作查詢
- ResultSetHandler介面：該介面用于處理 java.sql.ResultSet，將資料按要求轉換為另一種形式
| 方法 | 解釋 |
|---|---|
| ArrayHandler | 將結果集中的第一行資料轉成物件陣列 |
| ArrayListHandler | 把結果集中的每一行資料都轉成一個陣列，再存放到List中 |
| BeanHandler | 將結果集中的第一行資料封裝到一個對應的JavaBean實體中 |
| BeanListHandler | 將結果集中的每一行資料都封裝到一個對應的JavaBean實體中，再存放到List中 |
| ScalarHandler | 可以回傳指定列的一個值或回傳一個統計函式的值，比如count(1) |
| ColumnListHandler | 將結果集中某一列的資料存放到List中 |
| KeyedHandler（name） | 將結果集中的每行資料都封裝到Map中，再把這些map再存放到一個map里，其key為指定的key |
| MapHandler | 將結果集中的第一行資料封裝到一個Map里，key是列名，value就是對應的值 |
| MapListHandler | 將結果集中的每一行資料都封裝到一個Map里，然后再存放到List |
DBUtils的jar包下載可以去官網下載
應用實體
使用DBUtils+資料庫連接池（德魯伊）方式，完成對表actor的crud操作
首先將DBUtils的jar包添加到專案的libs檔案夾下面，右鍵選擇add as library
Actor類詳見10.5.2
DBUtils_USE：
package li.jdbc.datasource;
import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.handlers.BeanListHandler;
import org.junit.Test;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.List;
public class DBUtils_USE {
//使用Apache-DBUtils工具類 + Druid 完成對表的crud操作
@Test
public void testQueryMany() throws SQLException {//回傳結果是多行多列的情況
//1.得到連接（Druid）
Connection connection = JDBCUtilsByDruid.getConnection();
//2.使用DBUtils類和介面（先引入相關的jar，加入到本地的project）
//3.創建QueryRunner
QueryRunner queryRunner = new QueryRunner();
//4.然后就可以執行相關的方法，回傳ArrayList結果集
//String sql = "Select * from actor where id >=?";
//注意 ：sql陳述句也可以查詢部分的列,沒有查詢的屬性就在actor物件中置空
String sql = "Select id,name from actor where id >=?";
/**
* (1) query方法就是執行sql陳述句，得到resultSet--封裝到-->Arraylist集合中
* (2) 然后回傳集合
* (3) connection就是連接
* (4) sql：執行的sql陳述句
* (5) new BeanListHandler<>(Actor.class): 將resultSet->Actor物件->封裝到ArrayList
* 底層使用反射機制，去獲取 Actor的屬性，然后進行封裝
* (6) 1 就是給sql陳述句中的?賦值,可以有多個值，因為是可變引數
* (7) 底層得到的resultSet，會在query關閉,同時也會關閉PreparedStatement物件
*/
List<Actor> list =
queryRunner.query(connection, sql, new BeanListHandler<>(Actor.class), 1);
System.out.println("輸出集合的資訊：");
for (Actor actor : list) {
System.out.print(actor);
}
//釋放資源
JDBCUtilsByDruid.close(null, null, connection);
}
}
10.5.4ApDBUtils原始碼分析
在上述10.5.3代碼中，在List<Actor> list = queryRunner.query(connection, sql, new BeanListHandler<>(Actor.class), 1);陳述句旁打上斷點，點擊debug，點擊step into
游標跳轉到如下方法：
public <T> T query(Connection conn, String sql, ResultSetHandler<T> rsh,
Object... params) throws SQLException {
PreparedStatement stmt = null;//定義PreparedStatement物件
ResultSet rs = null;//接識訓傳的resultSet
T result = null;//回傳ArrayList
try {
stmt = this.prepareStatement(conn, sql);//創建PreparedStatement
this.fillStatement(stmt, params);//對SQL陳述句進行?賦值
rs = this.wrap(stmt.executeQuery());//執行SQL，回傳resultSet
result = rsh.handle(rs);//將回傳的resultSet-->封裝到ArrayList中[使用反射，對傳入的class物件進行處理]
} catch (SQLException e) {
this.rethrow(e, sql, params);
} finally {
try {
close(rs);//關閉resultSet
} finally {
close(stmt);//關閉preparedStatement
}
}
return result;//回傳ArrayList
}
10.5.5ApDBUtils查詢
使用DBUtils+資料庫連接池（德魯伊）方式，完成對表actor的查詢操作
1.多行多列
package li.jdbc.datasource;
import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.handlers.BeanListHandler;
import org.junit.Test;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.List;
public class DBUtils_USE {
//回傳結果是多行多列的情況
@Test
public void testQueryMany() throws SQLException {
//得到連接（Druid）
Connection connection = JDBCUtilsByDruid.getConnection();
//創建QueryRunner
QueryRunner queryRunner = new QueryRunner();
//然后就可以執行相關的方法，回傳ArrayList結果集
//sql陳述句也可以查詢部分的列,沒有查詢的屬性就在actor物件中置空
String sql = "Select id,name from actor where id >=?";
List<Actor> list =
queryRunner.query(connection, sql, new BeanListHandler<>(Actor.class), 1);
System.out.println("輸出集合的資訊：");
for (Actor actor : list) {
System.out.print(actor);
}
//釋放資源
JDBCUtilsByDruid.close(null, null, connection);
}
}
2.單行多列
package li.jdbc.datasource;
import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.handlers.BeanHandler;
import org.junit.Test;
import java.sql.Connection;
public class DBUtils_USE {
//演示DBUtils+druid完成-回傳的結果是單行記錄（單個物件）的情況-單行多列
@Test
public void testQuerySingle() throws Exception {
//1.得到連接
Connection connection = JDBCUtilsByDruid.getConnection();
//2.創建QueryRunner物件
QueryRunner queryRunner = new QueryRunner();
//3.執行相關方法，回傳單個物件
String sql = "Select * from actor where id =?";
//因為我們回傳的是單行記錄，對應單個物件，
// 因此使用的 Handler是BeanHandler：將結果集中的第一行資料封裝到一個對應的JavaBean實體中
Actor actor =
queryRunner.query(connection, sql, new BeanHandler<>(Actor.class), 2);
System.out.println(actor);
//釋放資源
JDBCUtilsByDruid.close(null, null, connection);
}
}
3.單行單列
package li.jdbc.datasource;
import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.handlers.ScalarHandler;
import org.junit.Test;
import java.sql.Connection;
public class DBUtils_USE {
//演示DBUtils+druid完成-查詢結果是單行單列的情況-回傳的就是Object
@Test
public void testScalar() throws Exception {//Scalar 單一值
//獲取連接
Connection connection = JDBCUtilsByDruid.getConnection();
//創建QueryRunner物件
QueryRunner queryRunner = new QueryRunner();
//執行相關方法，回傳單行單列
String sql = "Select name from actor where id =?";
//因為回傳的是一個物件，因此使用的 Handler是 ScalarHandler
Object obj = queryRunner.query(connection, sql, new ScalarHandler(), 1);
System.out.println(obj);
//釋放資源
JDBCUtilsByDruid.close(null,null,connection);
}
}
10.5.6ApDBUtilsDML
使用DBUtils+資料庫連接池（德魯伊）方式，完成對表actor的DML(update,insert,delete)操作
package li.jdbc.datasource;
import org.apache.commons.dbutils.QueryRunner;
import org.junit.Test;
import java.sql.Connection;
import java.sql.SQLException;
public class DBUtils_USE {
//演示DBUtils+druid完成 dml操作
@Test
public void testDML() throws SQLException {
//獲取連接
Connection connection = JDBCUtilsByDruid.getConnection();
//創建QueryRunner物件
QueryRunner queryRunner = new QueryRunner();
//這里組織sql完成update，insert，delete
//String sql = "update actor set name =? where id =?";
//String sql = "insert into actor values (null,?,?,?,?)";
String sql = "delete from actor where id =?";
/**
* 1.執行dml的操作是queryRunner.update()
* 2.回傳的值是受影響的行數,如果回傳的是0，代表sql執行失敗 或者 執行成功但是表沒受影響
*/
//int affectedRow = queryRunner.update(connection, sql,"黎明","女","1999-10-09","123");
int affectedRow = queryRunner.update(connection, sql,1000);
System.out.println(affectedRow > 0 ? "執行成功" : "執行沒有影響到表");
//釋放資源
JDBCUtilsByDruid.close(null, null, connection);
}
}
10.6表和JavaBean的型別映射關系
轉載請註明出處，本文鏈接：https://www.uj5u.com/houduan/516286.html
標籤：Java