閱讀(3.9k) 書簽贊(0) 我要糾錯

Uncode-DAL使用文檔

2018-11-23 18:12 更新

本著不重復造輪子的原則，基于mybatis、spring jdbc、hibernate、mongo等ORM的通用數(shù)據(jù)訪問層，支持基于datasource的讀寫分離、主備自動切換和故障轉移，支持簡單的負載均衡。

功能概述

基于mybatis、spring jdbc、hibernate等各大orm框架實現(xiàn)通用dal層功能，并可以與已有項目完全兼容。同時也可以在已經(jīng)實現(xiàn)的orm框架之間任意切換，不需要對代碼作任何改動。
實現(xiàn)dal層cache，可以自由設置過期時間。
實現(xiàn)基于多數(shù)據(jù)源(datasource)的讀寫分離、主備切換、故障轉移、恢復檢測和負載均衡
使用該組件必須遵循以下規(guī)則：
- 在使用DTO時，字段名稱與數(shù)據(jù)庫表字段一致，也可以不使用任何DTO類。
- 不支持連表查詢，主要是單表操作，如果需要連表請與原生orm框架配合使用。
- sql默認主鍵字段為id，nosql默認主鍵字段為_id。

使用場景

隨著nosql等新方案的出現(xiàn)，關系型數(shù)據(jù)庫更多的被用在業(yè)務數(shù)據(jù)存儲中，對于一些像報表等復雜數(shù)據(jù)處理的工作大部分公司已經(jīng)不再使用關系型數(shù)據(jù)庫，而對于業(yè)務數(shù)據(jù)90%以上是不需要連表查詢等復雜操作的，該組件設計目標是將這90%的工作量變成零，避免重復工作，提高開發(fā)速度。使用該組件后將不再需要mybatis的自動生成，spring jdbc的sql語句，hibernate的各種注解，因為組件可以忙你處理。同時該組件只是基于orm框架對所有單表操作的提取和封裝，最終還是由相應的orm框架完成持久化工作，所以不會代替orm的工作。因此論你的項目是新項目，還是老項目都可以使用，不會對原有業(yè)務生產(chǎn)任何影響，只是使你的操作更加便利，不再需要無數(shù)dao類，只要在需要的service中注入即可。組件需要遵循一定的COC規(guī)則，所以存在一定的使用限制，請大家注意。

maven

目前組件存放于oschina的maven庫中，請在項目中添加以下地址：http://maven.oschina.net/content/repositories/thirdparty/

1 mybatis

    <dependency>
        <groupId>cn.uncode</groupId>
        <artifactId>uncode-dal</artifactId>
        <version>1.0.3</version>
    </dependency>
    <dependency>
        <groupId>cn.uncode</groupId>
        <artifactId>uncode-dal-mybatis</artifactId>
        <version>1.0.3</version>
    </dependency>

2 spring jdbc

    <dependency>
        <groupId>cn.uncode</groupId>
        <artifactId>uncode-dal</artifactId>
        <version>1.0.3</version>
    </dependency>
    <dependency>
        <groupId>cn.uncode</groupId>
        <artifactId>uncode-dal-spring-jdbc</artifactId>
        <version>1.0.3</version>
    </dependency>

3 mongo

    <dependency>
        <groupId>cn.uncode</groupId>
        <artifactId>uncode-dal</artifactId>
        <version>1.0.3</version>
    </dependency>
    <dependency>
        <groupId>cn.uncode</groupId>
        <artifactId>uncode-dal-mongo</artifactId>
        <version>1.0.3</version>
    </dependency>

jar文件下載地址：http://www.uncode.cn/uncode-dal/uncode-dal-all-1.0.3.zip

spring集成

動態(tài)數(shù)據(jù)源可以自動處理故障轉移和恢復檢測，讀寫分離時多個讀庫采用隨機獲取。緩存可以自定義實現(xiàn)，可以統(tǒng)一開啟或關閉，方便在開發(fā)環(huán)境使用。

