即日起在codingBlog上分享您的技术经验即可获得积分,积分可兑换现金哦。

DAO设计模式

编程语言 baidu_32045201 78℃ 0评论
本文目录
[隐藏]

本文完全根据我对DAO设计模式的理解程度完成,在未来不断地学习中,我也会不断更新这篇文章,如果你对文章内容有建议欢迎评论!

DAO(Data Access Object,数据访问接口)设计模式是J2EE(Java2平台企业版)的核心模式

这种设计模式很好的将底层数据访问与业务逻辑实现高度分离,这样便于开发人员专注于开发所需的功能实现代码,而不需要过多地考虑上下层交互的问题,很好地降低了出bug的几率,提高了开发效率


这里写图片描述

1.一个典型的DAO实现有下列几个组件:

  • 一个DAO工厂类
  • 一个DAO接口
  • 一个实现DAO接口的具体类
  • 数据传输对象(DTO)

废话不多说,我们直接上代码,通过一个例子来使大家对DAO设计模式有个了解


这里写图片描述

2.现在,假设我们需要搭建一个简单博客

3.那么,我们需要考虑一个博客需要哪些必要的元素?


最基本的元素一定是用户(User)文章(Article)评论(Comment)

4.好,现在假设我们的博客简单到只有这么几个元素


这里写图片描述

5.那么,根据那四个基本组件,首先我们来看看什么是DAO工厂类?

6.其实这个类就是像是一个DAO类菜单,里面有各种DAO类供你选择

public class DAOFactory{
    public static UserDAO getUserDAO()
        throws Exception{
            return UserDAOImpl(); //获取实现类
        }
    public static ArticleDAO getArticleDAO()
        throws Exception{
            return UserDAOImpl(); //获取实现类
        }
    public static CommentDAO getCommentDAO()
        throws Exception{
            return UserDAOImpl(); //获取实现类
        }
}

7.好, 接下来看看DAO接口怎么写?


在写每个元素的DAO接口之前,我们需要先写一个BaseDAO类


我们在这个类中来写对数据库的CRUD(增删改查)操作,这样可以简化我们后面写DAO接口的实现类

对于BaseDAO的实现大家可以不必细看,只需要知道它的作用是什么,在需要的时候自己实现即可,它只是起到一个简化代码的作用


ps.你即将要翻过一长串代码,请耐心享受这一过程

public class BaseDAO {

    public boolean insert(String sql, Object...args){

        Connection connection = null;
        PreparedStatement preparedStatement = null;

        try {
            connection = DBUtil.getConnection();
            preparedStatement = connection.prepareStatement(sql, Statement.RETURN_GENERATED_KEYS);
            if(args != null){
                for(int i = 0; i < args.length; i++){
                    preparedStatement.setObject(i + 1, args[i]);
                }
            }
            preparedStatement.executeUpdate();
        } catch (Exception e) {
            e.printStackTrace();
            System.out.println("插入失败");
            return false;
        } finally{
            DBUtil.release(preparedStatement, connection);
        }

        return true;
    }

    public boolean update(String sql, Object... args) {
        Connection connection = null;
        PreparedStatement preparedStatement = null;

        try {
            connection = DBUtil.getConnection();
            preparedStatement = connection.prepareStatement(sql);

            for (int i = 0; i < args.length; i++) {
                preparedStatement.setObject(i + 1, args[i]);
            }

            preparedStatement.executeUpdate();
        } catch (Exception e) {
            e.printStackTrace();
            return false;
        } finally {
            DBUtil.release(null, preparedStatement, connection);
        }

        return true;
    }

    @SuppressWarnings("hiding")
    public  T get(Class clazz, String sql, Object... args) {
        List result = getForList(clazz, sql, args);
        if(result.size() > 0){
            return result.get(0);
        }

        return null;
    }

    @SuppressWarnings("hiding")
    public  List getForList(Class clazz, 
            String sql, Object... args) {

        List list = new ArrayList();

        Connection connection = null;
        PreparedStatement preparedStatement = null;
        ResultSet resultSet = null;

        try {
            connection = DBUtil.getConnection();
            preparedStatement = connection.prepareStatement(sql);

            for (int i = 0; i < args.length; i++) {
                preparedStatement.setObject(i + 1, args[i]);
            }

            resultSet = preparedStatement.executeQuery();

            List> values = 
                    handleResultSetToMapList(resultSet);

            list = transfterMapListToBeanList(clazz, values);

        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            DBUtil.release(resultSet, preparedStatement, connection);
        }

        return list;
    }

