【JDBC核心】DAO 相關

阿新 • • 發佈：2020-12-13

DAO 相關

概念

DAO：Data Access Object 訪問資料資訊的類和介面，包括了對資料的 CRUD（Create、Retrival、Update、Delete），而不包含任何業務相關的資訊。有時也稱作 BaseDAO。

作用：為了實現功能的模組化，更有利於程式碼的維護和升級。

使用

表結構：

DAO使用：

package cn.parzulpan.jdbc.ch07.util;

import com.alibaba.druid.pool.DruidDataSourceFactory;
import org.apache.commons.dbutils.DbUtils;

import javax.sql.DataSource;
import java.io.InputStream;
import java.sql.*;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.Properties;

/**
 * @Author : parzulpan
 * @Time : 2020-12-02
 * @Desc : 操作資料庫的工具類，最終版
 */

public class JDBCUtils {
    private static DataSource dataSource = null;

    static {
        try {
            Properties properties = new Properties();
            InputStream is = ClassLoader.getSystemClassLoader().getResourceAsStream("druid.properties");
            properties.load(is);
            dataSource = DruidDataSourceFactory.createDataSource(properties);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    /**
     * 獲取資料庫連線，使用 Druid 資料庫連線池
     * @return 資料庫連線
     */
    public static Connection getDruidConnection() throws SQLException {
        return dataSource.getConnection();
    }

    /**
     * 使用DbUtils，靜默關閉資料庫資源
     * @param connection 資料庫連線
     * @param statement 宣告
     * @param resultSet 結果集
     */
    public static void closeResourceQuietly(Connection connection, Statement statement, ResultSet resultSet) {
        DbUtils.closeQuietly(connection);
        DbUtils.closeQuietly(statement);
        DbUtils.closeQuietly(resultSet);
    }

    public static Date getSqlDate(String dateStr) {
        java.sql.Date date = null;
        try {
            java.util.Date parse = new SimpleDateFormat("yyyy-MM-dd").parse(dateStr);
            date = new java.sql.Date(parse.getTime());
        } catch (ParseException e) {
            e.printStackTrace();
        }
        return date;
    }
}

package cn.parzulpan.jdbc.ch07.dao;

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.lang.reflect.ParameterizedType;
import java.lang.reflect.Type;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.List;

/**
 * @Author : parzulpan
 * @Time : 2020-12-01
 * @Desc : 對資料表的通用操作
 */

public abstract class BaseDAO<T> {
    // 泛型的型別
    private Class<T> type;
    private QueryRunner queryRunner = new QueryRunner();

    // 獲取 T 類物件，獲取泛型的型別，泛型是在被子類繼承時才確定的
    public BaseDAO() {
        // 獲取子類的型別
        Class<? extends BaseDAO> clazz = this.getClass();

        // 獲取父類的型別
        ParameterizedType parameterizedType = (ParameterizedType) clazz.getGenericSuperclass();

        // 獲取具體的泛型
        Type[] types = parameterizedType.getActualTypeArguments();

        this.type = (Class<T>)types[0];
    }

    /**
     * 通用的增刪改操作
     * @param connection 資料庫連線
     * @param sql   sql 語句
     * @param args 引數
     * @return 更新的條數
     */
    public int update(Connection connection, String sql, Object ... args) {
        int update = 0;
        try {
            update = queryRunner.update(connection, sql, args);
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return update;
    }

    /**
     * 通用的查詢操作
     * @param connection 資料庫連線
     * @param sql   sql 語句
     * @param args 引數
     * @return 返回一個物件
     */
    public T getBean(Connection connection, String sql, Object ... args) {
        T t = null;
        BeanHandler<T> beanHandler = new BeanHandler<>(type);
        try {
            t = queryRunner.query(connection, sql, beanHandler, args);
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return t;
    }

    /**
     * 通用的查詢操作
     * @param connection 資料庫連線
     * @param sql   sql 語句
     * @param args 引數
     * @return 返回一個物件列表
     */
    public List<T> getBeanList(Connection connection, String sql, Object ... args) {
        List<T> list = null;
        BeanListHandler<T> beanListHandler = new BeanListHandler<>(type);
        try {
            list = queryRunner.query(connection, sql, beanListHandler, args);
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return list;
    }

    /**
     * 查詢特殊值，類似於最大的，最小的，平均的，總和，個數相關的操作
     * @param connection 資料庫連線
     * @param sql   sql 語句
     * @param args 引數
     * @return 特殊值
     */
    public Object getValue(Connection connection, String sql, Object ... args) {
        Object obj = null;
        ScalarHandler scalarHandler = new ScalarHandler();
        try {
            obj = queryRunner.query(connection, sql, scalarHandler, args);
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return obj;
    }
}

package cn.parzulpan.jdbc.ch07.dao;

import cn.parzulpan.jdbc.ch07.bean.Customer;

import java.sql.Connection;
import java.sql.Date;
import java.util.List;

/**
 * @Author : parzulpan
 * @Time : 2020-12-01
 * @Desc : 此介面用於規範 customers 表的常用操作
 */

public interface CustomerDAO {

    /**
     * 將 customer 物件新增到資料庫中
     * @param connection 資料庫連線
     * @param customer customer 物件
     */
    void insert(Connection connection, Customer customer);

    /**
     * 用 customer 物件修改資料庫對應的資料中
     * @param connection 資料庫連線
     * @param customer customer 物件
     */
    void update(Connection connection, Customer customer);

    /**
     * 根據 Id 刪除一條記錄
     * @param connection 資料庫連線
     * @param id
     */
    void deleteById(Connection connection, int id);

    /**
     * 根據 Id 查詢一條記錄
     * @param connection 資料庫連線
     * @param id
     * @return
     */
    Customer getCustomerById(Connection connection, int id);

    /**
     * 查詢多條記錄
     * @param connection 資料庫連線
     * @return
     */
    List<Customer> getCustomerList(Connection connection);

    /**
     * 查詢記錄條數
     * @param connection 資料庫連線
     * @return
     */
    Long getCount(Connection connection);

    /**
     * 查詢最大的生日記錄
     * @param connection 資料庫連線
     * @return
     */
    Date getMaxBirth(Connection connection);

}

package cn.parzulpan.jdbc.ch07.impl;

import cn.parzulpan.jdbc.ch07.bean.Customer;
import cn.parzulpan.jdbc.ch07.dao.BaseDAO;
import cn.parzulpan.jdbc.ch07.dao.CustomerDAO;

import java.sql.Connection;
import java.sql.Date;
import java.util.List;

/**
 * @Author : parzulpan
 * @Time : 2020-12-01
 * @Desc :
 */

public class CustomerDAOImpl extends BaseDAO<Customer> implements CustomerDAO {
    /**
     * 將 customer 物件新增到資料庫中
     *
     * @param connection 資料庫連線
     * @param customer   customer 物件
     */
    @Override
    public void insert(Connection connection, Customer customer) {
        String sql = "insert into customers(name, email, birth)values(?,?,?)";
        update(connection, sql, customer.getName(), customer.getEmail(), customer.getBirth());
    }

    /**
     * 用 customer 物件修改資料庫對應的資料中
     *
     * @param connection 資料庫連線
     * @param customer   customer 物件
     */
    @Override
    public void update(Connection connection, Customer customer) {
        String sql = "update customers set name = ?, email = ?, birth = ? where id = ?";
        update(connection, sql, customer.getName(), customer.getEmail(), customer.getBirth(), customer.getId());
    }

    /**
     * 根據 Id 刪除一條記錄
     *
     * @param connection 資料庫連線
     * @param id
     */
    @Override
    public void deleteById(Connection connection, int id) {
        String sql = "delete from customers where id = ?";
        update(connection, sql, id);
    }

    /**
     * 根據 Id 查詢一條記錄
     *
     * @param connection 資料庫連線
     * @param id
     * @return
     */
    public Customer getCustomerById(Connection connection,  int id) {
        String sql = "select id, name, email, birth from customers where id = ?";
        return getBean(connection, sql, id);
    }

    /**
     * 查詢多條記錄
     *
     * @param connection 資料庫連線
     * @return
     */
    @Override
    public List<Customer> getCustomerList(Connection connection) {
        String sql = "select id, name, email, birth from customers";
        return getBeanList(connection, sql);
    }

    /**
     * 查詢記錄條數
     *
     * @param connection 資料庫連線
     * @return
     */
    @Override
    public Long getCount(Connection connection) {
        String sql = "select count(*) from customers";
        return (Long) getValue(connection, sql);
    }

    /**
     * 查詢最大的生日記錄
     *
     * @param connection 資料庫連線
     * @return
     */
    @Override
    public Date getMaxBirth(Connection connection) {
        String sql = "select max(birth) from customers";
        return (Date) getValue(connection, sql);
    }
}

package cn.parzulpan.jdbc.ch07.junit;

import cn.parzulpan.jdbc.ch07.bean.Customer;
import cn.parzulpan.jdbc.ch07.impl.CustomerDAOImpl;
import cn.parzulpan.jdbc.ch07.util.JDBCUtils;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;

import java.sql.Connection;
import java.sql.Date;
import java.sql.SQLException;
import java.util.List;

import static org.junit.Assert.*;

/**
 * @Author : parzulpan
 * @Time : 2020-12-02
 * @Desc :
 */

public class CustomerDAOImplTest {


    @Before
    public void setUp() throws Exception {
        System.out.println("CustomerDAOImplTest Before");
    }

    @After
    public void tearDown() throws Exception {
        System.out.println("CustomerDAOImplTest Down");
    }

    private CustomerDAOImpl customerDAO = new CustomerDAOImpl();

    @Test
    public void insert() {
        Connection connection = null;
        try {
            connection = JDBCUtils.getDruidConnection();
            Customer customer = new Customer(30, "DAO", "[email protected]", JDBCUtils.getSqlDate("1995-1-1"));
            customerDAO.insert(connection, customer);
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            JDBCUtils.closeResourceQuietly(connection, null, null);
        }
    }

    @Test
    public void update() {
        Connection connection = null;
        try {
            connection = JDBCUtils.getDruidConnection();
            Customer customer = new Customer(24, "DAOUpdate", "[email protected]", JDBCUtils.getSqlDate("1995-1-1"));
            customerDAO.update(connection, customer);
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            JDBCUtils.closeResourceQuietly(connection, null, null);
        }
    }

    @Test
    public void deleteById() {
        Connection connection = null;
        try {
            connection = JDBCUtils.getDruidConnection();
            customerDAO.deleteById(connection, 23);
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            JDBCUtils.closeResourceQuietly(connection, null, null);
        }
    }

    @Test
    public void getCustomerById() {
        Connection connection = null;
        try {
            connection = JDBCUtils.getDruidConnection();
            Customer customer = customerDAO.getCustomerById(connection, 10);
            System.out.println(customer);
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            JDBCUtils.closeResourceQuietly(connection, null, null);
        }
    }

    @Test
    public void getCustomerList() {
        Connection connection = null;
        try {
            connection = JDBCUtils.getDruidConnection();
            List<Customer> customers = customerDAO.getCustomerList(connection);
            customers.forEach(System.out::println);
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            JDBCUtils.closeResourceQuietly(connection, null, null);
        }
    }

    @Test
    public void getCount() {
        Connection connection = null;
        try {
            connection = JDBCUtils.getDruidConnection();
            Long count = customerDAO.getCount(connection);
            System.out.println(count);
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            JDBCUtils.closeResourceQuietly(connection, null, null);
        }
    }

    @Test
    public void getMaxBirth() {
        Connection connection = null;
        try {
            connection = JDBCUtils.getDruidConnection();
            Date maxBirth = customerDAO.getMaxBirth(connection);
            System.out.println(maxBirth);
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            JDBCUtils.closeResourceQuietly(connection, null, null);
        }
    }
}

練習和總結

【JDBC核心】DAO 相關

DAO 相關概念 DAO：Data Access Object 訪問資料資訊的類和介面，包括了對資料的 CRUD（Create、Retrival、Update、Delete），而不包含任何業務相關的資訊。有時也稱作 BaseDAO。

【JDBC核心】資料庫事務

資料庫事務概述事務是邏輯上的一組操作，或者說一個獨立的工作單元。事務內的語句，要麼全部執行成功，要麼全部執行失敗。

【JDBC核心】批量插入

批量插入批量執行 SQL 語句當需要成批插入或者更新記錄時，可以採用 Java 的批量更新機制，這一機制允許多條語句一次性提交給資料庫批量處理。通常情況下比單獨提交處理更有效率。

【JDBC核心】操作 BLOB 型別欄位

操作 BLOB 型別欄位 MySQL BLOB 型別 MySQL 中，BLOB 是一個二進位制大型物件，是一個可以儲存大量資料的容器，它能容納不同大小的資料。

【JDBC核心】實現 CRUD 操作

實現 CRUD 操作操作和訪問資料庫資料庫連線被用於向資料庫伺服器傳送命令和 SQL 語句，並接受資料庫伺服器返回的結果。其實一個數據庫連線就是一個 Socket 連線。

【JDBC核心】獲取資料庫連線

獲取資料庫連線要素一：Driver 介面實現類 Driver 介面： java.sql.Driver 介面是所有 JDBC 驅動程式需要實現的介面。這個介面是提供給資料庫廠商使用的，不同資料庫廠商提供不同的實現。

【JDBC核心】commons-dbutils

commons-dbutils 簡介 commons-dbutils 是 Apache 組織提供的一個開源 JDBC 工具類庫，它是對 JDBC 的簡單封裝，學習成本極低，並且使用 commons-dbutils 能極大簡化 JDBC 編碼的工作量，同時也不會影響程式的效能。

【JDBC核心】資料庫連線池

資料庫連線池傳統模式使用資料庫的傳統模式：在主程式（servlet、beans等）中建立資料庫連線；

【資料庫核心】RocksDB：事務鎖設計與實現

本文主要介紹 RocksDB 鎖結構設計、加鎖解鎖過程，並與 InnoDB 鎖實現做一個簡單對比。

【演算法】【高精度】大數相關問題總結

常考大數乘法題目連結：https://leetcode-cn.com/problems/multiply-strings/ class Solution { public:

【computer-basic】CPU相關

CPU相關 CPU是什麼CPU做什麼CPU的內部結構CPU是暫存器的集合體計算機語言暫存器的分類&組合語言

【進階】ZooKeeper 相關概念總結

1. 開卷有益學習是一種習慣，只有把這種習慣保持下來，每天不學習一點就感覺渾身不自在，達到這樣的境界，那麼你成為大佬也就不遠了買，正如我們標題所寫的“開卷有益”。人生匆匆，要想過得有意義，那麼加油吧！

【js知識】陣列相關方法——for迴圈和filter & map & findIndex & concat

技術標籤：js知識js演算法【js知識】陣列相關方法——for迴圈和filter & map & findIndex

【TcaplusDB知識庫】表格相關操作命令

【TcaplusDB知識庫】表格相關操作命令介紹說明 TcaplusDB CLI工具提供了大量的關於表操作的命令，支援騰訊雲環境和本地Docker開發環境。主要涉及：

使用者登陸註冊【JDBC版】

前言在講解Web開發模式的時候，曾經寫過XML版的使用者登陸註冊案例！現在在原有的專案上，使用資料庫版來完成使用者的登陸註冊！如果不瞭解的朋友，可以看看我Web開發模式的博文！

【JDBC第7章】DAO及相關實現類

第7章：DAO及相關實現類 DAO：Data Access Object訪問資料資訊的類和介面，包括了對資料的CRUD（Create、Retrival、Update、Delete），而不包含任何業務相關的資訊。有時也稱作：BaseDAO

【SQL server】建立、修改、刪除資料庫及其相關檔案

參考資料：愛課程·資源共享課 ·大型資料庫 use master --建立新資料庫時，要設定master為可用資料庫，即使用master

【字串-列表-元組相關函式和方法】

列表相關操作 (1)列表的拼接(同元組) (2)列表的重複(同元組) (3)列表的切片(同元組)

【Flutter 實戰】動畫核心

老孟導讀：動畫系統是任何一個UI框架的核心功能，也是開發者學習一個UI框架的重中之重，同時也是比較難掌握的一部分，下面我們就一層一層的揭開 Flutter 動畫的面紗。

【Unittest】unittest相關解說

一、什麼是unittest unittest是Python單元測試框架，類似於JUnit框架。 unittest中有4個重要的概念：test fixture, test case, test suite, test runner

【JDBC核心】DAO 相關

DAO 相關

概念

使用

練習和總結

相關推薦