一、 BeanUtils組件用法及類(lèi)型轉(zhuǎn)換器
使用BenUtils組件:
1. 引入commons-beanutils-1.8.3.jar核心包
2. 引入日志支持包: commons-logging-1.1.3.jar
如果缺少日志jar文件,報(bào)錯(cuò):
java.lang.NoClassDefFoundError: org/apache/commons/logging/LogFactory at org.apache.commons.beanutils.ConvertUtilsBean.<init>(ConvertUtilsBean.java:157) at org.apache.commons.beanutils.BeanUtilsBean.<init>(BeanUtilsBean.java:117) at org.apache.commons.beanutils.BeanUtilsBean$1.initialValue(BeanUtilsBean.java:68) at package com.xp.tools;import java.text.ParseException;import java.text.SimpleDateFormat;import java.util.Date;import java.util.HashMap;import java.util.Map;import org.apache.commons.beanutils.BeanUtils;import org.apache.commons.beanutils.ConvertUtils;import org.apache.commons.beanutils.Converter;import org.apache.commons.beanutils.locale.converters.DateLocaleConverter;import org.junit.Test;public class App { //1. 對(duì)javabean的基本操作 @Test public void test1() throws Exception { // a. 基本操作 Admin admin = new Admin();// admin.setUserName("Jack");// admin.setPwd("999"); // b. BeanUtils組件實(shí)現(xiàn)對(duì)象屬性的拷貝 BeanUtils.copyPRoperty(admin, "userName", "jack"); BeanUtils.setProperty(admin, "age", 18); // 總結(jié)1: 對(duì)于基本數(shù)據(jù)類(lèi)型,會(huì)自動(dòng)進(jìn)行類(lèi)型轉(zhuǎn)換! // c. 對(duì)象的拷貝 Admin newAdmin = new Admin(); BeanUtils.copyProperties(newAdmin, admin); // d. map數(shù)據(jù),拷貝到對(duì)象中 Admin adminMap = new Admin(); Map<String,Object> map = new HashMap<String,Object>(); map.put("userName", "Jerry"); map.put("age", 29); // 注意:map中的key要與javabean的屬性名稱(chēng)一致 BeanUtils.populate(adminMap, map); // 測(cè)試 System.out.println(adminMap.getUserName()); System.out.println(adminMap.getAge()); } //2. 自定義日期類(lèi)型轉(zhuǎn)換器 @Test public void test2() throws Exception { // 模擬表單數(shù)據(jù) String name = "jack"; String age = "20"; String birth = " "; // 對(duì)象 Admin admin = new Admin(); // 注冊(cè)日期類(lèi)型轉(zhuǎn)換器:1, 自定義的方式 ConvertUtils.register(new Converter() { // 轉(zhuǎn)換的內(nèi)部實(shí)現(xiàn)方法,需要重寫(xiě) @Override public Object convert(Class type, Object value) { // 判斷 if (type != Date.class) { return null; } if (value == null || "".equals(value.toString().trim())) { return null; } try { // 字符串轉(zhuǎn)換為日期 SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd"); return sdf.parse(value.toString()); } catch (ParseException e) { throw new RuntimeException(e); } } },Date.class); // 把表單提交的數(shù)據(jù),封裝到對(duì)象中 BeanUtils.copyProperty(admin, "userName", name); BeanUtils.copyProperty(admin, "age", age); BeanUtils.copyProperty(admin, "birth", birth); //------ 測(cè)試------ System.out.println(admin); } //2. 使用提供的日期類(lèi)型轉(zhuǎn)換器工具類(lèi) @Test public void test3() throws Exception { // 模擬表單數(shù)據(jù) String name = "userName"; String age = "20"; String birth = null; // 對(duì)象 Admin admin = new Admin(); // 注冊(cè)日期類(lèi)型轉(zhuǎn)換器:2, 使用組件提供的轉(zhuǎn)換器工具類(lèi) ConvertUtils.register(new DateLocaleConverter(), Date.class); // 把表單提交的數(shù)據(jù),封裝到對(duì)象中 BeanUtils.copyProperty(admin, "userName", name); BeanUtils.copyProperty(admin, "age", age); BeanUtils.copyProperty(admin, "birth", birth); //------ 測(cè)試------ System.out.println(admin); }}二、 BeanUtils在項(xiàng)目中應(yīng)用
public class WebUtils { @Deprecated public static <T> T copyToBean_old(HttpServletRequest request, Class<T> clazz) { try { // 創(chuàng)建對(duì)象 T t = clazz.newInstance(); // 獲取所有的表單元素的名稱(chēng) Enumeration<String> enums = request.getParameterNames(); // 遍歷 while (enums.hasMoreElements()) { // 獲取表單元素的名稱(chēng):<input type="passWord" name="pwd"/> String name = enums.nextElement(); // pwd // 獲取名稱(chēng)對(duì)應(yīng)的值 String value = request.getParameter(name); // 把指定屬性名稱(chēng)對(duì)應(yīng)的值進(jìn)行拷貝 BeanUtils.copyProperty(t, name, value); } return t; } catch (Exception e) { throw new RuntimeException(e); } } /** * 處理請(qǐng)求數(shù)據(jù)的封裝 */ public static <T> T copyToBean(HttpServletRequest request, Class<T> clazz) { try { // (注冊(cè)日期類(lèi)型轉(zhuǎn)換器) // 創(chuàng)建對(duì)象 T t = clazz.newInstance(); BeanUtils.populate(t, request.getParameterMap()); return t; } catch (Exception e) { throw new RuntimeException(e); } }}三、 更新通用方法元數(shù)據(jù)元數(shù)據(jù)- DataBaseMetaData 元數(shù)據(jù):數(shù)據(jù)庫(kù)、表、列的定義信息。 Connection.getDatabaseMetaData() DataBaseMetaData對(duì)象? getURL():返回一個(gè)String類(lèi)對(duì)象,代表數(shù)據(jù)庫(kù)的URL。? getUserName():返回連接當(dāng)前數(shù)據(jù)庫(kù)管理系統(tǒng)的用戶(hù)名。? getDatabaseProductName():返回?cái)?shù)據(jù)庫(kù)的產(chǎn)品名稱(chēng)。? getDatabaseProductVersion():返回?cái)?shù)據(jù)庫(kù)的版本號(hào)。? getDriverName():返回驅(qū)動(dòng)驅(qū)動(dòng)程序的名稱(chēng)。? getDriverVersion():返回驅(qū)動(dòng)程序的版本號(hào)。? isReadOnly():返回一個(gè)boolean值,指示數(shù)據(jù)庫(kù)是否只允許讀操作。元數(shù)據(jù)- ParameterMetaData PreparedStatement . getParameterMetaData() ? 獲得代表PreparedStatement元數(shù)據(jù)的ParameterMetaData對(duì)象。 ? Select * from user where name=? And password=? ParameterMetaData對(duì)象? getParameterCount() ? 獲得指定參數(shù)的個(gè)數(shù)? getParameterType(int param) ? 獲得指定參數(shù)的sql類(lèi)型元數(shù)據(jù)- ResultSetMetaData ResultSet. getMetaData() ? 獲得代表ResultSet對(duì)象元數(shù)據(jù)的ResultSetMetaData對(duì)象。 ResultSetMetaData對(duì)象? getColumnCount() ? 返回resultset對(duì)象的列數(shù)? getColumnName(int column) ? 獲得指定列的名稱(chēng)? getColumnTypeName(int column)? 獲得指定列的類(lèi)型 使用元數(shù)據(jù)簡(jiǎn)化JDBC代碼 業(yè)務(wù)背景:系統(tǒng)中所有實(shí)體對(duì)象都涉及到基本的CRUD操作:? 所有實(shí)體的CUD操作代碼基本相同,僅僅發(fā)送給數(shù)據(jù)庫(kù)的SQL語(yǔ)句不同而已,因此可以把CUD操作的所有相同代碼抽取到工具類(lèi)的一個(gè)update方法中,并定義參數(shù)接收變化的SQL語(yǔ)句。實(shí)體的R操作,除SQL語(yǔ)句不同之外,根據(jù)操作的實(shí)體不同,對(duì)ResultSet的映射也各不相同,因此可義一個(gè)query方法,除以參數(shù)形式接收變化的SQL語(yǔ)句外,可以使用策略模式由qurey方法的調(diào)用者決定如何把ResultSet中的數(shù)據(jù)映射到實(shí)體對(duì)象中package com.xp.metadata;import java.sql.Connection;import java.sql.DatabaseMetaData;import java.sql.ParameterMetaData;import java.sql.PreparedStatement;import java.sql.ResultSet;import java.sql.ResultSetMetaData;import org.junit.Test;import com.xp.utils.JdbcUtil;public class App { //1. 數(shù)據(jù)庫(kù)元數(shù)據(jù) @Test public void testDB() throws Exception { // 獲取連接 Connection conn = JdbcUtil.getConnection(); // 獲取數(shù)據(jù)庫(kù)元數(shù)據(jù) DatabaseMetaData metaData = conn.getMetaData();// alt + shift + L 快速獲取方法返回值 System.out.println(metaData.getUserName()); System.out.println(metaData.getURL()); System.out.println(metaData.getDatabaseProductName()); } //2. 參數(shù)元數(shù)據(jù) @Test public void testParams() throws Exception { // 獲取連接 Connection conn = JdbcUtil.getConnection(); // SQL String sql = "select * from dept where deptid=? and deptName=?"; // Object[] values = {"tom","888"}; PreparedStatement pstmt = conn.prepareStatement(sql); // 參數(shù)元數(shù)據(jù) ParameterMetaData p_metaDate = pstmt.getParameterMetaData(); // 獲取參數(shù)的個(gè)數(shù) int count = p_metaDate.getParameterCount(); // 測(cè)試 System.out.println(count); } // 3. 結(jié)果集元數(shù)據(jù) @Test public void testRs() throws Exception { String sql = "select * from dept "; // 獲取連接 Connection conn = JdbcUtil.getConnection(); PreparedStatement pstmt = conn.prepareStatement(sql); ResultSet rs = pstmt.executeQuery(); // 得到結(jié)果集元數(shù)據(jù)(目標(biāo):通過(guò)結(jié)果集元數(shù)據(jù),得到列的名稱(chēng)) ResultSetMetaData rs_metaData = rs.getMetaData(); // 迭代每一行結(jié)果 while (rs.next()) { // 1. 獲取列的個(gè)數(shù) int count = rs_metaData.getColumnCount(); // 2. 遍歷,獲取每一列的列的名稱(chēng) for (int i=0; i<count; i++) { // 得到列的名稱(chēng) String columnName = rs_metaData.getColumnName(i + 1); // 獲取每一行的每一列的值 Object columnValue = rs.getObject(columnName); // 測(cè)試 System.out.print(columnName + "=" + columnValue + ","); } System.out.println(); } }}Dao操作的抽取Dao操作通用的步驟:0. 寫(xiě)SQL語(yǔ)句1. 獲取連接2. 創(chuàng)建stmt3. 執(zhí)行sqla) 更新b) 查詢(xún)4. 關(guān)閉/異常通過(guò)的dao,1. 更新String sql = “select * from admin”;String sql = “select * from admin where id=? And pwd =?”;public void update(String sql, Object[] paramValues);2. 查詢(xún)String sql = “select * from admin”;String sql = “select * from admin where id=? And pwd =?”;// 傳入的什么類(lèi)型的對(duì)象,就封裝為什么類(lèi)型// 要求: 列的名稱(chēng),要與指定類(lèi)型的對(duì)象的屬性名稱(chēng)一樣Public List<T> query (String sql , Object[] paramValues , Class<T> clazz);T t; // 對(duì)象賦值package com.xp.jdbc;public class Admin { private int id; public int getId() { return id; } public void setId(int id) { this.id = id; } public String getUserName() { return userName; } public void setUserName(String userName) { this.userName = userName; } public String getPwd() { return pwd; } public void setPwd(String pwd) { this.pwd = pwd; } private String userName; private String pwd;}@Override public String toString() { return "Admin [id=" + id + ", userName=" + userName + ", pwd=" + pwd + "]"; }四、 查詢(xún)的通用方法package com.xp.jdbc;import java.sql.Connection;import java.sql.PreparedStatement;import java.sql.ResultSet;import java.sql.ResultSetMetaData;import java.util.ArrayList;import java.util.List;import org.apache.commons.beanutils.BeanUtils;import com.xp.utils.JdbcUtil;public class BaseDao { // 初始化參數(shù) private Connection con; private PreparedStatement pstmt; private ResultSet rs; /** * 更新的通用方法 * @param sql 更新的sql語(yǔ)句(update/insert/delete) * @param paramsValue sql語(yǔ)句中占位符對(duì)應(yīng)的值(如果沒(méi)有占位符,傳入null) */ public void update(String sql,Object[] paramsValue){ try { // 獲取連接 con = JdbcUtil.getConnection(); // 創(chuàng)建執(zhí)行命令的stmt對(duì)象 pstmt = con.prepareStatement(sql); // 參數(shù)元數(shù)據(jù): 得到占位符參數(shù)的個(gè)數(shù) int count = pstmt.getParameterMetaData().getParameterCount(); // 設(shè)置占位符參數(shù)的值 if (paramsValue != null && paramsValue.length > 0) { // 循環(huán)給參數(shù)賦值 for(int i=0;i<count;i++) { pstmt.setObject(i+1, paramsValue[i]); } } // 執(zhí)行更新 pstmt.executeUpdate(); } catch (Exception e) { throw new RuntimeException(e); } finally { JdbcUtil.closeAll(con, pstmt, null); } } /** * 查詢(xún)的通用方法 * @param sql * @param paramsValue */ public <T> List<T> query(String sql, Object[] paramsValue,Class<T> clazz){ try { // 返回的集合 List<T> list = new ArrayList<T>(); // 對(duì)象 T t = null; // 1. 獲取連接 con = JdbcUtil.getConnection(); // 2. 創(chuàng)建stmt對(duì)象 pstmt = con.prepareStatement(sql); // 3. 獲取占位符參數(shù)的個(gè)數(shù), 并設(shè)置每個(gè)參數(shù)的值 //int count = pstmt.getParameterMetaData().getParameterCount(); if (paramsValue != null && paramsValue.length > 0) { for (int i=0; i<paramsValue.length; i++) { pstmt.setObject(i+1, paramsValue[i]); } } // 4. 執(zhí)行查詢(xún) rs = pstmt.executeQuery(); // 5. 獲取結(jié)果集元數(shù)據(jù) ResultSetMetaData rsmd = rs.getMetaData(); // ---> 獲取列的個(gè)數(shù) int columnCount = rsmd.getColumnCount(); // 6. 遍歷rs while (rs.next()) { // 要封裝的對(duì)象 t = clazz.newInstance(); // 7. 遍歷每一行的每一列, 封裝數(shù)據(jù) for (int i=0; i<columnCount; i++) { // 獲取每一列的列名稱(chēng) String columnName = rsmd.getColumnName(i + 1); // 獲取每一列的列名稱(chēng), 對(duì)應(yīng)的值 Object value = rs.getObject(columnName); // 封裝: 設(shè)置到t對(duì)象的屬性中 【BeanUtils組件】 BeanUtils.copyProperty(t, columnName, value); } // 把封裝完畢的對(duì)象,添加到list集合中 list.add(t); } return list; } catch (Exception e) { throw new RuntimeException(e); } finally { JdbcUtil.closeAll(con, pstmt, rs); } } }package com.xp.jdbc;import java.util.List;public class AdminDao extends BaseDao{ // 刪除 public void delete(int id) { String sql = "delete from admin where id=?"; Object[] paramsValue = {id}; super.update(sql, paramsValue); } // 插入 public void save(Admin admin) { String sql = "insert into admin (userName,pwd) values (?,?)"; Object[] paramsValue = {admin.getUserName(),admin.getPwd()}; super.update(sql, paramsValue); } // 查詢(xún)?nèi)?public List<Admin> getAll(){ String sql = "select * from admin"; List<Admin> list = super.query(sql, null, Admin.class); return list; } // 根據(jù)條件查詢(xún)(主鍵) public Admin findById(int id){ String sql = "select * from admin where id=?"; List<Admin> list = super.query(sql, new Object[]{id}, Admin.class); return (list!=null&&list.size()>0) ? list.get(0) : null; }}package com.xp.jdbc;import java.util.List;import org.junit.Test;public class AdminDaoTest { @Test public void testUpdate() throws Exception { AdminDao adminDao = new AdminDao(); //adminDao.delete(2); //adminDao.save(new Admin()); // 測(cè)試查詢(xún) List<Admin> list = adminDao.getAll(); System.out.println(list); }}五、 DbUtils組件O-R Mapping簡(jiǎn)介 常用O-R Mapping映射工具? Hibernate? Ibatis? Commons DbUtils(只是對(duì)JDBC簡(jiǎn)單封裝)DbUtils組件 commons-dbutils 是 Apache 組織提供的一個(gè)開(kāi)源 JDBC工具類(lèi)庫(kù),它是對(duì)JDBC的簡(jiǎn)單封裝,學(xué)習(xí)成本極低,并且使用dbutils能極大簡(jiǎn)化jdbc編碼的工作量,同時(shí)也不會(huì)影響程序的性能。因此dbutils成為很多不喜歡hibernate的公司的首選。 API介紹:? org.apache.commons.dbutils.QueryRunner ? org.apache.commons.dbutils.ResultSetHandler? 工具類(lèi) org.apache.commons.dbutils.DbUtils 下載組件,引入jar文件 : commons-dbutils-1.6.jarDbutils類(lèi) DbUtils :提供如關(guān)閉連接、裝載JDBC驅(qū)動(dòng)程序等常規(guī)工作的工具類(lèi),里面的所有方法都是靜態(tài)的。主要方法如下:? public static void close(…) throws java.sql.SQLException: DbUtils類(lèi)提供了三個(gè)重載的關(guān)閉方法。這些方法檢查所提供的參數(shù)是不是NULL,如果不是的話(huà),它們就關(guān)閉Connection、Statement和ResultSet。? public static void closeQuietly(…): 這一類(lèi)方法不僅能在Connection、Statement和ResultSet為NULL情況下避免關(guān)閉,還能隱藏一些在程序中拋出的SQLEeception。? public static void commitAndCloseQuietly(Connection conn): 用來(lái)提交連接,然后關(guān)閉連接,并且在關(guān)閉連接時(shí)不拋出SQL異常。 ? public static boolean loadDriver(java.lang.String driverClassName):這一方裝載并注冊(cè)JDBC驅(qū)動(dòng)程序,如果成功就返回true。使用該方法,你不需要捕捉這個(gè)異常ClassNotFoundException。DButil實(shí)例|-- DbUtils 關(guān)閉資源、加載驅(qū)動(dòng)|-- QueryRunner 組件的核心工具類(lèi):定義了所有的與數(shù)據(jù)庫(kù)操作的方法(查詢(xún)、更新)該類(lèi)簡(jiǎn)單化了SQL查詢(xún),它與ResultSetHandler組合在一起使用可以完成大部分的數(shù)據(jù)庫(kù)操作,能夠大大減少編碼量。QueryRunner類(lèi)提供了兩個(gè)構(gòu)造方法:默認(rèn)的構(gòu)造方法需要一個(gè) javax.sql.DataSource 來(lái)作參數(shù)的構(gòu)造方法。Int update(Connection conn, String sql, Object param); 執(zhí)行更新帶一個(gè)占位符的sqlInt update(Connection conn, String sql, Object… param); 執(zhí)行更新帶多個(gè)占位符的sqlInt[] batch(Connection conn, String sql, Object[][] params) 批處理T query(Connection conn ,String sql, ResultSetHandler<T> rsh, Object... params) 查詢(xún)方法Int update( String sql, Object param); Int update( String sql, Object… param); Int[] batch( String sql, Object[][] params) 注意: 如果調(diào)用DbUtils組件的操作數(shù)據(jù)庫(kù)方法,沒(méi)有傳入連接對(duì)象,那么在實(shí)例化QueryRunner對(duì)象的時(shí)候需要傳入數(shù)據(jù)源對(duì)象: QueryRunner qr = new QueryRunner(ds);DbUtils提供的封裝結(jié)果的一些對(duì)象:1) BeanHandler: 查詢(xún)返回單個(gè)對(duì)象2) BeanListHandler: 查詢(xún)返回list集合,集合元素是指定的對(duì)象3) ArrayHandler, 查詢(xún)返回結(jié)果記錄的第一行,封裝對(duì)對(duì)象數(shù)組, 即返回:Object[]4) ArrayListHandler, 把查詢(xún)的每一行都封裝為對(duì)象數(shù)組,再添加到list集合中5) ScalarHandler 查詢(xún)返回結(jié)果記錄的第一行的第一列 (在聚合函數(shù)統(tǒng)計(jì)的時(shí)候用)6) MapHandler 查詢(xún)返回結(jié)果的第一條記錄封裝為mappackage com.xp.dbutils;import org.junit.Test;public class Demo { public void sum(int... num) { int total = 0; for (int i=0;i <num.length;i++) { total += num[i]; } System.out.println("和: " + total); } @Test public void test() { int[] n = {1,2,3}; //sum(n); sum(1,2,5,5); }}package com.xp.dbutils;import java.sql.Connection;import org.apache.commons.dbutils.DbUtils;import org.apache.commons.dbutils.QueryRunner;import org.junit.Test;import com.xp.utils.JdbcUtil;public class App_update { private Connection conn; // 1. 更新 @Test public void testUpdate() throws Exception { String sql = "delete from admin where id=?"; // 連接對(duì)象 conn = JdbcUtil.getConnection(); // 創(chuàng)建DbUtils核心工具類(lèi)對(duì)象 QueryRunner qr = new QueryRunner(); qr.update(conn, sql, 26); // 關(guān)閉 DbUtils.close(conn); } // 2. 批處理 @Test public void testBatch() throws Exception { String sql = "insert into admin (userName, pwd) values(?,?)"; conn = JdbcUtil.getConnection(); QueryRunner qr = new QueryRunner(); // 批量刪除 qr.batch(conn, sql, new Object[][]{ {"jack1","888"},{"jack2","999"} }); // 關(guān)閉 conn.close(); }}QueryRunner類(lèi)的主要方法 public Object query(Connection conn, String sql, Object[] params, ResultSetHandler rsh) throws SQLException:執(zhí)行一個(gè)查詢(xún)操作,在這個(gè)查詢(xún)中,對(duì)象數(shù)組中的每個(gè)元素值被用來(lái)作為查詢(xún)語(yǔ)句的置換參數(shù)。該方法會(huì)自行處理 PreparedStatement 和 ResultSet 的創(chuàng)建和關(guān)閉。 public Object query(String sql, Object[] params, ResultSetHandler rsh) throws SQLException: 幾乎與第一種方法一樣;唯一的不同在于它不將數(shù)據(jù)庫(kù)連接提供給方法,并且它是從提供給構(gòu)造方法的數(shù)據(jù)源(DataSource) 或使用的setDataSource 方法中重新獲得 Connection。 public Object query(Connection conn, String sql, ResultSetHandler rsh) throws SQLException : 執(zhí)行一個(gè)不需要置換參數(shù)的查詢(xún)操作。 public int update(Connection conn, String sql, Object[] params) throws SQLException:用來(lái)執(zhí)行一個(gè)更新(插入、更新或刪除)操作。 public int update(Connection conn, String sql) throws SQLException:用來(lái)執(zhí)行一個(gè)不需要置換參數(shù)的更新操作。六、 DbUtis組件查詢(xún)結(jié)果對(duì)象用法ResultSetHandler接口 該接口用于處理 java.sql.ResultSet,將數(shù)據(jù)按要求轉(zhuǎn)換為另一種形式。 ResultSetHandler 接口提供了一個(gè)單獨(dú)的方法:Object handle (java.sql.ResultSet .rs)。ResultSetHandler 接口的實(shí)現(xiàn)類(lèi) ArrayHandler:把結(jié)果集中的第一行數(shù)據(jù)轉(zhuǎn)成對(duì)象數(shù)組。 ArrayListHandler:把結(jié)果集中的每一行數(shù)據(jù)都轉(zhuǎn)成一個(gè)數(shù)組,再存放到List中。 BeanHandler:將結(jié)果集中的第一行數(shù)據(jù)封裝到一個(gè)對(duì)應(yīng)的JavaBean實(shí)例中。 BeanListHandler:將結(jié)果集中的每一行數(shù)據(jù)都封裝到一個(gè)對(duì)應(yīng)的JavaBean實(shí)例中,存放到List里。 ColumnListHandler(列名):將結(jié)果集中某一列的數(shù)據(jù)存放到List中。 KeyedHandler(name):將結(jié)果集中的每一行數(shù)據(jù)都封裝到一個(gè)Map里,再把這些map再存到一個(gè)map里,其key為指定的key。 MapHandler:將結(jié)果集中的第一行數(shù)據(jù)封裝到一個(gè)Map里,key是列名,value就是對(duì)應(yīng)的值。 MapListHandler:將結(jié)果集中的每一行數(shù)據(jù)都封裝到一個(gè)Map里,然后再存放到List使用jdbc操作多個(gè)表import java.sql.Connection;import java.sql.ResultSet;import java.sql.SQLException;import java.util.List;import java.util.Map;import org.apache.commons.dbutils.QueryRunner;import org.apache.commons.dbutils.ResultSetHandler;import org.apache.commons.dbutils.handlers.BeanHandler;import org.apache.commons.dbutils.handlers.BeanListHandler;import org.apache.commons.dbutils.handlers.MapHandler;import org.junit.Test;import cn.itcast.c_jdbc.Admin;import cn.itcast.utils.JdbcUtil;public class App_query { private Connection conn; // 一、查詢(xún), 自定義結(jié)果集封裝數(shù)據(jù) @Test public void testQuery() throws Exception { String sql = "select * from admin where id=?"; // 獲取連接 conn = JdbcUtil.getConnection(); // 創(chuàng)建DbUtils核心工具類(lèi)對(duì)象 QueryRunner qr = new QueryRunner(); // 查詢(xún) Admin admin = qr.query(conn, sql, new ResultSetHandler<Admin>() { // 如何封裝一個(gè)Admin對(duì)象 public Admin handle(ResultSet rs) throws SQLException { if (rs.next()) { Admin admin = new Admin(); admin.setId(rs.getInt("id")); admin.setUserName(rs.getString("userName")); admin.setPwd(rs.getString("pwd")); return admin; } return null; } }, 29); // 測(cè)試 System.out.println(admin); // 關(guān)閉 conn.close(); } // 二、查詢(xún), 使用組件提供的結(jié)果集對(duì)象封裝數(shù)據(jù) // 1)BeanHandler: 查詢(xún)返回單個(gè)對(duì)象 @Test public void testQueryOne() throws Exception { String sql = "select * from admin where id=?"; // 獲取連接 conn = JdbcUtil.getConnection(); // 創(chuàng)建DbUtils核心工具類(lèi)對(duì)象 QueryRunner qr = new QueryRunner(); // 查詢(xún)返回單個(gè)對(duì)象 Admin admin = qr.query(conn, sql, new BeanHandler<Admin>(Admin.class), 29); System.out.println(admin); conn.close(); } // 2)BeanListHandler: 查詢(xún)返回list集合,集合元素是指定的對(duì)象 @Test public void testQueryMany() throws Exception { String sql = "select * from admin"; conn = JdbcUtil.getConnection(); QueryRunner qr = new QueryRunner(); // 查詢(xún)?nèi)繑?shù)據(jù) List<Admin> list = qr.query(conn, sql, new BeanListHandler<Admin>(Admin.class)); System.out.println(list); conn.close(); } @Test// 3) ArrayHandler, 查詢(xún)返回結(jié)果記錄的第一行,封裝對(duì)對(duì)象數(shù)組, 即返回:Object[]// 4) ArrayListHandler, 把查詢(xún)的每一行都封裝為對(duì)象數(shù)組,再添加到list集合中// 5) ScalarHandler 查詢(xún)返回結(jié)果記錄的第一行的第一列 (在聚合函數(shù)統(tǒng)計(jì)的時(shí)候用)// 6) MapHandler 查詢(xún)返回結(jié)果的第一條記錄封裝為map public void testArray() throws Exception { String sql = "select * from admin"; conn = JdbcUtil.getConnection(); QueryRunner qr = new QueryRunner(); // 查詢(xún) //Object[] obj = qr.query(conn, sql, new ArrayHandler()); //List<Object[]> list = qr.query(conn, sql, new ArrayListHandler()); //Long num = qr.query(conn, sql, new ScalarHandler<Long>()); Map<String, Object> map = qr.query(conn,sql, new MapHandler()); conn.close(); }}
|
新聞熱點(diǎn)
疑難解答
圖片精選
網(wǎng)友關(guān)注