QueryRunner.java通过dbutils进行查询操作的得时候调用QueryRunner的query方法
[Java] 纯文本查看 复制代码
public <T> T query(Connection conn, String sql, ResultSetHandler<T> rsh, Object... params) throws SQLException {
return this.<T>query(conn, false, sql, rsh, params);
}调用重载方法
[Java] 纯文本查看 复制代码
private <T> T query(Connection conn, boolean closeConn, String sql, ResultSetHandler<T> rsh, Object... params)
throws SQLException {
//判断数据库连接
if (conn == null) {
throw new SQLException("Null connection");
}
//判断sql语句
if (sql == null) {
if (closeConn) {
close(conn);
}
throw new SQLException("Null SQL statement");
}
//判断处理的结果集实现类
if (rsh == null) {
if (closeConn) {
close(conn);
}
throw new SQLException("Null ResultSetHandler");
}
PreparedStatement stmt = null;
ResultSet rs = null;
T result = null;
try {
//sql预编译执行平台
stmt = this.prepareStatement(conn, sql);
this.fillStatement(stmt, params);
//执行查询操作
rs = this.wrap(stmt.executeQuery());
//对结果集进行下一步处理
//--------------------------重点---------------------------------
result = rsh.handle(rs);
//--------------------------重点---------------------------------
} catch (SQLException e) {
...
} finally {
...
}
return result;
}
通过标记代码发现,对结果的处理是由ResultSetHandler的子类实现的
ResultSetHandler实现类,ArrayHandler和ArrayListHandler源码分析因为整体差不多,所以以这2个点击进行分析
Interface ResultSetHandler 通过api文档看出该类为接口,所以实现类都需要实现其handle方法
所以入口就在具体实现类的handle方法上
ArrayHandler.java
[Java] 纯文本查看 复制代码
public Object[] handle(ResultSet rs) throws SQLException {
//如果查询结果集存在数据调用RowProcessor对象的toArray()方法
return rs.next() ? this.convert.toArray(rs) : EMPTY_ARRAY;
}RowProcessor.java
本身为接口,所以要找具体实现类,实现类是BasicRowProcessor.java
[Java] 纯文本查看 复制代码
public Object[] toArray(ResultSet rs) throws SQLException {
ResultSetMetaData meta = rs.getMetaData();
//获取到列的数量
int cols = meta.getColumnCount();
//创建一个长度为列的数量的Object[]数组
Object[] result = new Object[cols];
for (int i = 0; i < cols; i++) {
//把每列对应的数据塞到数组对应的位置
result = rs.getObject(i + 1);
}
//将改数组返回到调用处 ArrayHandler的handle方法
return result;
}
先看继承结构
class ArrayListHandler extends AbstractListHandler<Object[]>
abstract class AbstractListHandler implements ResultSetHandler<List>
首先,判断出ArrayListHandler的父类也是实现了ResultSetHandler接口
AbstractListHandler.java
[Java] 纯文本查看 复制代码
public List<T> handle(ResultSet rs) throws SQLException {
//创建一个arraylist
List<T> rows = new ArrayList<T>();
while (rs.next()) {
//循环取出所有结果然后添加到rows集合中
rows.add(this.handleRow(rs));
}
return rows;
}
protected abstract T handleRow(ResultSet rs) throws SQLException;this.handleRow(rs)这个方法表示是带哦用本类对象的handleRow(rs)方法,而AbstractListHandler为抽象类,所以无法直接创建对象,所以具体对象为ArrayListHandler.java.所以定位到ArrayListHandler的handleRow方法
ArrayListHandler.java
[Java] 纯文本查看 复制代码
protected Object[] handleRow(ResultSet rs) throws SQLException {
return this.convert.toArray(rs);
}调用RowProcessor对象的toArray()方法
RowProcessor.java
本身为接口,所以要找具体实现类,实现类是BasicRowProcessor.java
[Java] 纯文本查看 复制代码
public Object[] toArray(ResultSet rs) throws SQLException {
ResultSetMetaData meta = rs.getMetaData();
//获取到列的数量
int cols = meta.getColumnCount();
//创建一个长度为列的数量的Object[]数组
Object[] result = new Object[cols];
for (int i = 0; i < cols; i++) {
//把每列对应的数据塞到数组对应的位置
result = rs.getObject(i + 1);
}
//将改数组返回到调用处 AbstractListHandler的handle方法
return result;
}
