JarCastingJDBC工具包
一、简介
1.1概述
提供基于JDBC的基本CRUD封装。
1.2坐标
<dependency>
<groupId>com.fixiu</groupId>
<artifactId>jdbc-utils</artifactId>
<version>1.0.0-RELEASE</version>
</dependency>
1.3 特性
- 支持多种连接类型：
MySQL、Oracle、SqlServer、TiDB和Hive - 支持多种连接池：
C3P0、Dbcp2、HikariCP和Druid - 支持CRUD操作
1.4 注意
- 使用对应数据源时，请自助在使用的服务中添加对应数据源的驱动
二、使用
2.1查询
2.1.1 使用查询器构建工厂类构建查询器
-
查询器构建工厂类 :
com.fixiu.jdbc.QueryFactory -
查询器类：
com.fixiu.jdbc.Query -
查询器构建参数说明
参数名称 参数类型 是否必须 说明 driverClass String 是 驱动类 datasourceUrl String 是 数据源连接URL username String 是 用户名 password String 是 密码 dbType enum 是 数据库类型 dbPoolType enum 是 连接池类型 options Map 连接池类型为 NO时非必须连接池参数
2.1.2 查询器支持的操作
Connection getJdbcConnection(): 获取JDBC连接Map query(sqlText): 获取可执行SQL执行结果，结果返回一个Map，Map中包含一个值为DATA的Key，对应的Value是一个列表，列表中的每一个元素为一个Map，该Map中的Key为查询列，值为每一行记录对应列的值。Map query(sqlText, pageStatement): 分页获取可执行SQL执行结果，pageStatement为分页参数long queryCount(sqlText): 获取可执行SQL的结果数量String countSql(sqlText): 将可执行SQL转换为COUNT SQLString pageSql(sqlText, sqlPageStatement): 将可执行SQL转换为分页SQL，会自动判断当前数据库类型，按照数据库类型生成不同的SQL
2.1.3 查询器的使用
DatasourceStatement ds = new DatasourceStatement(
"FIXIU-TEST",
"com.mysql.cj.jdbc.Driver",
"jdbc:mysql://localhost:3306/test_db?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=UTC",
"root",
"123456",
"com.fixiu.jdbc.query.MySqlQueryer",
"com.fixiu.jdbc.dbpool.HikariCPDataSourcePool");
// 1. initialization Query or Update instance
Query query = QueryFactory.create(ds);
// --------------OR--------------
Map<String, Object> options = new HashMap<>();
// Argument example
options.put("database_conn_pool_arg_key", "database_conn_pool_arg_value");
Query query = QueryFactory.create(
"FIXIU-TEST",
"com.mysql.cj.jdbc.Driver",
"jdbc:mysql://localhost:3306/test_db?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=UTC",
"root",
"123456",
DatabaseTypeEnum.MYSQL,
DBPoolTypeEnum.HIKARI,
options);
// 2. Execute SQL and get results
Map<String, Object> result = query.query("SELECT * FROM yours_table");
2.2 增删改
2.2.1 构建增删改执行器对象：
-
增删改执行器类 :
com.fixiu.jdbc.Update -
增删改执行器构建参数说明
参数名称 参数类型 是否必须 说明 driverClass String 是 驱动类 datasourceUrl String 是 数据源连接URL username String 是 用户名 password String 是 密码 dbType enum 是 数据库类型 dbPoolType enum 是 连接池类型 options Map 连接池类型为 NO时非必须连接池参数
2.2.2 增删改执行器支持的操作
Connection getJdbcConnection(): 获取JDBC连接executeAndClose(sqlText): 执行增删改SQL并且自动提交，关闭连接executeAndClose(sqlTexts): 批量执行增删改SQL并且自动提交，关闭连接execute(sqlText): 执行增删改SQL，返回JDBC连接，并且不提交execute(sqlTexts): 批量执行增删改SQL，返回JDBC连接，并且不提交commitAndClose(): 提交并且关闭连接
2.2.3 增删改执行器的使用
DatasourceStatement ds = new DatasourceStatement(
"FIXIU-TEST",
"com.mysql.cj.jdbc.Driver",
"jdbc:mysql://localhost:3306/test_db?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=UTC",
"root",
"123456",
"com.fixiu.jdbc.query.MySqlQueryer",
"com.fixiu.jdbc.dbpool.HikariCPDataSourcePool");
// 1. initialization Query or Update instance
Update update = UpdateFactory.create(ds);
// --------------OR--------------
Map<String, Object> options = new HashMap<>();
// Argument example
options.put("database_conn_pool_arg_key", "database_conn_pool_arg_value");
Update update = UpdateFactory.create(
"FIXIU-TEST",
"com.mysql.cj.jdbc.Driver",
"jdbc:mysql://localhost:3306/test_db?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=UTC",
"root",
"123456",
DatabaseTypeEnum.MYSQL,
DBPoolTypeEnum.HIKARI,
options);
// 2. Execute SQL and get results
int result = update.executeAndClose("INSERT INTO at_jdbc(a) values('A')");