Dbutils项目实例

package cn.fansunion.dbutils.example; import java.sql.ResultSet; import java.sql.ResultSetMetaData; import java.sql.SQLException; import org.apache.commons.dbutils.QueryRunner; import org.apache.commons.dbutils.ResultSetHandler; import cn.fansunion.dbutils.example.common.DbUtilsExampleBase; /** * 演示结果集处理器如何使用。 * * @author Fans.Lei[FansUnion@qq.com] * * 2012-9-1 上午10:13:24 */ public class ResultSetHandlerExample extends DbUtilsExampleBase { /** * @param args */ public static void main(String[] args) { ResultSetHandlerExample test = new ResultSetHandlerExample(); Object[] result = test.testResultSetHandler(); print(result); test.close(); } // 取得第一行记录，Connection public Object[] testResultSetHandler() { // 创建一个ResultSetHandler实现类对象，将第一行结果转化为一个对象数组 ResultSetHandler<Object[]> handler = new RowToArrayResultSetHandler(); // 根据数据源构造QueryRunner QueryRunner run = new QueryRunner(); // 执行查询并返回结果 Object[] result = null; try { result = run.query(connection, "SELECT * FROM Person WHERE name=?", handler, "fans"); } catch (SQLException e) { e.printStackTrace(); } return result; } /** * 把第一行结果转化为一个数组 * * @author Fans.Lei[FansUnion@qq.com] * * 2012-9-1 上午10:28:25 */ class RowToArrayResultSetHandler implements ResultSetHandler<Object[]> { public Object[] handle(ResultSet rs) throws SQLException { if (!rs.next()) { return null; } // 根据结果元数据，获得结果集有多少列 ResultSetMetaData meta = rs.getMetaData(); int cols = meta.getColumnCount(); Object[] result = new Object[cols]; for (int i = 0; i < cols; i++) { result[i] = rs.getObject(i + 1); } return result; } } }