07-DAO及相關實現類
阿新 • • 發佈：2020-12-20
宣告：學習內容來自尚矽谷-宋紅康老師（推薦）：https://www.bilibili.com/video/BV1eJ411c7rf?from=search&seid=8058522927071118751
- DAO：Data Access Object訪問資料資訊的類和介面，包括了對資料的CRUD（Create、Retrival、Update、Delete），而不包含任何業務相關的資訊。有時也稱作：BaseDAO
- 作用：為了實現功能的模組化，更有利於程式碼的維護和升級。
- 層次結構：
【BaseDAO.java】
import java.lang.reflect.ParameterizedType; import java.lang.reflect.Type; import java.sql.Connection; import java.sql.SQLException; import java.util.List; 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; /** * 定義一個用來被繼承的對資料庫進行基本操作的Dao * * @param <T> */ public abstract class BaseDao<T> { private QueryRunner queryRunner = new QueryRunner(); // 定義一個變數來接收泛型的型別 private Class<T> type; // 獲取T的Class物件，獲取泛型的型別，泛型是在被子類繼承時才確定 public BaseDao() { // 獲取子類的型別 Class clazz = this.getClass(); // 獲取父類的型別 // getGenericSuperclass()用來獲取當前類的父類的型別 // ParameterizedType表示的是帶泛型的型別 ParameterizedType parameterizedType = (ParameterizedType) clazz.getGenericSuperclass(); // 獲取具體的泛型型別 getActualTypeArguments獲取具體的泛型的型別 // 這個方法會返回一個Type的陣列 Type[] types = parameterizedType.getActualTypeArguments(); // 獲取具體的泛型的型別· this.type = (Class<T>) types[0]; } /** * 通用的增刪改操作 * * @param sql * @param params * @return */ public int update(Connection conn,String sql, Object... params) { int count = 0; try { count = queryRunner.update(conn, sql, params); } catch (SQLException e) { e.printStackTrace(); } return count; } /** * 獲取一個物件 * * @param sql * @param params * @return */ public T getBean(Connection conn,String sql, Object... params) { T t = null; try { t = queryRunner.query(conn, sql, new BeanHandler<T>(type), params); } catch (SQLException e) { e.printStackTrace(); } return t; } /** * 獲取所有物件 * * @param sql * @param params * @return */ public List<T> getBeanList(Connection conn,String sql, Object... params) { List<T> list = null; try { list = queryRunner.query(conn, sql, new BeanListHandler<T>(type), params); } catch (SQLException e) { e.printStackTrace(); } return list; } /** * 獲取一個但一值得方法，專門用來執行像 select count(*)...這樣的sql語句 * * @param sql * @param params * @return */ public Object getValue(Connection conn,String sql, Object... params) { Object count = null; try { // 呼叫queryRunner的query方法獲取一個單一的值 count = queryRunner.query(conn, sql, new ScalarHandler<>(), params); } catch (SQLException e) { e.printStackTrace(); } return count; } }
【BookDAO.java】
import java.sql.Connection; import java.util.List; public interface BookDao { /** * 從資料庫中查詢出所有的記錄 * * @return */ List<Book> getBooks(Connection conn); /** * 向資料庫中插入一條記錄 * * @param book */ void saveBook(Connection conn,Book book); /** * 從資料庫中根據圖書的id刪除一條記錄 * * @param bookId */ void deleteBookById(Connection conn,String bookId); /** * 根據圖書的id從資料庫中查詢出一條記錄 * * @param bookId * @return */ Book getBookById(Connection conn,String bookId); /** * 根據圖書的id從資料庫中更新一條記錄 * * @param book */ void updateBook(Connection conn,Book book); /** * 獲取帶分頁的圖書資訊 * * @param page：是隻包含了使用者輸入的pageNo屬性的page物件 * @return 返回的Page物件是包含了所有屬性的Page物件 */ Page<Book> getPageBooks(Connection conn,Page<Book> page); /** * 獲取帶分頁和價格範圍的圖書資訊 * * @param page：是隻包含了使用者輸入的pageNo屬性的page物件 * @return 返回的Page物件是包含了所有屬性的Page物件 */ Page<Book> getPageBooksByPrice(Connection conn,Page<Book> page, double minPrice, double maxPrice); }
【UserDAO.java】
import java.sql.Connection; public interface UserDao { /** * 根據User物件中的使用者名稱和密碼從資料庫中獲取一條記錄 * * @param user * @return User 資料庫中有記錄 null 資料庫中無此記錄 */ User getUser(Connection conn,User user); /** * 根據User物件中的使用者名稱從資料庫中獲取一條記錄 * * @param user * @return true 資料庫中有記錄 false 資料庫中無此記錄 */ boolean checkUsername(Connection conn,User user); /** * 向資料庫中插入User物件 * * @param user */ void saveUser(Connection conn,User user); }
【BookDaoImpl.java】
import java.sql.Connection;
import java.util.List;
public class BookDaoImpl extends BaseDao<Book> implements BookDao {
@Override
public List<Book> getBooks(Connection conn) {
// 呼叫BaseDao中得到一個List的方法
List<Book> beanList = null;
// 寫sql語句
String sql = "select id,title,author,price,sales,stock,img_path imgPath from books";
beanList = getBeanList(conn,sql);
return beanList;
}
@Override
public void saveBook(Connection conn,Book book) {
// 寫sql語句
String sql = "insert into books(title,author,price,sales,stock,img_path) values(?,?,?,?,?,?)";
// 呼叫BaseDao中通用的增刪改的方法
update(conn,sql, book.getTitle(), book.getAuthor(), book.getPrice(), book.getSales(), book.getStock(),book.getImgPath());
}
@Override
public void deleteBookById(Connection conn,String bookId) {
// 寫sql語句
String sql = "DELETE FROM books WHERE id = ?";
// 呼叫BaseDao中通用增刪改的方法
update(conn,sql, bookId);
}
@Override
public Book getBookById(Connection conn,String bookId) {
// 呼叫BaseDao中獲取一個物件的方法
Book book = null;
// 寫sql語句
String sql = "select id,title,author,price,sales,stock,img_path imgPath from books where id = ?";
book = getBean(conn,sql, bookId);
return book;
}
@Override
public void updateBook(Connection conn,Book book) {
// 寫sql語句
String sql = "update books set title = ? , author = ? , price = ? , sales = ? , stock = ? where id = ?";
// 呼叫BaseDao中通用的增刪改的方法
update(conn,sql, book.getTitle(), book.getAuthor(), book.getPrice(), book.getSales(), book.getStock(), book.getId());
}
@Override
public Page<Book> getPageBooks(Connection conn,Page<Book> page) {
// 獲取資料庫中圖書的總記錄數
String sql = "select count(*) from books";
// 呼叫BaseDao中獲取一個單一值的方法
long totalRecord = (long) getValue(conn,sql);
// 將總記錄數設定都page物件中
page.setTotalRecord((int) totalRecord);
// 獲取當前頁中的記錄存放的List
String sql2 = "select id,title,author,price,sales,stock,img_path imgPath from books limit ?,?";
// 呼叫BaseDao中獲取一個集合的方法
List<Book> beanList = getBeanList(conn,sql2, (page.getPageNo() - 1) * Page.PAGE_SIZE, Page.PAGE_SIZE);
// 將這個List設定到page物件中
page.setList(beanList);
return page;
}
@Override
public Page<Book> getPageBooksByPrice(Connection conn,Page<Book> page, double minPrice, double maxPrice) {
// 獲取資料庫中圖書的總記錄數
String sql = "select count(*) from books where price between ? and ?";
// 呼叫BaseDao中獲取一個單一值的方法
long totalRecord = (long) getValue(conn,sql,minPrice,maxPrice);
// 將總記錄數設定都page物件中
page.setTotalRecord((int) totalRecord);
// 獲取當前頁中的記錄存放的List
String sql2 = "select id,title,author,price,sales,stock,img_path imgPath from books where price between ? and ? limit ?,?";
// 呼叫BaseDao中獲取一個集合的方法
List<Book> beanList = getBeanList(conn,sql2, minPrice , maxPrice , (page.getPageNo() - 1) * Page.PAGE_SIZE, Page.PAGE_SIZE);
// 將這個List設定到page物件中
page.setList(beanList);
return page;
}
}
【UserDaoImpl.java】
import java.sql.Connection;
public class UserDaoImpl extends BaseDao<User> implements UserDao {
@Override
public User getUser(Connection conn,User user) {
// 呼叫BaseDao中獲取一個物件的方法
User bean = null;
// 寫sql語句
String sql = "select id,username,password,email from users where username = ? and password = ?";
bean = getBean(conn,sql, user.getUsername(), user.getPassword());
return bean;
}
@Override
public boolean checkUsername(Connection conn,User user) {
// 呼叫BaseDao中獲取一個物件的方法
User bean = null;
// 寫sql語句
String sql = "select id,username,password,email from users where username = ?";
bean = getBean(conn,sql, user.getUsername());
return bean != null;
}
@Override
public void saveUser(Connection conn,User user) {
//寫sql語句
String sql = "insert into users(username,password,email) values(?,?,?)";
//呼叫BaseDao中通用的增刪改的方法
update(conn,sql, user.getUsername(),user.getPassword(),user.getEmail());
}
}
【Book.java】
/**
* 圖書類
*
*/
public class Book {
private Integer id;
private String title; // 書名
private String author; // 作者
private double price; // 價格
private Integer sales; // 銷量
private Integer stock; // 庫存
private String imgPath = "static/img/default.jpg"; // 封面圖片的路徑
//構造器，get()，set()，toString()方法略
}
【Page.java】
import java.util.List;
/**
* 頁碼類
*
*/
public class Page<T> {
private List<T> list; // 每頁查到的記錄存放的集合
public static final int PAGE_SIZE = 4; // 每頁顯示的記錄數
private int pageNo; // 當前頁
// private int totalPageNo; // 總頁數，通過計算得到
private int totalRecord; // 總記錄數，通過查詢資料庫得到
【User.java】
/**
* 使用者類
*
*/
public class User {
private Integer id;
private String username;
private String password;
private String email;