OStorageRemote (OrientDB 2.2.1-SNAPSHOT API)

java.lang.Object
- com.orientechnologies.orient.core.storage.OStorageAbstract
- - com.orientechnologies.orient.client.remote.OStorageRemote

All Implemented Interfaces:

OSharedContainer, OStorage, OStorageProxy, OBackupable
```
public class OStorageRemote
extends OStorageAbstract
implements OStorageProxy
```
This object is bound to each remote ODatabase instances.

Nested Class Summary

Nested Classes
Modifier and Type Class and Description

static class OStorageRemote.CONNECTION_STRATEGY
- Nested classes/interfaces inherited from interface com.orientechnologies.orient.core.storage.OStorage
  OStorage.LOCKING_STRATEGY, OStorage.SIZE, OStorage.STATUS

Nested Classes
Modifier and Type	Class and Description
`static class`	`OStorageRemote.CONNECTION_STRATEGY`

Field Summary

Fields
Modifier and Type	Field and Description
`protected Map<String,OCluster>`	`clusterMap`
`static String`	`DRIVER_NAME`
`static String`	`PARAM_CONNECTION_STRATEGY`
`protected List<String>`	`serverURLs`

Fields inherited from class com.orientechnologies.orient.core.storage.OStorageAbstract
componentsFactory, configuration, dataLock, mode, name, stateLock, status, storageThreadGroup, url, version

Fields inherited from interface com.orientechnologies.orient.core.storage.OStorage
CLUSTER_DEFAULT_NAME

Constructor Summary

