Class OStorageRemote
java.lang.Object
com.orientechnologies.orient.client.remote.OStorageRemote
- All Implemented Interfaces:
ORemotePushHandler,OStorage,OStorageInfo,OStorageProxy,OBackupable
This object is bound to each remote ODatabase instances.
-
Nested Class Summary
Nested ClassesNested classes/interfaces inherited from interface com.orientechnologies.orient.core.storage.OStorage
OStorage.LOCKING_STRATEGY, OStorage.STATUS -
Field Summary
FieldsModifier and TypeFieldDescriptionstatic final Stringprotected OCurrentStorageComponentsFactoryprotected OStorageConfigurationprotected final OrientDBRemotestatic final Stringprotected Stringstatic final StringDeprecated.protected OSharedContextprotected final ReentrantReadWriteLockprotected OStorage.STATUSprotected final StringFields inherited from interface com.orientechnologies.orient.core.storage.OStorage
CLUSTER_DEFAULT_NAME -
Constructor Summary
ConstructorsConstructorDescriptionOStorageRemote(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 TypeMethodDescriptionintaddCluster(String iClusterName, int iRequestedId) Add a new cluster into the storage.intaddCluster(String iClusterName, Object... iArguments) Add a new cluster into the storage.voidaddNewClusterToConfiguration(int clusterId, String iClusterName) intaddUser()<T extends OBinaryResponse>
TasyncNetworkOperationNoRetry(OBinaryAsyncRequest<T> request, int mode, ORecordId recordId, ORecordCallback<T> callback, String errorMessage) <T extends OBinaryResponse>
TasyncNetworkOperationRetry(OBinaryAsyncRequest<T> request, int mode, ORecordId recordId, ORecordCallback<T> callback, String errorMessage, int retry) backup(OutputStream out, Map<String, Object> options, Callable<Object> callable, OCommandOutputListener iListener, int compressionLevel, int bufferSize) Executes a backup of the database.<T> TbaseNetworkOperation(OStorageRemoteOperation<T> operation, String errorMessage, int retry) beginRequest(OChannelBinaryAsynchClient network, byte iCommand, OStorageRemoteSession session) Acquire a network channel from the pool.static voidbeginResponse(OChannelBinaryAsynchClient iNetwork, OStorageRemoteSession session) voidbeginTransaction(ODatabaseDocumentRemote database, OTransactionOptimistic transaction) ceilingPhysicalPositions(int clusterId, OPhysicalPosition physicalPosition) booleanbooleancleanOutRecord(ORecordId recordId, int recordVersion, int iMode, ORecordCallback<Boolean> callback) voidvoidclose()voidclose(boolean iForce, boolean onDelete) voidcloseQuery(ODatabaseDocumentRemote database, String queryId) command(ODatabaseDocumentRemote db, String query, Object[] args) command(ODatabaseDocumentRemote db, String query, Map args) command(OCommandRequestText iCommand) Execute the command remotely and get the results back.copy(ODatabaseDocumentRemote source, ODatabaseDocumentRemote dest) longcount(int iClusterId) longcount(int[] iClusterIds) longcount(int[] iClusterIds, boolean countTombstones) longcount(int iClusterId, boolean countTombstones) longReturns the total number of records.voidcreate(OContextConfiguration contextConfiguration) createPush(byte type) createRecord(ORecordId iRid, byte[] iContent, int iRecordVersion, byte iRecordType, int iMode, ORecordCallback<Long> iCallback) voiddelete()deleteRecord(ORecordId iRid, int iVersion, int iMode, ORecordCallback<Boolean> iCallback) booleandropCluster(int iClusterId) Drops a cluster.booleandropCluster(String iClusterName) voidendRequest(OChannelBinaryAsynchClient iNetwork) Ends the request and unlock the write lockvoidendResponse(OChannelBinaryAsynchClient iNetwork) End response reached: release the channel in the pool to being reusedexecute(ODatabaseDocumentRemote db, String language, String query, Object[] args) execute(ODatabaseDocumentRemote db, String language, String query, Map args) voidexecuteLiveQueryPush(OLiveQueryPushRequest pushRequest) executeUpdateSchema(OPushSchemaRequest request) booleanexists()voidfetchNextPage(ODatabaseDocumentRemote database, ORemoteResultSet rs) voidfloorPhysicalPositions(int clusterId, OPhysicalPosition physicalPosition) voidfullIncrementalBackup(OutputStream stream) long[]getClusterDataRange(int iClusterId) Returns a pair of long values telling the begin and end positions of data in the requested cluster.getClusterEncryption(int clusterId) intgetClusterIdByName(String iClusterName) intgetClusterName(int clusterId) getClusterNameById(int clusterId) longgetClusterNextPosition(int clusterId) getClusterRecordConflictStrategy(int clusterId) longgetClusterRecordsSizeById(int clusterId) longgetClusterRecordsSizeByName(String clusterName) intint[]getClustersIds(Set<String> filterClusters) Supported only in embedded storage.protected Stringprotected OStorageRemoteSessionintlonggetLastClusterPosition(int clusterId) getName()getNetwork(String iCurrentURL) static OChannelBinaryAsynchClientgetNetwork(String iCurrentURL, ORemoteConnectionManager connectionManager, OContextConfiguration config) protected StringgetNextAvailableServerURL(boolean iIsConnectOperation, OStorageRemoteSession session) getPhysicalClusterNameById(int iClusterId) getRecordMetadata(ORID rid) getRecordStatus(ORID rid) intlonggetSize()Returns the size of the database.Returns the current storage's statusgetType()Returns the storage's type.getURL()intgetUsers()longhigherPhysicalPositions(int iClusterId, OPhysicalPosition iClusterPosition) voidimportDatabase(String options, InputStream inputStream, String name, OCommandOutputListener listener) incrementalBackup(String backupDirectory, OCallable<Void, Void> started) booleanbooleanisClosed()booleanbooleanbooleanisRemote()booleanisSystemCluster(int clusterId) liveQuery(ODatabaseDocumentRemote database, String query, OLiveQueryClientListener listener, Object[] params) liveQuery(ODatabaseDocumentRemote database, String query, OLiveQueryClientListener listener, Map<String, ?> params) lockRecord(OIdentifiable iRecord, OStorage.LOCKING_STRATEGY lockingStrategy, long timeout) lowerPhysicalPositions(int iClusterId, OPhysicalPosition physicalPosition) <T extends OBinaryResponse>
TnetworkOperation(OBinaryRequest<T> request, String errorMessage) <T extends OBinaryResponse>
TnetworkOperationNoRetry(OBinaryRequest<T> request, String errorMessage) <T extends OBinaryResponse>
TnetworkOperationRetryTimeout(OBinaryRequest<T> request, String errorMessage, int retry, int timeout) voidonPushDisconnect(OChannelBinary network, Exception e) voidonPushReconnect(String host) voidopen(String iUserName, String iUserPassword, OContextConfiguration conf) protected voidvoidprotected voidopenRemoteDatabase(String currentURL) paramsArrayToParamsMap(Object[] positionalParams) protected voidParse the URLs.query(ODatabaseDocumentRemote db, String query, Object[] args) query(ODatabaseDocumentRemote db, String query, Map args) readRecord(ORecordId iRid, String iFetchPlan, boolean iIgnoreCache, boolean prefetchRecords, ORecordCallback<ORawBuffer> iCallback) readRecordIfVersionIsNotLatest(ORecordId rid, String fetchPlan, boolean ignoreCache, int recordVersion) voidreBeginTransaction(ODatabaseDocumentRemote database, OTransactionOptimistic transaction) voidregisterLiveListener(int monitorId, OLiveQueryClientListener listener) voidreload()voidremoveClusterFromConfiguration(int iClusterId) voidremoveProperty(String property) intprotected Stringvoidrestore(InputStream in, Map<String, Object> options, Callable<Object> callable, OCommandOutputListener iListener) Executes a restore of a database backup.voidrestoreFromIncrementalBackup(String filePath) voidvoidreturnSocket(OChannelBinary network) voidserverCommand(String query, Object[] args) serverCommand(String query, Map args) voidsetCharset(String charset) booleansetClusterAttribute(int id, OCluster.ATTRIBUTES attribute, Object value) voidsetClusterSelection(String clusterSelection) voidsetConflictStrategy(ORecordConflictStrategy iResolver) voidsetDateFormat(String dateFormat) voidsetDateTimeFormat(String dateTimeFormat) voidsetDefaultClusterId(int defaultClusterId) voidsetIndexMgrRecordId(String indexMgrRecordId) voidsetLocaleCountry(String localeCountry) voidsetLocaleLanguage(String locale) voidsetMinimumClusters(int minimumClusters) voidsetProperty(String property, String value) voidsetRecordSerializer(String recordSerializer, int version) voidsetSchemaRecordId(String schemaRecordId) voidsetSharedContext(OSharedContext sharedContext) voidsetTimeZone(TimeZone timeZoneValue) voidsetValidation(boolean validation) voidshutdown()This method is called inOrient.shutdown()method.voidbooleanvoidsynch()voidunlockRecord(OIdentifiable iRecord) voidvoidunsubscribeLive(ODatabaseDocumentRemote database, int monitorId) updateRecord(ORecordId iRid, boolean updateContent, byte[] iContent, int iVersion, byte iRecordType, int iMode, ORecordCallback<Integer> iCallback) voidupdateStorageConfiguration(OStorageConfiguration storageConfiguration) protected StringuseNewServerURL(String iUrl) Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface com.orientechnologies.orient.core.storage.OStorage
isIcrementalBackupRunning
-
Field Details
-
PARAM_CONNECTION_STRATEGY
Deprecated.- See Also:
-
DRIVER_NAME
- See Also:
-
connectionManager
-
context
-
url
-
stateLock
-
configuration
-
componentsFactory
-
name
-
status
-
ADDRESS_SEPARATOR
- See Also:
-
-
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
- Specified by:
getConfigurationin interfaceOStorageInfo
-
checkForRecordValidity
- Specified by:
checkForRecordValidityin interfaceOStorage
-
getName
- Specified by:
getNamein interfaceOStorage- Specified by:
getNamein interfaceOStorageInfo
-
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:
isAssigningClusterIdsin interfaceOStorage- Specified by:
isAssigningClusterIdsin interfaceOStorageInfo
-
getCreatedAtVersion
Supported only in embedded storage. UseSELECT FROM metadata:storageinstead.- Specified by:
getCreatedAtVersionin interfaceOStorage- Returns:
- Version of product release under which storage was created.
-
getSessionId
public int getSessionId() -
getServerURL
-
open
-
getSBtreeCollectionManager
- Specified by:
getSBtreeCollectionManagerin interfaceOStorage
-
reload
public void reload() -
create
-
exists
public boolean exists() -
close
public void close(boolean iForce, boolean onDelete) -
shutdown
public void shutdown()Description copied from interface:OStorageThis method is called inOrient.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. -
getUsers
public int getUsers()- Specified by:
getUsersin interfaceOStorageProxy
-
addUser
public int addUser()- Specified by:
addUserin interfaceOStorageProxy
-
removeUser
public int removeUser()- Specified by:
removeUserin interfaceOStorageProxy
-
delete
public void delete() -
getClusterNames
- Specified by:
getClusterNamesin interfaceOStorage- Specified by:
getClusterNamesin interfaceOStorageInfo
-
createRecord
public OStorageOperationResult<OPhysicalPosition> createRecord(ORecordId iRid, byte[] iContent, int iRecordVersion, byte iRecordType, int iMode, ORecordCallback<Long> iCallback) -
getRecordMetadata
- Specified by:
getRecordMetadatain interfaceOStorage
-
readRecordIfVersionIsNotLatest
public OStorageOperationResult<ORawBuffer> readRecordIfVersionIsNotLatest(ORecordId rid, String fetchPlan, boolean ignoreCache, int recordVersion) throws ORecordNotFoundException - Specified by:
readRecordIfVersionIsNotLatestin interfaceOStorage- Throws:
ORecordNotFoundException
-
readRecord
public OStorageOperationResult<ORawBuffer> readRecord(ORecordId iRid, String iFetchPlan, boolean iIgnoreCache, boolean prefetchRecords, ORecordCallback<ORawBuffer> iCallback) - Specified by:
readRecordin interfaceOStorage
-
incrementalBackup
- Specified by:
incrementalBackupin interfaceOStorage- Returns:
- Backup file name
-
supportIncremental
public boolean supportIncremental()- Specified by:
supportIncrementalin interfaceOStorage
-
fullIncrementalBackup
- Specified by:
fullIncrementalBackupin interfaceOStorage- Throws:
UnsupportedOperationException
-
restoreFromIncrementalBackup
- Specified by:
restoreFromIncrementalBackupin interfaceOStorage
-
restoreFullIncrementalBackup
- Specified by:
restoreFullIncrementalBackupin interfaceOStorage- 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:
deleteRecordin interfaceOStorage
-
cleanOutRecord
public boolean cleanOutRecord(ORecordId recordId, int recordVersion, int iMode, ORecordCallback<Boolean> callback) - Specified by:
cleanOutRecordin interfaceOStorage
-
backup
public List<String> backup(OutputStream out, Map<String, Object> options, Callable<Object> callable, OCommandOutputListener iListener, int compressionLevel, int bufferSize) throws IOExceptionDescription copied from interface:OBackupableExecutes a backup of the database. During the backup the database will be frozen in read-only mode.- Specified by:
backupin interfaceOBackupable- Parameters:
out- OutputStream used to write the backup content. Use a FileOutputStream to make the backup persistent on diskoptions- Backup options as Map<String, Object> objectcallable- Callback to execute when the database is lockediListener- Listener called for backup messagescompressionLevel- 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 executebufferSize- Buffer size in bytes, the bigger is the buffer, the more efficient will be the compression- Throws:
IOException- See Also:
-
restore
public void restore(InputStream in, Map<String, Object> options, Callable<Object> callable, OCommandOutputListener iListener) throws IOExceptionDescription copied from interface:OBackupableExecutes a restore of a database backup. During the restore the database will be frozen in read-only mode.- Specified by:
restorein interfaceOBackupable- Parameters:
in- InputStream used to read the backup content. Use a FileInputStream to read a backup on a diskoptions- Backup options as Map<String, Object> objectcallable- Callback to execute when the database is lockediListener- Listener called for backup messages- Throws:
IOException- See Also:
-
getClientConfiguration
-
count
public long count(int iClusterId) -
count
public long count(int iClusterId, boolean countTombstones) -
getClusterDataRange
public long[] getClusterDataRange(int iClusterId) Description copied from interface:OStorageReturns 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:
getClusterDataRangein interfaceOStorage- Parameters:
iClusterId- Cluster id
-
higherPhysicalPositions
public OPhysicalPosition[] higherPhysicalPositions(int iClusterId, OPhysicalPosition iClusterPosition) - Specified by:
higherPhysicalPositionsin interfaceOStorage
-
ceilingPhysicalPositions
public OPhysicalPosition[] ceilingPhysicalPositions(int clusterId, OPhysicalPosition physicalPosition) - Specified by:
ceilingPhysicalPositionsin interfaceOStorage
-
lowerPhysicalPositions
public OPhysicalPosition[] lowerPhysicalPositions(int iClusterId, OPhysicalPosition physicalPosition) - Specified by:
lowerPhysicalPositionsin interfaceOStorage
-
floorPhysicalPositions
public OPhysicalPosition[] floorPhysicalPositions(int clusterId, OPhysicalPosition physicalPosition) - Specified by:
floorPhysicalPositionsin interfaceOStorage
-
getSize
public long getSize()Description copied from interface:OStorageReturns the size of the database. -
countRecords
public long countRecords()Description copied from interface:OStorageReturns the total number of records.- Specified by:
countRecordsin interfaceOStorage
-
count
public long count(int[] iClusterIds) -
count
public long count(int[] iClusterIds, boolean countTombstones) -
command
Execute the command remotely and get the results back. -
stickToSession
public void stickToSession() -
unstickToSession
public void unstickToSession() -
query
-
query
-
command
-
command
-
serverCommand
-
serverCommand
-
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
-
fetchNextPage
-
commit
-
rollback
- Specified by:
rollbackin interfaceOStorageProxy
-
getClusterIdByName
- Specified by:
getClusterIdByNamein interfaceOStorage- Specified by:
getClusterIdByNamein interfaceOStorageInfo
-
getDefaultClusterId
public int getDefaultClusterId()- Specified by:
getDefaultClusterIdin interfaceOStorageInfo
-
setDefaultClusterId
public void setDefaultClusterId(int defaultClusterId) - Specified by:
setDefaultClusterIdin interfaceOStorage
-
addCluster
Description copied from interface:OStorageAdd a new cluster into the storage.- Specified by:
addClusterin interfaceOStorage- Parameters:
iClusterName- name of the cluster
-
addCluster
Description copied from interface:OStorageAdd a new cluster into the storage.- Specified by:
addClusterin interfaceOStorage- Parameters:
iClusterName- name of the clusteriRequestedId- requested id of the cluster
-
getClusterNameById
- Specified by:
getClusterNameByIdin interfaceOStorage
-
getClusterRecordsSizeById
public long getClusterRecordsSizeById(int clusterId) - Specified by:
getClusterRecordsSizeByIdin interfaceOStorage
-
getClusterRecordsSizeByName
- Specified by:
getClusterRecordsSizeByNamein interfaceOStorage
-
getClusterRecordConflictStrategy
- Specified by:
getClusterRecordConflictStrategyin interfaceOStorage
-
getClusterEncryption
- Specified by:
getClusterEncryptionin interfaceOStorage
-
isSystemCluster
public boolean isSystemCluster(int clusterId) - Specified by:
isSystemClusterin interfaceOStorage
-
getLastClusterPosition
public long getLastClusterPosition(int clusterId) - Specified by:
getLastClusterPositionin interfaceOStorage
-
getClusterNextPosition
public long getClusterNextPosition(int clusterId) - Specified by:
getClusterNextPositionin interfaceOStorage
-
getRecordStatus
- Specified by:
getRecordStatusin interfaceOStorage
-
dropCluster
public boolean dropCluster(int iClusterId) Description copied from interface:OStorageDrops a cluster.- Specified by:
dropClusterin interfaceOStorage- Parameters:
iClusterId- id of the cluster to delete- Returns:
- true if has been removed, otherwise false
-
getClusterName
- Specified by:
getClusterNamein interfaceOStorage
-
setClusterAttribute
- Specified by:
setClusterAttributein interfaceOStorage
-
removeClusterFromConfiguration
public void removeClusterFromConfiguration(int iClusterId) -
synch
public void synch() -
getPhysicalClusterNameById
- Specified by:
getPhysicalClusterNameByIdin interfaceOStorage- Specified by:
getPhysicalClusterNameByIdin interfaceOStorageInfo
-
getClusterMap
public int getClusterMap() -
getClusterInstances
- Specified by:
getClusterInstancesin interfaceOStorage
-
getVersion
public long getVersion()- Specified by:
getVersionin interfaceOStorage
-
getClusterConfiguration
-
endRequest
Ends the request and unlock the write lock- Throws:
IOException
-
endResponse
End response reached: release the channel in the pool to being reused- Throws:
IOException
-
isRemote
public boolean isRemote() -
isPermanentRequester
public boolean isPermanentRequester() -
getRecordConflictStrategy
- Specified by:
getRecordConflictStrategyin interfaceOStorage- Specified by:
getRecordConflictStrategyin interfaceOStorageInfo
-
setConflictStrategy
- Specified by:
setConflictStrategyin interfaceOStorage
-
getURL
- Specified by:
getURLin interfaceOStorageInfo
-
getClusters
public int getClusters()- Specified by:
getClustersin interfaceOStorageInfo
-
getType
Description copied from interface:OStorageReturns the storage's type. -
getUserName
- Specified by:
getUserNamein interfaceOStorageProxy
-
reopenRemoteDatabase
- Throws:
IOException
-
openRemoteDatabase
- Throws:
IOException
-
openRemoteDatabase
- Throws:
IOException
-
openRemoteDatabase
-
useNewServerURL
-
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 atOChannelBinaryProtocol- Returns:
- connection to server
- Throws:
IOException
-
getNextAvailableServerURL
protected String getNextAvailableServerURL(boolean iIsConnectOperation, OStorageRemoteSession session) -
getCurrentServerURL
-
getNetwork
- Specified by:
getNetworkin interfaceORemotePushHandler
-
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
-
getCurrentSession
-
isClosed
public boolean isClosed() -
copy
-
importDatabase
public void importDatabase(String options, InputStream inputStream, String name, OCommandOutputListener listener) -
addNewClusterToConfiguration
-
beginTransaction
-
reBeginTransaction
public void reBeginTransaction(ODatabaseDocumentRemote database, OTransactionOptimistic transaction) -
fetchTransaction
-
createPush
- Specified by:
createPushin interfaceORemotePushHandler
-
executeUpdateDistributedConfig
public OBinaryPushResponse executeUpdateDistributedConfig(OPushDistributedConfigurationRequest request) - Specified by:
executeUpdateDistributedConfigin interfaceORemotePushHandler
-
executeUpdateFunction
- Specified by:
executeUpdateFunctionin interfaceORemotePushHandler
-
executeUpdateSequences
- Specified by:
executeUpdateSequencesin interfaceORemotePushHandler
-
executeUpdateStorageConfig
- Specified by:
executeUpdateStorageConfigin interfaceORemotePushHandler
-
executeUpdateSchema
- Specified by:
executeUpdateSchemain interfaceORemotePushHandler
-
executeUpdateIndexManager
- Specified by:
executeUpdateIndexManagerin interfaceORemotePushHandler
-
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
-
registerLiveListener
-
paramsArrayToParamsMap
-
executeLiveQueryPush
- Specified by:
executeLiveQueryPushin interfaceORemotePushHandler
-
onPushReconnect
- Specified by:
onPushReconnectin interfaceORemotePushHandler
-
onPushDisconnect
- Specified by:
onPushDisconnectin interfaceORemotePushHandler
-
lockRecord
public OLockRecordResponse lockRecord(OIdentifiable iRecord, OStorage.LOCKING_STRATEGY lockingStrategy, long timeout) -
unlockRecord
-
returnSocket
- Specified by:
returnSocketin interfaceORemotePushHandler
-
setSchemaRecordId
- Specified by:
setSchemaRecordIdin interfaceOStorage
-
setDateFormat
- Specified by:
setDateFormatin interfaceOStorage
-
setTimeZone
- Specified by:
setTimeZonein interfaceOStorage
-
setLocaleLanguage
- Specified by:
setLocaleLanguagein interfaceOStorage
-
setCharset
- Specified by:
setCharsetin interfaceOStorage
-
setIndexMgrRecordId
- Specified by:
setIndexMgrRecordIdin interfaceOStorage
-
setDateTimeFormat
- Specified by:
setDateTimeFormatin interfaceOStorage
-
setLocaleCountry
- Specified by:
setLocaleCountryin interfaceOStorage
-
setClusterSelection
- Specified by:
setClusterSelectionin interfaceOStorage
-
setMinimumClusters
public void setMinimumClusters(int minimumClusters) - Specified by:
setMinimumClustersin interfaceOStorage
-
setValidation
public void setValidation(boolean validation) - Specified by:
setValidationin interfaceOStorage
-
removeProperty
- Specified by:
removePropertyin interfaceOStorage
-
setProperty
- Specified by:
setPropertyin interfaceOStorage
-
setRecordSerializer
- Specified by:
setRecordSerializerin interfaceOStorage
-
clearProperties
public void clearProperties()- Specified by:
clearPropertiesin interfaceOStorage
-
getServerURLs
-
isDistributed
public boolean isDistributed()- Specified by:
isDistributedin interfaceOStorage
-
getStatus
Description copied from interface:OStorageReturns the current storage's status -
close
public void close() -
dropCluster
- Specified by:
dropClusterin interfaceOStorage
-
getComponentsFactory
- Specified by:
getComponentsFactoryin interfaceOStorage
-
getUnderlying
- Specified by:
getUnderlyingin interfaceOStorage
-
getClustersIds
- Specified by:
getClustersIdsin interfaceOStorage
-
getContext
- Specified by:
getContextin interfaceOStorage
-