Package com.orientechnologies.orient.client.remote

Class OStorageRemote

java.lang.Object

com.orientechnologies.orient.client.remote.OStorageRemote

All Implemented Interfaces:

ORemotePushHandler, OStorage, OStorageInfo, OStorageProxy, OBackupable

public class OStorageRemote
extends Object
implements OStorageProxy, ORemotePushHandler, OStorage

This object is bound to each remote ODatabase instances.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	OStorageRemote.CONNECTION_STRATEGY

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

OStorage.LOCKING_STRATEGY, OStorage.STATUS

Field Summary

Fields

Modifier and Type	Field	Description
static final String	ADDRESS_SEPARATOR
protected OCurrentStorageComponentsFactory	componentsFactory
protected OStorageConfiguration	configuration
ORemoteConnectionManager	connectionManager
protected final OrientDBRemote	context
static final String	DRIVER_NAME
protected String	name
static final String	PARAM_CONNECTION_STRATEGY	Deprecated.
protected OSharedContext	sharedContext
protected final ReentrantReadWriteLock	stateLock
protected OStorage.STATUS	status
protected final String	url

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

CLUSTER_DEFAULT_NAME

Constructor Summary

Constructors

Constructor	Description
OStorageRemote(ORemoteURLs hosts, String name, OrientDBRemote context, String iMode, ORemoteConnectionManager connectionManager, OrientDBConfig config)
OStorageRemote(ORemoteURLs hosts, String name, OrientDBRemote context, String iMode, ORemoteConnectionManager connectionManager, OStorage.STATUS status, OrientDBConfig config)

Method Summary