    @SuppressWarnings("hiding")
    public  List transfterMapListToBeanList(Class clazz,
            List> values) throws InstantiationException,
            IllegalAccessException, InvocationTargetException {

        List result = new ArrayList();

        T bean = null;

        if (values.size() > 0) {
            for (Map m : values) {
                bean = clazz.newInstance();
                for (Map.Entry entry : m.entrySet()) {
                    String propertyName = entry.getKey();
                    Object value = entry.getValue();

                    BeanUtils.setProperty(bean, propertyName, value);
                }
                result.add(bean);
            }
        }

        return result;
    }

    public List> handleResultSetToMapList(
            ResultSet resultSet) throws SQLException {

        List> values = new ArrayList>();

        List columnLabels = getColumnLabels(resultSet);
        Map map = null;

        while (resultSet.next()) {
            map = new HashMap();

            for (String columnLabel : columnLabels) {
                Object value = resultSet.getObject(columnLabel);
                map.put(columnLabel, value);
            }

            values.add(map);
        }
        return values;
    }

    private List getColumnLabels(ResultSet rs) throws SQLException {
        List labels = new ArrayList();

        ResultSetMetaData rsmd = rs.getMetaData();
        for (int i = 0; i < rsmd.getColumnCount(); i++) {
            labels.add(rsmd.getColumnLabel(i + 1));
        }

        return labels;
    }

    @SuppressWarnings("unchecked")
    public  E getForValue(String sql, Object... args) {

        Connection connection = null;
        PreparedStatement preparedStatement = null;
        ResultSet resultSet = null;

        try {
            connection = DBUtil.getConnection();
            preparedStatement = connection.prepareStatement(sql);

            for (int i = 0; i < args.length; i++) {
                preparedStatement.setObject(i + 1, args[i]);
            }

            resultSet = preparedStatement.executeQuery();

            if(resultSet.next()){
                return (E) resultSet.getObject(1);
            }
        } catch(Exception ex){
            ex.printStackTrace();
        } finally{
            DBUtil.release(resultSet, preparedStatement, connection);
        }

        return null;
    }

}

这里写图片描述

7.1.哪位哥们儿知道怎么让代码折叠起来请评论!在线等!

8.好了,接下来就是各个元素的DAO接口


你希望对这个元素做哪些操作,你就将哪些方法写进去

/*
 * 我希望能够对User基本的增删改查,那就写这四个方法
 * 如果你还希望有其他特殊的操作,也可以进去
 * 例如:queryByName(name)根据名字查找,等等
 * 接口中所有方法默认为public abstract可以不用写出
 */
public interface UserDAO{
    boolean addUser(String name, String password, String email);
    boolean deleteUser(String email);
    boolean alterUser(String name, String password, String email);
    User queryUser(String email);
}

9.好的,我就写这么一个,不是因为我懒,而是大家那么聪明,一点就通,其他的一定已经知道怎么写了


9.1.去你妈的.jpg

10.那么,接下来自然就是写实现这些DAO接口的DAOImpl实现类

/*
 * 实现类继承BaseDAO
 */
public class UserDAOImpl extends BaseDAO<User>
     implements UserDAO {
     //sql语句中的'?'是因为BaseDAO使用了prepareStatement
     //它以'?'为占位符,用来接收参数
     @Override
     public boolean addUser(String name, String password, String email){
         String sql = "insert into User(name, password, email) values(?, ?, ?)";
         return insert(sql, name, password, email);
         //insert()来自BaseDAO
         //看看,这就是BaseDAO好处的体现,就这么简单的两行就结束了
     }
     @Override
     public boolean deleteUser(String email){
         String sql = "delete from User where email=?";
         return update(sql, email);
     }
     @Override
     public boolean alterUser(String name, String password, String email){
         String sql = "update User name=?,password=?,email=? where email=?";
         return update(sql, name, password, email);
     }
     @Override
     public User queryUser(String email){
         String sql = "select * from User where email=?";
         return get(sql, email);
    }
}

11.DAO设计模式的核心就是以上那些,关于数据传输对象DTO(Data Transfer Object)它是用来在表现层与应用层之间传输数据的,它会根据表现层的需求来对数据进行打包发送,具体的使用我不是很熟悉,日后再更新


这里写图片描述

转载请注明:CodingBlog » DAO设计模式

喜欢 (0)or分享 (0)
发表我的评论
取消评论

*

表情