Constructors
Constructor and Description
`OStorageRemote(String iClientId, String iURL, String iMode)`
`OStorageRemote(String iClientId, String iURL, String iMode, OStorage.STATUS status, boolean managePushMessages)`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`int`	`addCluster(String iClusterName, boolean forceListBased, Object... iArguments)` Add a new cluster into the storage.
`int`	`addCluster(String iClusterName, int iRequestedId, boolean forceListBased, Object... iParameters)` Add a new cluster into the storage.
`protected String`	`addHost(String host)` Registers the remote server with port.
`int`	`addUser()`
`List<String>`	`backup(OutputStream out, Map<String,Object> options, Callable<Object> callable, OCommandOutputListener iListener, int compressionLevel, int bufferSize)` Executes a backup of the database.
`OChannelBinaryAsynchClient`	`beginRequest(OChannelBinaryAsynchClient network, byte iCommand)` Acquire a network channel from the pool.
`void`	`beginResponse(OChannelBinaryAsynchClient iNetwork)` Starts listening the response.
`OPhysicalPosition[]`	`ceilingPhysicalPositions(int clusterId, OPhysicalPosition physicalPosition)`
`boolean`	`cleanOutRecord(ORecordId recordId, int recordVersion, int iMode, ORecordCallback<Boolean> callback)`
`void`	`close(boolean iForce, boolean onDelete)`
`Object`	`command(OCommandRequestText iCommand)` Execute the command remotely and get the results back.
`List<ORecordOperation>`	`commit(OTransaction iTx, Runnable callback)`
`OStorageRemote`	`copy(ODatabaseDocumentTx source, ODatabaseDocumentTx dest)`
`long`	`count(int iClusterId)`
`long`	`count(int[] iClusterIds)`
`long`	`count(int[] iClusterIds, boolean countTombstones)`
`long`	`count(int iClusterId, boolean countTombstones)`
`long`	`countRecords()` Returns the total number of records.
`void`	`create(Map<String,Object> iOptions)`
`OStorageOperationResult<OPhysicalPosition>`	`createRecord(ORecordId iRid, byte[] iContent, int iRecordVersion, byte iRecordType, int iMode, ORecordCallback<Long> iCallback)`
`void`	`delete()`
`OStorageOperationResult<Boolean>`	`deleteRecord(ORecordId iRid, int iVersion, int iMode, ORecordCallback<Boolean> iCallback)`
`boolean`	`dropCluster(int iClusterId, boolean iTruncate)` Drops a cluster.
`void`	`endRequest(OChannelBinaryAsynchClient iNetwork)` Ends the request and unlock the write lock
`void`	`endResponse(OChannelBinaryAsynchClient iNetwork)` End response reached: release the channel in the pool to being reused
`boolean`	`exists()`
`OPhysicalPosition[]`	`floorPhysicalPositions(int clusterId, OPhysicalPosition physicalPosition)`
`OContextConfiguration`	`getClientConfiguration()`
`OCluster`	`getClusterById(int iClusterId)`
`OCluster`	`getClusterByName(String iClusterName)`
`ODocument`	`getClusterConfiguration()`
`long[]`	`getClusterDataRange(int iClusterId)` Returns a pair of long values telling the begin and end positions of data in the requested cluster.
`int`	`getClusterIdByName(String iClusterName)`
`Collection<OCluster>`	`getClusterInstances()`
`int`	`getClusterMap()`
`Set<String>`	`getClusterNames()`
`int`	`getClusters()`
`ORecordConflictStrategy`	`getConflictStrategy()`
`protected String`	`getCurrentServerURL()`
`protected OStorageRemoteSession`	`getCurrentSession()`
`int`	`getDefaultClusterId()`
`protected int`	`getDefaultPort()`
`protected int`	`getDefaultSSLPort()`
`OEngineRemote`	`getEngine()`
`OChannelBinaryAsynchClient`	`getNetwork(String iCurrentURL)`
`protected String`	`getNextAvailableServerURL(boolean iIsConnectOperation, OStorageRemoteSession session)`
`String`	`getPhysicalClusterNameById(int iClusterId)`
`ORecordMetadata`	`getRecordMetadata(ORID rid)`
`protected void`	`getResponse(OChannelBinaryAsynchClient iNetwork)`
`OSBTreeCollectionManager`	`getSBtreeCollectionManager()`
`protected String`	`getServerURFromList(boolean iNextAvailable, OStorageRemoteSession session)`
`String`	`getServerURL()`
`int`	`getSessionId()`
`long`	`getSize()` Returns the size of the database.
`String`	`getType()` Returns the storage's type.
`String`	`getURL()`
`String`	`getUserName()`
`int`	`getUsers()`
`long`	`getVersion()` Returns current storage's version as serial.
`OStorageOperationResult<Boolean>`	`hideRecord(ORecordId recordId, int mode, ORecordCallback<Boolean> callback)`
`OPhysicalPosition[]`	`higherPhysicalPositions(int iClusterId, OPhysicalPosition iClusterPosition)`
`String`	`incrementalBackup(String backupDirectory)`
`OUncompletedCommit<List<ORecordOperation>>`	`initiateCommit(OTransaction iTx, Runnable callback)`
`boolean`	`isAssigningClusterIds()`
`boolean`	`isClosed()`
`boolean`	`isPermanentRequester()`
`boolean`	`isRemote()`
`OPhysicalPosition[]`	`lowerPhysicalPositions(int iClusterId, OPhysicalPosition physicalPosition)`
`<T> T`	`networkOperation(OStorageRemoteOperation<T> operation, String errorMessage)`
`void`	`open(String iUserName, String iUserPassword, Map<String,Object> iOptions)`
`protected String`	`openRemoteDatabase()`
`void`	`openRemoteDatabase(OChannelBinaryAsynchClient network)`
`protected String`	`openRemoteDatabase(String currentURL)`
`protected void`	`parseServerURLs()` Parse the URLs.
`OStorageOperationResult<ORawBuffer>`	`readRecord(ORecordId iRid, String iFetchPlan, boolean iIgnoreCache, ORecordCallback<ORawBuffer> iCallback)`
`OStorageOperationResult<ORawBuffer>`	`readRecordIfVersionIsNotLatest(ORecordId rid, String fetchPlan, boolean ignoreCache, int recordVersion)`
`protected Object`	`readSynchResult(OChannelBinaryAsynchClient network, ODatabaseDocument database)`
`OStorageOperationResult<Integer>`	`recyclePosition(ORecordId iRecordId, byte[] iContent, int iVersion, byte recordType)` Resurrects a record that was previously deleted, with a new content.
`void`	`reload()`
`int`	`removeUser()`
`protected String`	`reopenRemoteDatabase()`
`void`	`restore(InputStream in, Map<String,Object> options, Callable<Object> callable, OCommandOutputListener iListener)` Executes a restore of a database backup.
`void`	`restoreFromIncrementalBackup(String filePath)`
`void`	`rollback(OTransaction iTx)`
`protected void`	`sendClientInfo(OChannelBinaryAsynchClient network, String driverName, boolean supportsPushMessages, boolean collectStats)`
`void`	`setConflictStrategy(ORecordConflictStrategy iResolver)`
`void`	`setDefaultClusterId(int defaultClusterId)`
`void`	`synch()`
`void`	`updateClusterConfiguration(String iConnectedURL, byte[] obj)`
`OStorageOperationResult<Integer>`	`updateRecord(ORecordId iRid, boolean updateContent, byte[] iContent, int iVersion, byte iRecordType, int iMode, ORecordCallback<Integer> iCallback)`
`protected String`	`useNewServerURL(String iUrl)`