Modifier and Type	Method	Description
int	addCluster(String iClusterName, int iRequestedId)	Add a new cluster into the storage.
int	addCluster(String iClusterName, Object... iArguments)	Add a new cluster into the storage.
void	addNewClusterToConfiguration(int clusterId, String iClusterName)
int	addUser()
<T extends OBinaryResponse> T	asyncNetworkOperationNoRetry(OBinaryAsyncRequest<T> request, int mode, ORecordId recordId, ORecordCallback<T> callback, String errorMessage)
<T extends OBinaryResponse> T	asyncNetworkOperationRetry(OBinaryAsyncRequest<T> request, int mode, ORecordId recordId, ORecordCallback<T> callback, String errorMessage, int retry)
List<String>	backup(OutputStream out, Map<String,Object> options, Callable<Object> callable, OCommandOutputListener iListener, int compressionLevel, int bufferSize)	Executes a backup of the database.
<T> T	baseNetworkOperation(OStorageRemoteOperation<T> operation, String errorMessage, int retry)
OChannelBinaryAsynchClient	beginRequest(OChannelBinaryAsynchClient network, byte iCommand, OStorageRemoteSession session)	Acquire a network channel from the pool.
static void	beginResponse(OChannelBinaryAsynchClient iNetwork, OStorageRemoteSession session)
void	beginTransaction(ODatabaseDocumentRemote database, OTransactionOptimistic transaction)
OPhysicalPosition[]	ceilingPhysicalPositions(int clusterId, OPhysicalPosition physicalPosition)
boolean	checkForRecordValidity(OPhysicalPosition ppos)
boolean	cleanOutRecord(ORecordId recordId, int recordVersion, int iMode, ORecordCallback<Boolean> callback)
void	clearProperties()
void	close()
void	close(boolean iForce, boolean onDelete)
void	closeQuery(ODatabaseDocumentRemote database, String queryId)
ORemoteQueryResult	command(ODatabaseDocumentRemote db, String query, Object[] args)
ORemoteQueryResult	command(ODatabaseDocumentRemote db, String query, Map args)
Object	command(OCommandRequestText iCommand)	Execute the command remotely and get the results back.
List<ORecordOperation>	commit(OTransactionInternal iTx)
OStorageRemote	copy(ODatabaseDocumentRemote source, ODatabaseDocumentRemote 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(OContextConfiguration contextConfiguration)
OBinaryPushRequest	createPush(byte type)
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)	Drops a cluster.
boolean	dropCluster(String iClusterName)
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
ORemoteQueryResult	execute(ODatabaseDocumentRemote db, String language, String query, Object[] args)
ORemoteQueryResult	execute(ODatabaseDocumentRemote db, String language, String query, Map args)
void	executeLiveQueryPush(OLiveQueryPushRequest pushRequest)
OBinaryPushResponse	executeUpdateDistributedConfig(OPushDistributedConfigurationRequest request)
OBinaryPushResponse	executeUpdateFunction(OPushFunctionsRequest request)
OBinaryPushResponse	executeUpdateIndexManager(OPushIndexManagerRequest request)
OBinaryPushResponse	executeUpdateSchema(OPushSchemaRequest request)
OBinaryPushResponse	executeUpdateSequences(OPushSequencesRequest request)
OBinaryPushResponse	executeUpdateStorageConfig(OPushStorageConfigurationRequest payload)
boolean	exists()
void	fetchNextPage(ODatabaseDocumentRemote database, ORemoteResultSet rs)
void	fetchTransaction(ODatabaseDocumentRemote remote)
OPhysicalPosition[]	floorPhysicalPositions(int clusterId, OPhysicalPosition physicalPosition)
void	fullIncrementalBackup(OutputStream stream)
OContextConfiguration	getClientConfiguration()
ODocument	getClusterConfiguration()
long[]	getClusterDataRange(int iClusterId)	Returns a pair of long values telling the begin and end positions of data in the requested cluster.
String	getClusterEncryption(int clusterId)
int	getClusterIdByName(String iClusterName)
Collection<OCluster>	getClusterInstances()
int	getClusterMap()
String	getClusterName(int clusterId)
String	getClusterNameById(int clusterId)
Set<String>	getClusterNames()
long	getClusterNextPosition(int clusterId)
String	getClusterRecordConflictStrategy(int clusterId)
long	getClusterRecordsSizeById(int clusterId)
long	getClusterRecordsSizeByName(String clusterName)
int	getClusters()
int[]	getClustersIds(Set<String> filterClusters)
OCurrentStorageComponentsFactory	getComponentsFactory()
OStorageConfiguration	getConfiguration()
OrientDBInternal	getContext()
String	getCreatedAtVersion()	Supported only in embedded storage.
protected String	getCurrentServerURL()
protected OStorageRemoteSession	getCurrentSession()
int	getDefaultClusterId()
long	getLastClusterPosition(int clusterId)
String	getName()
OChannelBinaryAsynchClient	getNetwork(String iCurrentURL)
static OChannelBinaryAsynchClient	getNetwork(String iCurrentURL, ORemoteConnectionManager connectionManager, OContextConfiguration config)
protected String	getNextAvailableServerURL(boolean iIsConnectOperation, OStorageRemoteSession session)
String	getPhysicalClusterNameById(int iClusterId)
ORecordConflictStrategy	getRecordConflictStrategy()
ORecordMetadata	getRecordMetadata(ORID rid)
OPaginatedCluster.RECORD_STATUS	getRecordStatus(ORID rid)
OSBTreeCollectionManager	getSBtreeCollectionManager()
String	getServerURL()
List<String>	getServerURLs()
int	getSessionId()
OSharedContext	getSharedContext()
long	getSize()	Returns the size of the database.
OStorage.STATUS	getStatus()	Returns the current storage's status
String	getType()	Returns the storage's type.
OStorage	getUnderlying()
String	getURL()
String	getUserName()
int	getUsers()
long	getVersion()
OPhysicalPosition[]	higherPhysicalPositions(int iClusterId, OPhysicalPosition iClusterPosition)
void	importDatabase(String options, InputStream inputStream, String name, OCommandOutputListener listener)
String	incrementalBackup(String backupDirectory, OCallable<Void,Void> started)
boolean	isAssigningClusterIds()
boolean	isClosed()
boolean	isDistributed()
boolean	isPermanentRequester()
boolean	isRemote()
boolean	isSystemCluster(int clusterId)
OLiveQueryMonitor	liveQuery(ODatabaseDocumentRemote database, String query, OLiveQueryClientListener listener, Object[] params)
OLiveQueryMonitor	liveQuery(ODatabaseDocumentRemote database, String query, OLiveQueryClientListener listener, Map<String,?> params)
OLockRecordResponse	lockRecord(OIdentifiable iRecord, OStorage.LOCKING_STRATEGY lockingStrategy, long timeout)
OPhysicalPosition[]	lowerPhysicalPositions(int iClusterId, OPhysicalPosition physicalPosition)
<T extends OBinaryResponse> T	networkOperation(OBinaryRequest<T> request, String errorMessage)
<T extends OBinaryResponse> T	networkOperationNoRetry(OBinaryRequest<T> request, String errorMessage)
<T extends OBinaryResponse> T	networkOperationRetryTimeout(OBinaryRequest<T> request, String errorMessage, int retry, int timeout)
void	onPushDisconnect(OChannelBinary network, Exception e)
void	onPushReconnect(String host)
void	open(String iUserName, String iUserPassword, OContextConfiguration conf)
protected void	openRemoteDatabase()
void	openRemoteDatabase(OChannelBinaryAsynchClient network)
protected void	openRemoteDatabase(String currentURL)
static HashMap<String,Object>	paramsArrayToParamsMap(Object[] positionalParams)
protected void	parseServerURLs()	Parse the URLs.
ORemoteQueryResult	query(ODatabaseDocumentRemote db, String query, Object[] args)
ORemoteQueryResult	query(ODatabaseDocumentRemote db, String query, Map args)
OStorageOperationResult<ORawBuffer>	readRecord(ORecordId iRid, String iFetchPlan, boolean iIgnoreCache, boolean prefetchRecords, ORecordCallback<ORawBuffer> iCallback)
OStorageOperationResult<ORawBuffer>	readRecordIfVersionIsNotLatest(ORecordId rid, String fetchPlan, boolean ignoreCache, int recordVersion)
void	reBeginTransaction(ODatabaseDocumentRemote database, OTransactionOptimistic transaction)
void	registerLiveListener(int monitorId, OLiveQueryClientListener listener)
void	reload()
void	removeClusterFromConfiguration(int iClusterId)
void	removeProperty(String property)
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	restoreFullIncrementalBackup(InputStream stream)
void	returnSocket(OChannelBinary network)
void	rollback(OTransactionInternal iTx)
ORemoteQueryResult	serverCommand(String query, Object[] args)
ORemoteQueryResult	serverCommand(String query, Map args)
void	setCharset(String charset)
boolean	setClusterAttribute(int id, OCluster.ATTRIBUTES attribute, Object value)
void	setClusterSelection(String clusterSelection)
void	setConflictStrategy(ORecordConflictStrategy iResolver)
void	setDateFormat(String dateFormat)
void	setDateTimeFormat(String dateTimeFormat)
void	setDefaultClusterId(int defaultClusterId)
void	setIndexMgrRecordId(String indexMgrRecordId)
void	setLocaleCountry(String localeCountry)
void	setLocaleLanguage(String locale)
void	setMinimumClusters(int minimumClusters)
void	setProperty(String property, String value)
void	setRecordSerializer(String recordSerializer, int version)
void	setSchemaRecordId(String schemaRecordId)
void	setSharedContext(OSharedContext sharedContext)
void	setTimeZone(TimeZone timeZoneValue)
void	setValidation(boolean validation)
void	shutdown()	This method is called in Orient.shutdown() method.
void	stickToSession()
boolean	supportIncremental()
void	synch()
void	unlockRecord(OIdentifiable iRecord)
void	unstickToSession()
void	unsubscribeLive(ODatabaseDocumentRemote database, int monitorId)
OStorageOperationResult<Integer>	updateRecord(ORecordId iRid, boolean updateContent, byte[] iContent, int iVersion, byte iRecordType, int iMode, ORecordCallback<Integer> iCallback)
void	updateStorageConfiguration(OStorageConfiguration storageConfiguration)
protected String	useNewServerURL(String iUrl)