1 DataSource配置

可以使用任意數(shù)據(jù)庫連接池組件，建議使用Druid。配置Fastser-DAL動態(tài)數(shù)據(jù)源，將自動實現(xiàn)讀寫分離、主備自動切換和故障轉移等，建議使用。使用Fastser-DAL動態(tài)數(shù)據(jù)源后，在spring jdbc/mybatis配置中將所有的ref="dataSource"換成ref="dynamicDataSource"即可。

    <!--可選，動態(tài)數(shù)據(jù)源配置 -->
    <bean id="dynamicDataSource" class="cn.uncode.dal.datasource.DynamicDataSource">
        <!-- 從數(shù)據(jù)庫配置，用于讀操作，目前負載均衡機制為隨機取一個 -->
        <property name="slaveDataSources">
            <map key-type="java.lang.String">
                <entry key="readDataSourceOne" value-ref="dataSource3"/>
                <entry key="readDataSourceTwo" value-ref="dataSource4"/>
            </map>
        </property>
        <!-- 主數(shù)據(jù)庫配置 -->
        <property name="masterDataSource" ref="dataSource1" />
        <!-- 備數(shù)據(jù)庫配置 -->
        <property name="standbyDataSource" ref="dataSource2" />
    </bean>

    <!--可選，使用動態(tài)數(shù)據(jù)源讀寫分離時必選 -->
    <bean id="transactionManager" class="cn.uncode.dal.jdbc.datasource.DataSourceTransactionManager">
        <property name="dataSource" ref="dataSource" />
    </bean>

    <!-- 可選，Spring事務 -->
    <tx:annotation-driven transaction-manager="transactionManager" />

2 Spring jdbc 實現(xiàn)配置

    <!-- 可選，緩存默認實現(xiàn)，集群時建議使用分布式緩存自定義實現(xiàn) -->
    <bean id="dalCache" class="cn.uncode.dal.cache.impl.ConcurrentMapCache"></bean>
    <!-- 配置緩存 -->
    <bean id="cacheManager" class="cn.uncode.dal.cache.support.SimpleCacheManager">
        <property name="cache" ref="dalCache"></property>
    </bean>
    <!-- 配置數(shù)據(jù)源解析器 -->
    <bean id="resolveDatabase" class="cn.uncode.dal.descriptor.db.impl.SimpleResolveDatabase">
        <property name="dataSource" ref="dataSource" />
        <property name="cacheManager" ref="cacheManager" />
    </bean>

    <!-- spring jdbc實現(xiàn)配置 -->
    <bean id="commonJdbcSupport" class="cn.uncode.dal.spring.jdbc.CommonJdbcSupport">
        <property name="dataSource" ref="dataSource" />
    </bean>    
    <bean id="baseDAL" class="cn.uncode.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>

3 Mybatis 實現(xiàn)配置

    <!-- 可選，緩存默認實現(xiàn)，集群時建議使用分布式緩存自定義實現(xiàn) -->
    <bean id="dalCache" class="cn.uncode.dal.cache.impl.ConcurrentMapCache"></bean>
    <!-- 配置緩存 -->
    <bean id="cacheManager" class="cn.uncode.dal.cache.support.SimpleCacheManager">
        <property name="cache" ref="dalCache"></property>
    </bean>
    <!-- 配置數(shù)據(jù)源解析器 -->
    <bean id="resolveDatabase" class="cn.uncode.dal.descriptor.db.impl.SimpleResolveDatabase">
        <property name="dataSource" ref="dataSource" />
        <property name="cacheManager" ref="cacheManager" />
    </bean>

    <!-- mybatis實現(xiàn)配置 -->
    <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="cn.uncode.dal.mybatis.CommonMapper" />
    </bean>
    <bean id="baseDAL" class="cn.uncode.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>

