Java开发———DAO设计模式及优化

2019-11-14 09:46:36

字体：大中小

来源：转载

供稿：网友

什么是DAO？

DAO是Data access Object 数据访问接口，顾名思义：就是与数据库打交道。夹在业务逻辑与数据资源的中间。

DAO模式有哪些？

DAO模式实际上是两个模式的组合既Data Accessor 模式和Active Domain Object模式。

它们的意义和作用

Data Accessor模式实现了数据访问和业务逻辑的分离，Active Domain Object 模式实现了业务数据的对象化封装。以javaWeb中对数据库的为例： 首先预先准备一个工具类DBUtils.class

public class DBUtils { public final static String URL="jdbc:MySQL://localhost:3306/mydb"; public final static String USERNAME="root";//用户名 public final static String PASSWord="*****";//密码 public final static String DRIVER="com.mysql.jdbc.Driver"; PRivate DBUtils(){ } //使用静态快加载驱动 static{ try { Class.forName(DRIVER); } catch (ClassNotFoundException e) { // TODO Auto-generated catch block e.printStackTrace(); } } //定义一个获取数据库连接的方法 public static Connection getconnection() { Connection connection=null; try { connection=DriverManager.getConnection(URL, USERNAME, PASSWORD); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); System.out.println("获取连接失败"); } return connection; } public static void close(ResultSet rs,Statement statement,Connection conn){ if (rs!=null) try { rs.close(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } if (statement!=null) { try { statement.close(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } } if (conn!=null) { try { conn.close(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } } }}

接下来我们要来实现Dao模式

一个典型的DAO模式有以下几个组件：一个接口，数据传递对象或者领域模型，先建立一个类 person.class 数据模型类

public class Person { private int id; private String name; private int age; private String description; public int getId() { return id; } public void setId(int id) { this.id = id; } public String getName() { return name; } public void setName(String name) { this.name = name; } public int getAge() { return age; } public void setAge(int age) { this.age = age; } public String getDescription() { return description; } public void setDescription(String description) { this.description = description; } public Person( String name, int age, String description) { super(); this.name = name; this.age = age; this.description = description; } public Person() { super(); // TODO Auto-generated constructor stub } @Override public String toString() { return "person [id=" + id + ", name=" + name + ", age=" + age + ", description=" + description + "]"; }

声明一个接口，数据操作类 PersonDao.class

import java.sql.SQLException; import java.util.List; import com.vince.domain.Person; public interface PersonDao { public void add(Person p) throws SQLException;//这里需要抛出异常；否则在下面操作的时候会报错！！！！ public void update(Person p) throws SQLException; public void delete(int id) throws SQLException; public Person findById(int id) throws SQLException; public List<Person> findAll() throws SQLException; }

编写接口的实现类 PersonDanImpl.class

import java.sql.Connection;import java.sql.PreparedStatement;import java.sql.ResultSet;import java.sql.SQLException;import java.util.ArrayList;import java.util.List;import com.util.db.DBUtils;import com.util.db.JdbcTemplete;import com.vince.base.ResultSetHandler;import com.vince.dao.PersonDao;import com.vince.domain.Person;public class PersonDaoImpl implements PersonDao {private JdbcTemplete jdbcTemolete; public PersonDaoImpl() { jdbcTemolete=new JdbcTemplete();} @Override public void add(Person p) throws SQLException { Connection connection=null; PreparedStatement ps=null; String sql="insert into person(name,age,description)values(?,?,?)"; try { connection=DBUtils.getconnection(); ps=connection.prepareStatement(sql); ps.setString(1, p.getName()); ps.setInt(2, p.getAge()); ps.setString(3, p.getDescription()); ps.executeUpdate(); } catch (SQLException e) { throw new SQLException("数据库添加异常"); }finally { DBUtils.close(null, ps, connection); } }@Override public void update(Person p) throws SQLException { Connection connection=null; PreparedStatement ps=null; String sql="update person set name=?,age=?,description=? where id=?"; try { connection=DBUtils.getconnection(); ps=connection.prepareStatement(sql); ps.setString(1, p.getName()); ps.setInt(2, p.getAge()); ps.setString(3, p.getDescription()); ps.setInt(4, p.getId()); ps.executeUpdate(); } catch (SQLException e) { throw new SQLException("数据库更新异常"); }finally { DBUtils.close(null, ps, connection); } } @Override public void delete(int id) throws SQLException { Connection connection=null; PreparedStatement ps=null; String sql="delete from person where id=?"; try { connection=DBUtils.getconnection(); ps.setInt(1,id); ps.executeUpdate(); } catch (SQLException e) { e.printStackTrace(); throw new SQLException("数据库删除异常"); }finally { DBUtils.close(null, ps, connection); } }@Override public List<Person> findAll() throws SQLException { Connection connection=null; PreparedStatement ps=null; ResultSet rs=null; Person p=null; List<Person> persons=new ArrayList<Person>(); String sql="selectid,name,age,description from person"; try { connection=DBUtils.getconnection(); ps=connection.prepareStatement(sql); rs=ps.executeQuery(); while(rs.next()){ p=new Person(); p.setId(rs.getInt(1)); p.setName(rs.getString(2)); p.setAge(rs.getInt(3)); p.setDescription(rs.getString(4)); persons.add(p); } } catch (SQLException e) { // TODO: handle exception throw new SQLException("查询所有数据异常"); }finally { DBUtils.close(rs, ps, connection); } return persons; }}

上面就是DAO模式的实现过程。这种DAO设计模式主要是可以让我们写的代码，更加简洁，冗余小，实现了软件设计设计模式中的一条规则：高内聚，低耦合；下面呢？我们来思考能不能继续优化DAO设计模式的实现，

新建一个类，JdbcTemplete .class 来再做个一个提炼抽象； import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import com.vince.base.ResultSetHandler; public class JdbcTemplete { public int update(String sql,Object ...args){ Connection connection=null; PreparedStatement ps=null; try { connection=DBUtils.getconnection(); ps=connection.prepareStatement(sql); if (args!=null) { for(int i=0;i<args.length;i++){ ps.setObject(i+1, args[i]); } } return ps.executeUpdate(); } catch (SQLException e) { e.printStackTrace(); return 0; }finally { DBUtils.close(null, ps, connection); } } public Object query(String sql,ResultSetHandler handler,Object...args){ Connection connection=null; PreparedStatement ps=null; ResultSet rs=null; try { connection=DBUtils.getconnection(); connection.prepareStatement(sql); if (args!=null) { for(int i=0;i<args.length;i++){ ps.setObject(i+1, args[i]); } } rs=ps.executeQuery(); return handler.doHandler(rs); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); return null; } } } 所有类的父类是Objects 有多个参数，所有我们使用Object …args；接下来在PersonDaoImpl.class类中，我们就可以使用我们提取处在的抽象类了嘻嘻~ 是不是代码简单多了~~ 向对于数据库的增删更新的操作都可以使用类似的方法，

@Override public void add(Person p) throws SQLException { String sql="insert into person(name,age,description)values(?,?,?)"; jdbcTemolete.update(sql, p.getName(),p.getDescription()); }

对于一个需要从数据库查询的操作，在查询的操作，需要用道 ResultSet这个方法的我们这里定义一个接口ResultSetHandler.class；

import java.sql.ResultSet;import java.sql.SQLException;public interface ResultSetHandler { public Object doHandler(ResultSet rs)throws SQLException;}

**在JdbcTemplete.class中的query这个方法中就需要用的这个接口在PersonDaoImpl.class中这个查询方法，我们就可以这样写了**

@Override public Person findById(final int id) throws SQLException { String sql="select name,age,description from person where id=?"; return (Person) jdbcTemolete.query(sql, new ResultSetHandler() { @Override public Object doHandler(ResultSet rs)throws SQLException { Person p=null; if(rs.next()){ p=new Person(); p.setId(id); p.setName(rs.getString(1)); p.setAge(rs.getInt(2)); p.setDescription(rs.getString(3)); } return p; } },id); }

最后就是弄一个main 方法来使用我们定义好对数据操作的方法喽

有什么错误需要改正欢迎指出，共同学习 有什么错误需要改正欢迎指出，共同学习

上一篇：The Linux Programming Interface 笔记之malloc和free的实现

下一篇：【bzoj2697】特技飞行