sf.database.jdbc.sql

Interface CrudModelInf

All Known Implementing Classes:

CrudModelImpl

public interface CrudModelInf

按模型操作

Author:

sxf

Method Summary

Modifier and Type	Method and Description
int[]	batchDelete(Connection conn, Collection<? extends DBObject> modelList, int batchSize)
int[]	batchDelete(Connection conn, Collection<? extends DBObject> modelList, int batchSize, boolean useFirstSql)
int[]	batchInsert(Connection conn, Collection<? extends DBObject> modelList, boolean insertFast, boolean useOptimisticLock, int batchSize) 批量插入
int[]	batchInsert(Connection conn, Collection<? extends DBObject> modelList, boolean insertFast, boolean useOptimisticLock, int batchSize, boolean useAll) 批量插入
int[]	batchUpdate(Connection conn, Collection<? extends DBObject> modelList, int batchSize) 更新对象,如果有乐观锁,会根据乐观锁条件更新,并会更新数据库中的乐观锁条件.但不会更新对象的乐观锁字段的值.
int[]	batchUpdate(Connection conn, Collection<? extends DBObject> modelList, int batchSize, boolean useNvl)
boolean	createTable(Connection conn, Class<?> clz) 创建表
<T extends DBObject> int	delete(Connection conn, T obj) 删除方法
<T extends DBObject> int	deleteByPrimaryKeys(Connection conn, Class<T> clz, Object... keyParams) 根据主键删除
<T extends DBObject> int	deleteCascade(Connection conn, T obj, DBCascadeField... fields) 将对象删除的同时，也将符合一个正则表达式的所有关联字段关联的对象统统删除 注意：
<T extends DBObject> int	deleteLinks(Connection con, T obj, DBCascadeField... fields) 仅删除对象所有的关联字段，并不包括对象本身。 注意：
<T extends DBObject> int	deleteRelation(Connection con, T obj, DBCascadeField... fields) 多对多关联是通过一个中间表将两条数据表记录关联起来。
boolean	dropTable(Connection conn, Class<?> clz) 删除表
int	execute(Connection conn, SQLContext context) 执行语句,非查询语句
<T extends DBObject> boolean	exists(Connection conn, T query) 查询对象是否存在
<T extends DBObject> boolean	existsByPrimaryKeys(Connection conn, Class<T> clz, Object... keyParams) 根据主键查询是否存在
<T extends DBObject> List<T>	fetchCascade(Connection conn, T query, Class<T> clz, DBCascadeField... fields) fixme beetsql hibernate 使用了一级缓存,导致比他们慢 根据查询条件查询列表并根据级联字段查询级联对象
<T extends DBObject> T	fetchLinks(Connection conn, T obj) 根据一个正则表达式，获取对象所有的关联字段
<T extends DBObject> T	fetchLinks(Connection conn, T obj, DBCascadeField... fields) 根据字段，获取对象所有的关联字段
int	insert(Connection conn, DBObject obj) 插入
int	insert(Connection conn, DBObject obj, boolean fast, boolean useOptimisticLock)
int	insertCascade(Connection conn, DBObject obj, DBCascadeField... fields) 将对象插入数据库同时，也将符合一个正则表达式的所有关联字段关联的对象统统插入相应的数据库
<T extends DBObject> T	insertLinks(Connection con, T obj, DBCascadeField... fields) 仅将对象所有的关联字段插入到数据库中，并不包括对象本身
<T extends DBObject> T	insertRelation(Connection con, T obj, DBCascadeField... fields) 将对象的一个或者多个，多对多的关联信息，插入数据表
int	merge(Connection conn, DBObject obj) 合并记录
<T extends DBObject> T	selectByPrimaryKeys(Connection conn, Class<T> clz, Object... keyParams)
<T extends DBObject> Long	selectCount(Connection conn, T query) 查询总数
<T extends DBObject> void	selectIterator(Connection conn, OrmIterator<T> ormIt, T query) 查询结果返回迭代
<T extends DBObject> void	selectIterator(Connection conn, OrmIterator<T> ormIt, T query, long start, int limit) 查询结果返回迭代(分页查询)
<T> List<T>	selectList(Connection conn, Class<T> beanClass, SQLContext context)
<T> List<T>	selectList(Connection conn, Class<T> beanClass, SQLContext context, long start, int limit)
<T extends DBObject> List<T>	selectList(Connection conn, T query) 查询列表
<T extends DBObject> List<T>	selectList(Connection conn, T query, long start, int limit)
<T extends DBObject> List<T>	selectListForUpdate(Connection conn, T query) 悲观锁(Pessimistic Lock)
List<Map<String,Object>>	selectListMap(Connection conn, SQLContext context)
<T> T	selectOne(Connection conn, Class<T> beanClass, SQLContext context)
<T extends DBObject> T	selectOne(Connection conn, T query) 查询一条记录，如果结果不唯一则抛出异常
<T extends DBObject> T	selectOneForUpdate(Connection conn, T query) 悲观锁(Pessimistic Lock)
<T> Page<T>	selectPage(Connection conn, long start, int limit, Class<T> beanClass, SQLContext context)
<T> Page<T>	selectPage(Connection conn, long start, int limit, Class<T> beanClass, SQLContext context, PageStrategy strategy)
<T extends DBObject> Page<T>	selectPage(Connection conn, T query, long start, int limit) 查询并分页
<T extends DBObject> void	selectStream(Connection conn, OrmStream<T> ormStream, T query) 查询结果返回迭代
<T extends DBObject> int	update(Connection conn, T obj) 更新对象(不区分乐观锁条件)
<T extends DBObject> int	updateAndSet(Connection conn, T obj) 乐观锁(Optimistic Lock), 以特定字段的值作为限制条件,更新对象,并更新该字段的值.参考字段的Java属性名.必须设置了@Version标签 注意:对于时间作为乐观锁,由于数据库和java时间存在差异,如果需要设置更新后的值,需要重新调用OptimisticLock.setNewOptimisticLockValues查询方法设置最新的值.
int	updateCascade(Connection conn, DBObject obj, DBCascadeField... fields) 将对象更新的同时，也将符合一个正则表达式的所有关联字段关联的对象统统更新
<T extends DBObject> int	updateLinks(Connection con, T obj, DBCascadeField... fields) 仅更新对象所有的关联字段，并不包括对象本身
<T extends DBObject> int	updateRelation(Connection con, T obj, DBCascadeField... fields) 多对多关联是通过一个中间表将两条数据表记录关联起来。
<T extends DBObject> int	updateWithVersion(Connection conn, T obj) 乐观锁(Optimistic Lock) 根据乐观锁条件更新,并会更新数据库中的乐观锁条件.但不会更新对象的乐观锁字段的值.

