AnylineService
AnylineService用来完成大部分的数据库操作
为保持版本兼容query与select功能完全一致
/**
* 按条件查询
* @param src 数据源(表或自定义SQL或SELECT语句) src 数据源(表或自定义SQL或SELECT语句)
* @param configs 封装来自于http的查询条件 configs 封装来自于http的查询条件
* @param conditions 固定查询条件 conditions 固定查询条件
* 原生SQL(AND GROUP ORDER)
* {原生}
* [+]CD:1
* [+]CD:
* [+]CD:null
* [+]CD:NULL
*
* @return return
*/
public DataSet querys(String src, ConfigStore configs, String ... conditions);
public DataSet querys(String src, String ... conditions);
public DataSet querys(String src, int fr, int to, String ... conditions);
public DataRow query(String src, ConfigStore configs, String ... conditions);
public DataRow query(String src, String ... conditions);
//实现与query相同的功能
public DataSet selects(String src, ConfigStore configs, String ... conditions);
public DataSet selects(String src, String ... conditions);
public DataSet selects(String src, int fr, int to, String ... conditions);
public DataRow select(String src, ConfigStore configs, String ... conditions);
public DataRow select(String src, String ... conditions);
/**
* 如果二级缓存开启 会从二级缓存中提取数据
* @param cache 对应ehcache缓存配置文件 中的cache.name
* @param src src
* @param configs configs
* @param conditions conditions
* @return return
*/
public DataSet caches(String cache, String src, ConfigStore configs, String ... conditions);
public DataSet caches(String cache, String src, String ... conditions);
public DataSet caches(String cache, String src, int fr, int to, String ... conditions);
/**
* 只用一级缓存 忽略二级缓存
* @param cache cache
* @param src src
* @param configs configs
* @param conditions conditions
* @return return
*/
public DataSet cacheL1(String cache, String src, ConfigStore configs, String ... conditions);
public DataSet cacheL1(String cache, String src, String ... conditions);
public DataSet cacheL1(String cache, String src, int fr, int to, String ... conditions);
public DataRow next(DataRow row, String column, SQL.ORDER_TYPE order, ConfigStore configs, String ... conditions);
public DataRow next(DataRow row, String column, SQL.ORDER_TYPE order, String ... conditions);
public DataRow next(DataRow row, SQL.ORDER_TYPE order, String ... conditions);
public DataRow next(DataRow row, ConfigStore configs, String ... conditions);
public DataRow next(DataRow row, String ... conditions);
public DataRow prev(DataRow row, String column, SQL.ORDER_TYPE order, ConfigStore configs, String ... conditions);
public DataRow prev(DataRow row, String column, SQL.ORDER_TYPE order, String ... conditions);
public DataRow prev(DataRow row, SQL.ORDER_TYPE order, String ... conditions);
public DataRow prev(DataRow row, ConfigStore configs, String ... conditions);
public DataRow prev(DataRow row, String ... conditions);
public DataRow cache(String cache, String src, ConfigStore configs, String ... conditions);
public DataRow cache(String cache, String src, String ... conditions);
/**
* 删除缓存 参数保持与查询参数完全一致
* @param channel channel
* @param src src
* @param configs configs
* @param conditions conditions
* @return return
*/
public boolean removeCache(String channel, String src, ConfigStore configs, String ... conditions);
public boolean removeCache(String channel, String src, String ... conditions);
public boolean removeCache(String channel, String src, int fr, int to, String ... conditions);
/**
* 清空缓存
* @param channel channel
* @return return
*/
public boolean clearCache(String channel);
/**
* 是否存在
* @param src src
* @param configs configs
* @param conditions conditions
* @return return
*/
public boolean exists(String src, ConfigStore configs, String ... conditions);
public boolean exists(String src, String ... conditions);
public boolean exists(String src, DataRow row);
public boolean exists(DataRow row);
public int count(String src, ConfigStore configs, String ... conditions);
public int count(String src, String ... conditions);
/**
* 更新记录
* @param columns 需要更新的列
* @param dest 表
* @param data data
* @return return
*/
public int update(String dest, Object data, String ... columns);
public int update(Object data, String ... columns);
public int update(String dest, ConfigStore configs, String ... conditions);
public int update(boolean sync, String dest, Object data, String ... columns);
public int update(boolean sync, Object data, String ... columns);
/**
* 保存(insert|update)
* @param data data
* @param checkPriamry checkPriamry
* @param columns columns
* @param dest 表
* @return return
*/
public int save(String dest, Object data, boolean checkPriamry, String ... columns);
public int save(Object data, boolean checkPriamry, String ... columns);
public int save(Object data, String ... columns);
public int save(String dest, Object data, String ... columns);
//
public int save(boolean sync, String dest, Object data, boolean checkPriamry, String ... columns);
public int save(boolean sync, Object data, boolean checkPriamry, String ... columns);
public int save(boolean sync, Object data, String ... columns);
public int save(boolean sync, String dest, Object data, String ... columns);
public int insert(String dest, Object data, boolean checkPriamry, String ... columns);
public int insert(Object data, boolean checkPriamry, String ... columns);
public int insert(Object data, String ... columns);
public int insert(String dest, Object data, String ... columns);
/**
* 异步插入
* @param dest dest
* @param data data
* @param checkPriamry checkPriamry
* @param columns columns
* @return return
*/
public int batchInsert(String dest, Object data, boolean checkPriamry, String ... columns);
public int batchInsert(Object data, boolean checkPriamry, String ... columns);
public int batchInsert(Object data, String ... columns);
public int batchInsert(String dest, Object data, String ... columns);
/**
* save insert区别
* 操作单个对象时没有区别
* 在操作集合时区别:
* save会循环操作数据库每次都会判断insert|update
* save 集合中的数据可以是不同的表不同的结构
* insert 集合中的数据必须保存到相同的表,结构必须相同
* insert 将一次性插入多条数据整个过程有可能只操作一次数据库 并 不考虑update情况 对于大批量数据来说 性能是主要优势
*
*/
/**
* 执行
* @param src src
* @param configs configs
* @param conditions conditions
* @return return
*/
public int execute(String src, ConfigStore configs, String ... conditions);
public int execute(String src, String ... conditions);
/**
* 执行存储过程
* @param procedure procedure
* @param inputs inputs
* @return return
*/
public boolean executeProcedure(String procedure, String... inputs);
public boolean executeProcedure(Procedure procedure);
/**
* 根据存储过程查询
* @param procedure procedure
* @param inputs inputs
* @return return
*/
public DataSet queryProcedure(String procedure, String ... inputs);
public DataSet query(Procedure procedure);
public DataSet selectProcedure(String procedure, String ... inputs);
public DataSet select(Procedure procedure);
/**
* 删除 根据主键删除
* @param dest dest
* @param data data
* @return return
*/
public int delete(String dest, Object data);
public int delete(Object data);
public int delete(String table, String key, Collection<Object> values);
public int delete(String table, String key, String ... values);