【JDBC第7章】DAO及相关实现类

前端之家收集整理的这篇文章主要介绍了【JDBC第7章】DAO及相关实现类前端之家小编觉得挺不错的,现在分享给大家,也给大家做个参考。

第7章:DAO及相关实现类

  • DAO:Data Access Object访问数据信息的类和接口,包括了对数据的CRUD(Create、Retrival、Update、Delete),而不包含任何业务相关的信息。有时也称作:BaseDAO
  • 作用:为了实现功能的模块化,更有利于代码的维护和升级
  • 下面是尚硅谷JavaWeb阶段书城项目中DAO使用的体现:

  • 层次结构:

【BaseDAO.java】

为了不让此类被实例化,我们加上了abstract,让它变成抽象类。

  1. package com.atguigu.bookstore.dao;
  2. import java.lang.reflect.ParameterizedType;
  3. import java.lang.reflect.Type;
  4. import java.sql.Connection;
  5. import java.sql.sqlException;
  6. import java.util.List;
  7. import org.apache.commons.dbutils.QueryRunner;
  8. import org.apache.commons.dbutils.handlers.BeanHandler;
  9. import org.apache.commons.dbutils.handlers.BeanListHandler;
  10. import org.apache.commons.dbutils.handlers.ScalarHandler;
  11. /**
  12. * 定义一个用来被继承的对数据库进行基本操作的Dao
  13. *
  14. * @author HanYanBing
  15. *
  16. * @param <T>
  17. */
  18. public abstract class BaseDao<T> {
  19. private QueryRunner queryRunner = new QueryRunner();
  20. // 定义一个变量来接收泛型的类型
  21. private Class<T> type;
  22. // 获取T的Class对象,获取泛型的类型,泛型是在被子类继承时才确定
  23. public BaseDao() {
  24. // 获取子类的类型
  25. Class clazz = this.getClass();
  26. // 获取父类的类型
  27. // getGenericSuperclass()用来获取当前类的父类的类型
  28. // ParameterizedType表示的是带泛型的类型
  29. ParameterizedType parameterizedType = (ParameterizedType) clazz.getGenericSuperclass();
  30. // 获取具体的泛型类型 getActualTypeArguments获取具体的泛型的类型
  31. // 这个方法会返回一个Type的数组
  32. Type[] types = parameterizedType.getActualTypeArguments();
  33. // 获取具体的泛型的类型·
  34. this.type = (Class<T>) types[0];
  35. }
  36. /**
  37. * 通用的增删改操作
  38. *
  39. * @param sql
  40. * @param params
  41. * @return
  42. */
  43. public int update(Connection conn,String sql,Object... params) {
  44. int count = 0;
  45. try {
  46. count = queryRunner.update(conn,sql,params);
  47. } catch (sqlException e) {
  48. e.printStackTrace();
  49. }
  50. return count;
  51. }
  52. /**
  53. * 获取一个对象
  54. *
  55. * @param sql
  56. * @param params
  57. * @return
  58. */
  59. public T getBean(Connection conn,Object... params) {
  60. T t = null;
  61. try {
  62. t = queryRunner.query(conn,new BeanHandler<T>(type),params);
  63. } catch (sqlException e) {
  64. e.printStackTrace();
  65. }
  66. return t;
  67. }
  68. /**
  69. * 获取所有对象
  70. *
  71. * @param sql
  72. * @param params
  73. * @return
  74. */
  75. public List<T> getBeanList(Connection conn,Object... params) {
  76. List<T> list = null;
  77. try {
  78. list = queryRunner.query(conn,new BeanListHandler<T>(type),params);
  79. } catch (sqlException e) {
  80. e.printStackTrace();
  81. }
  82. return list;
  83. }
  84. /**
  85. * 获取一个但一值得方法,专门用来执行像 select count(*)...这样的sql语句
  86. *
  87. * @param sql
  88. * @param params
  89. * @return
  90. */
  91. public Object getValue(Connection conn,Object... params) {
  92. Object count = null;
  93. try {
  94. // 调用queryRunner的query方法获取一个单一的值
  95. count = queryRunner.query(conn,new ScalarHandler<>(),params);
  96. } catch (sqlException e) {
  97. e.printStackTrace();
  98. }
  99. return count;
  100. }
  101. }

