1.Dao层是用来做什么的
在整个DAO中实际上都是以接口为操作标准的,即:客户端依靠DAO实现的接口进行操作,而服务端要将接口进行具体的实现。DAO由以下几个部分组成。
1)、DatabaseConnection数据库连接类: 专门负责数据库打开与关闭的类,即连接数据库并获取连接对象。
2)、VO实体类:主要由属性、setter、getter方法组成,VO类中的属性与表中的字段相对应,每一个VO类的对象都表示表中的每一条记录,即包含属性和表中字段完全对应的类。
3)、DAO接口:主要定义操作的接口,定义一系列数据库的原子性操作,例如:增加、修改、删除、按ID查询等,即提供了用户所有的操作方法(就如老师给学生提供一些学习方法)。
4)、Impl(DAO实现类): DAO接口的真实实现类,完成具体的数据库操作,但是不负责数据库的打开和关闭,即实现DAO中所有的方法(就如老师给提供的方法看你如何去完成);
5)、Proxy :代理实现类,主要完成数据库的打开和关闭,并且调用真实实现类对象的操作
6)、Factory(DAO工厂类):通过工厂类取得一个DAO的实例化对象,为程序提供方法,如果要替换DAO实现类,只需要修改该Dao工厂类中的方法代码,而不必邀修改所有的操作数据库代码(如代理人专门为需要的公司提供人才,也叫做服务层)。
2.具体代码实现与解释
2.1 项目结构
项目中用到了四个外部包,以简化JDBC的实现和连接池的实现,本演示项目使用mysql进行,数据库中表名分别为shop、warehouse。
2.2 测试用数据表
- shop表
- warehouse表
2.3 具体实现步骤
- c3p0-config.xml的配置
<?xml version="1.0" encoding="UTF-8"?>
<!-- c3p0的配置 包含了最近基本的数据源 -->
<c3p0-config>
<!--
C3P0的缺省(默认)配置,
如果在代码中“ComboPooledDataSource ds = new ComboPooledDataSource();”这样写就表示使用的是C3P0的缺省(默认)配置信息来创建数据源
-->
<default-config>
<property name="driverClass">com.mysql.jdbc.Driver</property>
<property name="jdbcUrl">jdbc:mysql://localhost:3306/test?userUnicode=true&characterEncoding=utf-8</property>
<property name="user">test</property>
<property name="password">123456</property>
<!--配置增长的数量 -->
<property name="acquireIncrement">5</property>
<!-- 初始化的连接池数量 -->
<property name="initialPoolSize">10</property>
<!-- 最低池资源的数量 -->
<property name="minPoolSize">5</property>
<!-- 最高的池资源的数量 -->
<property name="maxPoolSize">20</property>
</default-config>
</c3p0-config>
- JDBCUtil类
package com.onetreeforest.utils;
import com.mchange.v2.c3p0.ComboPooledDataSource;
import javax.sql.DataSource;
import java.sql.Connection;
import java.sql.SQLException;
/**
* 把建立连接,关闭连接的操作封装在这个类里
*
* 连接不再自己去编写,而是来自连接池——装载连接的容器,LinkedList
*/
public class JDBCUtil {
public static void main(String[] args) {
Connection conn = JDBCUtil.getConn();
System.out.println(conn);
}
//数据源:这个对象在创建的时候,发生了很多事情
//读取配置文件,创建很多个连接,放入连接池
private static ComboPooledDataSource cpds = new ComboPooledDataSource();
public static DataSource getDataSouce(){
return cpds;
}
public static Connection getConn(){
//从连接池中获得连接返回:connection是连接池的对象
try {
return cpds.getConnection();
} catch (SQLException e) {
e.printStackTrace();
}
return null;
}
public void closeConn(Connection conn){
try {
conn.close();//连接池的close方法,没有真正的关闭连接,而是将这个连接放回池中
} catch (SQLException e) {
e.printStackTrace();
}
}
}
- Shop类为实体数据库表的抽象映射,属性与数据表中的列属性一一对应,且实现set、get方法、toString方法。
package com.onetreeforest.domain;
class Shop {
private int id;
private String name;
private int price;
private String type;
public int getId() {
return id;
}
public void setId(int id) {
this.id = id;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public int getPrice() {
return price;
}
public void setPrice(int price) {
this.price = price;
}
public String getType() {
return type;
}
public void setType(String type) {
this.type = type;
}
@Override
public String toString() {
return "Shop{" +
"id=" + id +
", name='" + name + '\'' +
", price='" + price + '\'' +
", type='" + type + '\'' +
'}';
}
}
- ShopDao接口
package com.onetreeforest.dao;
import com.onetreeforest.domain.Shop;
import com.onetreeforest.domain.vo.ProductAmmount;
import java.util.List;
/**
* @InterfaceName ShopDao
* @Description 提供增删改查的方法
* @Author 1TreeForest
* @Date 2020/7/15 12:59
* @Version 1.0
*/
public interface ShopDao {
public List<Shop> findAll() throws Exception;
public Shop findById(int id) throws Exception;
public int insert(Shop shop) throws Exception;
public int update(Shop shop) throws Exception;
public int delete(int id) throws Exception;
//查询所有产品的库存
public List<ProductAmmount> findAllAmmount() throws Exception ;
}
- ShopDao的具体实现类
package com.onetreeforest.dao.impl;
import com.onetreeforest.dao.ShopDao;
import com.onetreeforest.domain.Shop;
import com.onetreeforest.domain.vo.ProductAmmount;
import com.onetreeforest.utils.JDBCUtil;
import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.handlers.BeanHandler;
import org.apache.commons.dbutils.handlers.BeanListHandler;
import java.util.List;
public class ShopDaoImpl implements ShopDao {
//创建一个qr作为执行SQL的对象,直接跟数据源绑定
QueryRunner qr = new QueryRunner(JDBCUtil.getDataSouce());
@Override
public List<Shop> findAll() throws Exception {
String sql = "select * from shop";
//sql:代表要执行的sql
//返回结果通过反射变成一个javabean的list,User是javaBean的类
List<Shop> list = qr.query(sql, new BeanListHandler<Shop>(Shop.class));
return list;
}
@Override
public Shop findById(int id) throws Exception {
String sql = "select * from shop where id = " + id;
//反射成一个bean,User类
return qr.query(sql, new BeanHandler<Shop>(Shop.class));
}
@Override
public int insert(Shop shop) throws Exception {
String sql = "insert into shop(id,name,price,type) values(?,?,?,?)";
return qr.update(sql, shop.getId(), shop.getName(), shop.getPrice(), shop.getType());
}
@Override
public int update(Shop shop) throws Exception {
String sql = "update shop set name =?,price=?,type=? where id=?";
return qr.update(sql, shop.getName(), shop.getPrice(), shop.getType(), shop.getId());
}
@Override
public int delete(int id) throws Exception {
String sql = "delete from shop where id=?";
return qr.update(sql, id);
}
@Override
public List<ProductAmmount> findAllAmmount() throws Exception {
String sql = "SELECT id,name,ammount\n" +
"FROM shop inner join warehouse\n" +
"on shop.id = warehouse.pid"; //结果集反射成对象:列和属性一定要对应
return qr.query(sql, new BeanListHandler<ProductAmmount>(ProductAmmount.class));
}
}
- 用于做多表联查的子表demo,现实情况之中常常需要给用户展示某些特定的数据,需要设计子表连接两个数据表中的数据并展示,这里是将两表中产品id、产品名称与库存连接成子表后展示给用户。
package com.onetreeforest.domain.vo;
public class ProductAmmount {
private int id;
private String name;
private int ammount;
public int getId() {
return id;
}
public void setId(int id) {
this.id = id;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public int getAmmount() {
return ammount;
}
public void setAmmount(int ammount) {
this.ammount = ammount;
}
@Override
public String toString() {
return "ProductAmmount{" +
"id=" + id +
", name='" + name + '\'' +
", ammount=" + ammount +
'}';
}
}
- 测试代码
public static void main(String[] args) throws Exception {
ShopDao dao = new ShopDaoImpl();
// List<Shop> list = dao.findAll(); //全查测试
// System.out.println(list);
// Shop shop = dao.findById(2); //单查测试
// System.out.println(shop);
// Shop shop = new Shop(); //插入测试
// shop.setId(999);
// shop.setName("test");
// shop.setPrice(987);
// shop.setType("tttt");
// dao.insert(shop);
// Shop shop = new Shop(); //更新测试
// shop.setId(999);
// shop.setName("te1st");
// shop.setPrice(97);
// shop.setType("t1234");
// dao.update(shop);
// dao.delete(999); //删除测试
// List<ProductAmmount> list2 = dao.findAllAmmount(); //多表联查测试
// System.out.println(list2);
以上仅为个人学习过程中的学习记录,在开发过程中会持续完善。若有理解错误的地方欢迎指正。