JDBC篇-第七章 DAO及其相关实现类

女爷i 2021-06-24 13:58 360阅读 0赞

# 第七章 DAO及其相关实现类 #

## 7.1 版本一 ##

### 【BaseDAO.java】 ###

public class BaseDAO { 
    	// 通用的增删改操作---version 2.0 （考虑上事务）
    	public int update(Connection conn, String sql, Object... args) { // sql中占位符的个数与可变形参的长度相同！
    		PreparedStatement ps = null;
    		try { 
    			// 1.预编译sql语句，返回PreparedStatement的实例
    			ps = conn.prepareStatement(sql);
    			// 2.填充占位符
    			for (int i = 0; i < args.length; i++) { 
    				ps.setObject(i + 1, args[i]);// 小心参数声明错误！！
    			}
    			// 3.执行
    			return ps.executeUpdate();
    		} catch (Exception e) { 
    			e.printStackTrace();
    		} finally { 
    			// 4.资源的关闭
    			JDBCUtils.closeResource(null, ps);
    		}
    		return 0;
    	}
    
    	// 通用的查询操作，用于返回数据表中的一条记录（version 2.0：考虑上事务）
    	public <T> T getInstance(Connection conn,Class<T> clazz, String sql, Object... args) { 
    		PreparedStatement ps = null;
    		ResultSet rs = null;
    		try { 
    			ps = conn.prepareStatement(sql);
    			for (int i = 0; i < args.length; i++) { 
    				ps.setObject(i + 1, args[i]);
    			}
    			rs = ps.executeQuery();
    			// 获取结果集的元数据 :ResultSetMetaData
    			ResultSetMetaData rsmd = rs.getMetaData();
    			// 通过ResultSetMetaData获取结果集中的列数
    			int columnCount = rsmd.getColumnCount();
    
    			if (rs.next()) { 
    				T t = clazz.newInstance();
    				// 处理结果集一行数据中的每一个列
    				for (int i = 0; i < columnCount; i++) { 
    					// 获取列值
    					Object columValue = rs.getObject(i + 1);
    
    					// 获取每个列的列名
    					// String columnName = rsmd.getColumnName(i + 1);
    					String columnLabel = rsmd.getColumnLabel(i + 1);
    
    					// 给t对象指定的columnName属性，赋值为columValue：通过反射
    					Field field = clazz.getDeclaredField(columnLabel);
    					field.setAccessible(true);
    					field.set(t, columValue);
    				}
    				return t;
    			}
    		} catch (Exception e) { 
    			e.printStackTrace();
    		} finally { 
    			JDBCUtils.closeResource(null, ps, rs);
    		}
    		return null;
    	}
    	
    	// 通用的查询操作，用于返回数据表中的一条记录（version 2.0：考虑上事务）
    	public <T> List<T> getForList(Connection conn,Class<T> clazz,String sql,Object ...args){ 
    		PreparedStatement ps = null;
    		ResultSet rs = null;
    		try { 
    			ps = conn.prepareStatement(sql);
    			for (int i = 0; i < args.length; i++) { 
    				ps.setObject(i + 1, args[i]);
    			}
    
    			rs = ps.executeQuery();
    			// 获取结果集的元数据 :ResultSetMetaData
    			ResultSetMetaData rsmd = rs.getMetaData();
    			// 通过ResultSetMetaData获取结果集中的列数
    			int columnCount = rsmd.getColumnCount();
    			//创建集合对象
    			ArrayList<T> list = new ArrayList<T>();
    			while (rs.next()) { 
    				T t = clazz.newInstance();
    				// 处理结果集一行数据中的每一个列:给t对象指定的属性赋值
    				for (int i = 0; i < columnCount; i++) { 
    					// 获取列值
    					Object columValue = rs.getObject(i + 1);
    
    					// 获取每个列的列名
    					// String columnName = rsmd.getColumnName(i + 1);
    					String columnLabel = rsmd.getColumnLabel(i + 1);
    
    					// 给t对象指定的columnName属性，赋值为columValue：通过反射
    					Field field = clazz.getDeclaredField(columnLabel);
    					field.setAccessible(true);
    					field.set(t, columValue);
    				}
    				list.add(t);
    			}
    			return list;
    		} catch (Exception e) { 
    			e.printStackTrace();
    		} finally { 
    			JDBCUtils.closeResource(null, ps, rs);
    
    		}
    		return null;
    	}
    	
    	
    	
    	public <T> T getValue(Connection conn,String sql,Object ...args){ 
    		PreparedStatement ps = null;
    		ResultSet rs = null;
    		try { 
    			ps = conn.prepareStatement(sql);
    			for(int i=0 ;i<args.length;i++){ 
    				ps.setObject(i + 1, args[i]);
    			}
    			
    			rs = ps.executeQuery();
    			if(rs.next()){ 
    				return (T) rs.getObject(1);
    			}
    			
    		} catch (Exception e) { 
    			e.printStackTrace();
    		}finally { 
    			
    			JDBCUtils.closeResource(null, ps, rs);
    		}
    		return null;
    	}
    }

### 【CustomerDAO.java】 ###