Methods inherited from class com.orientechnologies.orient.core.storage.OStorageAbstract
callInLock, checkForClusterPermissions, checkForRecordValidity, close, dropCluster, existsResource, getComponentsFactory, getConfiguration, getName, getResource, getStatus, getUnderlying, isDistributed, normalizeName, removeResource, shutdown, toString

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface com.orientechnologies.orient.core.storage.OStorage
callInLock, checkForClusterPermissions, checkForRecordValidity, close, dropCluster, getComponentsFactory, getConfiguration, getName, getStatus, getUnderlying, isDistributed, shutdown

Methods inherited from interface com.orientechnologies.common.concur.resource.OSharedContainer
existsResource, getResource, removeResource

Field Detail

PARAM_CONNECTION_STRATEGY

public static final String PARAM_CONNECTION_STRATEGY

See Also:: Constant Field Values

DRIVER_NAME
```
public static final String DRIVER_NAME
```
See Also:

Constant Field Values

serverURLs

protected final List<String> serverURLs

clusterMap

protected final Map<String,OCluster> clusterMap

Constructor Detail

OStorageRemote

public OStorageRemote(String iClientId,
                      String iURL,
                      String iMode)
               throws IOException

Throws:: IOException

OStorageRemote

public OStorageRemote(String iClientId,
                      String iURL,
                      String iMode,
                      OStorage.STATUS status,
                      boolean managePushMessages)
               throws IOException

Throws:: IOException

Method Detail

networkOperation

public <T> T networkOperation(OStorageRemoteOperation<T> operation,
                              String errorMessage)

isAssigningClusterIds
```
public boolean isAssigningClusterIds()
```
Specified by:

isAssigningClusterIds in interface OStorage

Overrides:

isAssigningClusterIds in class OStorageAbstract

getSessionId
```
public int getSessionId()
```

getServerURL
```
public String getServerURL()
```

open

public void open(String iUserName,
                 String iUserPassword,
                 Map<String,Object> iOptions)

Specified by:: open in interface OStorage

getSBtreeCollectionManager
```
public OSBTreeCollectionManager getSBtreeCollectionManager()
```
Specified by:

getSBtreeCollectionManager in interface OStorage

reload
```
public void reload()
```
Specified by:

reload in interface OStorage

create

public void create(Map<String,Object> iOptions)

Specified by:: create in interface OStorage

exists
```
public boolean exists()
```
Specified by:

exists in interface OStorage

close
```
public void close(boolean iForce,
                  boolean onDelete)
```
Specified by:

close in interface OStorage

Overrides:

