Apache-DBUtils实现CRUD操作,已封装的API实现jdbc对数据库进行操作

简介: Apache-DBUtils实现CRUD操作,已封装的API实现jdbc对数据库进行操作

文章目录


一、Apache-DBUtils简介

二、主要API的使用

1、DbUtils类

2、QueryRunner类

3、ResultSetHandler接口及实现类

三、Apache-DBUtils驱动下载


一、Apache-DBUtils简介


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


API介绍:


493e65c4fe28437d8c4b3b69a5e06038.png8139709e2de84b0091e4aa37b8ff8520.png



二、主要API的使用


1、DbUtils类

提供如关闭连接、装载JDBC驱动程序等常规工作的工具类,里面的所有方法都是静态的。主要方法如下:

①public static void close(…) throws java.sql.SQLException: DbUtils类提供了三个重载的关闭方法。这些方法检查所提供的参数是不是NULL,如果不是的话,它们就关闭Connection、Statement和ResultSet。

②public static void closeQuietly(…):这一类方法不仅能在Connection、Statement和ResultSet为NULL情况下避免关闭,还能隐藏一些在程序中抛出的SQLEeception。

③public 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

⑦rollbackAndCloseQuietly(Connection)

⑧public static boolean loadDriver(java.lang.String driverClassName):这一方装载并注册JDBC驱动程序,如果成功就返回true。


2、QueryRunner类

该类简单化了SQL查询,它与ResultSetHandler组合在一起使用可以完成大部分的数据库操作,能够大大减少编码量。


QueryRunner类提供了两个构造器:

①默认的构造器

②需要一个 javax.sql.DataSource 来作参数的构造器


QueryRunner类的主要方法:

①更新

public int update(Connection conn, String sql, Object... params) throws SQLException:用来执行一个更新(插入、更新或删除)操作。

②插入

public T insert(Connection conn,String sql,ResultSetHandler rsh, Object... params) throws SQLException:只支持INSERT语句,其中 rsh - The handler used to create the result object from the ResultSet of auto-generated keys. 返回值: An object generated by the handler.即自动生成的键值。

③批量处理

public int[] batch(Connection conn,String sql,Object[][] params) throws SQLException: INSERT、UPDATE、DELETE语句。

public T insertBatch(Connection conn,String sql,ResultSetHandler rsh,Object[][] params)throws SQLException:只支持INSERT语句

④查询

public Object query(Connection conn, String sql, ResultSetHandler rsh,Object... params) throws SQLException:执行一个查询操作,在这个查询中,对象数组中的每个元素值被用来作为查询语句的置换参数。该方法会自行处理 PreparedStatement 和 ResultSet 的创建和关闭。


测试:


//添加
public void testInsert() throws Exception {
  QueryRunner runner = new QueryRunner();
  Connection conn = JDBCUtils.getConnection3();
  String sql = "insert into customers(name,email,birth)values(?,?,?)";
  int count = runner.update(conn, sql, "何成飞", "he@qq.com", "1992-09-08");
  System.out.println("添加了" + count + "条记录");
  JDBCUtils.closeResource(conn, null);
}


//删除
public void testDelete() throws Exception {
  QueryRunner runner = new QueryRunner();
  Connection conn = JDBCUtils.getConnection3();
  String sql = "delete from customers where id < ?";
  int count = runner.update(conn, sql,3);
  System.out.println("删除了" + count + "条记录");
  JDBCUtils.closeResource(conn, null);
}


3、ResultSetHandler接口及实现类

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

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


接口的主要实现类:


cd63b973ee924fb6b79c3e7c411f5e8f.png


测试:


/*
* 测试查询:查询一条记录
* 使用ResultSetHandler的实现类:BeanHandler
*/
public void testQueryInstance() throws Exception{
  QueryRunner runner = new QueryRunner();
  Connection conn = JDBCUtils.getConnection();
  String sql = "select id,name,email,birth from customers where id = ?";
  BeanHandler<Customer> handler = new BeanHandler<>(Customer.class);
  Customer customer = runner.query(conn, sql, handler, 23);
  System.out.println(customer);
  JDBCUtils.closeResource(conn, null);
}


/*
* 测试查询:查询多条记录构成的集合
* 使用ResultSetHandler的实现类:BeanListHandler
*/
public void testQueryList() throws Exception{
  QueryRunner runner = new QueryRunner();
  Connection conn = JDBCUtils.getConnection();
  String sql = "select id,name,email,birth from customers where id < ?";
  BeanListHandler<Customer> handler = new BeanListHandler<>(Customer.class);
  List<Customer> list = runner.query(conn, sql, handler, 23);
  list.forEach(System.out::println);
  JDBCUtils.closeResource(conn, null);
}


