一. DBUtils的引出
1、connection不能提前关闭
当我们查出结果集resultSet的时候，就关闭了connection连接，这时resultSet就不能使用了
示例代码如下：
public class jdbcDBUtils {
@Test
public void test() throws Exception{
Connection connection = JDBCUtils.getConnection();
String sql = "select * from admin";
PreparedStatement preStatement = connection.prepareStatement(sql);
ResultSet resultSet = preStatement.executeQuery();
/**注意:
* 以下三种方式，都会导致 java.sql.SQLException: Operation not allowed after ResultSet closed
* 在使用完resultSet结果集之前，不能将resultSet、preStatement、connection关闭。
*/
//JDBCUtils.Close(resultSet,null,null);
//JDBCUtils.Close(null,preStatement,null);
JDBCUtils.Close(null,null,connection);
while(resultSet.next()){
int id = resultSet.getInt("id");
String name = resultSet.getString("name");
String pwd = resultSet.getString("pwd");
System.out.println("id:" + id +" name:" + name + " pwd:" + pwd);
}
}
}
运行结果如下：
总结：在使用resultSet结果集之前，不能提前关闭resultSet，preStatement以及connection。
2.resultSet无法重复使用
当遍历完resultSet之后，肯定要关闭连接，导致resultSet无法重复使用。
由1和2引出如下问题：
① 如何让resultSet结果集重复使用
② 在遍历的过程中，能否简化遍历过程
解决方案：使用DBUtils的jar包
二. DBUtils的使用
1. 在libs中引入dbutils的jar包
2. query语句：
① 将表中数据全部查找出来【多行】
public class jdbcDBUtils {
/**
* 查询表中所有结果
* @throws Exception
*/
@Test
public void testSearchAll() throws Exception{
// 1. 在libs中引入dbutils的jar包
// 2. 获取druid连接池的连接
Connection connection = JDBCUtilsByDruid.getConnection();
// 3.使用queryRunner查询结果
String sql = "select * from admin";
QueryRunner queryRunner = new QueryRunner();
// 4.将connection,sql,bean对象，作为参数放入query()中
// 1)传入连接connection
// 2)传入sql语句
// 3)传入bean对象 new BeanListHandler<>(Admin.class) 【反射机制】
// resultSet -> admin对象 -> List<Admin>集合
/** QueryRunner的query()源码如下:
* 1) public <T> T query(Connection conn, String sql, ResultSetHandler<T> rsh) throws SQLException {
* return this.query(conn, sql, rsh, (Object[])null);
*
* }
* 注意在 1) 中 调用 2) 时，传入的可变参数是null
*
* 2) public <T> T query(Connection conn, String sql, ResultSetHandler<T> rsh, Object... params)
* throws SQLException {
* PreparedStatement stmt = null;
* ResultSet rs = null;
* Object result = null;
*
* try {
* // 通过conn和sql创建PreparedStatement类的stmt对象
* stmt = this.prepareStatement(conn, sql);
* // 将可变参数params传入给sql语句的占位符?
* this.fillStatement(stmt, params);
* // stmt执行sql语句
* rs = this.wrap(stmt.executeQuery());
* // 将得到的结果集resultSet--反射机制-->admin对象--封装-->result集合中
* result = rsh.handle(rs); // handle()动态绑定机制
* } catch (SQLException var33) {
* this.rethrow(var33, sql, params);
* } finally {
* try {
* this.close(rs);
* } finally {
* this.close((Statement)stmt);
* }
* }
*
* // 返回result集合
* return result;
* }
*/
List<Admin> query = queryRunner.query(connection,sql, new BeanListHandler<>(Admin.class));
for (Admin admin : query) {
System.out.println(admin);
}
JDBCUtilsByDruid.Close(null,null,connection);
}
}
①运行结果如下：
Admin{id=3, name='Tom3', pwd='123'}
Admin{id=5, name='Tom2', pwd='123'}
Admin{id=6, name='Tom3', pwd='123'}
Admin{id=8, name='Tom2', pwd='123'}
Admin{id=9, name='Tom3', pwd='123'}
Admin{id=11, name='zw', pwd='123'}
Admin{id=12, name='郑为', pwd='1234'}
Admin{id=13, name='郑威', pwd='1234'}
Admin{id=14, name='郑为', pwd='1234'}
Admin{id=15, name='郑威', pwd='1234'}
Process finished with exit code 0
View Code
注意①中源码 1) 和 2) 的区别，体现了重载的好处。
② 将表中数据按照指定条件筛选出来【单行】
public class jdbcDBUtils {
/**
* 查询单行结果
* @throws Exception
*/
@Test
public void testSearchSingle() throws Exception{
Connection connection = JDBCUtilsByDruid.getConnection();
QueryRunner queryRunner = new QueryRunner();
String sql = "select * from admin where id = ?";
Admin admin = queryRunner.query(connection, sql, new BeanHandler<>(Admin.class),3);
System.out.println(admin);
JDBCUtilsByDruid.Close(null,null,connection);
}
}
② 运行结果如下：
Admin{id=3, name='Tom3', pwd='123'}
③ 将表中的某一字段按照指定条件筛选出来【单行单列】
public class jdbcDBUtils {
/**
* 执行单行单列的查询
* @throws Exception
*/
@Test
public void testSearchScalar() throws Exception{
Connection connection = JDBCUtilsByDruid.getConnection();
QueryRunner queryRunner = new QueryRunner();
String sql = "select name from admin where id = ?";
Object query = queryRunner.query(connection, sql, new ScalarHandler(), 3);
System.out.println(query);
JDBCUtilsByDruid.Close(null,null,connection);
}
}
③ 运行结果如下：
Tom3
①，②，③的区别
① 返回集合，调用的方法：
List<Admin> query = queryRunner.query(connection,sql, new BeanListHandler<>(Admin.class));
具体运行步骤：resultSet--反射机制--》admin对象--封装--》result集合中。
② 返回对象，调用的方法：
Admin admin = queryRunner.query(connection, sql, new BeanHandler<>(Admin.class),3);
具体运行步骤：resultSet--反射机制--》admin对象。
③ 返回字段，调用的方法：
Object query = queryRunner.query(connection, sql, new ScalarHandler(), 3);
总结1：
ScalarHandler、BeanHandler、BeanListHandler 都实现了 handle()的方法，①的源码 result = rsh.handle(rs)，由动态绑定机制可知，result结果不相同
总结2：
当需要查出多行数据集时，使用 new BeanListHandler<>(Admin.class) ；
当需要查出单行数据时，使用 new BeanHandler<>(Admin.class)；
当需要查出单行单例【字段】时，使用 new ScalarHandler()。
3. update语句
public class jdbcDBUtils {
/**
* 执行DML语句
* @throws Exception
*/
@Test
public void testDML() throws Exception{
Connection connection = JDBCUtilsByDruid.getConnection();
QueryRunner queryRunner = new QueryRunner();
// 增加insert
/*
String insert = "insert into admin values(null,?,?),(null,?,?)";
int ins = queryRunner.update(connection, insert, "郑为", "1234", "郑威", "1234");
System.out.println(ins > 0 ? "添加成功":"添加失败");
*/
// 修改update
/*
String update = "update admin set pwd = ? where id = ?";
int upd = queryRunner.update(connection, update, "123456", 2);
System.out.println(upd > 0 ? "更新成功":"更新失败");
*/
// 删除delete
/*
String delete = "delete from admin where id = ?";
queryRunner.update(connection,delete,2);
*/
// 展现查询结果集，验证是否插入成功
String sql = "select * from admin";
// new BeanListHandler<>(Admin.class) 反射机制 result->admin对象->装入list集合
List<Admin> query1 = queryRunner.query(connection, sql, new BeanListHandler<>(Admin.class));
for (Admin admin : query1) {
System.out.println(admin);
}
// 查询单行结果，验证是否修改/删除成功
sql = "select * from admin where id = ?";
Admin query2 = queryRunner.query(connection, sql, new BeanHandler<>(Admin.class),2);
System.out.println(query2);
// 带条件的查询，查询结果
sql = "select * from admin where name = ?";
List<Admin> query3 = queryRunner.query(connection, sql, new BeanListHandler<>(Admin.class), "郑为");
for (Admin admin : query3) {
System.out.println(admin);
}
JDBCUtilsByDruid.Close(null,null,connection);
}
}
4. 总结
a：使用DBUtils工具类时，无论执行查询语句，还是DML语句，都是由QueryRunner类的对象queryRunner来执行；
b：查询时，queryRunner调用query()方法；修改【增，删，改】时，queryRunner调用update()方法；
c：执行sql语句时，queryRunner(连接名，SQL语句，具体语句具体分析)。
如果是查询，则是2中①②③的某一类的对象；
如果是修改，则是3中传入参数。
标签：queryRunner,Admin,使用,admin,connection,sql,query,DBUtils From： https://www.cnblogs.com/zwgitOne123/p/17081518.html