1. 程式人生 > >DBUtils結果集處理

DBUtils結果集處理

params exce runner demo handlers plist 資源 esc tor

1、BeanHandler查詢

 1 package jdbc;
 2 
 3 import java.sql.Connection;
 4 import java.sql.SQLException;
 5 
 6 import org.apache.commons.dbutils.DbUtils;
 7 import org.apache.commons.dbutils.QueryRunner;
 8 import org.apache.commons.dbutils.handlers.BeanHandler;
 9 
10 /**
11  * <p>
12  * Description:BeanHandler處理結果集演示
13 * </p> 14 * 15 * @author Administrator 16 * @date 2018年11月5日下午5:04:55 17 */ 18 public class BeanHandlerDemo { 19 20 public static void main(String[] args) throws SQLException { 21 // 創建sql語句執行對象 22 QueryRunner qr = new QueryRunner(); 23 // sql語句 24 String sql = "select * from sort";
25 Object[] params = {}; 26 // 獲得連接 27 Connection conn = JDBCUtils.getConnection(); 28 // 執行sql語句 29 Sort sort = qr.query(conn, sql, new BeanHandler<Sort>(Sort.class), params); 30 // 打印結果集 31 System.out.println(sort); 32 // 關閉資源 33 DbUtils.closeQuietly(conn);
34 } 35 36 }

2、BeanListHandler查詢

 1 package jdbc;
 2 
 3 import java.sql.Connection;
 4 import java.sql.SQLException;
 5 import java.util.List;
 6 
 7 import org.apache.commons.dbutils.QueryRunner;
 8 import org.apache.commons.dbutils.handlers.BeanListHandler;
 9 
10 /**
11  * <p> Description:BeanListHandler類處理結果集演示</p>
12  * @author Administrator
13  * @date 2018年11月5日下午5:11:32
14  */
15 public class BeanListHandlerDemo {
16 
17     public static void main(String[] args) throws SQLException {
18         // 創建sql語句執行對象
19         QueryRunner qr = new QueryRunner();
20         // sql語句
21         String sql = "select * from sort";
22         Object[] params = {};
23         // 獲得連接
24         Connection conn = JDBCUtils.getConnection();
25         // 執行sql語句
26         List<Sort> list = qr.query(conn, sql, new BeanListHandler<Sort>(Sort.class), params);
27         // 結果集處理
28         for (Sort s: list) {
29             System.out.println(s);
30         }
31     }
32 
33 }

3、ColumeListHandler查詢

 1 package jdbc;
 2 
 3 import java.sql.Connection;
 4 import java.sql.SQLException;
 5 import java.util.List;
 6 
 7 import org.apache.commons.dbutils.QueryRunner;
 8 import org.apache.commons.dbutils.handlers.ColumnListHandler;
 9 
10 /**
11  * <p>Description:ColumeListHandler類查詢演示 </p>
12  * @author Administrator
13  * @date 2018年11月5日下午5:16:17
14  */
15 public class ColumnListHandlerDemo {
16 
17     public static void main(String[] args) throws SQLException {
18         // 創建sql語句執行對象
19         QueryRunner qr = new QueryRunner();
20         // sql語句
21         String sql = "select * from sort";
22         Object[] params = {};
23         // 獲得連接
24         Connection conn = JDBCUtils.getConnection();
25         // 執行sql語句
26         List<Object> list = qr.query(conn, sql, new ColumnListHandler<Object>(), params);
27         // 處理結果集
28         for (Object s: list) {
29             System.out.println(s);
30         }
31     }
32 
33 }

4、ScalarHandler查詢

 1 package jdbc;
 2 
 3 import java.sql.Connection;
 4 import java.sql.SQLException;
 5 
 6 import org.apache.commons.dbutils.QueryRunner;
 7 import org.apache.commons.dbutils.handlers.ScalarHandler;
 8 /**
 9  * <p>Description:ScalarHandler類查詢演示 </p>
10  * @author Administrator
11  * @date 2018年11月5日下午5:23:49
12  */
13 public class ScalarHandlerDemo {
14 
15     public static void main(String[] args) throws SQLException {
16         // 創建sql語句執行對象
17         QueryRunner qr = new QueryRunner();
18         // sql語句
19         String sql = "select count(*) from sort";
20         Object[] params = {};
21         // 獲得連接
22         Connection conn = JDBCUtils.getConnection();
23         // 執行sql語句
24         Long l = qr.query(conn, sql, new ScalarHandler<Long>(), params);
25         // 處理結果集
26         System.out.println(l);
27     }
28 
29 }

5、MapHandler查詢

 1 package jdbc;
 2 
 3 import java.sql.Connection;
 4 import java.sql.SQLException;
 5 import java.util.Map;
 6 
 7 import org.apache.commons.dbutils.QueryRunner;
 8 import org.apache.commons.dbutils.handlers.MapHandler;
 9 /**
10  * <p>Description:MapHandler處理結果集演示 </p>
11  * @author Administrator
12  * @date 2018年11月5日下午5:28:31
13  */
14 public class MapHandlerDemo {
15 
16     public static void main(String[] args) throws SQLException {
17         // 創建sql語句執行對象
18         QueryRunner qr = new QueryRunner();
19         // sql語句
20         String sql = "select * from sort";
21         // 獲得連接
22         Connection conn = JDBCUtils.getConnection();
23         // 執行sql語句
24         Map<String, Object> map = qr.query(conn, sql, new MapHandler());
25         // 處理結果集
26         for (String key: map.keySet()) {
27             System.out.println(key + "..." + map.get(key));
28         }
29     }
30 
31 }

6、MapListHandler查詢

 1 package jdbc;
 2 
 3 import java.sql.Connection;
 4 import java.sql.SQLException;
 5 import java.util.List;
 6 import java.util.Map;
 7 
 8 import org.apache.commons.dbutils.QueryRunner;
 9 import org.apache.commons.dbutils.handlers.MapListHandler;
10 /**
11  * <p>Description:MapListHandler處理結果集演示 </p>
12  * @author Administrator
13  * @date 2018年11月5日下午5:35:22
14  */
15 public class MapListHandlerDemo {
16 
17     public static void main(String[] args) throws SQLException {
18         // 創建sql語句執行對象
19         QueryRunner qr = new QueryRunner();
20         // sql語句
21         String sql = "select * from sort";
22         // 獲得連接
23         Connection conn = JDBCUtils.getConnection();
24         // 執行sql語句
25         List<Map<String, Object>> list = qr.query(conn, sql, new MapListHandler());
26         // 處理結果集
27         for (Map<String, Object> map : list) {
28             for (String key : map.keySet()) {
29                 // 打印一條記錄
30                 System.out.print(key + "..." + map.get(key));
31             }
32             // 換行
33             System.out.println();
34         }
35 
36     }
37 
38 }

DBUtils結果集處理