dao 层结构的设计方案
包和类的分配结构
1.新建一个项目
2.导入相关的开发包 (比如驱动包等)
3.定义出包的结构
4.将连接数据库的连接工具放到 util 包中
5.创建 Emp(简单 JAVA类, VO类, 实体类,JavaBean) 对象 (该对象放到 vo 包中)
6.开发 dao 层的接口 IEmpDAO (操作标准, 放入dao 包中)
dao 层需要自己的接口为了解耦合 (同样的 service 也有自己的接口).
7. 开发出父工具类(此类父工具类中的方法都是泛型方法,因为要让不同的子类使用工具类中的方法)
1 public class BaseDAOUtil { 2 private PreparedStatement pst; 3 private ResultSet rst; 4 5 public <T> int save(Connection conn,String sql,Class<T> clz,T vo) throws Exception { 6 pst = conn.prepareStatement(sql); 7 //为 sql 设置占位符 (insert into 表(字段1,字段2,字段3,) VALUES(?,?,?)) 8 String[] columns = sql.split("\(")[1].split("\)")[0].split(","); 9 for (int i = 0; i < columns.length; i++) { 10 Field f = vo.getClass().getDeclaredField(columns[i]); 11 //打开访问权限 12 f.setAccessible(true); 13 //取得字段对应的属性值 14 Object fvalue = f.get(vo); 15 pst.setObject(i+1, fvalue); 16 } 17 return pst.executeUpdate(); 18 } 19 public <T> int edit(Connection conn,String sql,T vo) throws Exception { 20 pst = conn.prepareStatement(sql); 21 //UPDATE emp SET sal=?,job=?,comm=? WHERE empno=? AND ; 22 String[] strs = sql.split("SET")[1].split("WHERE")[0].split(","); 23 int i = 0; 24 for (i = 0; i < strs.length; i++) { 25 //获取要修改的字段名称 26 String column = strs[i].split("=")[0]; 27 //通过反射获取 column 对应在 vo 中的属性对象 28 Field f = vo.getClass().getDeclaredField(column.trim()); 29 f.setAccessible(true); 30 //取得该字段在vo 对象中的值 31 Object fvalue = f.get(vo); 32 //为占位符设置具体的内容 33 pst.setObject(i+1, fvalue); 34 } 35 String conditions = sql.split("WHERE")[1].split("=")[0]; 36 Field f = vo.getClass().getDeclaredField(conditions.trim()); 37 f.setAccessible(true); 38 //取得该字段在vo 对象中的值 39 Object fvalue = f.get(vo); 40 pst.setObject(i+1, fvalue); 41 return pst.executeUpdate(); 42 } 43 44 45 public int removeBuId(Connection conn,String sql,Object id) throws Exception { 46 pst = conn.prepareStatement(sql); 47 pst.setObject(1, id); 48 return pst.executeUpdate(); 49 } 50 51 52 public int removeBatch(Connection conn,StringBuffer sql,List<Object> ids) throws Exception { 53 Iterator<Object> iter = ids.iterator(); 54 55 while (iter.hasNext()) { 56 sql.append(iter.next() + ",") ; 57 } 58 sql.delete(sql.length()-1, sql.length()); 59 sql.append(")"); 60 61 pst = conn.prepareStatement(sql.toString()); 62 63 return pst.executeUpdate(); 64 } 65 66 /* 67 * 根据编号查询数据 68 */ 69 public <T> T selectOne(Connection conn,String sql,Class<T> clz,Object id) throws Exception { 70 pst = conn.prepareStatement(sql); 71 pst.setObject(1, id); 72 //执行 sql 语句 73 rst = pst.executeQuery(); 74 75 T t = null; 76 if (rst.next()) { 77 t=clz.newInstance(); 78 //取得所有属性 79 Field[] fs = clz.getDeclaredFields(); 80 for (Field f : fs) { 81 //打开访问权限 82 f.setAccessible(true); 83 //取得属性名 84 String fname = f.getName(); 85 //使用该属性名称从结果集中取得数据 86 Object fvalue = rst.getObject(fname); 87 //将取得的值保存给 t 对象的属性 88 f.set(t, fvalue); 89 } 90 return t; 91 } 92 return null; 93 } 94 95 96 public <T> List<T> selectList(Connection conn,String sql,Class<T> clz,Object...params) throws Exception { 97 List<T> list = new ArrayList<T>(); 98 pst = conn.prepareStatement(sql); 99 100 for (int i = 0; i < params.length; i++) { 101 pst.setObject(i+1, params[i]); 102 } 103 //执行 sql 语句 104 rst = pst.executeQuery(); 105 T t = null; 106 while (rst.next()) { 107 t = clz.newInstance(); 108 //取得所有属性 109 Field[] fs = clz.getDeclaredFields(); 110 for (Field f : fs) { 111 //打开访问权限 112 f.setAccessible(true); 113 //取得属性名 114 String fname = f.getName(); 115 //使用该属性名称从结果集中取得数据 116 Object fvalue = rst.getObject(fname); 117 //将取得的值保存给 t 对象的属性 118 f.set(t, fvalue); 119 } 120 list.add(t); 121 } 122 return list; 123 } 124 125 public int selectCount(Connection conn,String sql,Object...params) throws Exception { 126 pst = conn.prepareStatement(sql); 127 for (int i = 0; i < params.length; i++) { 128 pst.setObject(i+1, params[i]); 129 } 130 //执行 sql 语句 131 rst = pst.executeQuery(); 132 rst.next(); 133 return rst.getInt(1); 134 } 135 }
8.定义父接口
1 public interface IBaseDAO<T> { 2 /** 3 * 增加数据 4 * @param vo 保存了药插入数据的对象 5 * @return 增加的行数 6 * @throws Exception 7 */ 8 public int insert(T vo) throws Exception; 9 /** 10 * 修改数据 11 * @param vo 保存了要修改的数据的对象 12 * @return 修改的行数 13 * @throws Exception 14 */ 15 public int update(T vo) throws Exception; 16 /** 17 * 根据编号删除数据 18 * @param empno 要删除的数据的编号 19 * @return 删除的行数 20 * @throws Exception 21 */ 22 public int deleteBuId(Object id) throws Exception; 23 /** 24 * 实现批量删除数据 25 * @param empnos 保存了要删除的数据的编号的集合 26 * @return 删除的行数 27 * @throws Exception 28 */ 29 public int deleteBatch(List<Object> ids) throws Exception; 30 /** 31 * 根据编号查询数据 32 * @param id 要查询的数据编号 33 * @return 如有数据对象返回数据对象 否则返回 null 34 * @throws Exception 35 */ 36 public T selectById(Object id) throws Exception; 37 /** 38 * 根据姓名模糊分页查询 39 * @param kw 模糊查询的关键字 40 * @param cp 当前页 41 * @param ls 每页显示的数据量 42 * @return 返回保存了 Emp 对象的集合 43 * @throws Exception 44 */ 45 public List<T> selectSplitAll(String kw,Integer cp,Integer ls) throws Exception; 46 /** 47 * 统计数据量 48 * @param kw 模糊查询的关键字 49 * @return 返回查询到的数据量 50 * @throws Exception 51 */ 52 public int selectCount(String kw) throws Exception; 53 }
9.让子接口实现父接口的时候给出具体泛型
public interface IDeptDAO extends IBaseDAO<Dept>{ //定义子接口特有的方法 } public interface IEmpDAO extends IBaseDAO<Emp>{ //定义子接口特有的方法 }
10让子类继承父工具类的同时实现自己的子接口
1 public class EmpDAOImpl extends BaseDAOUtil implements IEmpDAO { 2 private Connection conn; 3 public EmpDAOImpl() { 4 super(); 5 } 6 public EmpDAOImpl(Connection conn) { 7 super(); 8 this.conn = conn; 9 } 10 11 @Override 12 public int insert(Emp vo) throws Exception { 13 String sql = "INSERT INTO emp(empno,ename,job,sal,hiredate,mgr,comm,deptno)" + " VALUES(?,?,?,?,?,?,?,?)"; 14 return super.save(conn, sql, Emp.class, vo); 15 } 16 17 @Override 18 public int update(Emp vo) throws Exception { 19 String sql = "UPDATE emp SET ename=?,job=?,sal=?,hiredate=?,mgr=?,comm=?,deptno=? WHERE empno=?"; 20 return super.edit(conn, sql, vo); 21 } 22 23 @Override 24 public int deleteBuId(Object id) throws Exception { 25 String sql = "DELETE FROM emp WHERE empno=?"; 26 return super.removeBuId(conn, sql, id); 27 } 28 29 @Override 30 public int deleteBatch(List<Object> ids) throws Exception { 31 StringBuffer sql = new StringBuffer("DELETE FROM emp WHERE empno IN("); 32 return super.removeBatch(conn, sql, ids); 33 } 34 35 @Override 36 public Emp selectById(Object id) throws Exception { 37 String sql = "SELECT empno,ename,job,sal,hiredate,mgr,comm,deptno" + " FROM emp" + " WHERE empno=?"; 38 return super.selectOne(conn, sql, Emp.class, id); 39 } 40 41 @Override 42 public List<Emp> selectSplitAll(String kw, Integer cp, Integer ls) throws Exception { 43 String sql = "SELECT empno,ename,job,sal,hiredate,mgr,comm,deptno" + " FROM emp" 44 + " WHERE ename LIKE ? LIMIT ?,?"; 45 return super.selectList(conn, sql, Emp.class, kw,(cp-1)*ls,ls); 46 } 47 48 @Override 49 public int selectCount(String kw) throws Exception { 50 String sql = "SELECT COUNT(*)" + " FROM emp" + " WHERE ename LIKE ?"; 51 return super.selectCount(conn, sql, kw); 52 } 53 }
测试:
public class Test { public static void main(String[] args) throws Exception { Connection conn = DBUitl.getConnection(); IEmpDAO dao1 = new EmpDAOImpl(conn); // IDeptDAO dao2 = new DeptDAOImpl(conn); // System.out.println(dao1.insert(new Emp(1115,"zhang33","音乐",9000.00,new Date(),7788,2000.00,10))); // System.out.println(dao1.deleteBuId(1115)); // List<Object> list = new ArrayList<Object>(); // list.add(1009); // list.add(1115); // System.out.println(dao1.deleteBatch(list)); // System.out.println(dao1.selectById(7788)); // System.out.println(dao1.selectCount("A%")); // List<Emp> list = dao1.selectSplitAll("%A%", 2, 5); // for (Emp emp : list) { // System.out.println(emp); // } // System.out.println(dao2.selectById(20)); // System.out.println(dao2.selectCount("A%")); } }