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 ? "操作成功" : "執行沒有影響表");

    }
}

運行結果：