public interface CustomerDAO { 
    	
    	/** * * @Description 将custimer对象添加到数据库中 * @author cVzhanshi * @date 2021年4月3日下午2:41:50 * @param conn * @param custimer */
    	void insert(Connection conn,Customer custimer);
    	
    	/** * * @Description 针对指定的id，删除表中的一条记录 * @author cVzhanshi * @date 2021年4月3日下午2:42:42 * @param conn * @param customer */
    	void deleteById(Connection conn,int id);
    	
    	/** * * @Description 针对内存中的custimer对象，去修改数据表中指定的记录 * @author cVzhanshi * @date 2021年4月3日下午2:43:34 * @param conn * @param custimer */
    	void update(Connection conn,Customer custimer);
    	
    	/** * * @Description 针对指定的id查询得到对应的Customer对象 * @author cVzhanshi * @date 2021年4月3日下午2:44:22 * @param connection * @param id * @return */
    	Customer getCustomerById(Connection conn ,int id);
    	
    	/** * * @Description 查询表中的所有记录构成的集合 * @author cVzhanshi * @date 2021年4月3日下午2:45:28 * @param conn * @return */
    	List<Customer> getAll(Connection conn);
    	
    	/** * * @Description 获取数据表中条目数 * @author cVzhanshi * @date 2021年4月3日下午2:45:49 * @param conn * @return */
    	Long getCount(Connection conn);
    	
    	
    	/** * * @Description 返回数据表中最大的生日 * @author cVzhanshi * @date 2021年4月3日下午2:46:46 * @param conn * @return */
    	Date getMaxBirth(Connection conn);
    }

### 【CustomerDAOImpl.java】 ###

public class CustomerDAOImpl extends BaseDAO implements CustomerDAO { 
    
    	@Override
    	public void insert(Connection conn, Customer custimer) { 
    		String sql = "insert into customers(name,email,birth)values(?,?,?)";
    		update(conn, sql, custimer.getName(),custimer.getEmail(),custimer.getBirth());
    	}
    
    	@Override
    	public void deleteById(Connection conn, int id) { 
    		String sql = "delete from customers where id = ?";
    		update(conn, sql, id);
    	}
    
    	@Override
    	public void update(Connection conn, Customer custimer) { 
    		String sql = "update customers set name = ?,email = ?,birth = ? where id = ?";
    		update(conn, sql,custimer.getName(),custimer.getEmail(),custimer.getBirth(),custimer.getId());
    	}
    
    	@Override
    	public Customer getCustomerById(Connection conn, int id) { 
    		String sql = "select id,name,email,birth from customers where id = ?";
    		Customer customer = getInstance(conn,Customer.class, sql,id);
    		return customer;
    	}
    
    	@Override
    	public List<Customer> getAll(Connection conn) { 
    		String sql = "select id,name,email,birth from customers";
    		List<Customer> list = getForList(conn,Customer.class, sql);
    		return list;
    	}
    
    	@Override
    	public Long getCount(Connection conn) { 
    		String sql = "select count(*) from customers";
    		return getValue(conn, sql);
    	}
    
    	@Override
    	public Date getMaxBirth(Connection conn) { 
    		String sql = "select max(birth) from customers";
    		return getValue(conn, sql);
    	}
    
    }

## 7.2 版本二 ##

与版本一的区别不需要手动传入实体类的类型，通过反射自动获取

### 【BaseDAO.java】 ###

public class BaseDAO<T> { 
    
    	private Class<T> clazz = null;
    	{ 
    		Type genericSuperclass = this.getClass().getGenericSuperclass();
    		ParameterizedType paramType = (ParameterizedType) genericSuperclass;
    		Type[] actualTypeArguments = paramType.getActualTypeArguments();
    		clazz = (Class<T>) actualTypeArguments[0];
    	}
    	// 通用的增删改操作---version 2.0 （考虑上事务）
    	public int update(Connection conn, String sql, Object... args) { // sql中占位符的个数与可变形参的长度相同！
    		PreparedStatement ps = null;
    		try { 
    			// 1.预编译sql语句，返回PreparedStatement的实例
    			ps = conn.prepareStatement(sql);
    			// 2.填充占位符
    			for (int i = 0; i < args.length; i++) { 
    				ps.setObject(i + 1, args[i]);// 小心参数声明错误！！
    			}
    			// 3.执行
    			return ps.executeUpdate();
    		} catch (Exception e) { 
    			e.printStackTrace();
    		} finally { 
    			// 4.资源的关闭
    			JDBCUtils.closeResource(null, ps);
    		}
    		return 0;
    	}
    
