使用JDBC实现数据访问对象层（DAO）代码示例

java是面向对象的语言，开发者在操作数据的时候，通常更习惯面对一个特定类型的对象，如一个用户就是一个user类的对象。dao层需要做的，就是为上层提供充分的对象支持，让上层再也看不到具体的数据，而是一个个活生生的对象。

增加，删除，查询和修改操作是dao需要做的最基本的4项操作。查询一般需要提供遍历查询和id查询，对于遍历查询，dao需要提供user泛型的list对象，对于id查询则提供已经装配好数据的user对象，至于增加和修改操作，上层一般会提供一个user对象，dao把user对象中的数据使用insert语句插入到表格中。删除操作则只需提供一个id即可

class user{
 private long id;
 private string name;
 private string gender;
 public user(){
 super();
 }
 public user(long id,string name,string gender){
 super();
 this.id = id;
 this.name = name;
 this.gender = gender;
 }
 //get,set方法
 }
 //dao类
 public class jdbcdao{
 static{
  try{
   class.forname("com.mysql.jdbc.driver");
  }catch(exception e){
  e.printstacktrace();
   }
  }
 private connection getconn(){
  try{
   return drivermanager.getconnection("jdbc:mysql://localhost:3306:xe","root","password");
   }catch(exception e){
   e.printstacktrace();
   }
  }
  return null;
 }
 private void release(resultset rs,statement ps,connection conn){
  if(rs!=null){
   try{
    rs.close();
   }catch(exception e){
    e.printstacktrace();
   }
  }
  if(ps!=null){
   try{
    ps.close();
   }catch(exception e){
    e.printstacktrace();
   }
  }
  if(conn!=null){
   try{
    conn.close();
   }catch(exception e){
    e.printstacktrace();
   }
  }
 }
 //用id获取用户对象
 public user getuserbyid(long id){
  resultset rs = null;
  preparedstatement ps = null;
  connection conn = null;
  string sql = "select * from user where id = ?";
  try{
   conn = this.getconnection();
   ps = conn.preparestatement(sql);
   ps.setlong(1,id);
   rs = ps.executequery();
   if(rs.next()){
    //如果存在，则直接构建并返回用户对象
    user user = new user(rs.getlong("id"),rs.getstring("name"),rs.getstring("gender"));
    return user;
   }
  }catch(exception e){
   e.printstacktrace();
  }finally{
   this.release(rs,ps,conn);
  }
  return null;
 }
 //查询所有用户
 public list<user> getallusers(){
  list<user> list = new arraylist<user>();
  resultset rs = null;
  preparedstatement ps = null;
  connection conn = null;
  string sql = "select * from user ";
  try{
   conn = this.getconnection();
   ps = conn.preparestatement(sql);
   rs = ps.executequery();
   //循环添加用户对象
   while(rs.next()){
    user user = new user(rs.getlong("id"),rs.getstring("name"),rs.getstring("gender"));
    list.add(user);
   }
  }catch(exception e){
   e.printstacktrace();
  }finally{
   this.release(rs,ps,conn);
  }
  return list;
 }
 //修改用户数据
 public user updateuser(user user){
  preparedstatement ps = null;
  connection conn = null;
  string sql = "update user set id =?,name=?,gender=?";
 try{
   conn = this.getconnection();
   conn.setautocommit(false);
   ps = conn.preparestatement(sql);
   ps.setlong(1,user.getid());
   ps.setstring(2,user.getname());
   ps.setstring(3,user.getgender());
   int rst = ps.executeupdate();
   if(rst>0){
    return new user(user.getid(),user.getname(),user.getgender());
   }
   conn.commit();
  }catch(exception e){
   e.printstacktrace();
   try{
    conn.rollback();
   }catch(exception e1){
    e1.printstacktrace();
   }
  }finally{
   this.release(null,ps,conn);
  }
  return null;
   }
  }
  //删除用户数据
 public boolean deleteuser(long id){
  preparedstatement ps = null;
  connection conn = null;
  string sql = "delete from user where id =?;
 try{
   conn = this.getconnection();
   conn.setautocommit(false);
   ps = conn.preparestatement(sql);
   ps.setlong(1,user.getid());
   ps.setstring(2,user.getname());
   ps.setstring(3,user.getgender());
   int rst = ps.executeupdate();
   if(rst>0){
    return user;
   }
   conn.commit();
  }catch(exception e){
   e.printstacktrace();
   try{
    conn.rollback();
   }catch(exception e1){
    e1.printstacktrace();
   }
  }finally{
   this.release(null,ps,conn);
  }
  return null;
   }
  }
  //插入用户数据
  public user insertuser(user user){
  preparedstatement ps = null;
  connection conn = null;
  string sql = "insert into user values(?,?,?)";
 try{
   conn = this.getconnection();
   conn.setautocommit(false);
   ps = conn.preparestatement(sql);
   ps.setlong(1,user.getid());
   ps.setstring(2,user.getname());
   ps.setstring(3,user.getgender());
   int rst = ps.executeupdate();
   if(rst>0){
    return user;
   }
   conn.commit();
  }catch(exception e){
   e.printstacktrace();
   try{
    conn.rollback();
   }catch(exception e1){
    e1.printstacktrace();
   }
  }finally{
   this.release(null,ps,conn);
  }
  return null;
   }
  }
 }
 }

总结

以上就是本文关于使用jdbc实现数据访问对象层（dao）代码示例的全部内容，希望对大家有所帮助。感兴趣的朋友可以继续参阅：jdbc常用接口总结、basejdbc和cruddao的写法实例代码、jdbc中resutset接口操作实例详解等，如有不足之处，欢迎留言指出，小编会及时回复大家并改正。感谢朋友们对的支持！