欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

使用JDBC實(shí)現(xiàn)數(shù)據(jù)訪問(wèn)對(duì)象層(DAO)代碼示例

 更新時(shí)間:2017年10月18日 11:12:58   作者:少帥java  
這篇文章主要介紹了使用JDBC實(shí)現(xiàn)數(shù)據(jù)訪問(wèn)對(duì)象層(DAO)代碼示例,具有一定參考價(jià)值,需要的朋友可以了解下。

JAVA是面向?qū)ο蟮恼Z(yǔ)言,開(kāi)發(fā)者在操作數(shù)據(jù)的時(shí)候,通常更習(xí)慣面對(duì)一個(gè)特定類型的對(duì)象,如一個(gè)用戶就是一個(gè)User類的對(duì)象。DAO層需要做的,就是為上層提供充分的對(duì)象支持,讓上層再也看不到具體的數(shù)據(jù),而是一個(gè)個(gè)活生生的對(duì)象。

增加,刪除,查詢和修改操作是DAO需要做的最基本的4項(xiàng)操作。查詢一般需要提供遍歷查詢和id查詢,對(duì)于遍歷查詢,DAO需要提供User泛型的list對(duì)象,對(duì)于id查詢則提供已經(jīng)裝配好數(shù)據(jù)的User對(duì)象,至于增加和修改操作,上層一般會(huì)提供一個(gè)User對(duì)象,DAO把User對(duì)象中的數(shù)據(jù)使用Insert語(yǔ)句插入到表格中。刪除操作則只需提供一個(gè)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獲取用戶對(duì)象
 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()){
    //如果存在,則直接構(gòu)建并返回用戶對(duì)象
    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();
   //循環(huán)添加用戶對(duì)象
   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;
 }
 //修改用戶數(shù)據(jù)
 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;
   }
  }
  //刪除用戶數(shù)據(jù)
 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;
   }
  }
  //插入用戶數(shù)據(jù)
  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;
   }
  }
 }
 }

總結(jié)

以上就是本文關(guān)于使用JDBC實(shí)現(xiàn)數(shù)據(jù)訪問(wèn)對(duì)象層(DAO)代碼示例的全部?jī)?nèi)容,希望對(duì)大家有所幫助。感興趣的朋友可以繼續(xù)參閱:JDBC常用接口總結(jié)、BaseJDBC和CRUDDAO的寫法實(shí)例代碼JDBC中resutset接口操作實(shí)例詳解等,如有不足之處,歡迎留言指出,小編會(huì)及時(shí)回復(fù)大家并改正。感謝朋友們對(duì)腳本之家的支持!

相關(guān)文章

最新評(píng)論