Method Detail

existsByPrimaryKeys

<T extends DBObject> boolean existsByPrimaryKeys(Connection conn,
                                                 Class<T> clz,
                                                 Object... keyParams)

根据主键查询是否存在

Type Parameters:

T -

Parameters:

conn -

clz - 实体类

keyParams - 主键列

Returns:

exists

<T extends DBObject> boolean exists(Connection conn,
                                    T query)

查询对象是否存在

Type Parameters:

T -

Parameters:

conn -

query - 查询实体

Returns:

selectByPrimaryKeys

<T extends DBObject> T selectByPrimaryKeys(Connection conn,
                                           Class<T> clz,
                                           Object... keyParams)

Type Parameters:

T -

Parameters:

conn -

clz -

keyParams -

Returns:

selectListMap

List<Map<String,Object>> selectListMap(Connection conn,
                                       SQLContext context)

Parameters:

conn -

context -

Returns:

selectOne

<T> T selectOne(Connection conn,
                Class<T> beanClass,
                SQLContext context)

Type Parameters:

T -

Parameters:

conn -

beanClass -

context -

Returns:

selectList

<T> List<T> selectList(Connection conn,
                       Class<T> beanClass,
                       SQLContext context)

Type Parameters:

T -

Parameters:

conn -

beanClass -

context -

Returns:

selectList

<T> List<T> selectList(Connection conn,
                       Class<T> beanClass,
                       SQLContext context,
                       long start,
                       int limit)

Type Parameters:

T -

Parameters:

conn -

beanClass -

context -

start -

limit -

Returns:

selectPage

<T> Page<T> selectPage(Connection conn,
                       long start,
                       int limit,
                       Class<T> beanClass,
                       SQLContext context)

Type Parameters:

T -

Parameters:

conn -

start -

limit -

beanClass -

context - 如果为分页参数,内部的listSql--带分页参数,countSql不能为空

Returns:

selectPage

<T> Page<T> selectPage(Connection conn,
                       long start,
                       int limit,
                       Class<T> beanClass,
                       SQLContext context,
                       PageStrategy strategy)

