fastser-dal

本着不重复造轮子的原则，基于mybatis、spring jdbc、hibernate等ORM的通用数据该问层，支持基于datasource的读写分离、主备自动切换和故障转移，支持简单的负载均衡。

功能概述

• 基于mybatis、spring jdbc、hibernate等各大orm框架实现通用dal层功能，并可以与已有项目完全兼容。
• 实现dal层cache
• 实现基于多数据源(datasource)的读写分离、主备切换、故障转移、恢复检测和负载均衡
• 使用该组件必须遵循以下规则：默认字段名称与数据库表字段一致，每张表有名称为id的唯一标识字段

与spring集成

动态数据源可以自动处理故障转移和恢复检测，读写分离时多个读库采用随机获取。缓存可以自定义实现，可以统一开启或关闭，方便在开发环境使用。

    <!-- 缓存默认实现，可以自定义实现 -->      <bean id="cacheManager" class="org.fastser.dal.cache.support.SimpleCacheManager"></bean>      <!-- 配置缓存 -->      <bean id="cacheManager" class="org.fastser.dal.cache.support.SimpleCacheManager">          <property name="cache" ref="dalRedisCache"></property>      </bean>      <!-- 配置数据源解析器 -->      <bean id="resolveDatabase" class="org.fastser.dal.descriptor.db.impl.SimpleResolveDatabase">          <property name="dataSource" ref="dataSource" />          <property name="cacheManager" ref="cacheManager" />      </bean>        <!-- spring jdbc实现配置 -->      <bean id="commonJdbcSupport" class="org.fastser.dal.spring.jdbc.CommonJdbcSupport">          <property name="dataSource" ref="dataSource" />      </bean>          <bean id="baseDAL" class="org.fastser.dal.spring.jdbc.SpringJDBCDAL">          <property name="cacheManager" ref="cacheManager" />          <property name="commonJdbcSupport" ref="commonJdbcSupport" />          <property name="resolveDatabase" ref="resolveDatabase" />          <!-- 可选，配置全局不使用缓存，默认为true -->          <property name="useCache" value="false" />          <!-- 可选，乐观锁，如果配置该项并且表中存在字段名为ver的字段，则该表可使用乐观锁机制 -->          <property name="version" value="ver" />      </bean>        <!-- mybatis实现配置 -->      <bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">          <property name="dataSource" ref="dataSource" />        </bean>      <bean id="commonMapper" class="org.mybatis.spring.mapper.MapperFactoryBean">            <property name="sqlSessionFactory" ref="sqlSessionFactory" />            <property name="mapperInterface" value="org.fastser.dal.mybatis.CommonMapper" />        </bean>      <bean id="baseDAL" class="org.fastser.dal.mybatis.MybatisDAL">          <property name="cacheManager" ref="cacheManager" />          <property name="commonMapper" ref="commonMapper" />          <property name="resolveDatabase" ref="resolveDatabase" />          <!-- 可选，配置全局不使用缓存，默认为true -->          <property name="useCache" value="false" />          <!-- 可选，乐观锁，如果配置该项并且表中存在字段名为ver的字段，则该表可使用乐观锁机制 -->          <property name="version" value="ver" />      </bean>        <!-- hibernate实现配置 -->      待实现        <!--可选，动态数据源配置 -->      <bean id="dynamicDataSource" class="org.fastser.dal.datasource.DynamicDataSource">          <!-- 从数据库配置，用于读操作，目前为随机取一个 -->          <property name="slaveDataSources">              <map key-type="java.lang.String">                  <entry key="readDataSourceOne" value-ref="dataSource3"/>                  <entry key="readDataSourceTwo" value-ref="dataSource4"/>              </map>          </property>          <!-- 主数据库配置 -->          <property name="masterDataSource" ref="dataSource1" />          <!-- 备数据库配置 -->          <property name="standbyDataSource" ref="dataSource2" />      </bean>

使用示例

1 现有方法

