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