day49-JDBC和连接池05

技术分享 3年前 (2022-10-18) 0 999+

关注

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 ? "操作成功" : "执行没有影响表");      } }

运行结果：

day49-JDBC和连接池05