JDBC之DAO

一、说明

DAO(Data Access Object)是数据访问信息类，包含了对数据的增删改查操作，而不包括任何业务相关的信息。

好处：有DAO层有利于实现功能的模块化，有利于代码的维护和升级。

1.使用JDBC编写DAO包含的方法：
(1)update(String sql,Object … args): INSERT、UPDATE、DELETE
(2)< T > T select(Class< T> clazz,String sal,Object … args);查询一条记录，返回对应对象
(3)< T> List< T> select(Class< T> clazz,String sql,Object … args);查询多条记录，返回对应的对象的集合
(4)< T> T getValue(String sql,Object … args);返回某条记录的某一个字段的值，或者一个统计值

二、DAO代码

public class DAO{
// 1.INSERT、UPDATE、DELETE
public static void updata(String sql,Object ... args){//Object数组,可变参数，来应对对象不同属性

Connection conn=null;
PreparedStatement pst=null;
ResultSet rs=null;
try{
conn=ToolOfDB.getConnection();
pst=conn.prepareStatement(sql);

for(int i=0;i<args.legth;i++){

pst.setObject(i+1;args[i]);//设置值，数组从0开始，表从1开始，由于未知所以setObject
}
preparedStatement.executeUpdata();//执行更新操作
}catch(Exception e){
e.printStackTrace();
}finally{
ToolOfDB.releaseResource(null,preparedStatement,conn);//关闭连接，null是ResultSet
}
}



//2.查询一条记录，返回对应对象
public <T> T Select(Class<T> c,String sql,Object ... args){

T entity=null;//对象实体
//链接数据库所需
Connection conn=null;
PreparedStatement pst=null;
ResultSet rs=null;

try{
//1.获取结果集
conn=ToolOfDB.getConnection();//获取连接
pst=conn.prepareStatement(sql);//创建PreparedStatement对象

//赋值
for(int i=0;i<args.length;i++){
pst.setObject(i+1,args[i]);//为占位符赋值
}
rs=pst.executeQuery();//获取结果集

//2.得到ResultSetMetaData对象
ResultSetMetaData rsmd=rs.getMetaData();
//3.创建一个Map<String,Object>对象,键：SQL查询的列的别名，值：列的值
Map<String,Object>values=new HashMap<>();
//4.处理结果集，利用ResultSetMetaData填充3对应的Map对象
if(rs.next()){
for(int i=0;i<rsmd.getColumnCount(i+1);i++){//以列值数循环
String columnLabel=rsmd.getColumnLabel(i+1);//获取列名
Object columnValue=rs.getObject(i+1);//获取列值

values.put(columnLabel,columnValue);//添加到map
}

//5.若Map不为空集，利用反射创建c对应的对象
if(values.size()>0){
//利用反射来创建对象，把方法调用的对象反射给方法内的实体对象
entity=c.newInstance();

//5.遍历Map对象，利用反射为Class对象对应的属性赋值
for(Map.Entry<String,Object> entry:values.entrySet()){
String fieldName=entry.getKey();
Object value=entry.getValue();
//ReflectionUtils.setFieldValue(entity,fieldName,value);//反射赋值
//改为beanutils赋值
BeanUtils.setProperty(entity,fieldName,value);
}
}

}


}catch(Exception e){
e.printStackTrace();
}finally{
ToolOfDB.releaseResource(rs,pst,conn);//关闭数据库连接
}
}

//3.查询多条记录，返回对应的对象的集合
public <T> List<T> select(Class<T> clazz,String sql,Object ... args){

List<T> list=new ArrayList<>();
Connection conn=null;
PreparedStatement pst=null;
ResultSet rs=null;

try{
//1.获取结果集
conn=ToolOfDB.getConnection();//获取连接
pst=conn.prepareStatement(sql);//创建PreparedStatement对象

//赋值
for(int i=0;i<args.length;i++){
pst.setObject(i+1,args[i]);//为占位符赋值
}
rs=pst.executeQuery();//获取结果集

//2.准备一个List<Map<String,Object>>:
//键：存放列名 值：存放列的值。其中一个Map对象对应一条记录
List<Map<String,Object>> values=new ArrayList<>();

ResultSetMetaData rsmd=resultSet.getMetaData();
Map<String,Object>map=null;
//3.处理rs，用while循环
while(rs.next()){

map=new HashMap<>();
for(int i=0;i<rsmd.getColumnCount();i++){
String columnLabel=rsmd.getColumnLabel(i+1);
Object value = resultSet.getObject(i+1);
 map.put(columnLabel,value);
}
//4.把一条记录的一个Map对象放入2准备的List中
values.add(map);
}

//5.判断List是否为空，如不为空，则遍历List,得到一个一个的Map对象，再把一个Map对象转为Class参数对应的Object对象
T Bean=null;
if(Values.size()>0){
for(Map<String,Object> map:values){
for(Map.Entry<String,Object> entry:map.entrySet()){

String fieldName=entry.getKey();
Object value=entry.getValue();
BeanUtils.setProperty(entity,fieldName,value);
}
list.add(bean);
}



}
}catch(Exception e){

e.printStackTrace();
}finally{

ToolOfDB.releaseResource(rs,pst,conn);//关闭数据库连接

}

return list;

}

//4.记录的某一个字段的值，或者一个统计值
public <T> T getValue(String sql,Object ... args);
Connection conn=null;
PreparedStatement pst=null;
ResultSet rs=null;

try{
conn=ToolOfDB.getConnection();
pst=conn.prepareStatement(sql);

for(int i=0;i<args.legth;i++){

pst.setObject(i+1,args[i]);//设置值，数组从0开始，表从1开始，由于未知所以setObject
}
rs=pst.executeQuery();

if(rs.next()){
return <T> rs.getObject(1);
}
}catch(Exception e){
e.printStackTrace();
}finally{
ToolOfDB.releaseResource(null,preparedStatement,conn);//关闭连接，null是ResultSet
}

}

