Java分层开发BaseDao



Java分层开发BaseDao

本文介绍的是在不使用持久层框架的情况下，用Java反射写的BaseDao，简化Dao层的操作，让Dao的实现层每个方法体只有一行。所有的Dao的实现类继承BaseDao。 下面具体讲如何使用BaseDao 。

  1. BaseDao代码如下：
    Java代码  收藏代码
    1. <span style=”font-size: small;”>package dao;
    3. import java.lang.reflect.Field;
    4. import java.lang.reflect.Method;
    5. import java.sql.Connection;
    6. import java.sql.PreparedStatement;
    7. import java.sql.ResultSet;
    8. import java.sql.SQLException;
    9. import java.util.ArrayList;
    10. import java.util.List;
    12. import utils.DbHelper;
    14. public class BaseDao {
    15.     private Connection conn = null;
    16.     private PreparedStatement ps = null;
    17.     private ResultSet rs = null;
    19.     /**
    20.      * 查询符合条件的记录数
    21.      *
    22.      * @param sql
    23.      *            要执行的sql语句
    24.      * @param args
    25.      *            给sql语句中的？赋值的参数列表
    26.      * @return 符合条件的记录数
    27.      */
    28.     public long getCount(String sql, Object… args) {
    29.         conn = DbHelper.getConn();
    30.         try {
    31.             ps = conn.prepareStatement(sql);
    32.             for (int i = 0; i < args.length; i++) {
    33.                 ps.setObject(i + 1, args[i]);
    34.             }
    35.             rs = ps.executeQuery();
    36.             if (rs.next()) {
    37.                 return rs.getLong(1);
    38.             }
    39.         } catch (SQLException e) {
    40.             e.printStackTrace();
    41.         } finally {
    42.             DbHelper.closeConn(conn, ps, rs);
    43.         }
    44.         return 0L;
    45.     }
    47.     /**
    48.      * 查询实体对象的，并封装到一个集合
    49.      *
    50.      * @param <T>
    51.      *            要查询的对象的集合
    52.      * @param sql
    53.      *            要执行的sql语句
    54.      * @param clazz
    55.      *            要查询的对象的类型
    56.      * @param args
    57.      *            给sql语句中的？赋值的参数列表
    58.      * @return 要查询的类的集合，无结果时返回null
    59.      */
    60.     public <T> List<T> executeQuery(String sql, Class<T> clazz, Object… args) {
    61.         conn = DbHelper.getConn();
    62.         List list = new ArrayList();
    63.         try {
    64.             ps = conn.prepareStatement(sql);
    65.             for (int i = 0; i < args.length; i++) {
    66.                 ps.setObject(i + 1, args[i]);
    67.             }
    68.             rs = ps.executeQuery();
    69.             Field[] fs = clazz.getDeclaredFields();
    70.             String[] colNames = new String[fs.length];
    71.             String[] rTypes = new String[fs.length];
    72.             Method[] methods = clazz.getMethods();
    73.             while (rs.next()) {
    74.                 for (int i = 0; i < fs.length; i++) {
    75.                     Field f = fs[i];
    76.                     String colName = f.getName().substring(0, 1).toUpperCase()
    77.                             + f.getName().substring(1);
    78.                     colNames[i] = colName;
    79.                     String rType = f.getType().getSimpleName();
    80.                     rTypes[i] = rType;
    81.                 }
    83.                 Object object = (T) clazz.newInstance();
    84.                 for (int i = 0; i < colNames.length; i++) {
    85.                     String colName = colNames[i];
    86.                     String methodName = ”set” + colName;
    87.                     // 查找并调用对应的setter方法赋
    88.                     for (Method m : methods) {
    89.                         if (methodName.equals((m.getName()))) {
    90.                             // 如果抛了参数不匹配异常，检查JavaBean中该属性类型，并添加else分支进行处理
    91.                             if (“int”.equals(rTypes[i])
    92.                                     || ”Integer”.equals(rTypes[i])) {
    93.                                 m.invoke(object, rs.getInt(colName));
    94.                             } else if (“Date”.equals(rTypes[i])) {
    95.                                 m.invoke(object, rs.getDate(colName));
    96.                             } else if (“Timestamp”.equals(rTypes[i])) {
    97.                                 m.invoke(object, rs.getTimestamp(colName));
    98.                             } else {
    99.                                 m.invoke(object, rs.getObject(colName));
    100.                             }
    101.                             break;
    102.                         }
    103.                     }
    104.                 }
    105.                 list.add(object);
    106.             }
    107.             return list;
    108.         } catch (Exception e) {
    109.             e.printStackTrace();
    110.         } finally {
    111.             DbHelper.closeConn(conn, ps, rs);
    112.         }
    113.         return null;
    114.     }
    116.     /**
    117.      * 以对象的形式保存或更新一个实体
    118.      *
    119.      * @param sql
    120.      *            要执行的sql语句
    121.      * @param object
    122.      *            要保存或更新的实体对象
    123.      * @param args
    124.      *            不需要赋值的列标组成的数组，例如sql语句
    125.      *            ”insert into tbl_user values(seq_user.nextval,?,?,?)”应为1
    126.      * @return 操作结果，1 成功，0 失败
    127.      */
    128.     public int saveEntity(String sql, Object object, int… args) {
    129.         conn = DbHelper.getConn();
    130.         try {
    131.             ps = conn.prepareStatement(sql);
    132.             Class c = object.getClass();
    133.             Field[] fields = object.getClass().getDeclaredFields();
    134.             int temp = 1;// 正赋值的？的下标，最大下标为args的长度
    135.             int colIndex = 1;// SQL语句中的当前字段下标
    136.             int t = 0;// args数组的下标
    137.             for (int j = 0; j < fields.length; j++) {
    138.                 Field field = fields[j];// 得到某个声明属性
    139.                 String methodName = ”get”
    140.                         + field.getName().substring(0, 1).toUpperCase()
    141.                         + field.getName().substring(1);
    142.                 Method method = c.getMethod(methodName);// 得到了当前类中的一个method
    143.                 String rType = field.getType().getSimpleName().toString();
    144.                 if (t < args.length && colIndex == args[t]) {
    145.                     t++;
    146.                 } else if (“int”.equals(rType) || ”INTEGER”.equals(rType)) {
    147.                     ps.setInt(temp++, (Integer) method.invoke(object));
    148.                 } else {
    149.                     ps.setObject(temp++, method.invoke(object));
    150.                 }
    151.                 colIndex++;// 更新索引下标
    152.             }
    153.             return ps.executeUpdate();
    154.         } catch (Exception e) {
    155.             e.printStackTrace();
    156.         } finally {
    157.             DbHelper.closeConn(conn, ps, null);
    158.         }
    159.         return 0;
    160.     }
    162.     /**
    163.      * 执行可变参数的SQL语句，进行保存、删除或更新操作
    164.      *
    165.      * @param sql
    166.      *            要执行的sql语句，?的赋值顺序必须与args数组的顺序相同
    167.      * @param args
    168.      *            要赋值的参数列表
    169.      * @return 操作结果，正数 成功，0 失败
    170.      */
    171.     public int saveOrUpdate(String sql, Object… args) {
    172.         conn = DbHelper.getConn();
    173.         try {
    174.             ps = conn.prepareStatement(sql);
    175.             for (int j = 0; j < args.length; j++) {
    176.                 ps.setObject(j + 1, args[j]);
    177.             }
    178.             return ps.executeUpdate();
    179.         } catch (Exception e) {
    180.             e.printStackTrace();
    181.         } finally {
    182.             DbHelper.closeConn(conn, ps, null);
    183.         }
    184.         return 0;
    185.     }
    186. }
    187. </span>
  2. 连接数据库的DbHelper工具类
    Java代码  
    1. <span style=”font-size: small;”>package utils;
    3. import java.sql.Connection;
    4. import java.sql.DriverManager;
    5. import java.sql.ResultSet;
    6. import java.sql.Statement;
    8. /**
    9.  * 数据库工具类
    10.  *
    11.  * @author Jzl
    12.  *
    13.  */
    14. public class DbHelper {
    16.     /**
    17.      * 获得一个数据库连接
    18.      *
    19.      * @return
    20.      */
    21.     public static Connection getConn() {
    22.         Connection conn = null;
    23.         try {
    24.             Class.forName(“oracle.jdbc.driver.OracleDriver”);
    25.             String url = ”jdbc:oracle:thin:@localhost:1521:orcl”;
    26.             conn = DriverManager.getConnection(url, ”scott”, ”tiger”);
    27.         } catch (Exception e) {
    28.             e.printStackTrace();
    29.         }
    30.         return conn;
    31.     }
    33.     /**
    34.      * 关闭数据库连接资源
    35.      *
    36.      * @param conn
    37.      * @param ps
    38.      * @param rs
    39.      */
    40.     public static void closeConn(Connection conn, Statement ps, ResultSet rs) {
    41.         try {
    42.             if (rs != null) {
    43.                 rs.close();
    44.                 rs = null;
    45.             }
    46.             if (ps != null) {
    47.                 ps.close();
    48.                 ps = null;
    49.             }
    50.             if (conn != null) {
    51.                 conn.close();
    52.                 conn = null;
    53.             }
    54.         } catch (Exception e) {
    55.             e.printStackTrace();
    56.         }
    57.     }
    59. }
    60. </span>
  3. 接下来就可以测试BaseDao了。用于测试的User实体类：
    Java代码  收藏代码
    1. <span style=”font-size: small;”>package entity;
    3. import java.sql.Date;
    5. /**
    6.  * 用于测试的JavaBean，符合JavaBea命名规范
    7.  * @author Jzl
    8.  *
    9.  */
    10. public class User {
    11.     private int userId;
    12.     private String userName;
    13.     private String userPass;
    14.     private Date lastDate;
    16.     /**
    17.      * 无参构造函数，用于反射new一个实例（必须有）
    18.      */
    19.     public User() {
    20.     }
    22.     public User(String userName, String userPass, Date lastDate) {
    23.         super();
    24.         this.userName = userName;
    25.         this.userPass = userPass;
    26.         this.lastDate = lastDate;
    27.     }
    29.     public int getUserId() {
    30.         return userId;
    31.     }
    33.     public void setUserId(int userId) {
    34.         this.userId = userId;
    35.     }
    37.     public String getUserName() {
    38.         return userName;
    39.     }
    41.     public void setUserName(String userName) {
    42.         this.userName = userName;
    43.     }
    45.     public String getUserPass() {
    46.         return userPass;
    47.     }
    49.     public void setUserPass(String userPass) {
    50.         this.userPass = userPass;
    51.     }
    53.     public Date getLastDate() {
    54.         return lastDate;
    55.     }
    57.     public void setLastDate(Date lastDate) {
    58.         this.lastDate = lastDate;
    59.     }
    61. }
    62. </span>
  4. 用于测试的UserDao：
    Java代码  收藏代码
    1. <span style=”font-size: small;”>package dao;
    3. import java.util.List;
    5. import entity.User;
    7. /**
    8.  * 用于测试的UserDao
    9.  * @author Jzl
    10.  *
    11.  */
    12. public class UserDao extends BaseDao {
    13.     public int addUser1(User user) {
    14.         return super.saveEntity(
    15.                 ”insert into tbl_user values(seq_user.nextval,?,?,?)”, user, 1);
    16.     }
    18.     public int addUser2(User user) {
    19.         return super.saveOrUpdate(
    20.                 ”insert into tbl_user values(seq_user.nextval,?,?,?)”,
    21.                 user.getUserName(), user.getUserPass(), user.getLastDate());
    22.     }
    24.     public int deleteUserById(int userId) {
    25.         return super
    26.                 .saveOrUpdate(“delete from tbl_user where userId=?”, userId);
    27.     }
    29.     public int modUserById(int userId, User user) {
    30.         return super
    31.                 .saveOrUpdate(
    32.                         ”update tbl_user set userName=?,userPass=?,lastDate=? where userId=?”,
    33.                         user.getUserName(), user.getUserPass(),
    34.                         user.getLastDate(), userId);
    35.     }
    37.     public User getUser(int userId) {
    38.         return super.executeQuery(“select * from tbl_user where userId=?”,
    39.                 User.class, userId).get(0);
    40.     }
    42.     public List<User> getUserList() {
    43.         return super.executeQuery(“select * from tbl_user”, User.class);
    44.     }
    46.     public long getUserCount(){
    47.         return super.getCount(“select count(*) from tbl_user”);
    48.     }
    49. }
    50. </span>
  5. 用于测试UserDao的测试类：
    Java代码  收藏代码
    1. <span style=”font-size: small;”>package test;
    3. import java.sql.Date;
    4. import java.util.List;
    6. import org.junit.Test;
    8. import dao.UserDao;
    9. import entity.User;
    11. public class UserDaoTest {
    12.     private UserDao userDao = new UserDao();
    14.     @Test
    15.     public void testUserDao() {
    16.         testAdd1();
    17.         testAdd2();
    18.         testDeleteById();
    19.         testModById();
    20.         System.out.println(testGetById().getUserName());
    21.         List<User> users = testGetList();
    22.         for (User user : users) {
    23.             System.out.println(user.getUserId() + ”==” + user.getUserName());
    24.         }
    25.         System.out.println(testGetCount());
    26.     }
    28.     public int testAdd1() {
    29.         User user = new User(“zs”, ”zs”, new Date(System.currentTimeMillis()));
    30.         return userDao.addUser1(user);
    31.     }
    33.     public int testAdd2() {
    34.         User user = new User(“zs”, ”zs”, new Date(System.currentTimeMillis()));
    35.         return userDao.addUser2(user);
    36.     }
    38.     public int testDeleteById() {
    39.         return userDao.deleteUserById(104);
    40.     }
    42.     public User testGetById() {
    43.         return userDao.getUser(104);
    44.     }
    46.     public int testModById() {
    47.         User user = new User(“ls”, ”ls”, new Date(System.currentTimeMillis()));
    48.         return userDao.modUserById(104, user);
    49.     }
    51.     public List<User> testGetList() {
    52.         return userDao.getUserList();
    53.     }
    55.     public long testGetCount() {
    56.         return userDao.getUserCount();
    57.     }
    58. }
    59. </span>
  6. 创建用于测试的数据库表：

这里用Oracle数据库作测试，建表语句如下，

Sql代码  收藏代码
  1. –创建测试表
  2. create table tbl_user
  3. (
  4.   userId   number(8) primary key not null,
  5.   userName varchar2(20),
  6.   userPass varchar2(20),
  7.   lastDate Date
  8. );
  10. create sequence seq_user;