Java中使用Apache-DBUtils实现CRUD操作

举报
孤星恋悦 发表于 2021/10/09 10:35:09 2021/10/09
【摘要】 Java中使用Apache-DBUtils实现CRUD操作

1、Apache-DBUtils简介

commons-dbutils 是 Apache 组织提供的一个开源 JDBC工具类库,它是对JDBC的简单封装,学习成本极低,并且使用dbutils能极大简化jdbc编码的工作量,同时也不会影响程序的性能。

2、测试环境准备

2.1、maven工程添加依赖

<dependency>
    <groupId>com.alibaba</groupId>
    <artifactId>druid</artifactId>
    <version>1.2.8</version>
</dependency>
<dependency>
    <groupId>commons-dbutils</groupId>
    <artifactId>commons-dbutils</artifactId>
    <version>1.7</version>
</dependency>

2.2、新建获取数据库连接工具类

以下测试代码均使用Druid作为数据库连接池获取数据库连接,使用配置文件的方式获取,对应JdbcUtils.java代码如下:

import com.alibaba.druid.pool.DruidDataSourceFactory;

import javax.sql.DataSource;
import java.io.InputStream;
import java.sql.Connection;
import java.util.Properties;

/**
 * Jdbc工具类
 */
public class JdbcUtils {
    private static DataSource source = null;

    static {
        try {
            Properties pros = new Properties();
            // 加载配置文件
            InputStream is = DruidTest.class.getClassLoader().getResourceAsStream("druid.properties");
            pros.load(is);
            // 根据提供的DruidDataSourceFactory创建对应的DataSource对象
            source = DruidDataSourceFactory.createDataSource(pros);
        } catch (Exception e) {
            e.printStackTrace();
        }

    }

    /**
     * 使用Druid数据库连接池的配置文件方式,获取数据库的连接:推荐
     */
    public static Connection getConnection() throws Exception {
        return source.getConnection();
    }
}

【druid.properties】内容如下:

driverClassName=com.mysql.cj.jdbc.Driver
url=jdbc:mysql://192.168.175.128:3306/test?rewriteBatchedStatements=true
username=root
password=root

initialSize=10
maxActive=20
maxWait=1000
filters=wall

2.3、创建数据库表