【BookDAO.java】

  1. package com.atguigu.bookstore.dao;
  2. import java.sql.Connection;
  3. import java.util.List;
  4. import com.atguigu.bookstore.beans.Book;
  5. import com.atguigu.bookstore.beans.Page;
  6. public interface BookDao {
  7. /**
  8. * 从数据库查询出所有的记录
  9. *
  10. * @return
  11. */
  12. List<Book> getBooks(Connection conn);
  13. /**
  14. * 向数据库中插入一条记录
  15. *
  16. * @param book
  17. */
  18. void saveBook(Connection conn,Book book);
  19. /**
  20. * 从数据库中根据图书的id删除一条记录
  21. *
  22. * @param bookId
  23. */
  24. void deleteBookById(Connection conn,String bookId);
  25. /**
  26. * 根据图书的id从数据库查询出一条记录
  27. *
  28. * @param bookId
  29. * @return
  30. */
  31. Book getBookById(Connection conn,String bookId);
  32. /**
  33. * 根据图书的id从数据库中更新一条记录
  34. *
  35. * @param book
  36. */
  37. void updateBook(Connection conn,Book book);
  38. /**
  39. * 获取分页的图书信息
  40. *
  41. * @param page:是只包含了用户输入的pageNo属性的page对象
  42. * @return 返回的Page对象是包含了所有属性的Page对象
  43. */
  44. Page<Book> getPageBooks(Connection conn,Page<Book> page);
  45. /**
  46. * 获取分页和价格范围的图书信息
  47. *
  48. * @param page:是只包含了用户输入的pageNo属性的page对象
  49. * @return 返回的Page对象是包含了所有属性的Page对象
  50. */
  51. Page<Book> getPageBooksByPrice(Connection conn,Page<Book> page,double minPrice,double maxPrice);
  52. }

【UserDAO.java】

  1. package com.atguigu.bookstore.dao;
  2. import java.sql.Connection;
  3. import com.atguigu.bookstore.beans.User;
  4. public interface UserDao {
  5. /**
  6. * 根据User对象中的用户名和密码从数据库获取一条记录
  7. *
  8. * @param user
  9. * @return User 数据库中有记录 null 数据库中无此记录
  10. */
  11. User getUser(Connection conn,User user);
  12. /**
  13. * 根据User对象中的用户名数据库获取一条记录
  14. *
  15. * @param user
  16. * @return true 数据库中有记录 false 数据库中无此记录
  17. */
  18. boolean checkUsername(Connection conn,User user);
  19. /**
  20. * 向数据库中插入User对象
  21. *
  22. * @param user
  23. */
  24. void saveUser(Connection conn,User user);
  25. }

【BookDaoImpl.java】

  1. package com.atguigu.bookstore.dao.impl;
  2. import java.sql.Connection;
  3. import java.util.List;
  4. import com.atguigu.bookstore.beans.Book;
  5. import com.atguigu.bookstore.beans.Page;
  6. import com.atguigu.bookstore.dao.BaseDao;
  7. import com.atguigu.bookstore.dao.BookDao;
  8. public class BookDaoImpl extends BaseDao<Book> implements BookDao {
  9. @Override
  10. public List<Book> getBooks(Connection conn) {
  11. // 调用BaseDao中得到一个List的方法
  12. List<Book> beanList = null;
  13. // 写sql语句
  14. String sql = "select id,title,author,price,sales,stock,img_path imgPath from books";
  15. beanList = getBeanList(conn,sql);
  16. return beanList;
  17. }
  18. @Override
  19. public void saveBook(Connection conn,Book book) {
  20. // 写sql语句
  21. String sql = "insert into books(title,img_path) values(?,?,?)";
  22. // 调用BaseDao中通用的增删改的方法
  23. update(conn,book.getTitle(),book.getAuthor(),book.getPrice(),book.getSales(),book.getStock(),book.getImgPath());
  24. }
  25. @Override
  26. public void deleteBookById(Connection conn,String bookId) {
  27. // 写sql语句
  28. String sql = "DELETE FROM books WHERE id = ?";
  29. // 调用BaseDao中通用增删改的方法
  30. update(conn,bookId);
  31. }
  32. @Override
  33. public Book getBookById(Connection conn,String bookId) {
  34. // 调用BaseDao中获取一个对象的方法
  35. Book book = null;
  36. // 写sql语句
  37. String sql = "select id,img_path imgPath from books where id = ?";
  38. book = getBean(conn,bookId);
  39. return book;
  40. }
  41. @Override
  42. public void updateBook(Connection conn,Book book) {
  43. // 写sql语句
  44. String sql = "update books set title = ?,author = ?,price = ?,sales = ?,stock = ? where id = ?";
  45. // 调用BaseDao中通用的增删改的方法
  46. update(conn,book.getId());
  47. }
  48. @Override
  49. public Page<Book> getPageBooks(Connection conn,Page<Book> page) {
  50. // 获取数据库中图书的总记录数
  51. String sql = "select count(*) from books";
  52. // 调用BaseDao中获取一个单一值的方法
  53. long totalRecord = (long) getValue(conn,sql);
  54. // 将总记录数设置都page对象中
  55. page.setTotalRecord((int) totalRecord);
  56. // 获取当前页中的记录存放的List
  57. String sql2 = "select id,img_path imgPath from books limit ?,?";
  58. // 调用BaseDao中获取一个集合的方法
  59. List<Book> beanList = getBeanList(conn,sql2,(page.getPageNo() - 1) * Page.PAGE_SIZE,Page.PAGE_SIZE);
  60. // 将这个List设置到page对象中
  61. page.setList(beanList);
  62. return page;
  63. }
  64. @Override
  65. public Page<Book> getPageBooksByPrice(Connection conn,double maxPrice) {
  66. // 获取数据库中图书的总记录数
  67. String sql = "select count(*) from books where price between ? and ?";
  68. // 调用BaseDao中获取一个单一值的方法
  69. long totalRecord = (long) getValue(conn,minPrice,maxPrice);
  70. // 将总记录数设置都page对象中
  71. page.setTotalRecord((int) totalRecord);
  72. // 获取当前页中的记录存放的List
  73. String sql2 = "select id,img_path imgPath from books where price between ? and ? limit ?,maxPrice,Page.PAGE_SIZE);
  74. // 将这个List设置到page对象中
  75. page.setList(beanList);
  76. return page;
  77. }
  78. }

