//查詢多條記錄，返回對應(yīng)的對象的集合?public List getForList(Class clazz, String sql, Object...args){

List list = new ArrayList();

Connection connection = null;

PreparedStatement preparedStatement = null;

ResultSet resultSet = null;

try {

//1.得到結(jié)果集???connection = JDBCTools.GetConnection();

preparedStatement = connection.prepareStatement(sql);

for(int i = 0; i < args.length; i++){

preparedStatement.setObject(i + 1, args[i]);

}

resultSet = preparedStatement.executeQuery();

//2.處理結(jié)果集，得到 Map 的List，其中 一個 Map對象 就是一條記錄

//Map 的 key 為 resultSet 中 列的別名， Map的 value 為列的值???List> values = handleResultSettoMapList(resultSet);

//3.把 Map的List 轉(zhuǎn)為 clazz 對應(yīng)的 List

//其中 Map 的key 即為 clazz 對應(yīng)的對象的 propertyName

//而 Map 的 value 即為 clazz 對應(yīng)的對象的 propertyValue。???list = transferMapListToBeanList(clazz, values);

} catch (Exception e) {

e.printStackTrace();

}finally{

JDBCTools.release(resultSet, preparedStatement, connection);

}

return list;

}

/**

* 處理結(jié)果集，得到 Map的一個List，其中 一個 Map對象對應(yīng)一條記錄

*@paramresultSet

*@return

*@throwsSQLException

*/?private List> handleResultSettoMapList(

ResultSet resultSet) throws SQLException {

//5.準(zhǔn)備一個 List>:

//鍵：存放列的別名， 值：存放列的值。其中一個Map 對象對應(yīng)著一條記錄??List> values =

new ArrayList>();

ResultSetMetaData rsmd = resultSet.getMetaData();

Map map = null;

//7.處理 ResultSet， 使用 while 循環(huán)??while(resultSet.next()){

map = new HashMap();

for(int i = 0; i < rsmd.getColumnCount(); i ++){

String columLabel = rsmd.getColumnLabel(i + 1);

Object value = resultSet.getObject(i + 1);

map.put(columLabel, value);

}

//11.把一條記錄的一個 Map 對象放入 5 準(zhǔn)備的List中???values.add(map);

}

return values;

}

private List transferMapListToBeanList(Class clazz,

List> values) throws InstantiationException,

IllegalAccessException, InvocationTargetException {

//12. 判斷 List 是否為空集合，若不為空

//則遍歷List，得到一個一個的Map對象，再把一個 Map對象轉(zhuǎn)換為一個 Class參數(shù)對應(yīng)的 Object對象??List result = new ArrayList();

T bean = null;

if(values.size() > 0){

for(Map m:values){

bean = clazz.newInstance();

for(Map.Entry entry:m.entrySet()){

String propertyName = entry.getKey();

Object value = entry.getValue();

BeanUtils.setProperty(bean, propertyName, value);

}

//13. 把 Object 對象放入到 list 中????result.add(bean);

}

}

return result;

}

//查詢一條記錄，返回對應(yīng)的對象?public T get(Class clazz, String sql, Object...args){

List results = getForList(clazz, sql, args);

if(results.size() > 0){

return results.get(0);

}

return null;

}

//返回某條記錄的某一個字段的值 或一個統(tǒng)計的值(一共有多少條記錄等)?public E getForValue(String sql, Object...args){

//1.得到結(jié)果集：該結(jié)果集應(yīng)該只有一行，且只有一列??Connection connection = null;

PreparedStatement preparedStatement = null;

ResultSet resultSet = null;

try {

//1.得到結(jié)果集???connection = JDBCTools.GetConnection();

preparedStatement = connection.prepareStatement(sql);

for(int i = 0; i < args.length; i++){

preparedStatement.setObject(i + 1, args[i]);

}

resultSet = preparedStatement.executeQuery();

//2.取得結(jié)果集???if(resultSet.next()){

return (E) resultSet.getObject(1);

}

} catch(Exception e){

e.printStackTrace();

} finally{

JDBCTools.release(resultSet, preparedStatement, connection);

}

return null;

}

測試

@Test

public void testGet() {

String sql = "SELECT flow_id flowid, type, id_card idcard," +

" exam_card examcard,"

+ "student_name studentname, location, grade " + "FROM examstudent "

+ "WHERE flow_id = ?";

Student student = dao.get(Student.class, sql, 7);

System.out.println(student);

}

@Test

public void testGetForList() {

String sql = "SELECT flow_id flowid, type, id_card idcard," +

" exam_card examcard,"

+ "student_name studentname, location, grade " + "FROM examstudent";

List students = dao.getForList(Student.class, sql);

System.out.println(students);

}

@Test

public void testGetForValue() {

String sql = "SELECT id_card idcard FROM examstudent "

+ "WHERE flow_id = ?";

String idCard = dao.getForValue(sql, 7);

System.out.println(idCard);

sql = "SELECT max(grade) FROM examstudent";

int grade = dao.getForValue(sql);

System.out.println(grade);

}

總結(jié)

以上是生活随笔為你收集整理的MySQL批量查询能返回集合吗_JDBC——查询多条记录，返回对应的对象的集合；查询一条记录，返回对应的对象...的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。