第一步：實現一個調用類：

/**

* 有回調的查詢

*/

public <T> T query(String sql,MyHandler<T> mh){

T t = null;

//聲明conn

Connection con = null;

try{

con = ds.getConnection();

//執行查詢

Statement st = con.createStatement();

ResultSet rs = st.executeQuery(sql);

//讓回調去執行數據封裝

t = mh.handler(rs);

}catch(Exception e){

e.PRintStackTrace();

}finally{

try {

con.close();

} catch (SQLException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

}

return t;

}

第二步：定義回調規范

package cn.itcast.dbutils;

import java.sql.ResultSet;

/**

* 接收rs結果集

* @author Administrator

*

* @param <T>

*/

public interface MyHandler<T> {

T handler(ResultSet rs);

}

第三步：實現一個回調

package cn.itcast.dbutils;

import java.lang.reflect.Method;

import java.sql.ResultSet;

import java.sql.ResultSetMetaData;

import java.util.ArrayList;

import java.util.List;

public class MyBeanListHandler<T> implements MyHandler<List<T>> {

private Class<T> cls;

public MyBeanListHandler(Class<T> cls) {

this.cls=cls;

}

public List<T> handler(ResultSet rs) {

List<T> list = new ArrayList<T>();

try{

ResultSetMetaData rsmd = rs.getMetaData();

int cols = rsmd.getColumnCount();

while(rs.next()){

T t = cls.newInstance();

//獲取列名

for(int i=0;i<cols;i++){

String colName = rsmd.getColumnName(i+1);

String methodName =

"set"+colName.substring(0,1)

.toUpperCase()

+colName.substring(1).toLowerCase();

//獲取類型

String javaType = rsmd.getColumnClassName(i+1);//="java.lang.String";

try{

Method mm =

cls.getMethod(methodName, Class.forName(javaType));

Object val = rs.getObject(i+1);

mm.invoke(t,val);

}catch(Exception e){}

}

list.add(t);

}

}catch (Exception e) {

}

return list;

}

}

第四步：測試：

@Test

public void myutils3(){

QueryRunner run = new QueryRunner(DataSourceUtils.getDatasSource());

String sql = "select * from users";

List<User> cs =

run.query(sql,new MyBeanListHandler<User>(User.class));

for(User c:cs){

System.err.println(">>:"+c);

}

}