CREATE TABLE `user_info` (
  `id` int NOT NULL AUTO_INCREMENT,
  `name` varchar(255) COLLATE utf8_bin DEFAULT NULL,
  `balance` int DEFAULT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=5 DEFAULT CHARSET=utf8mb3 COLLATE=utf8_bin;

3、主要API介绍

3.1、DbUtils类

  • DbUtils:提供如关闭连接、装载JDBC驱动程序等常规工作的工具类,里面的所有方法都是静态的。主要方法如下:
public static void close() throws java.sql.SQLExceptionDbUtils类提供了三个重载的关闭方法。这些方法检查所提供的参数是不是NULL,如果不是的话,它们就关闭ConnectionStatementResultSetpublic static void closeQuietly(): 这一类方法不仅能在ConnectionStatementResultSet为NULL情况下避免关闭,还能隐藏一些在程序中抛出的SQLEeceptionpublic static void commitAndClose(Connection conn)throws SQLException: 用来提交连接的事务,然后关闭连接
public static void commitAndCloseQuietly(Connection conn): 用来提交连接,然后关闭连接,并且在关闭连接时不抛出SQL异常。 
public static void rollback(Connection conn)throws SQLException:允许conn为null,因为方法内部做了判断
public static void rollbackAndClose(Connection conn)throws SQLException 
public static void rollbackAndCloseQuietly(Connection)
public static boolean loadDriver(java.lang.String driverClassName):这一方装载并注册JDBC驱动程序,如果成功就返回true。使用该方法,你不需要捕捉这个异常ClassNotFoundException

3.2、QueryRunner类

  • 该类简单化了SQL查询,它与ResultSetHandler组合在一起使用可以完成大部分的数据库操作,能够大大减少编码量。
  • QueryRunner类提供了两个构造器:
    • 默认的构造器
    • 需要一个 javax.sql.DataSource 来作参数的构造器
  • QueryRunner类的主要方法:
更新:
public int update(Connection conn, String sql, Object... params) throws SQLException:用来执行一个更新(插入、更新或删除)操作。

插入:
public <T> T insert(Connection conn,String sql,ResultSetHandler<T> rsh, Object... params) throws SQLException:只支持INSERT语句,其中 rsh 为自动生成的键值。

批处理:
public int[] batch(Connection conn,String sql,Object[][] params)throws SQLException: INSERT, UPDATE, or DELETE语句
public <T> T insertBatch(Connection conn,String sql,ResultSetHandler<T> rsh,Object[][] params)throws SQLException:只支持INSERT语句

查询:
public Object query(Connection conn, String sql, ResultSetHandler rsh,Object... params) throws SQLException:执行一个查询操作,在这个查询中,对象数组中的每个元素值被用来作为查询语句的置换参数。该方法会自行处理 PreparedStatementResultSet 的创建和关闭。
  • 测试代码如下
/**
 * 测试添加
 */
@Test
public void testInsert() throws Exception {
    QueryRunner runner = new QueryRunner();
    Connection conn = JdbcUtils.getConnection();
    String sql = "insert into user_info(name, balance) values (?, ?)";
    ResultSetHandler<Integer> rsh = resultSet -> {
        if (resultSet.next()) {
            return resultSet.getInt(1);
        }
        return 0;
    };
    int id = runner.insert(conn, sql, rsh, "张三", 20000);
    System.out.println("添加了的数据id值为:" + id);
    DbUtils.close(conn);
}

/**
 * 测试更新
 */
@Test
public void testUpdate() throws Exception {
    QueryRunner runner = new QueryRunner();
    Connection conn = JdbcUtils.getConnection();
    String sql = "update user_info set balance = balance + ? where id < ?";
    int count = runner.update(conn, sql, 500, 3);
    System.out.println("更新了" + count + "条记录");
    DbUtils.close(conn);
}

/**
 * 测试删除
 */
@Test
public void testDelete() throws Exception {
    QueryRunner runner = new QueryRunner();
    Connection conn = JdbcUtils.getConnection();
    String sql = "delete from user_info where id > ?";
    int count = runner.update(conn, sql, 3);
    System.out.println("删除了" + count + "条记录");
    DbUtils.close(conn);
}

3.3、ResultSetHandler接口及实现类

  • 该接口用于处理 java.sql.ResultSet,将数据按要求转换为另一种形式。

  • ResultSetHandler 接口提供了一个单独的方法:Object handle (java.sql.ResultSet .rs)。

  • 接口的主要实现类:

    • ArrayHandler:把结果集中的第一行数据转成对象数组。
    • ArrayListHandler:把结果集中的每一行数据都转成一个数组,再存放到List中。
    • BeanHandler:将结果集中的第一行数据封装到一个对应的JavaBean实例中。
    • BeanListHandler:将结果集中的每一行数据都封装到一个对应的JavaBean实例中,存放到List里。
    • ColumnListHandler:将结果集中某一列的数据存放到List中。
    • KeyedHandler(name):将结果集中的每一行数据都封装到一个Map里,再把这些map再存到一个map里,其key为指定的key。
    • MapHandler:将结果集中的第一行数据封装到一个Map里,key是列名,value就是对应的值。
    • MapListHandler:将结果集中的每一行数据都封装到一个Map里,然后再存放到List
    • ScalarHandler:查询单个值对象
  • 测试代码如下

UserInfo.java实体类代码:

public class UserInfo {
    private String name;
    private Integer balance;

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public Integer getBalance() {
        return balance;
    }

    public void setBalance(Integer balance) {
        this.balance = balance;
    }

    @Override
    public String toString() {
        return "UserInfo{name='" + name + '\'' + ", balance=" + balance + '}';
    }
}

测试代码:

/**
 * 测试查询:查询一条记录,使用ResultSetHandler的实现类:BeanHandler
 */
@Test
public void testQueryInstance() throws Exception {
    QueryRunner runner = new QueryRunner();
    Connection conn = JdbcUtils.getConnection();
    String sql = "select name, balance from user_info where name = ?";
    BeanHandler<UserInfo> handler = new BeanHandler<>(UserInfo.class);
    UserInfo userInfo = runner.query(conn, sql, handler, "AA");
    System.out.println(userInfo);
    DbUtils.close(conn);
}

/**
 * 测试查询:查询多条记录构成的集合:使用ResultSetHandler的实现类:BeanListHandler
 */
@Test
public void testQueryList() throws Exception {
    QueryRunner runner = new QueryRunner();
    Connection conn = JdbcUtils.getConnection();
    String sql = "select name, balance from user_info where balance <= ?";
    BeanListHandler<UserInfo> handler = new BeanListHandler<>(UserInfo.class);
    List<UserInfo> list = runner.query(conn, sql, handler, 5000);
    list.forEach(System.out::println);
    DbUtils.close(conn);
}
【版权声明】本文为华为云社区用户原创内容,转载时必须标注文章的来源(华为云社区)、文章链接、文章作者等基本信息, 否则作者和本社区有权追究责任。如果您发现本社区中有涉嫌抄袭的内容,欢迎发送邮件进行举报,并提供相关证据,一经查实,本社区将立刻删除涉嫌侵权内容,举报邮箱: cloudbbs@huaweicloud.com
  • 点赞
  • 收藏
  • 关注作者

评论(0

0/1000
抱歉,系统识别当前为高风险访问,暂不支持该操作

全部回复

上滑加载中

设置昵称

在此一键设置昵称,即可参与社区互动!

*长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。

*长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。