• JAVA【DAO及其实现类】

    目录

    一、BaseDAO中的基础查询功能 

    二、创建接口规范功能

    三、调用BaseDAO实现针对于某一张表具体的查询操作

    四、测试

     

    DAO：Data Access Object访问数据信息的类和接口，包括了对数据的CRUD（Create、Retrival、Update、Delete），而不包含任何业务相关的信息。有时也称作：BaseDAO

    作用：为了实现功能的模块化，更有利于代码的维护和升级。

    一、BaseDAO中的基础查询功能 

    下面是我们的BaseDAO中的具体功能 

    1. public abstract class BaseDAO {
    2.  
    3. 	//声明一个泛型
    4. 	private Class clazz = null;
    5. 	//可以在构造器中实例化clazz
    6. //	public BaseDAO(){
    7. //		
    8. //	}
    9. 	//或者直接写一个代码块
    10. 	{	
    11. 		//获取当前BaseDAO的子类继承的父类中的泛型
    12. 		//这个this指的是子类
    13. 		//先获取子类的类，然后再获取子类的带泛型的父类
    14. 		Type genericSuperclass = this.getClass().getGenericSuperclass();
    15. 		//用parameterizedType将其强转，使其能变成一个带参数的type
    16. 		ParameterizedType paramType = (ParameterizedType) genericSuperclass;
    17. 		//由于泛型可能会有多个，所以我们需要存为一个数组，
    18. 		Type[] typeArguments = paramType.getActualTypeArguments();//获取了父类的泛型参数
    19. 		//但是对于我们来说只有一个泛型，所以我们要用到第一个就可以了
    20. 		clazz = (Class) typeArguments[0];//泛型的第一个参数
    21. 		
    22. 	}
    23. 	
    24. 	
    25. 	// 通用的增删改操作---version 2.0 （考虑上事务）
    26. 	public int update(Connection conn, String sql, Object... args) {// sql中占位符的个数与可变形参的长度相同！
    27. 		PreparedStatement ps = null;
    28. 		try {
    29. 			// 1.预编译sql语句，返回PreparedStatement的实例
    30. 			ps = conn.prepareStatement(sql);
    31. 			// 2.填充占位符
    32. 			for (int i = 0; i < args.length; i++) {
    33. 				ps.setObject(i + 1, args[i]);// 小心参数声明错误！！
    34. 			}
    35. 			// 3.执行
    36. 			return ps.executeUpdate();
    37. 		} catch (Exception e) {
    38. 			e.printStackTrace();
    39. 		} finally {
    40. 			// 4.资源的关闭
    41. 			JDBCUtils.closeResource(null, ps);
    42.  
    43. 		}
    44. 		return 0;
    45.  
    46. 	}
    47.  
    48. 	// 通用的查询操作，用于返回数据表中的一条记录（version 2.0：考虑上事务）
    49. 	public T getInstance(Connection conn, String sql, Object... args) {
    50. 		PreparedStatement ps = null;
    51. 		ResultSet rs = null;
    52. 		try {
    53.  
    54. 			ps = conn.prepareStatement(sql);
    55. 			for (int i = 0; i < args.length; i++) {
    56. 				ps.setObject(i + 1, args[i]);
    57. 			}
    58.  
    59. 			rs = ps.executeQuery();
    60. 			// 获取结果集的元数据 :ResultSetMetaData
    61. 			ResultSetMetaData rsmd = rs.getMetaData();
    62. 			// 通过ResultSetMetaData获取结果集中的列数
    63. 			int columnCount = rsmd.getColumnCount();
    64.  
    65. 			if (rs.next()) {
    66. 				T t = clazz.newInstance();
    67. 				// 处理结果集一行数据中的每一个列
    68. 				for (int i = 0; i < columnCount; i++) {
    69. 					// 获取列值
    70. 					Object columValue = rs.getObject(i + 1);
    71.  
    72. 					// 获取每个列的列名
    73. 					// String columnName = rsmd.getColumnName(i + 1);
    74. 					String columnLabel = rsmd.getColumnLabel(i + 1);
    75.  
    76. 					// 给t对象指定的columnName属性，赋值为columValue：通过反射
    77. 					Field field = clazz.getDeclaredField(columnLabel);
    78. 					field.setAccessible(true);
    79. 					field.set(t, columValue);
    80. 				}
    81. 				return t;
    82. 			}
    83. 		} catch (Exception e) {
    84. 			e.printStackTrace();
    85. 		} finally {
    86. 			JDBCUtils.closeResource(null, ps, rs);
    87.  
    88. 		}
    89.  
    90. 		return null;
    91. 	}
    92. 	// 通用的查询操作，用于返回数据表中的多条记录构成的集合（version 2.0：考虑上事务）
    93. 	public List getForList(Connection conn, String sql, Object... args) {
    94. 		PreparedStatement ps = null;
    95. 		ResultSet rs = null;
    96. 		try {
    97.  
    98. 			ps = conn.prepareStatement(sql);
    99. 			for (int i = 0; i < args.length; i++) {
    100. 				ps.setObject(i + 1, args[i]);
    101. 			}
    102.  
    103. 			rs = ps.executeQuery();
    104. 			// 获取结果集的元数据 :ResultSetMetaData
    105. 			ResultSetMetaData rsmd = rs.getMetaData();
    106. 			// 通过ResultSetMetaData获取结果集中的列数
    107. 			int columnCount = rsmd.getColumnCount();
    108. 			// 创建集合对象
    109. 			ArrayList list = new ArrayList();
    110. 			while (rs.next()) {
    111. 				T t = clazz.newInstance();
    112. 				// 处理结果集一行数据中的每一个列:给t对象指定的属性赋值
    113. 				for (int i = 0; i < columnCount; i++) {
    114. 					// 获取列值
    115. 					Object columValue = rs.getObject(i + 1);
    116.  
    117. 					// 获取每个列的列名
    118. 					// String columnName = rsmd.getColumnName(i + 1);
    119. 					String columnLabel = rsmd.getColumnLabel(i + 1);
    120.  
    121. 					// 给t对象指定的columnName属性，赋值为columValue：通过反射
    122. 					Field field = clazz.getDeclaredField(columnLabel);
    123. 					field.setAccessible(true);
    124. 					field.set(t, columValue);
    125. 				}
    126. 				list.add(t);
    127. 			}
    128.  
    129. 			return list;
    130. 		} catch (Exception e) {
    131. 			e.printStackTrace();
    132. 		} finally {
    133. 			JDBCUtils.closeResource(null, ps, rs);
    134.  
    135. 		}
    136.  
    137. 		return null;
    138. 	}
    139. 	//用于查询特殊值的通用的方法
    140. 	//比方说select count(*)_ from user_table就是返回一共有几行数据
    141. 	public  E getValue(Connection conn,String sql,Object...args){
    142. 		PreparedStatement ps = null;
    143. 		ResultSet rs = null;
    144. 		try {
    145. 			ps = conn.prepareStatement(sql);
    146. 			for(int i = 0;i < args.length;i++){
    147. 				ps.setObject(i + 1, args[i]);
    148. 				
    149. 			}
    150. 			
    151. 			rs = ps.executeQuery();
    152. 			if(rs.next()){
    153. 				return (E) rs.getObject(1);
    154. 			}
    155. 		} catch (SQLException e) {
    156. 			e.printStackTrace();
    157. 		}finally{
    158. 			JDBCUtils.closeResource(null, ps, rs);
    159. 			
    160. 		}
    161. 		return null;
    162. 		
    163. 	}
    164.  
    165. 	public abstract void insert(Connection conn, Customer cust);
    166.  
    167. 	public abstract void update(Connection conn, Customer cust);
    168. }

    二、创建接口规范功能

    对于每一张不同的表，我们需要创建一定的接口去规范我们的查询操作

    1. import com.atguigu2.bean.Customer;
    2. //指明操作的是Customer类，因为我们重写所实现的方法均是针对于Customer接口的
    3. //然后再BaseDAO中获取这个当前类的父类的泛型，也就是Customer
    4. public class CustomerDAOImpl extends BaseDAO implements CustomerDAO{
    5.  
    6.  
    7. 	
    8. 	@Override
    9. 	public void insert(Connection conn, Customer cust) {
    10. 		String sql = "insert into customers(name,email,birth)values(?,?,?)";
    11. 		update(conn, sql,cust.getName(),cust.getEmail(),cust.getBirth());
    12. 	}
    13.  
    14. 	@Override
    15. 	public void deleteById(Connection conn, int id) {
    16. 		String sql = "delete from customers where id = ?";
    17. 		update(conn, sql, id);
    18. 	}
    19.  
    20. 	@Override
    21. 	public void update(Connection conn, Customer cust) {
    22. 		String sql = "update customers set name = ?,email = ?,birth = ? where id = ?";
    23. 		update(conn, sql,cust.getName(),cust.getEmail(),cust.getBirth(),cust.getId());
    24. 	}
    25.  
    26. 	@Override
    27. 	public Customer getCustomerById(Connection conn, int id) {
    28. 		String sql = "select id,name,email,birth from customers where id = ?";
    29. 		Customer customer = getInstance(conn, sql,id);
    30. 		return customer;
    31. 	}
    32.  
    33. 	@Override
    34. 	public List getAll(Connection conn) {
    35. 		String sql = "select id,name,email,birth from customers";
    36. 		List list = getForList(conn, sql);
    37. 		return list;
    38. 	}
    39.  
    40. 	@Override
    41. 	public Long getCount(Connection conn) {
    42. 		String sql = "select count(*) from customers";
    43. 		return getValue(conn, sql);
    44. 	}
    45.  
    46. 	@Override
    47. 	public Date getMaxBirth(Connection conn) {
    48. 		String sql = "select max(birth) from customers";
    49. 		return getValue(conn, sql);
    50. 	}
    51.  
    52. }

    三、调用BaseDAO实现针对于某一张表具体的查询操作

    重写接口所对应的方法，来实现具体的功能

    1. public class CustomerDAOImpl extends BaseDAO implements CustomerDAO{
    2. 	
    3. 	
    4. 	@Override
    5. 	public void insert(Connection conn, Customer cust) {
    6. 		String sql = "insert into customers(name,email,birth)values(?,?,?)";
    7. 		update(conn, sql,cust.getName(),cust.getEmail(),cust.getBirth());
    8. 	}
    9.  
    10. 	@Override
    11. 	public void deleteById(Connection conn, int id) {
    12. 		String sql = "delete from customers where id = ?";
    13. 		update(conn, sql, id);
    14. 	}
    15.  
    16. 	@Override
    17. 	public void update(Connection conn, Customer cust) {
    18. 		String sql = "update customers set name = ?,email = ?,birth = ? where id = ?";
    19. 		update(conn, sql,cust.getName(),cust.getEmail(),cust.getBirth(),cust.getId());
    20. 	}
    21.  
    22. 	@Override
    23. 	public Customer getCustomerById(Connection conn, int id) {
    24. 		String sql = "select id,name,email,birth from customers where id = ?";
    25. 		Customer customer = getInstance(conn, sql,id);
    26. 		return customer;
    27. 	}
    28.  
    29. 	@Override
    30. 	public List getAll(Connection conn) {
    31. 		String sql = "select id,name,email,birth from customers";
    32. 		List list = getForList(conn, sql);
    33. 		return list;
    34. 	}
    35.  
    36. 	@Override
    37. 	public Long getCount(Connection conn) {
    38. 		String sql = "select count(*) from customers";
    39. 		return getValue(conn, sql);
    40. 	}
    41.  
    42. 	@Override
    43. 	public Date getMaxBirth(Connection conn) {
    44. 		String sql = "select max(birth) from customers";
    45. 		return getValue(conn, sql);
    46. 	}
    47.  
    48. }

    四、测试

    由于我们查询时动态的，所以需要实例化一个DAO对象 

    private CustomerDAOImpl dao = new CustomerDAOImpl();

    测试插入单行数据

    1. @Test
    2. 	public void testInsert() {
    3. 		Connection conn = null;
    4. 		try {
    5. 			conn = JDBCUtils.getConnection();
    6. 			Customer cust = new Customer(1, "于小飞", "xiaofei@126.com",new Date(43534646435L));
    7. 			dao.insert(conn, cust);
    8. 			System.out.println("添加成功");
    9. 		} catch (Exception e) {
    10. 			e.printStackTrace();
    11. 		}finally{
    12. 			JDBCUtils.closeResource(conn, null);
    13.  
    14. 		}
    15.  
    16. 	}

    成功插入 

    测试删除ID为13的记录 

    1. @Test
    2. 	public void testDeleteById() {
    3. 		Connection conn = null;
    4. 		try {
    5. 			conn = JDBCUtils.getConnection();
    6.  
    7. 			dao.deleteById(conn, 13);
    8.  
    9.  
    10. 			System.out.println("删除成功");
    11. 		} catch (Exception e) {
    12. 			e.printStackTrace();
    13. 		}finally{
    14. 			JDBCUtils.closeResource(conn, null);
    15.  
    16. 		}
    17. 	}

     ID为13的成功被删除

    测试修改数据 

    1. @Test
    2. 	public void testUpdateConnectionCustomer() {
    3. 		Connection conn = null;
    4. 		try {
    5. 			conn = JDBCUtils.getConnection();
    6. 			Customer cust = new Customer(18,"阿木力","amuli@126.com",new Date(453465656L));
    7. 			dao.update(conn, cust);
    8.  
    9.  
    10. 			System.out.println("修改成功");
    11. 		} catch (Exception e) {
    12. 			e.printStackTrace();
    13. 		}finally{
    14. 			JDBCUtils.closeResource(conn, null);
    15.  
    16. 		}
    17. 	}

    修改成功

     测试查询数据

    1. @Test
    2. 	public void testGetCustomerById() {
    3. 		Connection conn = null;
    4. 		try {
    5. 			conn = JDBCUtils.getConnection();
    6.  
    7. 			Customer cust = dao.getCustomerById(conn, 21);
    8. 			System.out.println(cust);
    9.  
    10.  
    11. 		} catch (Exception e) {
    12. 			e.printStackTrace();
    13. 		}finally{
    14. 			JDBCUtils.closeResource(conn, null);
    15.  
    16. 		}
    17. 	}

     

    获取表中的所有记录 

    1. @Test
    2. 	public void testGetAll() {
    3. 		Connection conn = null;
    4. 		try {
    5. 			conn = JDBCUtils.getConnection();
    6.  
    7. 			List list = dao.getAll(conn);
    8. 			list.forEach(System.out::println);
    9.  
    10.  
    11. 			System.out.println("");
    12. 		} catch (Exception e) {
    13. 			e.printStackTrace();
    14. 		}finally{
    15. 			JDBCUtils.closeResource(conn, null);
    16.  
    17. 		}
    18. 	}

     

    测试统计表中的记录数 

    1. @Test
    2. 	public void testGetCount() {
    3. 		Connection conn = null;
    4. 		try {
    5. 			conn = JDBCUtils.getConnection();
    6.  
    7. 			Long count = dao.getCount(conn);
    8.  
    9. 			System.out.println("表中的记录数为：" + count);
    10. 		} catch (Exception e) {
    11. 			e.printStackTrace();
    12. 		}finally{
    13. 			JDBCUtils.closeResource(conn, null);
    14.  
    15. 		}
    16. 	}

     

     获取最大生日

    1. @Test
    2. 	public void testGetMaxBirth() {
    3. 		Connection conn = null;
    4. 		try {
    5. 			conn = JDBCUtils.getConnection();
    6.  
    7. 			Date maxBirth = dao.getMaxBirth(conn);
    8.  
    9. 			System.out.println("最大的生日为：" + maxBirth);
    10. 		} catch (Exception e) {
    11. 			e.printStackTrace();
    12. 		}finally{
    13. 			JDBCUtils.closeResource(conn, null);
    14.  
    15. 		}
    16. 	}

     

     

  • 相关阅读:
    一维数组根据父id转为嵌套树结构
    【TIM定时器】
    239. 滑动窗口最大值/76. 最小覆盖子串
    ORACLE insert 性能比较
    tf loss构建常用到函数
    Python之第八章 模块和包 --- 包
    数据结构与算法7-递归、分治、回溯
    IDEA的database使用教程（使用mysql数据库）
    SDK广告整合
    JAVA主要面向哪个方面？
  • 原文地址：https://blog.csdn.net/weixin_62684026/article/details/126240296