标签：属性 auth 字符 ide ogg delete cad 功能 用法
课程目标：
Jdbc的优化！
程序中对javabean的操作很频繁， 所以apache提供了一套开源的api，方便对javabean的操作！即BeanUtils组件。
BeanUtils组件， 作用是简化javabean的操作！
用户可以从www.apache.org下载BeanUtils组件，然后再在项目中引入jar文件！
使用BenUtils组件：
如果缺少日志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
方法1： 对象属性的拷贝
BeanUtils.copyProperty(admin, "userName", "jack");
BeanUtils.setProperty(admin, "age", 18);
方法2： 对象的拷贝
BeanUtils.copyProperties(newAdmin, admin);
方法3： map数据拷贝到javabean中
【注意：map中的key要与javabean的属性名称一致】
BeanUtils.populate(adminMap, map);
|
//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种方式参见下面代码：
|
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 = "jack"; 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); } } |
|
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); } } } |
l 在jdbc中获取数据库的定义，例如：数据库、表、列的定义信息。就用到元数据。
l 在jdbc中可以使用： 数据库元数据、参数元数据、结果集元数据
l (元数据定义相关api， ..MetaData)
|
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操作通用的步骤：
a) 更新
b) 查询
通过的dao,
String sql = “select * from admin”;
String sql = “select * from admin where id=? And pwd =?”;
public void update(String sql, Object[] paramValues);
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; // 对象赋值
|
/** * 通用的dao，自己写的所有的dao都继承此类; * 此类定义了2个通用的方法： * 1. 更新 * 2. 查询 * @author Jie.Yuan * */ 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); } } }
|
|
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.sql.jdbc; import java.sql.Connection; import java.sql.ResultSet; import java.sql.SQLException; import java.util.List; import org.apache.commons.dbutils.QueryRunner; import org.apache.commons.dbutils.ResultSetHandler; import org.apache.commons.dbutils.handlers.ArrayHandler; import org.apache.commons.dbutils.handlers.BeanHandler; import org.apache.commons.dbutils.handlers.BeanListHandler; import org.junit.Test; import com.sql.util.MysqlUtil; public class App_query { private Connection conn; /* * 自定义结果集 */ public void testQuery() throws Exception { String sql = "select * from admin where id=?"; conn = MysqlUtil.getConn(); QueryRunner qr = new QueryRunner(); Admin admin = qr.query(conn, sql, new ResultSetHandler<Admin>(){ @Override 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; } }, 3); System.out.println(admin); conn.close(); } /* * 使用组件 */ public void testQueryOne() throws Exception { String sql = "select * from admin where id=?"; conn = MysqlUtil.getConn(); QueryRunner qr = new QueryRunner(); Admin admin = qr.query(conn, sql, new BeanHandler<Admin>(Admin.class), 3); System.out.println(admin); conn.close(); } /* * list集合 */ public void testQueryMany() throws Exception { String sql = "select * from admin"; conn = MysqlUtil.getConn(); QueryRunner qr = new QueryRunner(); List<Admin> list = qr.query(conn, sql, new BeanListHandler<Admin>(Admin.class)); System.out.println(list); conn.close(); } /* * 3) ArrayHandler, 查询返回结果记录的第一行，封装对对象数组, 即返回：Object[] * 4) ArrayListHandler, 把查询的每一行都封装为对象数组，再添加到list集合中 * 5) ScalarHandler 查询返回结果记录的第一行的第一列 (在聚合函数统计的时候用) * 6) MapHandler 查询返回结果的第一条记录封装为map */ @Test public void testArray() throws Exception { String sql = "select * from admin"; conn = MysqlUtil.getConn(); QueryRunner qr = new QueryRunner(); Object[] objects = qr.query(conn, sql, new ArrayHandler()); System.out.println(objects); conn.close(); } }
daoTest:
package com.sql.jdbc; import java.util.List; import org.junit.Test; public class AdminDaoTest { @Test public void testUpdate() { AdminDao adminDao = new AdminDao(); //adminDao.delete("dept", 1); //adminDao.save(new Admin()); //List<Admin> list = adminDao.getAll("admin"); //System.out.println(list); Admin admin = adminDao.findById("admin", 3); System.out.println(admin.getUserName() + " : " + admin.getPwd()); } }
AdminDao:
package com.sql.jdbc; import java.util.List; public class AdminDao extends BaseDao{ public void delete(String tableName, int id) { String sql = "delete from "+tableName+" 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 tableName){ String sql = "select * from " + tableName; List<Admin> list = super.query(sql, null, Admin.class); return list; } public Admin findById(String tableName, int id) { String sql = "select * from "+ tableName + " where id=?"; List<Admin> list = super.query(sql, new Object[]{id}, Admin.class); return (list != null && list.size()>0)?list.get(0):null; } }
BaseDao:
package com.sql.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.sql.util.MysqlUtil; public class BaseDao { private Connection conn; private PreparedStatement statement; private ResultSet resultSet; /* * 更新 */ public void update(String sql, Object[] paramsValue) { //System.out.println(sql + "\n" + paramsValue[0]); try { conn = MysqlUtil.getConn(); statement = conn.prepareStatement(sql); int count = statement.getParameterMetaData().getParameterCount(); if(paramsValue != null && paramsValue.length > 0 && paramsValue.length == count){ for(int i = 0; i < count; i++){ statement.setObject(i + 1, paramsValue[i]); } } statement.executeUpdate(); } catch (Exception e) { throw new RuntimeException(e); }finally{ MysqlUtil.close(conn, statement); } } /* * 查询 */ public <T> List<T> query(String sql, Object[] paramsValue, Class<T>clazz){ try { ArrayList<T> list = new ArrayList<T>(); T t = null; conn = MysqlUtil.getConn(); statement = conn.prepareStatement(sql); int count = statement.getParameterMetaData().getParameterCount(); if(paramsValue != null && count > 0 && paramsValue.length == count){ for(int i= 0; i < count; i++){ statement.setObject(i + 1, paramsValue[i]); } } resultSet = statement.executeQuery(); ResultSetMetaData metaData = statement.getMetaData(); int columnCount = metaData.getColumnCount(); while(resultSet.next()){ t = clazz.newInstance(); for(int i = 0; i < columnCount; i++){ String columnName = metaData.getColumnName(i + 1); Object columnValue = resultSet.getObject(columnName); BeanUtils.copyProperty(t, columnName, columnValue); } list.add(t); } return list; } catch (Exception e) { throw new RuntimeException(e); }finally{ MysqlUtil.close(conn, statement, resultSet); } } }
l commons-dbutils 是 Apache 组织提供的一个开源 JDBC工具类库，它是对JDBC的简单封装，学习成本极低，并且使用dbutils能极大简化jdbc编码的工作量，同时也不会影响程序的性能。因此dbutils成为很多不喜欢hibernate的公司的首选。
DbUtils组件，
|-- DbUtils 关闭资源、加载驱动
|-- QueryRunner 组件的核心工具类：定义了所有的与数据库操作的方法(查询、更新)
Int update(Connection conn, String sql, Object param); 执行更新带一个占位符的sql
Int update(Connection conn, String sql, Object… param); 执行更新带多个占位符的sql
Int[] 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 查询返回结果的第一条记录封装为map
对之前的注册功能，优化，引入dbutils组件！
要求：
BaseDao.java
查询、更新的通用的方法！
其他的dao就继承baseDao即可！
练习：
标签：属性 auth 字符 ide ogg delete cad 功能 用法
原文地址：http://www.cnblogs.com/handsomecui/p/6234509.html