【UserDaoImpl.java】

  1. package com.atguigu.bookstore.dao.impl;
  2. import java.sql.Connection;
  3. import com.atguigu.bookstore.beans.User;
  4. import com.atguigu.bookstore.dao.BaseDao;
  5. import com.atguigu.bookstore.dao.UserDao;
  6. public class UserDaoImpl extends BaseDao<User> implements UserDao {
  7. @Override
  8. public User getUser(Connection conn,User user) {
  9. // 调用BaseDao中获取一个对象的方法
  10. User bean = null;
  11. // 写sql语句
  12. String sql = "select id,username,password,email from users where username = ? and password = ?";
  13. bean = getBean(conn,user.getUsername(),user.getPassword());
  14. return bean;
  15. }
  16. @Override
  17. public boolean checkUsername(Connection conn,email from users where username = ?";
  18. bean = getBean(conn,user.getUsername());
  19. return bean != null;
  20. }
  21. @Override
  22. public void saveUser(Connection conn,User user) {
  23. //写sql语句
  24. String sql = "insert into users(username,email) values(?,?)";
  25. //调用BaseDao中通用的增删改的方法
  26. update(conn,user.getPassword(),user.getEmail());
  27. }
  28. }

【Book.java】

  1. package com.atguigu.bookstore.beans;
  2. /**
  3. * 图书类
  4. * @author songhongkang
  5. *
  6. */
  7. public class Book {
  8. private Integer id;
  9. private String title; // 书名
  10. private String author; // 作者
  11. private double price; // 价格
  12. private Integer sales; // 销量
  13. private Integer stock; // 库存
  14. private String imgPath = "static/img/default.jpg"; // 封面图片的路径
  15. //构造器,get(),set(),toString()方法
  16. }

【Page.java】

  1. package com.atguigu.bookstore.beans;
  2. import java.util.List;
  3. /**
  4. * 页码
  5. * @author songhongkang
  6. *
  7. */
  8. public class Page<T> {
  9. private List<T> list; // 每页查到的记录存放的集合
  10. public static final int PAGE_SIZE = 4; // 每页显示的记录数
  11. private int pageNo; // 当前页
  12. // private int totalPageNo; // 总页数,通过计算得到
  13. private int totalRecord; // 总记录数,通过查询数据库得到

【User.java】

  1. package com.atguigu.bookstore.beans;
  2. /**
  3. * 用户
  4. * @author songhongkang
  5. *
  6. */
  7. public class User {
  8. private Integer id;
  9. private String username;
  10. private String password;
  11. private String email;

猜你在找的JDBC相关文章