当前位置：自学咖网 > 技术教程 > 编程最新 > day49-JDBC和连接池05
wenwen 编程最新

day49-JDBC和连接池05

day49-JDBC和连接池05

JDBC和连接池05

11.BasicDAO

  • 先来分析一个问题

    前面我们使用了Apache-DBUtils和Druid简化了JDBC开发，但仍存在以下不足：

    • SQL语句是固定的，不能通过参数传入，通用性不好，需要进行改进，来更方便执行增删改查

    • 对于select操作，如果有返回值，返回类型还不确定，应该使用泛型

    • 将来如果表很多，业务需求复杂，不可能只靠一个Java来完成

为了解决这些问题，就要引出BasicDAO的概念

11.1BasicDao分析

  • 基本说明

  1. DAO，即data access object(数据访问对象)

  2. 这样的通用类称为BasicDao，是专门和数据库进行交互的，即完成对数据库（表）的crud操作

  3. 在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 //写测试类

image-20221017212118550

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

    }
}

运行结果：

image-20221017203752269
image-20221017203650205

11.3练习

开发GoodsDAO和Goods，完成对表goods的crud

image-20221017212634726
image-20221017212649833

hmoban主题是根据ripro二开的主题，极致后台体验，无插件，集成会员系统
自学咖网 » day49-JDBC和连接池05

wen 普通

分享到：

相关推荐

MyBatis（三）：CRUD的操作实现

在MyBatis（二）的学习中我们已经实现了第一个MyBatis程序，现在我们要实现增删改查的完整操作，我们应该思考我们需要去修改哪些内容呢？ 修改三个内容：Mapper接口、对应Mapper接口的xml配置文件、测试类...

Leetcode 829. 连续整数求和（C语言）

829. 连续整数求和 给定一个正整数 N，试求有多少组连续正整数满足所有数字之和为 N? 示例 1: 输入: 5 输出: 2 解释: 5 = 5 = 2 + 3，共有两组连续整数([5],[2,3])求和后为 5。 示...

Java 加载、操作和保存WPS文字文档 – E

本文通过Java程序代码来展示如何来加载、操作及保存WPS格式的文字文档。 一、基本步骤：加载时，通过流加载WPS文字文档，完成相关文字操作后，再将结果文档保存到流，将流写入WPS文档，关闭流。 二、程序环境 这里使用的...

java开发JDK工具的安装

1.java开发工具的构成 （1）JVM即java虚拟机，用于解释翻译java生成的自解码文件，因为java中有了这个，才能实现java语言跨平台运行java自解码文件 （2）JRE即java运行环境，它是由JVM和ja...

到底什么是内存可见性？

我们都知道，volatile保证了内存可见性和禁止指令重排，但是对于内存可见性这一条，我一直没有完全弄明白，今天咱们一起看一下，这个可见性，到底是如何可见，数据到底是如何可见的。 首先我们要达成一个共识：单核CPU由于同...