com.sleepycat.je.sync.impl
Class SyncDB
java.lang.Object
com.sleepycat.je.sync.impl.SyncDB
public class SyncDB
- extends Object
Retrieves all pending and unprocessed changes for one or more SyncDataSets;
used only by SyncProcessor implementations and custom sources of change set
information.
Method Summary |
static String |
generateKey(String processorName,
String dataSetName,
SyncDB.DataType dataType)
|
long |
getCount()
|
DatabaseImpl |
getDatabaseImpl()
|
void |
readChangeSetData(Environment env,
Transaction txn,
String processorName,
String dataSetName,
DatabaseEntry data)
|
Map<String,DatabaseEntry> |
readDataForType(SyncDB.DataType dataType,
Environment env)
|
ProcessorMetadata |
readProcessorMetadata(Environment env,
Transaction txn,
SyncProcessor processor)
|
void |
readProcessorTxnData(Environment env,
Transaction txn,
String processorName,
String dataSetName,
DatabaseEntry data)
|
void |
writeChangeSetData(Environment env,
Transaction txn,
String processorName,
String dataSetName,
DatabaseEntry data,
SyncDB.OpType opType)
|
void |
writeProcessorMetadata(Environment env,
Transaction txn,
String processorName,
ProcessorMetadata metadata)
|
void |
writeProcessorTxnData(Environment env,
Transaction txn,
String processorName,
String dataSetName,
DatabaseEntry data)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
SyncDB
public SyncDB(EnvironmentImpl envImpl,
boolean allowCreate)
throws DatabaseNotFoundException
- Throws:
DatabaseNotFoundException
- if allowCreate is false and the sync
DB does not exist.
writeProcessorMetadata
public void writeProcessorMetadata(Environment env,
Transaction txn,
String processorName,
ProcessorMetadata metadata)
readProcessorMetadata
public ProcessorMetadata readProcessorMetadata(Environment env,
Transaction txn,
SyncProcessor processor)
writeChangeSetData
public void writeChangeSetData(Environment env,
Transaction txn,
String processorName,
String dataSetName,
DatabaseEntry data,
SyncDB.OpType opType)
generateKey
public static String generateKey(String processorName,
String dataSetName,
SyncDB.DataType dataType)
readChangeSetData
public void readChangeSetData(Environment env,
Transaction txn,
String processorName,
String dataSetName,
DatabaseEntry data)
writeProcessorTxnData
public void writeProcessorTxnData(Environment env,
Transaction txn,
String processorName,
String dataSetName,
DatabaseEntry data)
readProcessorTxnData
public void readProcessorTxnData(Environment env,
Transaction txn,
String processorName,
String dataSetName,
DatabaseEntry data)
getCount
public long getCount()
getDatabaseImpl
public DatabaseImpl getDatabaseImpl()
readDataForType
public Map<String,DatabaseEntry> readDataForType(SyncDB.DataType dataType,
Environment env)
Copyright (c) 2004-2012 Oracle. All rights reserved.