三十二章-- DAO
DAO是 简化 优化 封装JDBC的操作
一 了解什么是DAO模式
传统的JDBC操作(问题):
1.加载驱动和建立连接的步骤冗余
解决方案: 提取成公共的方法
2.释放资源/关流步骤冗余
解决方案: 提取成公共的方法
3.业务代码和数据访问代码耦合在一起 会导致阅读困难 数据访问代码复用性差
解决方案: 将业务代码和数据访问代码分离 无非就是抽成方法或类
什么是DAO模式
DAO:(Data Access Object)数据存取/访问对象
是业务逻辑和持久化数据之间的一个转换器
可以将Java对象和持久化数据(数据库表行/记录)进行转换
Java 对象 ->数据库表记录
Grade对象 ->JDBC ->数据库记录表
数据库记录表 -> Java对象
数据库表记录 ->JDBC->Grade
二 掌握DAO模式的组成
DAO模式不是设计模式
DAO模式的组成
1.DAO接口:(面向接口编程)
隔离了不同的数据库实现和不同的访问数据库技术实现
2.DAO实现类:
隔离了数据访问代码和业务逻辑代码
3.实体类:
和数据库表对应 使用DAO之后可以将数据在实体对象(Java对象)和数据库表记录之间转换
例如:保存一条学生信息,在Java中肯定会使用一个学生对象来存储学生信息
查询一条学生信息,在Java中肯定会使用一个学生对象来存储学生信息
查询多条学生信息,在Java中用什么存储?List
4.数据库连接和关闭工具类:
利用一个专门的工具类来实现数据连接开启和关闭
三 掌握DAO模式的使用
使用规范:
1.实体类:
符合JavaBean规范 和数据库表对应 一般放在entity包中
2.DAO接口:
A:我们的数据存取操作一般都是以表为单位,所以正好以和表对应的实体类为前缀命名 ,以Dao为后缀
例如:UserDao
B:一般放在dao包中
3.DAO实现类:
A.还是以上方接口的命名方式,只不过在后缀上多加一个impl标志标明它是实现类
例如:UserDaoImpl
B:一般会放在dao包下的impl包中
传统的DAO模式
按照上方的组成实现DAO模式
主流的DAO模式
对于上方的DAO模式组成做了一些调整优化
BaseDao:它的作用就是用来封装通用的增删改查的,同样数据的连接和关闭工具类的作用也会融合进来
public class UserDaoImpl extends BaseDao implements UserDao {
}
/**
* 用于封装通用的增删改查 顺便将通用的连接开启和关闭也封装过来
*
*/
public class BaseDao {
protected Connection conn;
protected PreparedStatement ps;
protected ResultSet rs;
static {
try {
// 加载驱动只需要执行一次即可
Class.forName("com.mysql.jdbc.Driver");
} catch (ClassNotFoundException e) {
e.printStackTrace();
}
}
/**
* 获取连接
* @return
* @throws Exception
*/
public Connection getConnection() throws Exception {
return DriverManager.getConnection("jdbc:mysql:///kgcnews", "root", "root");
}
/**
* 释放资源
* @param rs
* @param ps
* @param conn
*/
public void closeResource(ResultSet rs, PreparedStatement ps, Connection conn) {
// 先开的后关
if (rs != null) {
try {
rs.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
if (ps != null) {
try {
ps.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
if (conn != null) {
try {
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
/**
* 通用查询
*
* @param sql
* @param params
* @throws Exception
*/
public void executeQuery(String sql, Object[] params) throws Exception {
conn = this.getConnection();
ps = conn.prepareStatement(sql);
// 给占位符赋值 (根据占位符数组的长度决定赋值多少次)
if (params != null) {
for (int i = 0; i < params.length; i++) {
ps.setObject((i + 1), params[i]);
}
}
rs = ps.executeQuery();
}
/**
* 通用的增删改
*
* @param sql 增删改的SQL语句
* @param params 传递的不同的占位符参数值
* @return
* @throws Exception
*/
public int executeUpdate(String sql, Object[] params) throws Exception {
int row = 0;
try {
conn = this.getConnection();
ps = conn.prepareStatement(sql);
// 给占位符赋值 (根据占位符数组的长度决定赋值多少次)
if (params != null) {
for (int i = 0; i < params.length; i++) {
ps.setObject((i + 1), params[i]);
}
}
row = ps.executeUpdate();
} finally {
this.closeResource(null, ps, conn);
}
return row;
}
/*
* public int executeUpdate(String sql,Object... objects) {
*
* }
*/
}
四 掌使用Properties配置文件解决硬编码
# 键值对存储配置信息
datasource.driver=com.mysql.jdbc.Driver
datasource.url=jdbc:mysql:///kgcnews
datasource.username=root
datasource.password=root
public class BaseDao {
protected Connection conn;
protected PreparedStatement ps;
protected ResultSet rs;
private static String DRIVER;
private static String URL;
private static String USERNAME;
private static String PASSWORD;
static {
try {
// 初始化数据源信息
initProperty();
// 加载驱动只需要执行一次即可
Class.forName(DRIVER);
} catch (Exception e) {
e.printStackTrace();
}
}
/**
* 初始化数据源信息
* @throws IOException
*/
private static void initProperty() throws IOException {
Properties prop = new Properties();
prop.load(BaseDao.class.getClassLoader().getResourceAsStream("db.properties"));
DRIVER = prop.getProperty("datasource.driver");
URL = prop.getProperty("datasource.url");
USERNAME = prop.getProperty("datasource.username");
PASSWORD = prop.getProperty("datasource.password");
}
/**
* 获取连接
* @return
* @throws Exception
*/
public Connection getConnection() throws Exception {
return DriverManager.getConnection(URL, USERNAME, PASSWORD);
}
/**
* 释放资源
* @param rs
* @param ps
* @param conn
*/
public void closeResource(ResultSet rs, PreparedStatement ps, Connection conn) {
// 先开的后关
if (rs != null) {
try {
rs.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
if (ps != null) {
try {
ps.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
if (conn != null) {
try {
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
/**
* 通用查询
*
* @param sql
* @param params
* @throws Exception
*/
public void executeQuery(String sql, Object[] params) throws Exception {
conn = this.getConnection();
ps = conn.prepareStatement(sql);
// 给占位符赋值 (根据占位符数组的长度决定赋值多少次)
if (params != null) {
for (int i = 0; i < params.length; i++) {
ps.setObject((i + 1), params[i]);
}
}
rs = ps.executeQuery();
}
/**
* 通用的增删改
*
* @param sql 增删改的SQL语句
* @param params 传递的不同的占位符参数值
* @return
* @throws Exception
*/
public int executeUpdate(String sql, Object[] params) throws Exception {
int row = 0;
try {
conn = this.getConnection();
ps = conn.prepareStatement(sql);
// 给占位符赋值 (根据占位符数组的长度决定赋值多少次)
if (params != null) {
for (int i = 0; i < params.length; i++) {
ps.setObject((i + 1), params[i]);
}
}
row = ps.executeUpdate();
} finally {
this.closeResource(null, ps, conn);
}
return row;
}
/*
* public int executeUpdate(String sql,Object... objects) {
*
* }
*/
}