4 MongoDB 實現(xiàn)配置

    <!-- 可選，緩存默認實現(xiàn)，集群時建議使用分布式緩存自定義實現(xiàn) -->
    <bean id="dalCache" class="cn.uncode.dal.cache.impl.ConcurrentMapCache"></bean>
    <!-- 可選，配置緩存 -->
    <bean id="cacheManager" class="cn.uncode.dal.cache.support.SimpleCacheManager">
        <property name="cache" ref="dalCache"></property>
    </bean>

    <!-- mongo實現(xiàn)配置 -->
    <bean id="mongoDataBase" class="cn.uncode.dal.mongo.MongoDataBase">
        <property name="host" value="172.16.30.98" />
        <property name="port" value="27017" />
        <property name="db" value="test" />
        <property name="username" value="xiaocong" />
        <property name="password" value="xiaocong" />
    </bean>

    <!-- 注意，mongo3.x請使用cn.uncode.dal.mongo.Mongo3DAL -->
    <bean id="mongoDAL" class="cn.uncode.dal.mongo.MongoDAL">
        <property name="database" ref="mongoDataBase"></property>
        <!-- 可選，配置全局不使用緩存，默認為true -->
        <property name="useCache" value="false" />
    </bean>

與原生框架配合使用

該組件只處理所有單表操作，對于連表等復雜操作可以使用原生框架，以達到在滿足所有功能的前提下提高開發(fā)效率，降低成本。

1 Spring jdbc

JdbcTemplate jdbcTemplate = (JdbcTemplate)baseDAL.getTemplate();

2 Mybatis

<!-- 將原來的SqlSessionFactory配置修改如下 -->
<bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
        <property name="dataSource" ref="dataSource" />
        <property name="configLocation" value="classpath:mybatis.xml"></property>
        <property name="mapperLocations" value="classpath:/cn/uncode/mapper/*Mapper.xml" />
</bean> 

<!-- 掃描注入Dao -->
<bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">
  <property name="basePackage" value="cn.uncode.mapper" />
</bean>

3 MongoDB

MongoDB mongoDB = (MongoDB)baseDAL.getTemplate();

API

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);

2 統(tǒng)計查詢

    queryCriteria查詢條件，seconds緩存時間
    int countByCriteria(QueryCriteria queryCriteria);
    int countByCriteria(QueryCriteria queryCriteria, int seconds);

3 主鍵查詢

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(String[] fields, String database, Object obj, int seconds);
    QueryResult selectByPrimaryKey(Class<?> clazz, Object id);
    QueryResult selectByPrimaryKey(String table, Object id);
    QueryResult selectByPrimaryKey(Class<?> clazz, Object id, int seconds);
    QueryResult selectByPrimaryKey(String table, Object id, int seconds);
    QueryResult selectByPrimaryKey(List<String> fields, Class<?> clazz, Object id);
    QueryResult selectByPrimaryKey(List<String> fields, String table, Object id);
    QueryResult selectByPrimaryKey(List<String> fields, Class<?> clazz, Object id, int seconds);
    QueryResult selectByPrimaryKey(List<String> fields, String table, Object id, int seconds);

4 插入

Object帶主鍵對象實體

    Object insert(Object obj);
    Object insert(String table, Map<String, Object> obj);
    Object insert(String database, String table, Map<String, Object> obj);
    void asynInsert(Object obj);
    void asynInsert(String table, Map<String, Object> obj);
    void asynInsert(String database, String table, Map<String, Object> obj);

5 更新

Object帶主鍵對象實體，queryCriteria查詢條件

    int updateByCriteria(Object obj, QueryCriteria queryCriteria);
    int updateByPrimaryKey(Object obj);
    int updateByPrimaryKey(String table, Map<String, Object> obj);
    int updateByPrimaryKey(String database, String table, Map<String, Object> obj);

6 刪除

Object帶主鍵對象實體，queryCriteria查詢條件，clazz對象實例類型，id對象主鍵

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

7 其他操作

database數(shù)據(jù)名稱，tableName表名稱

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

