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

(0)

相关推荐

  • 基于JDBC封装的BaseDao(实例代码)

    最近闲暇时萌发写一写dao的封装的例子,就将以前写的整理一下. public class BaseDao<T> { Connection conn; PreparedStatement st; ResultSet rs; JdbcUtil jdbcUtil = new JdbcUtil(); int result = 0; private Class<T> persistentClass; @SuppressWarnings("unchecked") publi

  • BaseJDBC和CRUDDAO的写法实例代码

    我们首先看下BASEJDBC的写法实例: package com.dao; import java.sql.Connection; import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; import com.mysql.jdbc.Driver; public class BaseJDBC { // 表示你要操作的是哪种类型

  • spring的jdbctemplate的crud的基类dao

    复制代码 代码如下: import java.util.List; /*** * 基本接口 *  * @author xyq * @param <T> *  */public interface BaseDaoInf<T> { /***  * 查询接口  *   * @return  */ public List<T> find(String sql, Object[] parameters, Class<T> cl); /***  *  添加,更新,删除接

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

    JAVA是面向对象的语言,开发者在操作数据的时候,通常更习惯面对一个特定类型的对象,如一个用户就是一个User类的对象.DAO层需要做的,就是为上层提供充分的对象支持,让上层再也看不到具体的数据,而是一个个活生生的对象. 增加,删除,查询和修改操作是DAO需要做的最基本的4项操作.查询一般需要提供遍历查询和id查询,对于遍历查询,DAO需要提供User泛型的list对象,对于id查询则提供已经装配好数据的User对象,至于增加和修改操作,上层一般会提供一个User对象,DAO把User对象中的数

  • Yii学习总结之数据访问对象 (DAO)

    Yii提供了强大的数据库编程支持.Yii数据访问对象(DAO)建立在PHP的数据对象(PDO)extension上,使得在一个单一的统一的接口可以访问不同的数据库管理系统(DBMS).使用Yii的DAO开发的应用程序可以很容易地切换使用不同的数据库管理系统,而不需要修改数据访问代码. 数据访问对象(DAO) 对访问存储在不同数据库管理系统(DBMS)中的数据提供了一个通用的API. 因此,在将底层 DBMS 更换为另一个时,无需修改使用了 DAO 访问数据的代码. Yii DAO 基于 PHP

  • php设计模式 DAO(数据访问对象模式)

    复制代码 代码如下: <?php /** * 数据访问对象(Data Access Object) 示例 * * @create_date: 2010-01-04 */ class BaseDAO { var $_db = null; var $_table = null; function BaseDAO($config) { $this->_db = new MysqlDB(); // 这里的不能进行操作 } /** * 获取处理 * * @param array $filter // 过

  • Java的Spring框架中DAO数据访问对象的使用示例

    Spring DAO之JDBC   Spring提供的DAO(数据访问对象)支持主要的目的是便于以标准的方式使用不同的数据访问技术, 如JDBC,Hibernate或者JDO等.它不仅可以让你方便地在这些持久化技术间切换, 而且让你在编码的时候不用考虑处理各种技术中特定的异常. 为了便于以一种一致的方式使用各种数据访问技术,如JDBC.JDO和Hibernate, Spring提供了一套抽象DAO类供你扩展.这些抽象类提供了一些方法,通过它们你可以 获得与你当前使用的数据访问技术相关的数据源和其

  • PHP设计模式之数据访问对象模式(DAO)原理与用法实例分析

    本文实例讲述了PHP设计模式之数据访问对象模式(DAO)原理与用法.分享给大家供大家参考,具体如下: 这个数据访问对象模式主要就是描述了如何创建透明访问数据源的对象,这种设计模式对于同时学过PHP和MySQL的人来说,是一个全新的和令人兴奋的概念,并且这种设计模式的目的就是为了解决重复与数据源抽象化这两种特定的问题. 我们可以先创建一个数据访问对象设计模式的对象,这个数据访问对象封装了创建sQL调用.减少实例创建的复杂性和重复以及更新进程的智能方式,并且,这个数据访问对象的使用者不会知道实际使用

  • JS设计模式之数据访问对象模式的实例讲解

    引言 HTML5 提供了两种在客户端存储数据的新方法:localStorage.sessionStorage,他们是Web Storage API 提供的两种存储机制,区别在于前者属于永久性存储,而后者是局限于当前窗口的数据传递,存储在其中的数据会在当前会话结束时被删除.localStorage.sessionStorage的具体内容在这里就不多做介绍了,我们主要探讨一下在实际开发中怎样合理使用他们. 问题 大部分网站会将一些数据(如:用户Token)存储在前端,用来实现页面间的传值,对于一些大

  • PHP中关于PDO数据访问抽象层的功能操作实例

    PDO:数据访问抽象层 具有三大特点: 1.可以访问其它数据库  所有数据库都可以 2.具有事务功能 3.带有预处理语句功能(防止SQL注入攻击) 实例操作代码如下: <?php //1.造PDO对象 $dsn ="mysql:dbname=mydb;host=localhost";//数据库类型:dbname=数据库名称;host=链接的ip或本机 $pdo =new PDO($dsn,"root","root");//$dsn,帐号,密

  • SpringBoot+MyBatis简单数据访问应用的实例代码

    因为实习用的是MyBatis框架,所以写一篇关于SpringBoot整合MyBatis框架的总结. 一,Pom文件 <?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:

  • Java编程通过list接口实现数据的增删改查代码示例

    List接口常用的实现ArrayList. 常用方法:add(Object obj)  增加一个元素                      add(int index,Object obj) 在指定索引位置添加元素                      remove(int index) 删除指定位置的元素                      remove(Objiect)  从列表中删除元素                      set(index,Object) 修改指定位

  • Java的MyBatis+Spring框架中使用数据访问对象DAO模式的方法

    SqlSessionTemplate SqlSessionTemplate是MyBatis-Spring的核心.这个类负责管理MyBatis的SqlSession,调用MyBatis的SQL方法,翻译异常.SqlSessionTemplate是线程安全的,可以被多个DAO所共享使用. 当调用SQL方法时,包含从映射器getMapper()方法返回的方法,SqlSessionTemplate将会保证使用的SqlSession是和当前Spring的事务相关的.此外,它管理session的生命周期,包

随机推荐