com.sleepycat.je.sync.impl
Class SyncDB

java.lang.Object
  extended by 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.


Nested Class Summary
static class SyncDB.DataType
           
static class SyncDB.OpType
           
 
Constructor Summary
SyncDB(EnvironmentImpl envImpl, boolean allowCreate)
           
 
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
 

Constructor Detail

SyncDB

public SyncDB(EnvironmentImpl envImpl,
              boolean allowCreate)
       throws DatabaseNotFoundException
Throws:
DatabaseNotFoundException - if allowCreate is false and the sync DB does not exist.
Method Detail

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.