day49-JDBC和連接池05
JDBC和連接池05
11.BasicDAO
-
先來分析一個問題
前面我們使用了Apache-DBUtils和Druid簡化了JDBC開發，但仍存在以下不足：
-
SQL語句是固定的，不能通過參數傳入，通用性不好，需要進行改進，來更方便執行增刪改查
-
對於select操作，如果有返回值，返回類型還不確定，應該使用泛型
-
將來如果表很多，業務需求複雜，不可能只靠一個Java來完成
-
為了解決這些問題，就要引出BasicDAO的概念
11.1BasicDao分析
- 基本說明
-
DAO，即data access object(數據訪問對象)
-
這樣的通用類稱為BasicDao，是專門和資料庫進行交互的，即完成對資料庫（表）的crud操作
-
在BasicDao的基礎上，實現一張表對應一個Dao，更好的完成功能
比如：Customer表–Customer.java類（javabean）–CustomerDao.java
- 簡單的項目結構
- 進一步的項目結構
在實際的開發中，由於業務的複雜度，一般會在應用層TestDAO和DAO層之間增加一個業務層XxxService，這一層會完成一些綜合性的業務
11.2BasicDao實現
BasicDao應用實例
完成一個簡單設計
li.dao_
li.dao_.utils //工具類
li.dao_domain //Javabean
li.dao_.dao //存放XxxDao和BasicDao
li.dao_.test //寫測試類
11.2.1utils
JDBCUtilsByDruid類
package li.dao_.utils;
import com.alibaba.druid.pool.DruidDataSourceFactory;
import javax.sql.DataSource;
import java.io.FileInputStream;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Properties;
/**
* 基於Druid資料庫連接池的工具類
*/
public class JDBCUtilsByDruid {
private static DataSource ds;
//在靜態程式碼塊完成ds的初始化
//靜態程式碼塊在載入類的時候只會執行一次，因此數據源也只會初始化一次
static {
Properties properties = new Properties();
try {
properties.load(new FileInputStream("src\\druid.properties"));
ds = DruidDataSourceFactory.createDataSource(properties);
} catch (Exception e) {
e.printStackTrace();
}
}
//編寫getConnection方法
public static Connection getConnection() throws SQLException {
return ds.getConnection();
}
//關閉連接（注意：在資料庫連接池技術中，close不是真的關閉連接，而是將Connection對象放回連接池中）
public static void close(ResultSet resultSet, Statement statemenat, Connection connection) {
try {
if (resultSet != null) {
resultSet.close();
}
if (statemenat != null) {
statemenat.close();
}
if (connection != null) {
connection.close();
}
} catch (SQLException e) {
throw new RuntimeException(e);
}
}
}
11.2.2domain
Actor類
package li.dao_.domain;
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 + '\'' +
'}';
}
}
11.2.3dao
11.2.3.1BasicDAO類
package li.dao_.dao;
import li.dao_.utils.JDBCUtilsByDruid;
import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.handlers.BeanHandler;
import org.apache.commons.dbutils.handlers.BeanListHandler;
import org.apache.commons.dbutils.handlers.ScalarHandler;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.List;
/**
* 開發BasicDAO，是其他DAO的父類
*/
public class BasicDAO<T> {//泛型指定具體的類型
private QueryRunner qr = new QueryRunner();
//開發通用的dml方法，針對任意的表
/**
* @param sql 傳入的SQL語句,可以有佔位符?
* @param parameters 傳入佔位符?的具體的值，可以是多個
* @return 返回的值是受影響的行數
*/
public int update(String sql, Object... parameters) { //可變參數 Object… parameters
Connection connection = null;
try {
connection = JDBCUtilsByDruid.getConnection();
int update = qr.update(connection, sql, parameters);
return update;
} catch (SQLException e) {
throw new RuntimeException(e);//將一個編譯異常轉變為運行異常
} finally {
JDBCUtilsByDruid.close(null, null, connection);
}
}
//返回多個對象（即查詢的結果是多行），針對任意的表（多行多列）
/**
* @param sql 傳入的SQL語句,可以有佔位符?
* @param clazz 傳入一個類的Class對象，比如 Actor.class[底層需要通過反射來創建Javabean對象]
* @param parameters 傳入佔位符?的具體的值，可以是多個
* @return 根據傳入的class對象 Xxx.class 返回對應的ArrayList集合
*/
public List<T> queryMulti(String sql, Class<T> clazz, Object... parameters) {
Connection connection = null;
try {
connection = JDBCUtilsByDruid.getConnection();
return qr.query(connection, sql, new BeanListHandler<T>(clazz), parameters);
} catch (SQLException e) {
throw new RuntimeException(e);//將一個編譯異常轉變為運行異常
} finally {
JDBCUtilsByDruid.close(null, null, connection);
}
}
//查詢單行結果 的通用方法（單行多列）
public T querySingle(String sql, Class<T> clazz, Object... parameters) {
Connection connection = null;
try {
connection = JDBCUtilsByDruid.getConnection();
return qr.query(connection, sql, new BeanHandler<T>(clazz), parameters);
} catch (SQLException e) {
throw new RuntimeException(e);//將一個編譯異常轉變為運行異常
} finally {
JDBCUtilsByDruid.close(null, null, connection);
}
}
//查詢單行單列的方法，即返回單值的方法
public Object queryScalar(String sql, Object... parameters) {
Connection connection = null;
try {
connection = JDBCUtilsByDruid.getConnection();
return qr.query(connection, sql, new ScalarHandler(), parameters);
} catch (SQLException e) {
throw new RuntimeException(e);//將一個編譯異常轉變為運行異常
} finally {
JDBCUtilsByDruid.close(null, null, connection);
}
}
}
11.2.3.2ActorDAO類
package li.dao_.dao;
import li.dao_.domain.Actor;
public class ActorDAO extends BasicDAO<Actor>{
//1.ActorDAO可以使用BasicDAO的方法
//2.同時根據業務需求可以編寫特有的方法
}
11.2.4test
TestDAO類
package li.dao_.test;
import li.dao_.dao.ActorDAO;
import li.dao_.domain.Actor;
import org.junit.Test;
import java.util.List;
public class TestDAO {
//測試ActorDAO 對actor表的crud操作
@Test
public void testActorDAO() {
ActorDAO actorDAO = new ActorDAO();
//1.查詢
List<Actor> actors =
actorDAO.queryMulti("select * from actor where id >=?", Actor.class, 1);
System.out.print("====查詢-多行多列-結果====");
for (Actor actor : actors) {
System.out.print(actor);
}
System.out.println();
//2.查詢單行記錄
Actor actor = actorDAO.querySingle("select * from actor where id =?", Actor.class, 3);
System.out.print("====查詢-單行多列-結果====");
System.out.println(actor);
System.out.println();
//3.查詢單行單列
Object o = actorDAO.queryScalar("select name from actor where id =?", 1);
System.out.println("====查詢-單行單列-結果====");
System.out.println(o);
System.out.println();
//4.dml操作
int update = actorDAO.update("insert into actor values(null,?,?,?,?)", "張無忌", "男", "2000-11-11", "999");
System.out.println(update > 0 ? "操作成功" : "執行沒有影響表");
}
}
運行結果：
11.3練習
開發GoodsDAO和Goods，完成對錶goods的crud