close in class OStorageAbstract

getUsers
```
public int getUsers()
```
Specified by:

getUsers in interface OStorageProxy

addUser
```
public int addUser()
```
Specified by:

addUser in interface OStorageProxy

removeUser
```
public int removeUser()
```
Specified by:

removeUser in interface OStorageProxy

delete
```
public void delete()
```
Specified by:

delete in interface OStorage

getClusterNames
```
public Set<String> getClusterNames()
```
Specified by:

getClusterNames in interface OStorage

createRecord

public OStorageOperationResult<OPhysicalPosition> createRecord(ORecordId iRid,
                                                               byte[] iContent,
                                                               int iRecordVersion,
                                                               byte iRecordType,
                                                               int iMode,
                                                               ORecordCallback<Long> iCallback)

Specified by:: createRecord in interface OStorage

getRecordMetadata
```
public ORecordMetadata getRecordMetadata(ORID rid)
```
Specified by:

getRecordMetadata in interface OStorage

readRecordIfVersionIsNotLatest

public OStorageOperationResult<ORawBuffer> readRecordIfVersionIsNotLatest(ORecordId rid,
                                                                          String fetchPlan,
                                                                          boolean ignoreCache,
                                                                          int recordVersion)
                                                                   throws ORecordNotFoundException

Specified by:: readRecordIfVersionIsNotLatest in interface OStorage
Throws:: ORecordNotFoundException

readRecord

public OStorageOperationResult<ORawBuffer> readRecord(ORecordId iRid,
                                                      String iFetchPlan,
                                                      boolean iIgnoreCache,
                                                      ORecordCallback<ORawBuffer> iCallback)

Specified by:: readRecord in interface OStorage

incrementalBackup
```
public String incrementalBackup(String backupDirectory)
```
Specified by:

incrementalBackup in interface OStorage

Returns:

Backup file name

restoreFromIncrementalBackup
```
public void restoreFromIncrementalBackup(String filePath)
```
Specified by:

restoreFromIncrementalBackup in interface OStorage

updateRecord

public OStorageOperationResult<Integer> updateRecord(ORecordId iRid,
                                                     boolean updateContent,
                                                     byte[] iContent,
                                                     int iVersion,
                                                     byte iRecordType,
                                                     int iMode,
                                                     ORecordCallback<Integer> iCallback)

Specified by:: updateRecord in interface OStorage

recyclePosition

public OStorageOperationResult<Integer> recyclePosition(ORecordId iRecordId,
                                                        byte[] iContent,
                                                        int iVersion,
                                                        byte recordType)

Description copied from interface: OStorage

Resurrects a record that was previously deleted, with a new content.

Specified by:: recyclePosition in interface OStorage

deleteRecord

public OStorageOperationResult<Boolean> deleteRecord(ORecordId iRid,
                                                     int iVersion,
                                                     int iMode,
                                                     ORecordCallback<Boolean> iCallback)

Specified by:: deleteRecord in interface OStorage

hideRecord

public OStorageOperationResult<Boolean> hideRecord(ORecordId recordId,
                                                   int mode,
                                                   ORecordCallback<Boolean> callback)

Specified by:: hideRecord in interface OStorage

cleanOutRecord

public boolean cleanOutRecord(ORecordId recordId,
                              int recordVersion,
                              int iMode,
                              ORecordCallback<Boolean> callback)

Specified by:: cleanOutRecord in interface OStorage

backup
```
public List<String> backup(OutputStream out,
                           Map<String,Object> options,
                           Callable<Object> callable,
                           OCommandOutputListener iListener,
                           int compressionLevel,
                           int bufferSize)
                    throws IOException
```
Description copied from interface: OBackupable

Executes a backup of the database. During the backup the database will be frozen in read-only mode.

Specified by:

backup in interface OBackupable

Parameters:

out - OutputStream used to write the backup content. Use a FileOutputStream to make the backup persistent on disk

options - Backup options as Map object