Methods inherited from class java.lang.Object

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

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

isIcrementalBackupRunning

Field Details

PARAM_CONNECTION_STRATEGY

@Deprecated
public static final String PARAM_CONNECTION_STRATEGY

Deprecated.

See Also:

• Constant Field Values

DRIVER_NAME

public static final String DRIVER_NAME

See Also:

• Constant Field Values

connectionManager

public ORemoteConnectionManager connectionManager

context

protected final OrientDBRemote context

sharedContext

protected OSharedContext sharedContext

url

protected final String url

stateLock

protected final ReentrantReadWriteLock stateLock

configuration

protected volatile OStorageConfiguration configuration

componentsFactory

protected volatile OCurrentStorageComponentsFactory componentsFactory

name

protected String name

status

protected volatile OStorage.STATUS status

ADDRESS_SEPARATOR

public static final String ADDRESS_SEPARATOR

See Also:

• Constant Field Values

Constructor Details

OStorageRemote

public OStorageRemote(ORemoteURLs hosts,
 String name,
 OrientDBRemote context,
 String iMode,
 ORemoteConnectionManager connectionManager,
 OrientDBConfig config)
               throws IOException

Throws:

IOException

OStorageRemote

public OStorageRemote(ORemoteURLs hosts,
 String name,
 OrientDBRemote context,
 String iMode,
 ORemoteConnectionManager connectionManager,
 OStorage.STATUS status,
 OrientDBConfig config)
               throws IOException

