Package com.xzavier0722.mc.plugin.slimefun4.storage.controller

Class ADataController

java.lang.Object

com.xzavier0722.mc.plugin.slimefun4.storage.controller.ADataController

Direct Known Subclasses:

BlockDataController, ProfileDataController

public abstract class ADataController
extends Object

ADataController 是 Slimefun 数据库控制器的抽象类， 提供了对数据源适配器的访问和数据操作的基本方法。
该类提供了对数据库的增删查改操作以及异步读写的支持。

Field Summary

Fields

Modifier and Type	Field	Description
protected ExecutorService	callbackExecutor	数据库回调调度器
protected final Logger	logger	The logger for this data controller.
protected ExecutorService	readExecutor	数据库读取调度器
protected ExecutorService	serialWriteExecutor
protected ExecutorService	writeExecutor	数据库写入调度器

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	ADataController(DataType dataType)	Constructs a new ADataController.

Method Summary

Modifier and Type	Method	Description
protected void	abortScopeTask(ScopeKey key)
protected void	checkDestroy()
protected void	deleteData(RecordKey key)
protected List<RecordSet>	getData(RecordKey key)
protected List<RecordSet>	getData(RecordKey key, boolean distinct)
final DataType	getDataType()
void	init(IDataSourceAdapter<?> dataAdapter, int maxReadThread, int maxWriteThread)	初始化 ADataController
protected <T> void	invokeCallback(IAsyncReadCallback<T> callback, T result)
protected void	scheduleDeleteTask(ScopeKey scopeKey, RecordKey key, boolean forceScopeKey)
protected void	scheduleReadTask(Runnable run)
protected void	scheduleWriteTask(ScopeKey scopeKey, RecordKey key, RecordSet data, boolean forceScopeKey)
protected void	scheduleWriteTask(ScopeKey scopeKey, RecordKey key, Runnable task, boolean forceScopeKey)
protected void	scheduleWriteTask(Runnable run)
protected void	setData(RecordKey key, RecordSet data)
void	shutdown()	正常关闭 ADataController

Methods inherited from class java.lang.Object

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

Field Details

readExecutor

protected ExecutorService readExecutor

数据库读取调度器

writeExecutor

protected ExecutorService writeExecutor

数据库写入调度器

serialWriteExecutor

protected ExecutorService serialWriteExecutor

callbackExecutor

protected ExecutorService callbackExecutor

数据库回调调度器

logger

protected final Logger logger

The logger for this data controller.

Constructor Details

ADataController

protected ADataController(DataType dataType)

Constructs a new ADataController.

Parameters:

dataType - The data type this controller manages

Method Details

init

@OverridingMethodsMustInvokeSuper
public void init(IDataSourceAdapter<?> dataAdapter,
 int maxReadThread,
 int maxWriteThread)

初始化 ADataController

Parameters:

dataAdapter - The data source adapter

maxReadThread - Maximum number of read threads

maxWriteThread - Maximum number of write threads

shutdown

@OverridingMethodsMustInvokeSuper
public void shutdown()

正常关闭 ADataController

scheduleDeleteTask

protected void scheduleDeleteTask(ScopeKey scopeKey,
 RecordKey key,
 boolean forceScopeKey)

scheduleWriteTask

protected void scheduleWriteTask(ScopeKey scopeKey,
 RecordKey key,
 RecordSet data,
 boolean forceScopeKey)

scheduleWriteTask

protected void scheduleWriteTask(ScopeKey scopeKey,
 RecordKey key,
 Runnable task,
 boolean forceScopeKey)

checkDestroy

protected void checkDestroy()

invokeCallback

protected <T> void invokeCallback(IAsyncReadCallback<T> callback,
 T result)

scheduleReadTask

protected void scheduleReadTask(Runnable run)

scheduleWriteTask

protected void scheduleWriteTask(Runnable run)

getData

protected List<RecordSet> getData(RecordKey key)

getData

protected List<RecordSet> getData(RecordKey key,
 boolean distinct)

setData

protected void setData(RecordKey key,
 RecordSet data)

deleteData

protected void deleteData(RecordKey key)

abortScopeTask

protected void abortScopeTask(ScopeKey key)

getDataType

public final DataType getDataType()