    	// 通用的查询操作，用于返回数据表中的一条记录（version 2.0：考虑上事务）
    	public T getInstance(Connection conn, String sql, Object... args) { 
    		PreparedStatement ps = null;
    		ResultSet rs = null;
    		try { 
    			ps = conn.prepareStatement(sql);
    			for (int i = 0; i < args.length; i++) { 
    				ps.setObject(i + 1, args[i]);
    			}
    			rs = ps.executeQuery();
    			// 获取结果集的元数据 :ResultSetMetaData
    			ResultSetMetaData rsmd = rs.getMetaData();
    			// 通过ResultSetMetaData获取结果集中的列数
    			int columnCount = rsmd.getColumnCount();
    
    			if (rs.next()) { 
    				T t = clazz.newInstance();
    				// 处理结果集一行数据中的每一个列
    				for (int i = 0; i < columnCount; i++) { 
    					// 获取列值
    					Object columValue = rs.getObject(i + 1);
    
    					// 获取每个列的列名
    					// String columnName = rsmd.getColumnName(i + 1);
    					String columnLabel = rsmd.getColumnLabel(i + 1);
    
    					// 给t对象指定的columnName属性，赋值为columValue：通过反射
    					Field field = clazz.getDeclaredField(columnLabel);
    					field.setAccessible(true);
    					field.set(t, columValue);
    				}
    				return t;
    			}
    		} catch (Exception e) { 
    			e.printStackTrace();
    		} finally { 
    			JDBCUtils.closeResource(null, ps, rs);
    		}
    		return null;
    	}
    	
    	// 通用的查询操作，用于返回数据表中的一条记录（version 2.0：考虑上事务）
    	public List<T> getForList(Connection conn,String sql,Object ...args){ 
    		PreparedStatement ps = null;
    		ResultSet rs = null;
    		try { 
    			ps = conn.prepareStatement(sql);
    			for (int i = 0; i < args.length; i++) { 
    				ps.setObject(i + 1, args[i]);
    			}
    
    			rs = ps.executeQuery();
    			// 获取结果集的元数据 :ResultSetMetaData
    			ResultSetMetaData rsmd = rs.getMetaData();
    			// 通过ResultSetMetaData获取结果集中的列数
    			int columnCount = rsmd.getColumnCount();
    			//创建集合对象
    			ArrayList<T> list = new ArrayList<T>();
    			while (rs.next()) { 
    				T t = clazz.newInstance();
    				// 处理结果集一行数据中的每一个列:给t对象指定的属性赋值
    				for (int i = 0; i < columnCount; i++) { 
    					// 获取列值
    					Object columValue = rs.getObject(i + 1);
    
    					// 获取每个列的列名
    					// String columnName = rsmd.getColumnName(i + 1);
    					String columnLabel = rsmd.getColumnLabel(i + 1);
    
    					// 给t对象指定的columnName属性，赋值为columValue：通过反射
    					Field field = clazz.getDeclaredField(columnLabel);
    					field.setAccessible(true);
    					field.set(t, columValue);
    				}
    				list.add(t);
    			}
    			return list;
    		} catch (Exception e) { 
    			e.printStackTrace();
    		} finally { 
    			JDBCUtils.closeResource(null, ps, rs);
    
    		}
    		return null;
    	}
    	
    	
    	
    	public <T> T getValue(Connection conn,String sql,Object ...args){ 
    		PreparedStatement ps = null;
    		ResultSet rs = null;
    		try { 
    			ps = conn.prepareStatement(sql);
    			for(int i=0 ;i<args.length;i++){ 
    				ps.setObject(i + 1, args[i]);
    			}
    			
    			rs = ps.executeQuery();
    			if(rs.next()){ 
    				return (T) rs.getObject(1);
    			}
    			
    		} catch (Exception e) { 
    			e.printStackTrace();
    		}finally { 
    			
    			JDBCUtils.closeResource(null, ps, rs);
    		}
    		return null;
    	}
    }

### 【CustomerDAO.java】 ###

### 【CustomerDAOImpl.java】 ###

public class CustomerDAOImpl extends BaseDAO<Customer> implements CustomerDAO { 
    
    	@Override
    	public void insert(Connection conn, Customer custimer) { 
    		String sql = "insert into customers(name,email,birth)values(?,?,?)";
    		update(conn, sql, custimer.getName(),custimer.getEmail(),custimer.getBirth());
    	}
    
    	@Override
    	public void deleteById(Connection conn, int id) { 
    		String sql = "delete from customers where id = ?";
    		update(conn, sql, id);
    	}
    
    	@Override
    	public void update(Connection conn, Customer custimer) { 
    		String sql = "update customers set name = ?,email = ?,birth = ? where id = ?";
    		update(conn, sql,custimer.getName(),custimer.getEmail(),custimer.getBirth(),custimer.getId());
    	}
    
    	@Override
    	public Customer getCustomerById(Connection conn, int id) { 
    		String sql = "select id,name,email,birth from customers where id = ?";
    		Customer customer = getInstance(conn, sql,id);
    		return customer;
    	}
    
    	@Override
    	public List<Customer> getAll(Connection conn) { 
    		String sql = "select id,name,email,birth from customers";
    		List<Customer> list = getForList(conn, sql);
    		return list;
    	}
    
    	@Override
    	public Long getCount(Connection conn) { 
    		String sql = "select count(*) from customers";
    		return getValue(conn, sql);
    	}
    
    	@Override
    	public Date getMaxBirth(Connection conn) { 
    		String sql = "select max(birth) from customers";
    		return getValue(conn, sql);
    	}
    
    }