Throws:

IOException

Method Details

getConfiguration

public OStorageConfiguration getConfiguration()

Specified by:

getConfiguration in interface OStorageInfo

checkForRecordValidity

public boolean checkForRecordValidity(OPhysicalPosition ppos)

Specified by:

checkForRecordValidity in interface OStorage

getName

public String getName()

Specified by:

getName in interface OStorage

Specified by:

getName in interface OStorageInfo

setSharedContext

public void setSharedContext(OSharedContext sharedContext)

asyncNetworkOperationNoRetry

public <T extends OBinaryResponse> T asyncNetworkOperationNoRetry(OBinaryAsyncRequest<T> request,
 int mode,
 ORecordId recordId,
 ORecordCallback<T> callback,
 String errorMessage)

asyncNetworkOperationRetry

public <T extends OBinaryResponse> T asyncNetworkOperationRetry(OBinaryAsyncRequest<T> request,
 int mode,
 ORecordId recordId,
 ORecordCallback<T> callback,
 String errorMessage,
 int retry)

networkOperationRetryTimeout

public <T extends OBinaryResponse> T networkOperationRetryTimeout(OBinaryRequest<T> request,
 String errorMessage,
 int retry,
 int timeout)

networkOperationNoRetry

public <T extends OBinaryResponse> T networkOperationNoRetry(OBinaryRequest<T> request,
 String errorMessage)

networkOperation

public <T extends OBinaryResponse> T networkOperation(OBinaryRequest<T> request,
 String errorMessage)

baseNetworkOperation

public <T> T baseNetworkOperation(OStorageRemoteOperation<T> operation,
 String errorMessage,
 int retry)

isAssigningClusterIds

public boolean isAssigningClusterIds()

Specified by:

isAssigningClusterIds in interface OStorage

Specified by:

isAssigningClusterIds in interface OStorageInfo

getCreatedAtVersion

public String getCreatedAtVersion()

Supported only in embedded storage. Use SELECT FROM metadata:storage instead.

Specified by:

getCreatedAtVersion in interface OStorage

Returns:

Version of product release under which storage was created.

getSessionId

public int getSessionId()

getServerURL

public String getServerURL()

open

public void open(String iUserName,
 String iUserPassword,
 OContextConfiguration conf)

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(OContextConfiguration contextConfiguration)

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

shutdown

public void shutdown()

Description copied from interface: OStorage

This method is called in Orient.shutdown() method. For most of the storages it means that storage will be merely closed, but sometimes additional operations are need to be taken in account.

Specified by:

shutdown in interface OStorage

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

Specified by:

getClusterNames in interface OStorageInfo

createRecord

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

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,
 boolean prefetchRecords,
 ORecordCallback<ORawBuffer> iCallback)

Specified by:

readRecord in interface OStorage

incrementalBackup

public String incrementalBackup(String backupDirectory,
 OCallable<Void,Void> started)

Specified by:

incrementalBackup in interface OStorage

Returns:

Backup file name

supportIncremental

public boolean supportIncremental()

Specified by:

supportIncremental in interface OStorage

fullIncrementalBackup

public void fullIncrementalBackup(OutputStream stream)
                           throws UnsupportedOperationException

Specified by:

fullIncrementalBackup in interface OStorage

Throws:

UnsupportedOperationException

restoreFromIncrementalBackup

public void restoreFromIncrementalBackup(String filePath)

Specified by:

restoreFromIncrementalBackup in interface OStorage

restoreFullIncrementalBackup

public void restoreFullIncrementalBackup(InputStream stream)
                                  throws UnsupportedOperationException

Specified by:

restoreFullIncrementalBackup in interface OStorage

Throws:

UnsupportedOperationException

updateRecord

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

deleteRecord

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

Specified by:

deleteRecord 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<String, Object> 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<String, Object> 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

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

stickToSession

public void stickToSession()

unstickToSession

public void unstickToSession()

query

public ORemoteQueryResult query(ODatabaseDocumentRemote db,
 String query,
 Object[] args)

query

public ORemoteQueryResult query(ODatabaseDocumentRemote db,
 String query,
 Map args)

command

public ORemoteQueryResult command(ODatabaseDocumentRemote db,
 String query,
 Object[] args)

command

public ORemoteQueryResult command(ODatabaseDocumentRemote db,
 String query,
 Map args)

serverCommand

public ORemoteQueryResult serverCommand(String query,
 Object[] args)

serverCommand

public ORemoteQueryResult serverCommand(String query,
 Map args)

execute

public ORemoteQueryResult execute(ODatabaseDocumentRemote db,
 String language,
 String query,
 Object[] args)

execute

public ORemoteQueryResult execute(ODatabaseDocumentRemote db,
 String language,
 String query,
 Map args)

closeQuery

public void closeQuery(ODatabaseDocumentRemote database,
 String queryId)

fetchNextPage

public void fetchNextPage(ODatabaseDocumentRemote database,
 ORemoteResultSet rs)

commit

public List<ORecordOperation> commit(OTransactionInternal iTx)

Specified by:

commit in interface OStorage

rollback

public void rollback(OTransactionInternal iTx)

Specified by:

rollback in interface OStorageProxy

getClusterIdByName

public int getClusterIdByName(String iClusterName)

Specified by:

getClusterIdByName in interface OStorage

Specified by:

getClusterIdByName in interface OStorageInfo

getDefaultClusterId

public int getDefaultClusterId()

Specified by:

getDefaultClusterId in interface OStorageInfo

setDefaultClusterId

public void setDefaultClusterId(int defaultClusterId)

Specified by:

setDefaultClusterId in interface OStorage

addCluster

public int addCluster(String iClusterName,
 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)

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

getClusterNameById

public String getClusterNameById(int clusterId)

Specified by:

getClusterNameById in interface OStorage

getClusterRecordsSizeById

public long getClusterRecordsSizeById(int clusterId)

Specified by:

getClusterRecordsSizeById in interface OStorage

getClusterRecordsSizeByName

public long getClusterRecordsSizeByName(String clusterName)

Specified by:

getClusterRecordsSizeByName in interface OStorage

getClusterRecordConflictStrategy

public String getClusterRecordConflictStrategy(int clusterId)

Specified by:

getClusterRecordConflictStrategy in interface OStorage

getClusterEncryption

public String getClusterEncryption(int clusterId)

Specified by:

getClusterEncryption in interface OStorage

isSystemCluster

public boolean isSystemCluster(int clusterId)

Specified by:

isSystemCluster in interface OStorage

getLastClusterPosition

public long getLastClusterPosition(int clusterId)

Specified by:

getLastClusterPosition in interface OStorage

getClusterNextPosition

public long getClusterNextPosition(int clusterId)

Specified by:

getClusterNextPosition in interface OStorage

getRecordStatus

public OPaginatedCluster.RECORD_STATUS getRecordStatus(ORID rid)

Specified by:

getRecordStatus in interface OStorage

dropCluster

public boolean dropCluster(int iClusterId)

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

getClusterName

public String getClusterName(int clusterId)

Specified by:

getClusterName in interface OStorage

setClusterAttribute

public boolean setClusterAttribute(int id,
 OCluster.ATTRIBUTES attribute,
 Object value)

Specified by:

setClusterAttribute in interface OStorage

removeClusterFromConfiguration

public void removeClusterFromConfiguration(int iClusterId)

synch

public void synch()

Specified by:

synch in interface OStorage

getPhysicalClusterNameById

public String getPhysicalClusterNameById(int iClusterId)

Specified by:

getPhysicalClusterNameById in interface OStorage

Specified by:

getPhysicalClusterNameById in interface OStorageInfo

getClusterMap

public int getClusterMap()

getClusterInstances

public Collection<OCluster> getClusterInstances()

Specified by:

getClusterInstances in interface OStorage

getVersion

public long getVersion()

Specified by:

getVersion in interface OStorage

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)
                 throws IOException

End response reached: release the channel in the pool to being reused

Throws:

IOException

isRemote

public boolean isRemote()