callable - Callback to execute when the database is locked

iListener - Listener called for backup messages

compressionLevel - ZIP Compression level between 1 (the minimum) and 9 (maximum). The bigger is the compression, the smaller will be the final backup content, but will consume more CPU and time to execute

bufferSize - Buffer size in bytes, the bigger is the buffer, the more efficient will be the compression

Throws:

IOException

See Also:

ODatabaseExport

restore
```
public void restore(InputStream in,
                    Map<String,Object> options,
                    Callable<Object> callable,
                    OCommandOutputListener iListener)
             throws IOException
```
Description copied from interface: OBackupable

Executes a restore of a database backup. During the restore the database will be frozen in read-only mode.

Specified by:

restore in interface OBackupable

Parameters:

in - InputStream used to read the backup content. Use a FileInputStream to read a backup on a disk

options - Backup options as Map object

callable - Callback to execute when the database is locked

iListener - Listener called for backup messages

Throws:

IOException

See Also:

ODatabaseImport

getClientConfiguration

public OContextConfiguration getClientConfiguration()

count
```
public long count(int iClusterId)
```
Specified by:

count in interface OStorage

count

public long count(int iClusterId,
                  boolean countTombstones)

Specified by:: count in interface OStorage

getClusterDataRange
```
public long[] getClusterDataRange(int iClusterId)
```
Description copied from interface: OStorage

Returns a pair of long values telling the begin and end positions of data in the requested cluster. Useful to know the range of the records.

Specified by:

getClusterDataRange in interface OStorage

Parameters:

iClusterId - Cluster id

higherPhysicalPositions

public OPhysicalPosition[] higherPhysicalPositions(int iClusterId,
                                                   OPhysicalPosition iClusterPosition)

Specified by:: higherPhysicalPositions in interface OStorage

ceilingPhysicalPositions

public OPhysicalPosition[] ceilingPhysicalPositions(int clusterId,
                                                    OPhysicalPosition physicalPosition)

Specified by:: ceilingPhysicalPositions in interface OStorage

lowerPhysicalPositions

public OPhysicalPosition[] lowerPhysicalPositions(int iClusterId,
                                                  OPhysicalPosition physicalPosition)

Specified by:: lowerPhysicalPositions in interface OStorage

floorPhysicalPositions

public OPhysicalPosition[] floorPhysicalPositions(int clusterId,
                                                  OPhysicalPosition physicalPosition)

Specified by:: floorPhysicalPositions in interface OStorage

getSize
```
public long getSize()
```
Description copied from interface: OStorage

Returns the size of the database.

Specified by:

getSize in interface OStorage

countRecords
```
public long countRecords()
```
Description copied from interface: OStorage

Returns the total number of records.

Specified by:

countRecords in interface OStorage

Overrides:

countRecords in class OStorageAbstract

count
```
public long count(int[] iClusterIds)
```
Specified by:

count in interface OStorage

count

public long count(int[] iClusterIds,
                  boolean countTombstones)

Specified by:: count in interface OStorage

command
```
public Object command(OCommandRequestText iCommand)
```
Execute the command remotely and get the results back.

Specified by:

command in interface OStorage

readSynchResult

protected Object readSynchResult(OChannelBinaryAsynchClient network,
                                 ODatabaseDocument database)
                          throws IOException

Throws:: IOException

commit

public List<ORecordOperation> commit(OTransaction iTx,
                                     Runnable callback)

Specified by:: commit in interface OStorage

initiateCommit

public OUncompletedCommit<List<ORecordOperation>> initiateCommit(OTransaction iTx,
                                                                 Runnable callback)

Specified by:: initiateCommit in interface OStorage

rollback
```
public void rollback(OTransaction iTx)
```
Specified by:

rollback in interface OStorage

getClusterIdByName
```
public int getClusterIdByName(String iClusterName)
```
Specified by:

getClusterIdByName in interface OStorage

getDefaultClusterId
```
public int getDefaultClusterId()
```
Specified by:

getDefaultClusterId in interface OStorage

setDefaultClusterId
```
public void setDefaultClusterId(int defaultClusterId)
```
Specified by:

setDefaultClusterId in interface OStorage

addCluster
```
public int addCluster(String iClusterName,
                      boolean forceListBased,
                      Object... iArguments)
```
Description copied from interface: OStorage

Add a new cluster into the storage.

Specified by:

addCluster in interface OStorage

Parameters:

iClusterName - name of the cluster

addCluster
```
public int addCluster(String iClusterName,
                      int iRequestedId,
                      boolean forceListBased,
                      Object... iParameters)
```
Description copied from interface: OStorage

Add a new cluster into the storage.

Specified by:

addCluster in interface OStorage

Parameters:

iClusterName - name of the cluster

iRequestedId - requested id of the cluster

dropCluster
```
public boolean dropCluster(int iClusterId,
                           boolean iTruncate)
```
Description copied from interface: OStorage

Drops a cluster.

Specified by:

dropCluster in interface OStorage

Parameters:

iClusterId - id of the cluster to delete

Returns:

true if has been removed, otherwise false

synch
```
public void synch()
```
Specified by:

synch in interface OStorage

getPhysicalClusterNameById
```
public String getPhysicalClusterNameById(int iClusterId)
```
Specified by:

getPhysicalClusterNameById in interface OStorage

getClusterMap
```
public int getClusterMap()
```

getClusterInstances
```
public Collection<OCluster> getClusterInstances()
```
Specified by:

getClusterInstances in interface OStorage

getClusterById
```
public OCluster getClusterById(int iClusterId)
```
Specified by:

getClusterById in interface OStorage

getVersion
```
public long getVersion()
```
Description copied from class: OStorageAbstract

Returns current storage's version as serial.

Specified by:

getVersion in interface OStorage

Overrides:

getVersion in class OStorageAbstract

getClusterConfiguration

public ODocument getClusterConfiguration()

endRequest

public void endRequest(OChannelBinaryAsynchClient iNetwork)
                throws IOException

Ends the request and unlock the write lock

Throws:: IOException

endResponse
```
public void endResponse(OChannelBinaryAsynchClient iNetwork)
```
End response reached: release the channel in the pool to being reused

isRemote
```
public boolean isRemote()
```
Specified by:

isRemote in interface OStorage

isPermanentRequester
```
public boolean isPermanentRequester()
```

updateClusterConfiguration

public void updateClusterConfiguration(String iConnectedURL,
                                       byte[] obj)

getClusterByName
```
public OCluster getClusterByName(String iClusterName)
```
Specified by:

getClusterByName in interface OStorage

Specified by:

getClusterByName in class OStorageAbstract

getConflictStrategy
```
public ORecordConflictStrategy getConflictStrategy()
```
Specified by:

getConflictStrategy in interface OStorage

setConflictStrategy

public void setConflictStrategy(ORecordConflictStrategy iResolver)

Specified by:: setConflictStrategy in interface OStorage

getURL
```
public String getURL()
```
Specified by:

getURL in interface OStorage

Overrides:

getURL in class OStorageAbstract

getClusters
```
public int getClusters()
```
Specified by:

getClusters in interface OStorage

getType
```
public String getType()
```
Description copied from interface: OStorage

Returns the storage's type.

Specified by:

getType in interface OStorage

Returns:

getEngine
```
public OEngineRemote getEngine()
```

getUserName
```
public String getUserName()
```
Specified by:

getUserName in interface OStorageProxy

reopenRemoteDatabase

protected String reopenRemoteDatabase()
                               throws IOException

Throws:: IOException

openRemoteDatabase

protected String openRemoteDatabase()
                             throws IOException

Throws:: IOException

openRemoteDatabase

public void openRemoteDatabase(OChannelBinaryAsynchClient network)
                        throws IOException

Throws:: IOException

openRemoteDatabase