Type Parameters:

T -

Parameters:

conn -

start -

limit -

beanClass -

context - 如果为分页参数,内部的listSql--带分页参数,countSql不能为空

strategy - 分页策略

Returns:

selectCount

<T extends DBObject> Long selectCount(Connection conn,
                                      T query)

查询总数

Type Parameters:

T -

Parameters:

conn -

query -

Returns:

selectOne

<T extends DBObject> T selectOne(Connection conn,
                                 T query)

查询一条记录，如果结果不唯一则抛出异常

Parameters:

conn -

query -

Returns:

查询结果

selectOneForUpdate

<T extends DBObject> T selectOneForUpdate(Connection conn,
                                          T query)

悲观锁(Pessimistic Lock)

Type Parameters:

T -

Parameters:

conn -

query -

Returns:

selectList

<T extends DBObject> List<T> selectList(Connection conn,
                                        T query)

查询列表

Parameters:

query - 查询请求。

• 如果设置了Query条件，按query条件查询。 否则——
• 如果设置了主键值，按主键查询，否则——
• 按所有设置过值的字段作为条件查询。

Returns:

结果

selectList

<T extends DBObject> List<T> selectList(Connection conn,
                                        T query,
                                        long start,
                                        int limit)

Type Parameters:

T -

Parameters:

conn -

query -

start -

limit -

Returns:

selectListForUpdate

<T extends DBObject> List<T> selectListForUpdate(Connection conn,
                                                 T query)

悲观锁(Pessimistic Lock)

Type Parameters:

T -

Parameters:

conn -

query -

Returns:

selectPage

<T extends DBObject> Page<T> selectPage(Connection conn,
                                        T query,
                                        long start,
                                        int limit)

查询并分页

Parameters:

query - 查询请求

start - 起始记录，offset。从0开始。

limit - 限制记录条数。如每页10条传入10。

Returns:

selectIterator

<T extends DBObject> void selectIterator(Connection conn,
                                         OrmIterator<T> ormIt,
                                         T query)

查询结果返回迭代

Type Parameters:

T -

Parameters:

conn -

ormIt -

query -

selectIterator

<T extends DBObject> void selectIterator(Connection conn,
                                         OrmIterator<T> ormIt,
                                         T query,
                                         long start,
                                         int limit)

查询结果返回迭代(分页查询)

Type Parameters:

T -

Parameters:

conn -

ormIt -

query -

start -

limit -

selectStream

<T extends DBObject> void selectStream(Connection conn,
                                       OrmStream<T> ormStream,
                                       T query)

查询结果返回迭代

Type Parameters:

T -

Parameters:

conn -

ormStream -

query -

update

<T extends DBObject> int update(Connection conn,
                                T obj)

更新对象(不区分乐观锁条件)

Parameters:

conn -

obj -

Returns:

updateAndSet

<T extends DBObject> int updateAndSet(Connection conn,
                                      T obj)

乐观锁(Optimistic Lock), 以特定字段的值作为限制条件,更新对象,并更新该字段的值.参考字段的Java属性名.必须设置了@Version标签
注意:对于时间作为乐观锁,由于数据库和java时间存在差异,如果需要设置更新后的值,需要重新调用OptimisticLock.setNewOptimisticLockValues查询方法设置最新的值. 锁更新规则

1.对于数字,则+1;
2.对于日期取当前时间戳.
3.对于字符串,取UUID的值.

执行的sql如下:

update t_user set age=30, city="广州", version=version+1 where name="wendal" and version=124;

Parameters:

conn -

obj - 需要更新的对象, 必须带主键,并设置过主键的值.

Returns:

若更新成功, 返回值大于0, 否则小于等于0

updateWithVersion

<T extends DBObject> int updateWithVersion(Connection conn,
                                           T obj)

乐观锁(Optimistic Lock)
根据乐观锁条件更新,并会更新数据库中的乐观锁条件.但不会更新对象的乐观锁字段的值. 基于版本的更新，版本不一样无法更新到数据

Parameters:

conn -

obj - 需要更新的对象, 必须有@Version属性

Returns:

若更新成功, 大于0, 否则小于0

merge

int merge(Connection conn,
          DBObject obj)

合并记录

Parameters:

conn -

obj -

Returns:

deleteByPrimaryKeys