Specified by:

isRemote in interface OStorage

isPermanentRequester

public boolean isPermanentRequester()

getRecordConflictStrategy

public ORecordConflictStrategy getRecordConflictStrategy()

Specified by:

getRecordConflictStrategy in interface OStorage

Specified by:

getRecordConflictStrategy in interface OStorageInfo

setConflictStrategy

public void setConflictStrategy(ORecordConflictStrategy iResolver)

Specified by:

setConflictStrategy in interface OStorage

getURL

public String getURL()

Specified by:

getURL in interface OStorageInfo

getClusters

public int getClusters()

Specified by:

getClusters in interface OStorageInfo

getType

public String getType()

Description copied from interface: OStorage

Returns the storage's type.

Specified by:

getType in interface OStorage

getUserName

public String getUserName()

Specified by:

getUserName in interface OStorageProxy

reopenRemoteDatabase

protected String reopenRemoteDatabase()
                               throws IOException

Throws:

IOException

openRemoteDatabase

protected void openRemoteDatabase()
                           throws IOException

Throws:

IOException

openRemoteDatabase

public void openRemoteDatabase(OChannelBinaryAsynchClient network)
                        throws IOException

Throws:

IOException

openRemoteDatabase

protected void openRemoteDatabase(String currentURL)

useNewServerURL

protected String useNewServerURL(String iUrl)

parseServerURLs

protected void parseServerURLs()

Parse the URLs. Multiple URLs must be separated by semicolon (;)

beginRequest

public OChannelBinaryAsynchClient beginRequest(OChannelBinaryAsynchClient network,
 byte iCommand,
 OStorageRemoteSession session)
                                        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()

getNetwork

public OChannelBinaryAsynchClient getNetwork(String iCurrentURL)

Specified by:

getNetwork in interface ORemotePushHandler

getNetwork

public static OChannelBinaryAsynchClient getNetwork(String iCurrentURL,
 ORemoteConnectionManager connectionManager,
 OContextConfiguration config)

beginResponse

public static void beginResponse(OChannelBinaryAsynchClient iNetwork,
 OStorageRemoteSession session)
                          throws IOException

Throws:

IOException

updateStorageConfiguration

public void updateStorageConfiguration(OStorageConfiguration storageConfiguration)

getCurrentSession

protected OStorageRemoteSession getCurrentSession()

isClosed

public boolean isClosed()

Specified by:

isClosed in interface OStorage

copy

public OStorageRemote copy(ODatabaseDocumentRemote source,
 ODatabaseDocumentRemote dest)

importDatabase

public void importDatabase(String options,
 InputStream inputStream,
 String name,
 OCommandOutputListener listener)

addNewClusterToConfiguration

public void addNewClusterToConfiguration(int clusterId,
 String iClusterName)

beginTransaction

public void beginTransaction(ODatabaseDocumentRemote database,
 OTransactionOptimistic transaction)

reBeginTransaction

public void reBeginTransaction(ODatabaseDocumentRemote database,
 OTransactionOptimistic transaction)

fetchTransaction

public void fetchTransaction(ODatabaseDocumentRemote remote)

createPush

public OBinaryPushRequest createPush(byte type)

Specified by:

createPush in interface ORemotePushHandler

executeUpdateDistributedConfig

public OBinaryPushResponse executeUpdateDistributedConfig(OPushDistributedConfigurationRequest request)

Specified by:

executeUpdateDistributedConfig in interface ORemotePushHandler

executeUpdateFunction

public OBinaryPushResponse executeUpdateFunction(OPushFunctionsRequest request)

Specified by:

executeUpdateFunction in interface ORemotePushHandler

executeUpdateSequences

public OBinaryPushResponse executeUpdateSequences(OPushSequencesRequest request)

Specified by:

executeUpdateSequences in interface ORemotePushHandler

executeUpdateStorageConfig

public OBinaryPushResponse executeUpdateStorageConfig(OPushStorageConfigurationRequest payload)

Specified by:

executeUpdateStorageConfig in interface ORemotePushHandler

executeUpdateSchema

public OBinaryPushResponse executeUpdateSchema(OPushSchemaRequest request)

Specified by:

executeUpdateSchema in interface ORemotePushHandler

executeUpdateIndexManager

public OBinaryPushResponse executeUpdateIndexManager(OPushIndexManagerRequest request)