• 列表查询

  fields需要显示的字段，queryCriteria查询条件，seconds缓存时间

  QueryResult selectByCriteria(List<String> fields, QueryCriteria queryCriteria);    QueryResult selectByCriteria(String[] fields, QueryCriteria queryCriteria);    QueryResult selectByCriteria(List<String> fields, QueryCriteria queryCriteria, int seconds);    QueryResult selectByCriteria(String[] fields, QueryCriteria queryCriteria, int seconds);    QueryResult selectByCriteria(QueryCriteria queryCriteria);    QueryResult selectByCriteria(QueryCriteria queryCriteria, int seconds);    QueryResult selectPageByCriteria(List<String> fields, QueryCriteria queryCriteria);    QueryResult selectPageByCriteria(String[] fields, QueryCriteria queryCriteria);    QueryResult selectPageByCriteria(List<String> fields, QueryCriteria queryCriteria, int seconds);    QueryResult selectPageByCriteria(String[] fields, QueryCriteria queryCriteria, int seconds);    QueryResult selectPageByCriteria(QueryCriteria queryCriteria);    QueryResult selectPageByCriteria(QueryCriteria queryCriteria, int seconds);

• 统计查询

  queryCriteria查询条件，seconds缓存时间

  int countByCriteria(QueryCriteria queryCriteria);    int countByCriteria(QueryCriteria queryCriteria, int seconds);

• 主键查询

  Object带主键对象实体，fields需要显示的字段，queryCriteria查询条件，seconds缓存时间，clazz对象实例类型，id对象主键

  QueryResult selectByPrimaryKey(Object obj);    QueryResult selectByPrimaryKey(Object obj, int seconds);    QueryResult selectByPrimaryKey(List<String> fields, Object obj);    QueryResult selectByPrimaryKey(String[] fields, Object obj);    QueryResult selectByPrimaryKey(List<String> fields, Object obj, int seconds);    QueryResult selectByPrimaryKey(String[] fields, Object obj, int seconds);    QueryResult selectByPrimaryKey(Class<?> clazz, Object id);    QueryResult selectByPrimaryKey(Class<?> clazz, Object id, int seconds);    QueryResult selectByPrimaryKey(List<String> fields, Class<?> clazz, Object id);    QueryResult selectByPrimaryKey(List<String> fields, Class<?> clazz, Object id, int seconds);

• 插入

  Object带主键对象实体

  int insert(Object obj);

• 更新

  Object带主键对象实体，queryCriteria查询条件

  int updateByCriteria(Object obj, QueryCriteria queryCriteria);    int updateByPrimaryKey(Object obj);

• 删除

  Object带主键对象实体，queryCriteria查询条件，clazz对象实例类型，id对象主键

  int deleteByPrimaryKey(Object obj);    int deleteByPrimaryKey(Class<?> clazz, Object id);    int deleteByCriteria(QueryCriteria queryCriteria);

• 其他操作

  database数据名称，tableName表名称

  void reloadTable(String tableName);    void clearCache(String tableName);    void reloadTable(String database, String tableName);    void clearCache(String database, String tableName);

2 使用示例

• 数据库user表字段

  CREATE TABLE `user` (

  id int(11) NOT NULL AUTO_INCREMENT, name varchar(20) DEFAULT NULL COMMENT '用户名', pwd varchar(50) DEFAULT NULL '密码' email varchar(30) DEFAULT NULL '邮箱', status int(11) DEFAULT '0' COMMENT '1正常0禁用', age int(11) DEFAULT NULL '年龄', PRIMARY KEY (id), UNIQUE KEY unique_user_userName (userName) ) ENGINE=MyISAM AUTO_INCREMENT=167 DEFAULT CHARSET=utf8;

• dto对象User.class

  import java.io.Serializable;    public class User implements Serializable {    /**   *    */  private static final long serialVersionUID = 4799201163494761002L;    public static final String ID = "id";  public static final String NAME = "name";  public static final String PWD = "pwd";  public static final String EMAIL = "email";  public static final String STATUS = "status";  public static final String AGE = "age";    private int id;    private String name;    private String pwd;    private String email;    private int status;    private int age;    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 String getPwd() {      return pwd;  }    public void setPwd(String pwd) {      this.pwd = pwd;  }    public String getEmail() {      return email;  }    public void setEmail(String email) {      this.email = email;  }    public int getStatus() {      return status;  }    public void setStatus(int status) {      this.status = status;  }    public int getAge() {      return age;  }    public void setAge(int age) {      this.age = age;  }

  }