8 QueryCriteria方法

    //排序，如：id desc, name
    setOrderByClause(String orderByClause)
    //去重
    setDistinct(boolean distinct)
    //只查詢一條
    ssetSelectOne(boolean selectOne)
    //第幾頁，首頁為1
    setPageSize(int pageSize)
    //設置表名
    setTable(String table)
    //設置數(shù)據(jù)庫名稱，一般不需要設置
    setDatabase(String database)
    //使用樂觀鎖時設置版本，只用于更新操作
    setVersion(Object version)
    //根據(jù)DTO對象類型設置名表，此時DTO類名必須與表名一致
    setTable(Class<?> clazz)

9 Criteria方法

    Criteria append(Condition condition, String filed, Object value)
    Criteria append(String filed, Object value)
    Criteria append(String sql)
    andColumnIsNull(String column)
    andColumnIsNotNull(String column)
    andColumnEqualTo(String column, Object value) 
    andColumnNotEqualTo(String column, Object value)
    andColumnGreaterThan(String column, Object value) 
    andColumnGreaterThanOrEqualTo(String column, Object value)
    andColumnLessThan(String column, Object value)
    andColumnLessThanOrEqualTo(String column, Object value)
    andColumnIn(String column, List<Object> values)
    andColumnNotIn(String column, List<Object> values)
    andColumnLike(String column, Object value) 
    andColumnNotLike(String column, Object value)
    andColumnBetween(String column, Object value1, Object value2)
    andColumnNotBetween(String column, Object value1, Object value2)

10 QueryResult方法

    //單條數(shù)據(jù)以map獲取
    Map<String, Object> get()
      //單條數(shù)據(jù)以map獲取,并使用別名替換原來字段
    Map<String, Object> getWithAliasName(Map<String, String> aliasName)
    //單條數(shù)據(jù)以map獲取,并隱藏不需要顯示的字段
    Map<String, Object> get(List<String> hiddenFields)
    //單條數(shù)據(jù)以map獲取,隱藏不需要顯示的字段,使用別名替換原來字段
    Map<String, Object> getWithAliasName(List<String> hiddenFields, Map<String, String> aliasName)
    //多條數(shù)據(jù)以list獲取
    List<Map<String, Object>> getList()
    //多條數(shù)據(jù)以list獲取,并隱藏不需要顯示的字段
    List<Map<String, Object>> getList(List<String> hiddenFields)
    //多條數(shù)據(jù)以list獲取,并使用別名替換原來字段
    List<Map<String, Object>> getList(Map<String, String> aliasName)
    //多條數(shù)據(jù)以list獲取,隱藏不需要顯示的字段,使用別名替換原來字段
    List<Map<String, Object>> getList(List<String> hiddenFields, Map<String, String> aliasName)
    //單條數(shù)據(jù)轉為對象
    <T> T as(Class<T> beanClass)
    //多條數(shù)據(jù)轉為對象
    <T> List<T> asList(Class<T> beanClass)
    //獲取分頁信息
    Map<String, Object> getPage()

使用示例

1 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;

2 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;
    }
 }

3 BaseDal注入

注解方式

import cn.uncode.dal.core.BaseDAL;

@Service
public class UserService implements IUserService{

    @Autowired
    private BaseDAL baseDAL;