```    
##### 注意：Java类的属性：
(1)在JavaEE中，Java类的属性通过getter，setter来定义：get或set方法去掉get或set后，首写字母小写后即为Java类的属性
(2)而以前的那个属性，即成员变量，称之为字段。
(3)我们可以通过工具包beanutils以及conmmons-logging来setProperty()或getProperty()设置或者获取对象属性。

//导入beanutilshe commons-logging的jar包
Object obj=new Student();
BeanUtils.setProperty(obj,”name”,”zx”);//obj对象，name属性名，zx属性值
//获取属性值
Object value=BeanUtils.getProperty(obj,”name”);

          
#### 最终简化
1.所简化的方法

//获取结果集的ColumnLabel对应的List,列的集合
private List getColumnLabels(ResultSet rs)throws Exception{
List labels=new ArrayList<>();

ResultSetMetaData rsmd=rs.getMetaData();
for(int i=0;i<rsmd.getColumnCount();i++){
labels.add(rsmd.getColumnLabel(i+1));
}
return labels;
}

//处理结果集，得到Map的一个List,其中Map对应一条记录
public List<Map<String,Object>> handleResultSetToMapList(ResultSet resultSet)throws Exception{

List<Map<String,Object>> values=new ArrayList<>();

List columnLabels=getColumnLabels(rs);
Map<String,Object>map=null;
//处理rs，用while循环
while(rs.next()){

map=new HashMap<>();
for(String columnLabel:columnLabels){
Object value = resultSet.getObject(columnLabel);
map.put(columnLabel,value);
}
//把一条记录的一个Map对象放入2准备的List中
values.add(map);
}
}

/////
public List transfterMapListToBeanList(Class clazz,List<Map<String,Object>> values)throws Exception{
List result=new ArrayList<>();
T Bean=null;
if(values.size()>0){
for(Map<String,Object> map:values){
for(Map.Entry<String,Object> entry:map.entrySet()){

String fieldName=entry.getKey();
Object value=entry.getValue();
BeanUtils.setProperty(entity,fieldName,value);
}
result.add(bean);
}

}
return result;
}

2.最终DAO类（要导入1中的方法）

public class DAO{
// 1.INSERT、UPDATE、DELETE
public static void updata(String sql,Object … args){//Object数组,可变参数，来应对对象不同属性

Connection conn=null;
PreparedStatement pst=null;
ResultSet rs=null;

try{
conn=ToolOfDB.getConnection();
pst=conn.prepareStatement(sql);

for(int i=0;i<args.legth;i++){

preparedStatement.setObject(i+1;args[i]);//设置值，数组从0开始，表从1开始，由于未知所以setObject
}
preparedStatement.executeUpdata();//执行更新操作
}catch(Exception e){
e.printStackTrace();
}finally{
ToolOfDB.releaseResource(null,preparedStatement,conn);//关闭连接，null是ResultSet
}
}

//2.查询一条记录，返回对应对象
public T Select(Class c,String sql,Object … args){
//利用取多条的
List result=select(clazz,sql,args);
if(result.size()>0){
return result.get(0);
}
return null;
}catch(Exception e){
e.printStackTrace();
}finally{
ToolOfDB.releaseResource(rs,pst,conn);//关闭数据库连接
}
}

//3.查询多条记录，返回对应的对象的集合
public List select(Class clazz,String sql,Object … args){

List list=new ArrayList<>();
Connection conn=null;
PreparedStatement pst=null;
ResultSet rs=null;

try{
//1.获取结果集
conn=ToolOfDB.getConnection();//获取连接
pst=conn.prepareStatement(sql);//创建PreparedStatement对象

//赋值
for(int i=0;i<args.length;i++){
pst.setObject(i+1,args[i]);//为占位符赋值
}
rs=pst.executeQuery();//获取结果集

//2.准备一个List<Map<String,Object>>:
//键：存放列名 值：存放列的值。其中一个Map对象对应一条记录
List<Map<String,Object>> values=handleResultSetToMapList(rs)；

list=transfterMapListToBeanList(clazz,values);
}catch(Exception e){

e.printStackTrace();
}finally{

ToolOfDB.releaseResource(rs,pst,conn);//关闭数据库连接

}

return list;

}
//4.记录的某一个字段的值，或者一个统计值
public T getValue(String sql,Object … args);
Connection conn=null;
PreparedStatement pst=null;
ResultSet rs=null;

try{
conn=ToolOfDB.getConnection();
pst=conn.prepareStatement(sql);

for(int i=0;i<args.legth;i++){

pst.setObject(i+1,args[i]);//设置值，数组从0开始，表从1开始，由于未知所以setObject
}
rs=pst.executeQuery();

if(rs.next()){
return rs.getObject(1);
}
}catch(Exception e){
e.printStackTrace();
}finally{
ToolOfDB.releaseResource(null,preparedStatement,conn);//关闭连接，null是ResultSet
}

}

}

`

赏

Thank you,么么哒

支付宝

微信