• 列表查询

  • 示例1

    QueryCriteria queryCriteria = new QueryCriteria();  queryCriteria.setTable(User.class);  Criteria critera = queryCriteria.createCriteria();  critera.andColumnGreaterThan(User.AGE, 18);  critera.andColumnEqualTo(User.STATUS, 1);  //查询所有字段并缓存  QueryResult result =  baseDAL.selectByCriteria(queryCriteria);  //查询部分字段不缓存  QueryResult result =  baseDAL.selectByCriteria(new String[]{"name","pwd"},queryCriteria, BaseDal.NO_CACHE);  List<User> users = result.asList(User.class);

  • 示例2

    QueryCriteria queryCriteria = new QueryCriteria();  queryCriteria.setTable(User.class);  queryCriteria.setPageIndex(1);  queryCriteria.setPageSize(20);  queryCriteria.setOrderByClause(User.AGE+" desc");  //分页查询  QueryResult result =  baseDAL.selectPageByCriteria(queryCriteria);  List<Map<String, Object>> list = result.getList();  Map<String, Object>  page = result.getPage();

  </li>

• 主键查询

  • 示例1

    User user = new User();  user.setId(1);  //缓存20秒  QueryResult result =  baseDAL.selectByPrimaryKey(user, 20);  user = result.as(User.class);

  • 示例2

    Model model = new Model(User.class);  model.setSinglePrimaryKey(1);  //显示部分字段  QueryResult result =  baseDAL.selectByPrimaryKey(new String[]{"user","pwd"}, model);  Map<String, Object> result = result.get();

  • 示例3 //不使用缓存 QueryResult result = baseDAL.selectByPrimaryKey(User.class, 1，BaseDal.NO_CAHCE);

  </ul> </li>

  • 插入

    • 示例1

      User user = new User();  user.setName("fastser");  user.setPwd("faster");  int result = baseDAL.insert(user);

    </ul> </li>

    • 更新

      • 示例1

        User user = new User();  user.setName("fastser-dal-mybatis");  QueryCriteria queryCriteria = new QueryCriteria();  queryCriteria.setTable(User.class);  Criteria critera = queryCriteria.createCriteria();  critera.andColumnEqualTo(User.NAME, "fastser");  int result = baseDAL.updateByCriteria(user, queryCriteria);

      • 示例2

        User user = new User();  user.setEmail("ywj_316@qq.com");  user.setId(1);  int result = baseDAL.updateByPrimaryKey(user);

      </ul> </li>

      • 删除

        • 示例1

          Model model = new Model(User.class);  model.setSinglePrimaryKey(1);  int result = baseDAL.deleteByPrimaryKey(model);

        • 示例2

          User user = new User();  user.setId(1);  int result = baseDAL.deleteByPrimaryKey(user);

        • 示例3

          int result = baseDAL.deleteByPrimaryKey(User.class, 165);

        • 示例4

          QueryCriteria queryCriteria = new QueryCriteria();  queryCriteria.setTable(User.class);  Criteria critera = queryCriteria.createCriteria();  critera.andColumnEqualTo(User.NAME, "fastser");  int result = baseDAL.deleteByCriteria(queryCriteria);

        </ul> </li>

        • 其他操作

          • 示例1

            QueryCriteria queryCriteria = new QueryCriteria();  queryCriteria.setTable(User.class);  Criteria critera = queryCriteria.createCriteria();  critera.andColumnGreaterThan(User.AGE, 18);  critera.andColumnEqualTo(User.STATUS, 1);  //数量统计  int result =  baseDAL.countByCriteria(queryCriteria);

          </ul> </li> </ul>

          项目主页：http://www.open-open.com/lib/view/home/1419560404859