protected String openRemoteDatabase(String currentURL)

useNewServerURL

protected String useNewServerURL(String iUrl)

sendClientInfo

protected void sendClientInfo(OChannelBinaryAsynchClient network,
                              String driverName,
                              boolean supportsPushMessages,
                              boolean collectStats)
                       throws IOException

Throws:: IOException

parseServerURLs
```
protected void parseServerURLs()
```
Parse the URLs. Multiple URLs must be separated by semicolon (;)

addHost

protected String addHost(String host)

Registers the remote server with port.

getDefaultPort
```
protected int getDefaultPort()
```

getDefaultSSLPort
```
protected int getDefaultSSLPort()
```

beginRequest
```
public OChannelBinaryAsynchClient beginRequest(OChannelBinaryAsynchClient network,
                                               byte iCommand)
                                        throws IOException
```
Acquire a network channel from the pool. Don't lock the write stream since the connection usage is exclusive.

Parameters:

iCommand - id. Ids described at OChannelBinaryProtocol

Returns:

connection to server

Throws:

IOException

getNextAvailableServerURL

protected String getNextAvailableServerURL(boolean iIsConnectOperation,
                                           OStorageRemoteSession session)

getCurrentServerURL

protected String getCurrentServerURL()

getServerURFromList

protected String getServerURFromList(boolean iNextAvailable,
                                     OStorageRemoteSession session)

getNetwork

public OChannelBinaryAsynchClient getNetwork(String iCurrentURL)

beginResponse

public void beginResponse(OChannelBinaryAsynchClient iNetwork)
                   throws IOException

Starts listening the response.

Throws:: IOException

getResponse

protected void getResponse(OChannelBinaryAsynchClient iNetwork)
                    throws IOException

Throws:: IOException

getCurrentSession

protected OStorageRemoteSession getCurrentSession()

isClosed
```
public boolean isClosed()
```
Specified by:

isClosed in interface OStorage

Overrides:

isClosed in class OStorageAbstract

copy

public OStorageRemote copy(ODatabaseDocumentTx source,
                           ODatabaseDocumentTx dest)

Specified by:: copy in interface OStorageProxy

Class OStorageRemote

Nested Class Summary

Nested classes/interfaces inherited from interface com.orientechnologies.orient.core.storage.OStorage

Field Summary

Fields inherited from class com.orientechnologies.orient.core.storage.OStorageAbstract

Fields inherited from interface com.orientechnologies.orient.core.storage.OStorage

Constructor Summary

Method Summary

Methods inherited from class com.orientechnologies.orient.core.storage.OStorageAbstract

Methods inherited from class java.lang.Object

Methods inherited from interface com.orientechnologies.orient.core.storage.OStorage

Methods inherited from interface com.orientechnologies.common.concur.resource.OSharedContainer

Field Detail

PARAM_CONNECTION_STRATEGY

DRIVER_NAME

serverURLs

clusterMap

Constructor Detail

OStorageRemote

OStorageRemote

Method Detail

networkOperation

isAssigningClusterIds

getSessionId

getServerURL

open

getSBtreeCollectionManager

reload

create

exists

close

getUsers

addUser

removeUser

delete

getClusterNames

createRecord

getRecordMetadata

readRecordIfVersionIsNotLatest

readRecord

incrementalBackup

restoreFromIncrementalBackup

updateRecord

recyclePosition

deleteRecord

hideRecord

cleanOutRecord

backup

restore

getClientConfiguration

count

count

getClusterDataRange

higherPhysicalPositions

ceilingPhysicalPositions

lowerPhysicalPositions

floorPhysicalPositions

getSize

countRecords

count

count

command

readSynchResult

commit

initiateCommit

rollback

getClusterIdByName

getDefaultClusterId

setDefaultClusterId

addCluster

addCluster

dropCluster

synch

getPhysicalClusterNameById

getClusterMap

getClusterInstances

getClusterById

getVersion

getClusterConfiguration

endRequest