Specified by:

executeUpdateIndexManager in interface ORemotePushHandler

liveQuery

public OLiveQueryMonitor liveQuery(ODatabaseDocumentRemote database,
 String query,
 OLiveQueryClientListener listener,
 Object[] params)

liveQuery

public OLiveQueryMonitor liveQuery(ODatabaseDocumentRemote database,
 String query,
 OLiveQueryClientListener listener,
 Map<String,?> params)

unsubscribeLive

public void unsubscribeLive(ODatabaseDocumentRemote database,
 int monitorId)

registerLiveListener

public void registerLiveListener(int monitorId,
 OLiveQueryClientListener listener)

paramsArrayToParamsMap

public static HashMap<String,Object> paramsArrayToParamsMap(Object[] positionalParams)

executeLiveQueryPush

public void executeLiveQueryPush(OLiveQueryPushRequest pushRequest)

Specified by:

executeLiveQueryPush in interface ORemotePushHandler

onPushReconnect

public void onPushReconnect(String host)

Specified by:

onPushReconnect in interface ORemotePushHandler

onPushDisconnect

public void onPushDisconnect(OChannelBinary network,
 Exception e)

Specified by:

onPushDisconnect in interface ORemotePushHandler

lockRecord

public OLockRecordResponse lockRecord(OIdentifiable iRecord,
 OStorage.LOCKING_STRATEGY lockingStrategy,
 long timeout)

unlockRecord

public void unlockRecord(OIdentifiable iRecord)

returnSocket

public void returnSocket(OChannelBinary network)

Specified by:

returnSocket in interface ORemotePushHandler

setSchemaRecordId

public void setSchemaRecordId(String schemaRecordId)

Specified by:

setSchemaRecordId in interface OStorage

setDateFormat

public void setDateFormat(String dateFormat)

Specified by:

setDateFormat in interface OStorage

setTimeZone

public void setTimeZone(TimeZone timeZoneValue)

Specified by:

setTimeZone in interface OStorage

setLocaleLanguage

public void setLocaleLanguage(String locale)

Specified by:

setLocaleLanguage in interface OStorage

setCharset

public void setCharset(String charset)

Specified by:

setCharset in interface OStorage

setIndexMgrRecordId

public void setIndexMgrRecordId(String indexMgrRecordId)

Specified by:

setIndexMgrRecordId in interface OStorage

setDateTimeFormat

public void setDateTimeFormat(String dateTimeFormat)

Specified by:

setDateTimeFormat in interface OStorage

setLocaleCountry

public void setLocaleCountry(String localeCountry)

Specified by:

setLocaleCountry in interface OStorage

setClusterSelection

public void setClusterSelection(String clusterSelection)

Specified by:

setClusterSelection in interface OStorage

setMinimumClusters

public void setMinimumClusters(int minimumClusters)

Specified by:

setMinimumClusters in interface OStorage

setValidation

public void setValidation(boolean validation)

Specified by:

setValidation in interface OStorage

removeProperty

public void removeProperty(String property)

Specified by:

removeProperty in interface OStorage

setProperty

public void setProperty(String property,
 String value)

Specified by:

setProperty in interface OStorage

setRecordSerializer

public void setRecordSerializer(String recordSerializer,
 int version)

Specified by:

setRecordSerializer in interface OStorage

clearProperties

public void clearProperties()

Specified by:

clearProperties in interface OStorage

getServerURLs

public List<String> getServerURLs()

getSharedContext

public OSharedContext getSharedContext()

isDistributed

public boolean isDistributed()

Specified by:

isDistributed in interface OStorage

getStatus

public OStorage.STATUS getStatus()

Description copied from interface: OStorage

Returns the current storage's status

Specified by:

getStatus in interface OStorage

close

public void close()

Specified by:

close in interface OStorage

dropCluster

public boolean dropCluster(String iClusterName)

Specified by:

dropCluster in interface OStorage

getComponentsFactory

public OCurrentStorageComponentsFactory getComponentsFactory()

Specified by:

getComponentsFactory in interface OStorage

getUnderlying

public OStorage getUnderlying()

Specified by:

getUnderlying in interface OStorage

getClustersIds

public int[] getClustersIds(Set<String> filterClusters)

Specified by:

getClustersIds in interface OStorage

getContext

public OrientDBInternal getContext()

Specified by:

getContext in interface OStorage