JavaWeb学习笔记(二):Dao层的简单实现

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&amp;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);

以上仅为个人学习过程中的学习记录,在开发过程中会持续完善。若有理解错误的地方欢迎指正。

猜你喜欢

转载自blog.csdn.net/qq_37396476/article/details/107365352