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

所属分类: 软件编程 / java 阅读数: 25
收藏 0 赞 0 分享

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接口操作实例详解等,如有不足之处,欢迎留言指出,小编会及时回复大家并改正。感谢朋友们对脚本之家的支持!

更多精彩内容其他人还在看

Java的面向对象编程基本概念学习笔记整理

这篇文章主要介绍了Java的面向对象编程基本概念学习笔记整理,包括类与方法以及多态等支持面向对象语言中的重要特点,需要的朋友可以参考下
收藏 0 赞 0 分享

Eclipse下编写java程序突然不会自动生成R.java文件和包的解决办法

这篇文章主要介绍了Eclipse下编写java程序突然不会自动生成R.java文件和包的解决办法 的相关资料,需要的朋友可以参考下
收藏 0 赞 0 分享

基于Java实现杨辉三角 LeetCode Pascal's Triangle

这篇文章主要介绍了基于Java实现杨辉三角 LeetCode Pascal's Triangle的相关资料,需要的朋友可以参考下
收藏 0 赞 0 分享

Java中Spring获取bean方法小结

Spring是一个轻量级的控制反转(IoC)和面向切面(AOP)的容器框架,如何在程序中获取Spring配置的bean呢?下面通过本文给大家介绍Java中Spring获取bean方法小结,对spring获取bean方法相关知识感兴趣的朋友一起学习吧
收藏 0 赞 0 分享

如何计算Java对象占用了多少空间?

在Java中没有sizeof运算符,所以没办法知道一个对象到底占用了多大的空间,但是在分配对象的时候会有一些基本的规则,我们根据这些规则大致能判断出来对象大小,需要的朋友可以参考下
收藏 0 赞 0 分享

剖析Java中的事件处理与异常处理机制

这篇文章主要介绍了Java中的事件处理与异常处理机制,讲解Java是如何对事件或者异常作出响应以及定义异常的一些方法,需要的朋友可以参考下
收藏 0 赞 0 分享

详解Java的Struts2框架的结构及其数据转移方式

这篇文章主要介绍了详解Java的Struts2框架的结构及其数据转移方式,Struts框架是Java的SSH三大web开发框架之一,需要的朋友可以参考下
收藏 0 赞 0 分享

Java封装好的mail包发送电子邮件的类

本文给大家分享了2个java封装好的mail包发送电子邮件的类,并附上使用方法,小伙伴们可以根据自己的需求自由选择。
收藏 0 赞 0 分享

在Java的Struts中判断是否调用AJAX及用拦截器对其优化

这篇文章主要介绍了在Java的Struts中判断是否调用AJAX及用拦截器对其优化的方法,Struts框架是Java的SSH三大web开发框架之一,需要的朋友可以参考下
收藏 0 赞 0 分享

java多线程Future和Callable类示例分享

JAVA多线程实现方式主要有三种:继承Thread类、实现Runnable接口、使用ExecutorService、Callable、Future实现有返回结果的多线程。其中前两种方式线程执行完后都没有返回值,只有最后一种是带返回值的。今天我们就来研究下Future和Callab
收藏 0 赞 0 分享
查看更多