cn.weforward.data.persister.ms

类 MicroservicePersister<E extends Persistent>

java.lang.Object

cn.weforward.data.persister.support.AbstractPersister<E>

cn.weforward.data.persister.ms.MicroservicePersister<E>

所有已实现的接口:

cn.weforward.common.Nameable, Persister<E>

public class MicroservicePersister<E extends Persistent>
extends AbstractPersister<E>

基于微服务的存储器,暂时只实现了保存功能

作者:

daibo

嵌套类概要

从类继承的嵌套类/接口 cn.weforward.data.persister.support.AbstractPersister

AbstractPersister.Cache

字段概要

字段

限定符和类型	字段和说明
static String	DRIVEIT 控制实例id
static String	ID id属性
static String	LASTMODIFIED 最后修改时间
protected String	m_Collection
protected MicroservicePersisterFactory	m_Factory
protected cn.weforward.protocol.ext.ObjectMapper<E>	m_Mapper
static String	SERVERID 服务器id
static String	VERSION 版本

从类继承的字段 cn.weforward.data.persister.support.AbstractPersister

_Logger, m_Cache, m_Flusher, m_ForOwnerEnabled, m_IdGenerator, m_Listeners, m_Name, m_ReloadEnabled, m_VerifyNewIdTrys

构造器概要

构造器

限定符	构造器和说明
protected	MicroservicePersister(MicroservicePersisterFactory factory, cn.weforward.protocol.ext.ObjectMapper<E> mapper)

方法概要

限定符和类型	方法和说明
protected String	getCollectionName()
protected boolean	innerDelete(String id) 删除对象
protected ObjectWithVersion<E>	innerLoad(String id) 装入对象
protected String	innerNew(E object) 新增的对象（用于持久器在对象未刷写前能进行查询）
protected String	innerSave(E object) 保存对象状态
cn.weforward.common.ResultPage<String>	searchOfId(Condition condition, OrderBy orderBy) 条件查询
cn.weforward.common.ResultPage<String>	searchOfId(Date begin, Date end) 查找在指定时间段内变化（持久化）过的对象 (begin,end]
Iterator<String>	searchOfId(String serverId, Date begin, Date end) 查找在指定时间段内变化（持久化）过的对象
cn.weforward.common.ResultPage<String>	searchRangeOfId(String from, String to) 查找ID在指定区间内的对象，id>=from and id<=to
Iterator<String>	searchRangeOfId(String serverId, String from, String to) 查找ID在指定区间内的对象，id>=from and id<=to
cn.weforward.common.ResultPage<String>	startsWithOfId(String prefix) 查找ID为指定前缀的对象

从类继承的方法 cn.weforward.data.persister.support.AbstractPersister

addListener, cleanup, equals, flush, get, get, getCache, getFlusher, getIdGenerator, getName, getNewId, getNewId, getOfCache, getPersisterId, getVerifyNewIdTrys, getVersion, hold, innerSave, isDirty, isForOwnerEnabled, isOwner, isReloadEnabled, persist, persist, putOfCache, remove, remove, removeListener, removeOfCache, search, search, search, search, searchOfId, searchRange, searchRange, setFlusher, setForOwnerEnabled, setPersisterId, setReachable, setReloadEnabled, setVerifyNewIdTrys, startsWith, toString, update

从类继承的方法 java.lang.Object

clone, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

字段详细资料

ID

public static final String ID

id属性

另请参阅:

常量字段值

LASTMODIFIED

public static final String LASTMODIFIED

最后修改时间

另请参阅:

常量字段值

VERSION

public static final String VERSION

版本

另请参阅:

常量字段值

SERVERID

public static final String SERVERID

服务器id

另请参阅:

常量字段值

DRIVEIT

public static final String DRIVEIT

控制实例id

另请参阅:

常量字段值

m_Factory

protected MicroservicePersisterFactory m_Factory

m_Mapper

protected cn.weforward.protocol.ext.ObjectMapper<E extends Persistent> m_Mapper

m_Collection

protected String m_Collection

构造器详细资料

MicroservicePersister

protected MicroservicePersister(MicroservicePersisterFactory factory,
                                cn.weforward.protocol.ext.ObjectMapper<E> mapper)

方法详细资料

getCollectionName

protected String getCollectionName()

innerSave

protected String innerSave(E object)

从类复制的说明: AbstractPersister

保存对象状态

指定者:

innerSave 在类中 AbstractPersister<E extends Persistent>

参数:

object - 对象

返回:

对象保存后版本号

innerNew

protected String innerNew(E object)

从类复制的说明: AbstractPersister

新增的对象（用于持久器在对象未刷写前能进行查询）

指定者:

innerNew 在类中 AbstractPersister<E extends Persistent>

参数:

object - 新增的对象

返回:

创建后的版本号

innerDelete

protected boolean innerDelete(String id)

从类复制的说明: AbstractPersister

删除对象

指定者:

innerDelete 在类中 AbstractPersister<E extends Persistent>

参数:

id - 对象ID

返回:

成功/失败

innerLoad

protected ObjectWithVersion<E> innerLoad(String id)

从类复制的说明: AbstractPersister

装入对象

指定者:

innerLoad 在类中 AbstractPersister<E extends Persistent>

参数:

id - 对象ID

返回:

所加载的对象项及其版本号，没有则返回null

startsWithOfId

public cn.weforward.common.ResultPage<String> startsWithOfId(String prefix)

从接口复制的说明: Persister

查找ID为指定前缀的对象

参数:

prefix - ID前缀

返回:

对象结果页

searchOfId

public cn.weforward.common.ResultPage<String> searchOfId(Date begin,
                                                         Date end)

从接口复制的说明: Persister

查找在指定时间段内变化（持久化）过的对象 (begin,end]

参数:

begin - 开始时间，若=null则不限制开始时间

end - 结束时间，若=null则为当前时间

返回:

对象ID形式的结果页

searchRangeOfId

public cn.weforward.common.ResultPage<String> searchRangeOfId(String from,
                                                              String to)

从接口复制的说明: Persister

查找ID在指定区间内的对象，id>=from and id<=to

参数:

from - ID开始点，若为null则不限制开始（但to不能为null）

to - ID结束点，若为null则不限制结束（但from不能为null）

返回:

对象ID形式的结果页

searchOfId

public Iterator<String> searchOfId(String serverId,
                                   Date begin,
                                   Date end)

从接口复制的说明: Persister

查找在指定时间段内变化（持久化）过的对象

参数:

serverId - 服务器标识（1~255）

begin - 开始时间，若=null则不限制开始时间

end - 结束时间，若=null则为当前时间

返回:

结果集迭代器

searchRangeOfId

public Iterator<String> searchRangeOfId(String serverId,
                                        String from,
                                        String to)

从接口复制的说明: Persister

查找ID在指定区间内的对象，id>=from and id<=to

参数:

serverId - 服务器标识

from - ID开始点，若为null则不限制开始（但to不能为null）

to - ID结束点，若为null则不限制结束（但from不能为null）

返回:

结果集迭代器

searchOfId

public cn.weforward.common.ResultPage<String> searchOfId(Condition condition,
                                                         OrderBy orderBy)

从接口复制的说明: Persister

条件查询

参数:

condition - 条件 ConditionUtil

orderBy - 排序 OrderByUtil

返回:

对象结果页