目录
BenUtils组件和DbUtils组件
1.BenUtils组件
1.1.简介
程序中对javabean的操作很频繁,所有Apache提供了一套开源api,方便javabean的操作!即BeanUtils组件
BeanUtils组件的作用就是简化javabean的操作使用BeanUtils组件
- 引入commons-beanutils-1.8.3.jar核心包
- 引入日志支持包: commons-logging-1.1.3.jar 即使用BeanUtils必须导入两个包才可以
1.2.基本用法,对象属性,对象,map的拷贝
BeanUtils中有个常用的方法来拷贝数据:
1.对象属性的拷贝BeanUtils.conProperty(admin,"name","jack");
BeanUtils.setProperty(admin,"psw","123456"); 上面的两个方法作用是一样的,
2.对象的拷贝
BeanUtils.copyProperties(newAdmin,admin);
3.Map数据拷贝到javabean中
BeanUtils.populate(adminMap,map);
注意:map中的key要与javabean的属性名称一样
代码示例:
/** * 测试BeanUtils * Created by cenyu on 16-12-17. */public class BeanUtilsDemo { //1.对javabean的基本操作 @Test public void test1() throws InvocationTargetException, IllegalAccessException { //1.基本操作 Admin admin = new Admin();// admin.setName("jack");// admin.setPsw("123456"); //2.BeanUtils组件实现对象属性的拷贝 BeanUtils.copyProperty(admin,"name","juerry"); BeanUtils.copyProperty(admin,"psw","123456"); //总结1:对于基本数据类型,会自动进行类型转换! //3.对象的拷贝 //把admin对象拷贝到一个新的对象。 Admin newAdmin = new Admin(); //第一个参数是新对象,第二个参数是要拷贝的对象 BeanUtils.copyProperties(newAdmin,admin); //4.map数据,拷贝到对象中 //定义一个新的Admin对象,此时name和psw的值都是空的 Admin adminMap = new Admin(); //创建一个Map对象,并放进去两个值 Mapmap = new HashMap (); map.put("name","Tom"); map.put("psw","32453"); //注意:map中的key要与javabean的属性名称一致 BeanUtils.populate(adminMap,map); //测试 System.out.println(adminMap.getName()); System.out.println(admin.getPsw()); }}
1.3.日期类的拷贝
由于表单进来的数据都是String类型,也就是说表单填写一个日期类型,但是在实体要存放的是日期类型,这个时候就要对接收到的数据进行转换格式,常用的转换格式有两种:
一种是使用自定义方法,重写转换方法 另外一种是使用BeanUtils提供的日期类型转换工具,但是这种转换工具有一个问题就是可以为null,但是不能为空,为空的化报错 示例代码如下://2.自定义日期类型转换器 //需求:从表单接受过来的数据都是字符串,如果中间有时间,就要把字符串转换成日期类型 @Test public void test2() throws InvocationTargetException, IllegalAccessException { //模拟表单数据 String name = "jack"; String age = "20"; String birth = "1999-03-24"; //对象 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("yyy-MM-dd");// return sdf.parse(value.toString());// } catch (ParseException e) {// e.printStackTrace();// throw new RuntimeException(e);// }// // }, Date.class); //日期类型转发方式2: //使用提供的日期类型转换工具类 ConvertUtils.register(new DateLocaleConverter(),Date.class); //把表单提交的数据,封装到对象中 BeanUtils.copyProperty(admin,"name",name); BeanUtils.copyProperty(admin,"age",age); BeanUtils.copyProperty(admin,"birth",birth); //测试 System.out.println(admin); }
```
1.4.封装表单数据到实体
在servlet中,我们接收jsp传递过来的表单参数,之前的做法是通过request的方法来获取参数值,然后保存早实体对象中,但是这样做是写死的,修改起来会很麻烦,现在将这个过程重新优化封装一下:
常用的抽象方式有两种,第一种可以使用手写的方法,第一种通过使用BeanUtils工具类,由于两种方法都是抽取出来的抽象方法,所以这个方法是通用的,我们把该方法单独抽取出来,然后在Servlet中调用该方法用代码分别展示如何在Servlet中接收jsp表单的数据然后封装到实体对象中:
方法在单独一个类中的封装:/** * 封装从jsp表单中获取参数保存到实体的过程 * Created by cenyu on 16-12-17. */public class WebUtil { @Deprecated public staticT copyToBean_old(HttpServletRequest request, Class clazz) { try { // 创建对象 T t = clazz.newInstance(); // 获取所有的表单元素的名称 //getParameterNames();将请求页面中的form表单里所欲具有name属性的表单对象获取,返回一个Enumeration Enumeration enums = request.getParameterNames(); // 遍历 while (enums.hasMoreElements()) { // 获取表单元素的名称: 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 copyToBean(HttpServletRequest request, Class clazz) { try { // (注册日期类型转换器) // 创建对象 T t = clazz.newInstance(); BeanUtils.populate(t, request.getParameterMap()); return t; } catch (Exception e) { throw new RuntimeException(e); } }}
调用疯转的结果:
在Servlet的doGet()方法里面进行方法调用:/** * 调用jsp表单参数保存到实体对象方法的封装 * Created by cenyu on 16-12-17. */public class copyServlet extends javax.servlet.http.HttpServlet { protected void doPost(javax.servlet.http.HttpServletRequest request, javax.servlet.http.HttpServletResponse response) throws javax.servlet.ServletException, IOException { this.doGet(request,response); } protected void doGet(javax.servlet.http.HttpServletRequest request, javax.servlet.http.HttpServletResponse response) throws javax.servlet.ServletException, IOException { //使用WebUtil组件处理请求数据的封装 WebUtil.copyToBean(request, Admin.class); //已经把表单参数封装到实体,可以进行其他操作了 }}
2.BeanUtils组件优化DAO更新和查询数据库方法
2.1.对元数据的操作
此处的元数据是指数据库的定义数据,例如:数据库,表,列的定义信息。使用jdbc来获取这些信息就会使用到元数据
在jdbc中可以使用:数据元数据,参数元数据,结果集元数据 常用方法代码:/** * Created by cenyu on 16-12-17. * 测试元数据 */public class metaDataDemo { //1.数据库元数据 @Test public void testDB() throws Exception{ //获取连接 Connection conn = JdbcUtils.getConnection(); //创建数据库元数据对象 DatabaseMetaData metaData=conn.getMetaData(); //数据库元数据的方法 //getURL():返回一个String类对象,代表数据库的URL。 System.out.println(metaData.getURL()); //getUserName():返回连接当前数据库管理系统的用户名。 System.out.println(metaData.getUserName()); //getDatabaseProductName():返回数据库的产品名称。 System.out.println(metaData.getDatabaseProductName()); } //2.参数元数据 @Test public void testParams() throws Exception{ //获取连接 Connection conn = JdbcUtils.getConnection(); //SQL String sql = "select * form student where id = ? and name = ?"; 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 student"; //获取连接 Connection conn = JdbcUtils.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.getColumnClassName(i+1); //获取每一行的每一列的值 Object columnValue = rs.getObject(columnName); //测试 System.out.println(columnName+"="+columnValue); } System.out.println(); } }}
2.2.抽取DAO的更新和查询方法
在DAO中要经常使用对数据库的更新和查询操作,使用频繁且重复代码跟高,这个时候,我们把DAO中根据对数据库的操作不同,抽取出两个通用方法分别为插入,更改,删除的更新方法update方法和查询的query方法。通用方法接收一个sql语句,一个参数列表,一个操作对象。
1.现在假设数据库Admin有userName和password这两个字段,实体Admin也只有这个这两个方法,首先,我们在DAO中写出一个BaseDao类用来存放抽取出来的update和query方法 代码示例如下:/** * Created by cenyu on 16-12-17. * 调用的dao,自己写的所有的dao都继承此类 * 此类定义了两个通用的方法 * 1.更新(插入,修改,删除) * 2.查询(select语句) */public class BaseDao { //初始化参数 private Connection conn; private PreparedStatement pstmt; private ResultSet rs; //插入,更改,删除通用方法 public void update(String sql, Object[] patamsValue){ try { //获取连接 conn=JdbcUtils.getConnection(); //创建执行命令的stmt对象 pstmt=conn.prepareStatement(sql); //参数元数据,得到占位符参数的个数 int count = pstmt.getParameterMetaData().getParameterCount(); //设置占位符参数的值 if (patamsValue != null && patamsValue.length>0){ //循环给参数赋值 for (int i = 0; i < count; i++) { pstmt.setObject(i+1,patamsValue[i]); } //执行更新 pstmt.executeUpdate(); } } catch (SQLException e) { e.printStackTrace(); throw new RuntimeException(e); }finally { JdbcUtils.closeAll(conn,pstmt,null); } } //查询通用方法 publicList query(String sql,Object[] paramsValue,Class clazz){ try { //返回的集合 List list = new ArrayList (); //对象 T t = null; //1.获取连接 conn=JdbcUtils.getConnection(); //2.创建爱女stmt对象 pstmt = conn.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 coiumnCount = rsmd.getColumnCount(); //6.遍历结果集(rs) while (rs.next()) { //要封装的对象 t = clazz.newInstance(); //7.遍历每一行的每一列,封装到数据 for (int i = 0; i < coiumnCount ; i++) { //获取每一列的列名称 String columnName = rsmd.getColumnName(i+1); //获取每一列的列名称,对应的值 Object value = rs.getObject(columnName); //封装,设置到t对象的属性中 BeanUtils.copyProperty(t,columnName,value); } //把封装完毕的对象,添加到集合中 list.add(t); } return list; }catch (Exception e){ throw new RuntimeException(e); }finally { JdbcUtils.closeAll(conn,pstmt,null); } }}
2.通用方法写完之后,我们写具体的DAO方法,通过继承BaseDao类,只需要写参数,然后调用父类中的方法就可以了
示例代码如下:/** * Created by cenyu on 16-12-18. * 继承BaseDao,实现具体的数据库操作方法 */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,password) values (?,?)"; Object[] paramsValue = {admin.getUserName(),admin.getPassword()}; super.update(sql,paramsValue); } //查询 public ListgetAll(){ String sql = "select * from Admin"; List list = super.query(sql,null,Admin.class); return list; } //根据条件查询(主键) public Admin findById(int id){ String sql = "select * from admin where id=?"; List list = super.query(sql,new Object[]{id},Admin.class); return (list!=null&&list.size()>0) ? list.get(0) : null; }}
3.Dao方法已经写好,这个时候我们可以在其他地方调用Dao里面的方法对数据进行操作了。
测试类代码如下:/** * Created by cenyu on 16-12-18.s * 测试继承自BaseDao的Dao方法 */public class AdminDaoTest { //测试删除id=8 @Test public void testdelete(){ AdminDao adminDao = new AdminDao(); adminDao.delete(6); } //插入测试 @Test public void testInsert(){ AdminDao adminDao = new AdminDao(); Admin admin = new Admin(); admin.setUserName("cenyu"); admin.setPassword("cenyu"); adminDao.save(admin); } //测试查询 @Test public void testquery() throws Exception{ AdminDao adminDao = new AdminDao(); Listlist = adminDao.getAll(); System.out.println(list); }}
3.DbUtils组件
3.1.DBUtils组件简介
commons-dbutils是Apache组织提供的一个开源JDBC工具类库,他是对JDBC的简单封装,学习成本极地,并且使用dbutils能极简化jdbc编码的工作量,同时也不会影响程序的性能
使用方法: 引入jar文件:commons-dbutils-1.6.jar组件常用API介绍:
org.apache.commons.dbutils.QueryRunner
数据库查询的类库,主要是CURD操作org.apache.commons.dbutils.ResultSetHandler
处理ResultSet,将查询结果的数据按要求转换为另一种形式工具类: org.apache.commons.dbutils.DbUtils dbutils关闭资源,加载驱动
3.2.QueryRunner类使用方法
QueryRunner类简化了SQL的查询工作,与ResultSetHandle组合在一起使用可以完成大部分的数据库操作,能够大大减少编码量
1.QueryRunner类提供了两个构造方法- 默认构造方法
- 需要一个javax.sql.DataSource来做参数的构造方法
2.QueryRunner类的主要方法
public Object query(Connection conn, String sql, Object[] params, ResultSetHandler rsh) :
执行一个查询操作,在这个查询中,对象数组中的每个元素值被用来作为查询语句的置换参数。该方法会自行处理 PreparedStatement 和 ResultSet 的创建和关闭。
public Object query(String sql, Object[] params, ResultSetHandler rsh) :
几乎与第一种方法一样;唯一的不同在于它不将数据库连接提供给方法,并且它是从提供给构造方法的数据源(DataSource) 或使用的setDataSource 方法中重新获得 Connection。
public Object query(Connection conn, String sql, ResultSetHandler rsh):
执行一个不需要置换参数的查询操作。
public int update(Connection conn, String sql, Object[] params):
用来执行一个更新(插入、更新或删除)操作。
public int update(Connection conn, String sql) :
用来执行一个不需要置换参数的更新操作。
代码示例:
/** * 使用dbutils组件的QueryRunner类完成CURD,以及批处理 * Created by cenyu on 16-12-18. */public class bdutilsUpdate { private Connection conn; //1.删除 @Test public void testDelete() throws SQLException { String sql = "delete from Admin where id=?"; //连接对象 conn = JdbcUtils.getConnection(); //创建DBUtils核心工具类对象 QueryRunner qr=new QueryRunner(); qr.update(conn,sql,3);//一个参数 //关闭 DbUtils.close(conn); } //2.插入 @Test public void testInsert() throws SQLException { String sql = "INSERT INTO Admin(userName,password) VALUES (?,?)"; //连接对象 conn = JdbcUtils.getConnection(); //创建DBUtils核心工具类对象 QueryRunner qr=new QueryRunner(); qr.update(conn,sql,"a111","a111");//两个参数 //关闭 DbUtils.close(conn); } //3.更改 @Test public void testUpdate() throws SQLException { String sql = "UPDATE Admin SET userName=? WHERE id=?;"; //连接对象 conn = JdbcUtils.getConnection(); //创建DBUtils核心工具类对象 QueryRunner qr=new QueryRunner(); qr.update(conn,sql,"Juerry",5);//两个参数 //关闭 DbUtils.close(conn); } //4.查询 @Test public void testFind() throws SQLException { String sql = "select * from Admin where id=?"; //连接对象 conn = JdbcUtils.getConnection(); //创建DBUtils核心工具类对象 QueryRunner qr=new QueryRunner(); Admin admin=qr.query(conn,sql,new BeanHandler(Admin.class),5); //关闭 System.out.println(admin); DbUtils.close(conn); } //5.批处理 @Test public void testBatch() throws SQLException { String sql = "insert into Admin (userName, password) values(?,?)"; conn = JdbcUtils.getConnection(); QueryRunner qr = new QueryRunner(); //批量处理 qr.batch(conn,sql,new Object[][]{ {"jack1","888"},{"jack","999"}}); //关闭 conn.close(); }}
3.3.ResultSetHandler接口使用方法
ResultSetHandler接口用于处理java.sql.ResultSet,将数据按要求转换为另一种形式
ResultSetHandler接口的实现类BeanHandler:
将结果集中的第一行数据封装到一个对应的JavaBean实例中。BeanListHandler:
将结果集中的每一行数据都封装到一个对应的JavaBean实例中,存放到List里。ArrayHandler:
把结果集中的第一行数据转成对象数组。ArrayListHandler:
把结果集中的每一行数据都转成一个数组,再存放到List中。ScalarHandler
查询返回结果记录的第一行的第一列 (在聚合函数统计的时候用)MapHandler
查询返回结果的第一条记录封装为map 代码示例:
/** * 测试ResultSetHandler对查询结构的封装类 * Created by cenyu on 16-12-18. */public class bdutilsQuery { private Connection conn; // 一、查询, 自定义结果集封装数据 @Test public void testQuery() throws Exception { String sql = "select * from admin where id=?"; // 获取连接 conn = JdbcUtils.getConnection(); // 创建DbUtils核心工具类对象 QueryRunner qr = new QueryRunner(); // 查询 Admin admin = qr.query(conn, sql, new ResultSetHandler() { // 如何封装一个Admin对象 public Admin handle(ResultSet rs) throws SQLException { if (rs.next()) { Admin admin = new Admin(); admin.setUserName(rs.getString("userName")); admin.setPassword(rs.getString("password")); 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 = JdbcUtils.getConnection(); // 创建DbUtils核心工具类对象 QueryRunner qr = new QueryRunner(); // 查询返回单个对象 Admin admin = qr.query(conn, sql, new BeanHandler (Admin.class), 29); System.out.println(admin); conn.close(); } // 2)BeanListHandler: 查询返回list集合,集合元素是指定的对象 @Test public void testQueryMany() throws Exception { String sql = "select * from admin"; conn = JdbcUtils.getConnection(); QueryRunner qr = new QueryRunner(); // 查询全部数据 List list = qr.query(conn, sql, new BeanListHandler (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 = JdbcUtils.getConnection(); QueryRunner qr = new QueryRunner(); // 查询 //Object[] obj = qr.query(conn, sql, new ArrayHandler()); //List
3.4.DbUtils工具类使用
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。