public class SyncDB
extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
static class |
SyncDB.DataType |
static class |
SyncDB.OpType |
Constructor and Description |
---|
SyncDB(EnvironmentImpl envImpl,
boolean allowCreate) |
Modifier and Type | Method and Description |
---|---|
static java.lang.String |
generateKey(java.lang.String processorName,
java.lang.String dataSetName,
SyncDB.DataType dataType) |
long |
getCount() |
DatabaseImpl |
getDatabaseImpl() |
void |
readChangeSetData(Environment env,
Transaction txn,
java.lang.String processorName,
java.lang.String dataSetName,
DatabaseEntry data) |
java.util.Map<java.lang.String,DatabaseEntry> |
readDataForType(SyncDB.DataType dataType,
Environment env) |
ProcessorMetadata |
readProcessorMetadata(Environment env,
Transaction txn,
SyncProcessor processor) |
void |
readProcessorTxnData(Environment env,
Transaction txn,
java.lang.String processorName,
java.lang.String dataSetName,
DatabaseEntry data) |
void |
writeChangeSetData(Environment env,
Transaction txn,
java.lang.String processorName,
java.lang.String dataSetName,
DatabaseEntry data,
SyncDB.OpType opType) |
void |
writeProcessorMetadata(Environment env,
Transaction txn,
java.lang.String processorName,
ProcessorMetadata metadata) |
void |
writeProcessorTxnData(Environment env,
Transaction txn,
java.lang.String processorName,
java.lang.String dataSetName,
DatabaseEntry data) |
public SyncDB(EnvironmentImpl envImpl, boolean allowCreate) throws DatabaseNotFoundException
DatabaseNotFoundException
- if allowCreate is false and the sync
DB does not exist.public void writeProcessorMetadata(Environment env, Transaction txn, java.lang.String processorName, ProcessorMetadata metadata)
public ProcessorMetadata readProcessorMetadata(Environment env, Transaction txn, SyncProcessor processor)
public void writeChangeSetData(Environment env, Transaction txn, java.lang.String processorName, java.lang.String dataSetName, DatabaseEntry data, SyncDB.OpType opType)
public static java.lang.String generateKey(java.lang.String processorName, java.lang.String dataSetName, SyncDB.DataType dataType)
public void readChangeSetData(Environment env, Transaction txn, java.lang.String processorName, java.lang.String dataSetName, DatabaseEntry data)
public void writeProcessorTxnData(Environment env, Transaction txn, java.lang.String processorName, java.lang.String dataSetName, DatabaseEntry data)
public void readProcessorTxnData(Environment env, Transaction txn, java.lang.String processorName, java.lang.String dataSetName, DatabaseEntry data)
public long getCount()
public DatabaseImpl getDatabaseImpl()
public java.util.Map<java.lang.String,DatabaseEntry> readDataForType(SyncDB.DataType dataType, Environment env)
Copyright (c) 2004-2012 Oracle. All rights reserved.