day49-JDBC和连接池05
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 ? "操作成功" : "执行没有影响表");
}
}
运行结果：
11.3练习
开发GoodsDAO和Goods，完成对表goods的crud
