AWS MVC框架参考指南

DAO封装

AWS的DAO基于对JDBC的直接封装,与当今流行的Hibernate、iBATIS相比,去除了O/R映射关系的直接依赖,并借鉴了Apache DBUtils设计思想,只在需要的场景完成O/R Mapping。

采用AWS MVC的DAO优势如下:

  • 代码简单、直接,性能高
  • 无需拼写SQL语句,自动提供表查询、删除和更新操作
  • 屏蔽分页技术,自动适应不同数据库的物理分页
  • 提供自定义的RowMapper,将JDBC对象转换成业务实体对象(ModelBean
  • 提供操作复杂数据库操作的DBSql工具类
  • 所有操作受控于AWS SLA的质量和性能监控、告警

DaoObject类和方法介绍

Dao(Data Access Object)是一个设计模式,它是对数据访问的一种抽象。com.actionsoft.bpms.commons.mvc.dao.IDaoObject是AWS设计的数据库访问接口,DaoObject是实现了IDaoObject接口用于访问AWS本地数据库的抽象父类,该类对单主键数据库表的查询/更新/删除等常规操作提供了实现。

TestDao开发示例

  1. 继承ModelBean,实现业务实体对象
  2. 继承DaoObject,实现Dao处理对象

    public class TestDao extends DaoObject<TestModel> {
    
     public TestDao() {
     }
    
     /**
      * 插入一条测试记录
      */
     @Override
     public int insert(TestModel model) throws DataAccessException{
         model.setId(UUIDGener.getUUID());
         String sql = "INSERT INTO " + entityName() + "(ID,F1,F2)VALUES(:ID,:F1,:F2)";
         Map<String, Object> paraMap = new HashMap<>();
         paraMap.put("ID", model.getId());
         paraMap.put("F1", model.getF1());
         paraMap.put("F2", model.getF2());
         return DBSql.update(sql, paraMap);
     }
    
     /**
      * 更新一条测试记录
      */
     @Override
     public int update(TestModel model) throws DataAccessException{
         if (UtilString.isEmpty(model.getId())) {
             throw new DataAccessException("Method getId() Does Not Allow Empty!");
         }
         Map<String, Object> paraMap = new HashMap<>();
         paraMap.put("F1", model.getF1());
         paraMap.put("F2", model.getF2());
         // 不需要写sql,可调用基类封装的update方法
         return update(model.getId(), paraMap);
     }
    
     /**
      * 封装测试
      *
      * @param id
      * @param f2
      * @return
      */
     public int updateF2(String id, double f2) throws DataAccessException{
         Map<String, Object> paraMap = new HashMap<>();
         paraMap.put("F2", f2);
         return update(id, paraMap);
     }
    
     /**
      * 封装DBSql测试
      *
      * @return
      */
     public long count() {
         return DBSql.getLong("SELECT COUNT(ID) AS C FROM " + entityName(), "C");
     }
    
     /**
      * 封装DBSql测试
      *
      * @param f2
      * @return
      */
     public List<TestModel> queryByF1(String f1) {
         return query("F1=?", f1).orderBy("F2").desc().list();
     }
    
     /**
      * 该Dao实现的表名称
      */
     @Override
     public String entityName() {
         return "TEST_DAO";
     }
    
     /**
      * 构建该Dao从一条记录转换成对象的映射对象
      */
     @Override
     public RowMapper<TestModel> rowMapper() {
         return new Mapper();
     }
    
     /**
      * TestDao Mapper
      */
     private class Mapper implements RowMapper<TestModel> {
         public TestModel mapRow(ResultSet rset, int rowNum) throws SQLException {
             TestModel model = new TestModel();
             try {
                 model.setId(rset.getString("ID"));
                 model.setF1(rset.getString("F1"));
                 model.setF2(rset.getDouble("F2"));
             } catch (Exception e) {
                 e.printStackTrace();
             }
             return model;
         }
    
     }
    }
    

    异常处理

    当操作发生错误时,框架将抛出uncheck异常(如AWSDataAccessException),如果你的逻辑没有方案或需求去处理这个异常可以继续向外抛出。

当操作发生参数非法、执行非法等常见Dao处理逻辑场景时,建议抛出如下异常(详细请参见异常处理章节)

  • AWSIllegalArgumentException 非法参数异常造成错误的访问请求,对应400错误
  • AWSObjectNotFindException 资源未找到异常,对应404错误
  • AWSForbiddenException 访问被拒绝异常,对应403错误

默认编码字符集

utf-8

事务处理与资源释放

Spring MVC自动接管了事务与资源释放,这是非常棒的编程体验。为提高性能,目前AWS DAO框架未接管JDBC事务和自动完成Connection释放。

当你的程序需要事务支持时,可以遵循标准的JDBC编程规范,对Connection对象进行事务的开启、回滚或提交。

如果你的程序获得了一个新的Connection(如通过DBSql.open()),那么最终需要你的代码通过DBSql.close()释放这个连接。

物理表

建议使用AWS的BO模型设计和维护你的物理表结构,如果某些表必须由自己的sql创建(不推荐),那么需要遵循App开发规范中约定的表名前缀和sql安装/升级脚本规范。

数据库连接池

AWS MVC的数据库连接池使用了tomcat-jdbc,相关高级参数调优,可修改对应AWS安装目录bin/conf/db_pool.properties文件。

DBSql类和方法介绍

com.actionsoft.bpms.util.DBSql是和AWS数据库交互的工具类,它基于PreparedStatement实现了数据库的查询、插入、更新、批处理,DBSql一般用于DaoObject中。

  • get方法用于简单类型查询
  • query方法用于自定义复杂查询
  • update方法用于数据库的更新/插入/删除
  • batch方法用于批处理
  • open/close数据库连接/释放
  • 其它工具方法
// 查询单个字段
String value_a = DBSql.getString("select a from table_test where id=?", new Object[]{"id1"});

// 查询多个字段
Map<String,Object> value_map = DBSql.getMap("select a,b,c from table_test where id=?", "id1");

// 查询返回自定义对象,MyBean是java类
List<MyBean> list = DBSql.query("select a,b,c from table_test where id=?", new RowMapper<MyBean>() {

    @Override
    public MyBean mapRow(ResultSet rs, int rowNum) throws SQLException {
        MyBean mybean = new MyBean();
        mybean.setA(rs.getString("a"));
        return mybean;
    }

}, "id1");

详细请参见aws-api-docDBSql



Seven
 010-62962343-690
 liujx@actionsoft.com.cn
感谢您对该文档的关注!如果您对当前页面内容有疑问或好的建议,请与我联系。如果您需要解答相关技术问题请登录AWS客户成功社区