<T extends DBObject> int deleteByPrimaryKeys(Connection conn,
                                             Class<T> clz,
                                             Object... keyParams)

根据主键删除

Type Parameters:

T -

Parameters:

conn -

clz -

keyParams -

Returns:

delete

<T extends DBObject> int delete(Connection conn,
                                T obj)

删除方法

Type Parameters:

T -

Parameters:

conn -

obj -

Returns:

batchInsert

int[] batchInsert(Connection conn,
                  Collection<? extends DBObject> modelList,
                  boolean insertFast,
                  boolean useOptimisticLock,
                  int batchSize)

批量插入

Parameters:

conn -

modelList -

insertFast -

useOptimisticLock -

batchSize -

Returns:

batchInsert

int[] batchInsert(Connection conn,
                  Collection<? extends DBObject> modelList,
                  boolean insertFast,
                  boolean useOptimisticLock,
                  int batchSize,
                  boolean useAll)

批量插入

Parameters:

conn -

modelList -

insertFast -

useOptimisticLock -

batchSize -

useAll - 是否使用一条语句做完插入

Returns:

batchUpdate

int[] batchUpdate(Connection conn,
                  Collection<? extends DBObject> modelList,
                  int batchSize)

更新对象,如果有乐观锁,会根据乐观锁条件更新,并会更新数据库中的乐观锁条件.但不会更新对象的乐观锁字段的值.

Parameters:

conn -

modelList -

batchSize -

Returns:

batchUpdate

int[] batchUpdate(Connection conn,
                  Collection<? extends DBObject> modelList,
                  int batchSize,
                  boolean useNvl)

Parameters:

conn -

modelList -

batchSize -

useNvl - 是否使用数据库方法排除null值

Returns:

batchDelete

int[] batchDelete(Connection conn,
                  Collection<? extends DBObject> modelList,
                  int batchSize)

Parameters:

conn -

modelList -

batchSize -

Returns:

batchDelete

int[] batchDelete(Connection conn,
                  Collection<? extends DBObject> modelList,
                  int batchSize,
                  boolean useFirstSql)

Parameters:

conn -

modelList -

batchSize -

useFirstSql - 是否使用第一个对象生成的sql语句为准

Returns:

createTable

boolean createTable(Connection conn,
                    Class<?> clz)

创建表

Parameters:

conn -

clz -

Returns:

dropTable

boolean dropTable(Connection conn,
                  Class<?> clz)

删除表

Parameters:

conn -

clz -

Returns:

fetchCascade

<T extends DBObject> List<T> fetchCascade(Connection conn,
                                          T query,
                                          Class<T> clz,
                                          DBCascadeField... fields)

fixme beetsql hibernate 使用了一级缓存,导致比他们慢 根据查询条件查询列表并根据级联字段查询级联对象

Type Parameters:

T -

Parameters:

conn -

query -

clz -

fields -

Returns:

fetchLinks

<T extends DBObject> T fetchLinks(Connection conn,
                                  T obj)

根据一个正则表达式，获取对象所有的关联字段

Type Parameters:

T -

Parameters:

conn -

obj - 数据对象,不可以是Class啊!!!传对象或集合啊!!!

Returns:

更新后的数据对象本身

See Also:

OneToOne, ManyToMany, OneToMany

fetchLinks

<T extends DBObject> T fetchLinks(Connection conn,
                                  T obj,
                                  DBCascadeField... fields)

根据字段，获取对象所有的关联字段

Type Parameters:

T -

Parameters:

conn -

obj - 数据对象,不可以是Class啊!!!传对象或集合啊!!!

fields -

Returns:

更新后的数据对象本身

See Also:

OneToOne, ManyToMany, OneToMany

insert

int insert(Connection conn,
           DBObject obj)

插入

Parameters:

conn -

obj -

Returns:

insert

int insert(Connection conn,
           DBObject obj,
           boolean fast,
           boolean useOptimisticLock)

Parameters:

conn -

obj -

fast - 是否是快速插入

useOptimisticLock -

Returns:

insertCascade

int insertCascade(Connection conn,
                  DBObject obj,
                  DBCascadeField... fields)

将对象插入数据库同时，也将符合一个正则表达式的所有关联字段关联的对象统统插入相应的数据库

关于关联字段更多信息，请参看 '@One' | '@Many' | '@ManyMany' 更多的描述

Parameters:

conn -

obj -