    .....
｝

XML方式

<bean id="userService" class="cn.uncode.web.service.UserService">
    <property name="baseDAL" ref="baseDAL"></property>
</bean>

4 無DTO示例

列表查詢

示例1

//創(chuàng)建查詢對象
QueryCriteria queryCriteria = new QueryCriteria();
//沒有DTO對象時可以直接設置表名
//queryCriteria.setTable("user");
//創(chuàng)建條件封裝對象
Criteria critera = queryCriteria.createCriteria();
//設置條件
critera.append(Condition.GREATER_THAN, "age", 18).append("status", 1);
//critera.andColumnGreaterThan(“age”, 18);
//critera.andColumnEqualTo("status", 1);
//查詢所有字段并緩存
QueryResult result =  baseDAL.selectByCriteria(queryCriteria);
//查詢部分字段緩存60稱
QueryResult result =  baseDAL.selectByCriteria(new String[]{"name","pwd"},queryCriteria, 60);
List<Map<String, Object>> users = result.getList();
//也可以轉成對應的DTO列表
List<User> users = result.asList(User.class);

示例2

//創(chuàng)建查詢對象
QueryCriteria queryCriteria = new QueryCriteria();
//設置查詢表，這樣設置時類名必須與表名一致
queryCriteria.setTable(“user”);
//設置分頁
queryCriteria.setPageIndex(1);
queryCriteria.setPageSize(20);
//設置排序
queryCriteria.setOrderByClause("age desc");
//分頁查詢并緩存60稱
QueryResult result =  baseDAL.selectPageByCriteria(queryCriteria, 60);
List<Map<String, Object>> list = result.getList();
Map<String, Object>  page = result.getPage();

主鍵查詢

示例1

Map<String, Object> user = new HashMap<String, Object>();
user.put("id", 1);
//緩存20秒
QueryResult result =  baseDAL.selectByPrimaryKey(user, 20);
user = result.get();
//也可以傳為DTO對象
User dto = result.as(User.class);

示例2

//顯示部分字段，不使用緩存
QueryResult result =  baseDAL.selectByPrimaryKey(new String[]{"name","pwd"｝，"user", 1，BaseDal.NO_CAHCE);
Map<String, Object> user = result.get();

示例3

//不使用DTO對象，直接傳表名
QueryResult result =  baseDAL.selectByPrimaryKey(”user“, 1，BaseDal.NO_CAHCE);
Map<String, Object> user = result.get();

示例4

//聯(lián)合主鍵查詢
QueryCriteria queryCriteria = new QueryCriteria();
queryCriteria.setTable(“user”);
Criteria critera = queryCriteria.createCriteria();
critera.andColumnEqualTo("name", "uncode-dal");
critera.andColumnEqualTo("pwd", "uncode-dal-mybatis");
queryCriteria.setSelectOne(true);
QueryResult result =  baseDAL.selectByCriteria(queryCriteria);
Map<String, Object> user = result.get();

插入

示例1

Map<String, Object> user = new HashMap<String, Object>();
user.put("name", "uncode");
user.put("pwd", faster");
//第一個參數(shù)為表名
int result = baseDAL.insert("user", user);

更新

示例1

Map<String, Object> user = new HashMap<String, Object>();
user.put("name", "uncode-dal-mybatis");
user.setName("uncode-dal-mybatis");
QueryCriteria queryCriteria = new QueryCriteria();
queryCriteria.setTable("user");
Criteria critera = queryCriteria.createCriteria();
critera.andColumnEqualTo("name", "uncode");
int result = baseDAL.updateByCriteria(user, queryCriteria);

示例2

Map<String, Object> user = new HashMap<String, Object>();
user.put("email", "ywj_316@qq.com");
user.put("id", 1);
//第一個參數(shù)為表名，user中必須包括所有主鍵字段
int result = baseDAL.updateByPrimaryKey("user", user);

示例3

Map<String, Object> user = new HashMap<String, Object>();
//設置為null
user.put("email", null);
user.put("id", 1);
//第一個參數(shù)為表名，user中必須包括所有主鍵字段
int result = baseDAL.updateByPrimaryKey("user", user);

示例4

Map<String, Object> user = new HashMap<String, Object>();
//設置函數(shù)
user.put("email", "=concat('11','22')");
user.put("age", "=age+1");
user.put("id", 1);
//第一個參數(shù)為表名，user中必須包括所有主鍵字段
int result = baseDAL.updateByPrimaryKey("user", user);

刪除

示例1

Map<String, Object> user = new HashMap<String, Object>();
user.put("email", "ywj_316@qq.com");
user.put("id", 1);
//user中必須包括所有主鍵字段
int result = baseDAL.deleteByPrimaryKey("user", user);

示例2

//第一個參數(shù)為表名
int result = baseDAL.deleteByPrimaryKey(“user”, 165);

示例3

QueryCriteria queryCriteria = new QueryCriteria();
queryCriteria.setTable("user");
Criteria critera = queryCriteria.createCriteria();
critera.andColumnEqualTo("name", "uncode");
int result = baseDAL.deleteByCriteria(queryCriteria);

其他操作

示例1

QueryCriteria queryCriteria = new QueryCriteria();
queryCriteria.setTable("user");
Criteria critera = queryCriteria.createCriteria();
critera.andColumnGreaterThan("age", 18);
critera.andColumnEqualTo("status", 1);
//數(shù)量統(tǒng)計
int result =  baseDAL.countByCriteria(queryCriteria);

5 使用DTO示例

列表查詢

示例1

//創(chuàng)建查詢對象
QueryCriteria queryCriteria = new QueryCriteria();
//設置查詢表，這樣設置時類名必須與表名一致
queryCriteria.setTable(User.class);
//創(chuàng)建條件封裝對象
Criteria critera = queryCriteria.createCriteria();
//設置條件
critera.append(Condition.GREATER_THAN, "age", 18).append("status", 1);
//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

//創(chuàng)建查詢對象
QueryCriteria queryCriteria = new QueryCriteria();
//設置查詢表，這樣設置時類名必須與表名一致
queryCriteria.setTable(User.class);
//設置分頁
queryCriteria.setPageIndex(1);
queryCriteria.setPageSize(20);
//設置排序
queryCriteria.setOrderByClause(User.AGE+" desc");
//分頁查詢并緩存60稱
QueryResult result =  baseDAL.selectPageByCriteria(queryCriteria, 60);
List<User> users = result.asList(User.class);
Map<String, Object>  page = result.getPage();

主鍵查詢

示例1

User user = new User();
user.setId(1);
//緩存20秒,有多個主鍵時必須全部設值
QueryResult result =  baseDAL.selectByPrimaryKey(user, 20);
user = result.as(User.class);

示例2

//顯示部分字段，不使用緩存
QueryResult result =  baseDAL.selectByPrimaryKey(new String[]{"name","pwd"｝，User.class, 1，BaseDal.NO_CAHCE);
User user = result.as(User.class);

示例3

//聯(lián)合主鍵也可以使用這種方式查詢
QueryCriteria queryCriteria = new QueryCriteria();
queryCriteria.setTable(User.class);
Criteria critera = queryCriteria.createCriteria();
critera.andColumnEqualTo(User.NAME, "uncode-dal");
critera.andColumnEqualTo(User.PWD, "uncode-dal-mybatis");
queryCriteria.setSelectOne(true);
QueryResult result =  baseDAL.selectByCriteria(queryCriteria);
User user = result.as(User.class);

插入

示例1

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

更新

示例1

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

示例2

User user = new User();
user.setEmail("ywj_316@qq.com");
user.setId(1);
//user中必須設值所有主鍵字段
int result = baseDAL.updateByPrimaryKey(user);

刪除

示例1

User user = new User();
user.setId(1);
//user中必須設值所有主鍵字段
int result = baseDAL.deleteByPrimaryKey(user);

示例2

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

示例3

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

其他操作

示例1

QueryCriteria queryCriteria = new QueryCriteria();
queryCriteria.setTable(User.class);
Criteria critera = queryCriteria.createCriteria();
critera.andColumnGreaterThan(User.AGE, 18);
critera.andColumnEqualTo(User.STATUS, 1);
//數(shù)量統(tǒng)計
int result =  baseDAL.countByCriteria(queryCriteria);

版權

作者：冶衛(wèi)軍（ywj_316@qq.com,微信:yeweijun）

技術支持QQ群：47306892

以上內(nèi)容是否對您有幫助：

Uncode-Schedule使用文檔 →

寫筆記

我要補充