/*
* 如何查询类似于最大的,最小的,平均的,总和,个数相关的数据,
* 使用ScalarHandler
*/
public void testQueryValue() throws Exception{
  QueryRunner runner = new QueryRunner();
  Connection conn = JDBCUtils.getConnection();
  //个数:
  // String sql = "select count(*) from customers where id < ?";
  // ScalarHandler handler = new ScalarHandler();
  // long count = (long) runner.query(conn, sql, handler, 20);
  // System.out.println(count);
  //最大值:
  String sql = "select max(birth) from customers";
  ScalarHandler handler = new ScalarHandler();
  Date birth = (Date) runner.query(conn, sql, handler);
  System.out.println(birth);
  JDBCUtils.closeResource(conn, null);
}


三、Apache-DBUtils驱动下载


Apache-DBUtils


相关文章
|
2月前
|
Java 数据库连接
JDBC跨平台封装工具类
JDBC跨平台封装工具类
|
2月前
|
API 数据库 C语言
【C/C++ 数据库 sqlite3】SQLite C语言API返回值深入解析
【C/C++ 数据库 sqlite3】SQLite C语言API返回值深入解析
189 0
|
2月前
|
Prometheus 网络协议 JavaScript
api 网关 kong 数据库记录请求响应报文
Kong的tcp-log-with-body插件是一个高效的工具,它能够转发Kong处理的请求和响应。这个插件非常适用于需要详细记录API请求和响应信息的情景,尤其是在调试和排查问题时。
99 0
api 网关 kong 数据库记录请求响应报文
|
21天前
|
SQL Java 数据库连接
JDBC开发之四大核心API:DriverManager Connection Statement ResultSet
JDBC开发之四大核心API:DriverManager Connection Statement ResultSet
21 1
|
1月前
|
监控 Java 数据库连接
Java一分钟之-JDBC连接池:HikariCP, Apache DBCP, C3P0
【6月更文挑战第14天】本文介绍了Java中常用的三种JDBC连接池——HikariCP、Apache DBCP和C3P0。HikariCP以其高性能和低延迟领先,适合高并发环境;Apache DBCP稳定易配置;C3P0则提供高度可定制选项。文章讨论了各连接池的常见问题及避免策略,如配置不当、连接泄露等,并给出示例代码以供参考。选择合适的连接池并正确配置能有效提升应用性能。
40 7
|
15天前
|
DataWorks Oracle 数据库连接
DataWorks产品使用合集之如何实现数据集成接入提供ODBC API的Oracle数据库
DataWorks作为一站式的数据开发与治理平台,提供了从数据采集、清洗、开发、调度、服务化、质量监控到安全管理的全套解决方案,帮助企业构建高效、规范、安全的大数据处理体系。以下是对DataWorks产品使用合集的概述,涵盖数据处理的各个环节。
22 0
|
1月前
|
JSON 前端开发 API
Apache HttpClient调用Spring3 MVC Restful Web API演示
Apache HttpClient调用Spring3 MVC Restful Web API演示
22 1
|
18天前
|
SQL Java 数据库连接
老程序员分享:JDBC工具类封装、封装DAO方法与数据库表实体类封装的使用案列详情
老程序员分享:JDBC工具类封装、封装DAO方法与数据库表实体类封装的使用案列详情
|
2月前
|
Java 关系型数据库 数据库连接
实时计算 Flink版操作报错之遇到错误org.apache.flink.table.api.ValidationException: Could not find any factory for identifier 'jdbc',该如何解决
在使用实时计算Flink版过程中,可能会遇到各种错误,了解这些错误的原因及解决方法对于高效排错至关重要。针对具体问题,查看Flink的日志是关键,它们通常会提供更详细的错误信息和堆栈跟踪,有助于定位问题。此外,Flink社区文档和官方论坛也是寻求帮助的好去处。以下是一些常见的操作报错及其可能的原因与解决策略。
|
2月前
|
Java 关系型数据库 MySQL
flea-db使用之封装JDBC接入
【4月更文挑战第6天】本篇 Huazie 介绍 Flea 框架下的 flea-db 模块中封装JDBC的逻辑
41 1
flea-db使用之封装JDBC接入

推荐镜像

更多