fields - 指定字段,控制力度更细,至少一个或多个 描述了什么样的关联字段将被关注。如果为 null，则表示全部的关联字段都会被插入

Returns:

insertLinks

<T extends DBObject> T insertLinks(Connection con,
                                   T obj,
                                   DBCascadeField... fields)

仅将对象所有的关联字段插入到数据库中，并不包括对象本身

Parameters:

obj - 数据对象

fields - 字段名称，描述了什么样的关联字段将被关注。如果为 null，则表示全部的关联字段都会被插入

Returns:

数据对象本身

See Also:

OneToOne, ManyToMany, OneToMany

insertRelation

<T extends DBObject> T insertRelation(Connection con,
                                      T obj,
                                      DBCascadeField... fields)

将对象的一个或者多个，多对多的关联信息，插入数据表

Parameters:

obj - 对象

fields - 正则表达式，描述了那种多对多关联字段将被执行该操作

Returns:

对象自身

See Also:

ManyToMany

updateCascade

int updateCascade(Connection conn,
                  DBObject obj,
                  DBCascadeField... fields)

将对象更新的同时，也将符合一个正则表达式的所有关联字段关联的对象统统更新

关于关联字段更多信息，请参看 '@One' | '@Many' | '@ManyMany' 更多的描述

Parameters:

conn -

obj - 数据对象

fields - 指定字段,控制力度更细,至少一个或多个,描述了什么样的关联字段将被关注。如果为 null，则表示全部的关联字段都会被更新

Returns:

updateLinks

<T extends DBObject> int updateLinks(Connection con,
                                     T obj,
                                     DBCascadeField... fields)

仅更新对象所有的关联字段，并不包括对象本身

Type Parameters:

T -

Parameters:

con - 连接

obj - 数据对象

fields - 字段名称，描述了什么样的关联字段将被关注。如果为 null，则表示全部的关联字段都会被更新

Returns:

对象内部更新的级联数量

See Also:

OneToOne, ManyToMany, OneToMany

updateRelation

<T extends DBObject> int updateRelation(Connection con,
                                        T obj,
                                        DBCascadeField... fields)

多对多关联是通过一个中间表将两条数据表记录关联起来。

而这个中间表可能还有其他的字段，比如描述关联的权重等

这个操作可以让你一次更新某一个对象中多个多对多关联的数据

Parameters:

con - 数据库连接

obj - 数据对象

fields - 字段名称，描述了那种多对多关联字段将被执行该操作

Returns:

共有多少条数据被更新

See Also:

ManyToMany

execute

int execute(Connection conn,
            SQLContext context)

执行语句,非查询语句

Parameters:

conn -

context -

Returns:

deleteCascade

<T extends DBObject> int deleteCascade(Connection conn,
                                       T obj,
                                       DBCascadeField... fields)

将对象删除的同时，也将符合一个正则表达式的所有关联字段关联的对象统统删除 注意：

Java 对象的字段会被保留，这里的删除，将只会删除数据库中的记录

关于关联字段更多信息，请参看 '@One' | '@Many' | '@ManyMany' 更多的描述

Type Parameters:

T -

Parameters:

conn -

obj -

fields - 指定字段,控制力度更细,至少一个或多个 描述了什么样的关联字段将被关注。如果为 null，则表示全部的关联字段都会被删除

Returns:

deleteLinks

<T extends DBObject> int deleteLinks(Connection con,
                                     T obj,
                                     DBCascadeField... fields)

仅删除对象所有的关联字段，并不包括对象本身。 注意：

Java 对象的字段会被保留，这里的删除，将只会删除数据库中的记录

关于关联字段更多信息，请参看 '@One' | '@Many' | '@ManyMany' 更多的描述

Parameters:

obj - 数据对象

fields - 字段名称，描述了什么样的关联字段将被关注。如果为 null，则表示全部的关联字段都会被删除

Returns:

被影响的记录行数

See Also:

OneToOne, ManyToOne, ManyToMany

deleteRelation

<T extends DBObject> int deleteRelation(Connection con,
                                        T obj,
                                        DBCascadeField... fields)

多对多关联是通过一个中间表将两条数据表记录关联起来。

而这个中间表可能还有其他的字段，比如描述关联的权重等

这个操作可以让你一次删除某一个对象中多个多对多关联的数据

Parameters:

obj -

fields - 字段名称，描述了那种多对多关联字段将被执行该操作

Returns:

共有多少条数据被更新

See Also:

ManyToMany