com.orientechnologies.orient.core.db

Class OrientDBDistributed

java.lang.Object

com.orientechnologies.orient.core.db.OrientDBEmbedded

com.orientechnologies.orient.core.db.OrientDBDistributed

All Implemented Interfaces:

OrientDBInternal, OSchedulerInternal, OServerAware, AutoCloseable

public class OrientDBDistributed
extends OrientDBEmbedded
implements OServerAware

Created by tglman on 08/08/17.

Nested Class Summary

Nested classes/interfaces inherited from class com.orientechnologies.orient.core.db.OrientDBEmbedded

OrientDBEmbedded.DatabaseFound, OrientDBEmbedded.InstanceFactory<T>

Field Summary

Fields inherited from class com.orientechnologies.orient.core.db.OrientDBEmbedded

basePath, cachedPoolFactory, configurations, disk, doubleWriteLogMaxSegSize, maxWALSegmentSize, memory, orient, pools, sharedContexts, storages

Constructor Summary

Constructors

Constructor and Description
OrientDBDistributed(String directoryPath, OrientDBConfig config, Orient instance)

Method Summary

Modifier and Type	Method and Description
void	coordinatedRequest(OClientConnection connection, int requestType, int clientTxId, OChannelBinary channel)
protected OSharedContext	createSharedContext(OAbstractPaginatedStorage storage)
void	drop(String name, String user, String password) Drop a database
OStorage	fullSync(String dbName, InputStream backupStream, OrientDBConfig config)
OHazelcastPlugin	getPlugin()
void	init(OServer server)
protected ODatabaseDocumentEmbedded	newPooledSessionInstance(ODatabasePoolInternal pool, OAbstractPaginatedStorage storage)
protected ODatabaseDocumentEmbedded	newSessionInstance(OAbstractPaginatedStorage storage)
ODatabaseDocumentInternal	poolOpen(String name, String user, String password, ODatabasePoolInternal pool) Internal api for request to open a database with a pool
void	setPlugin(OHazelcastPlugin plugin)

Methods inherited from class com.orientechnologies.orient.core.db.OrientDBEmbedded

buildName, cachedPool, cachedPool, checkOpen, close, create, create, createCachedDatabasePoolFactory, execute, executeNoAuthorization, executeNoDb, exists, forceDatabaseClose, generateStorageId, getConfigurations, getDatabasePath, getOrCreateSharedContext, getOrInitStorage, getScriptManager, getStorage, getStorages, initAutoClose, initCustomStorage, internalClose, internalCreate, isEmbedded, isOpen, listDatabases, loadAllDatabases, networkRestore, open, open, openNoAuthenticate, openNoAuthorization, openPool, openPool, removePool, removeShutdownHook, restore, restore, schedule, scheduleOnce, solveConfig

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.db.OrientDBInternal

distributed, embedded, extract, fromUrl, newOrientDB, remote

Constructor Detail

OrientDBDistributed

public OrientDBDistributed(String directoryPath,
                           OrientDBConfig config,
                           Orient instance)

Method Detail

init

public void init(OServer server)

Specified by:

init in interface OServerAware

getPlugin

public OHazelcastPlugin getPlugin()

createSharedContext

protected OSharedContext createSharedContext(OAbstractPaginatedStorage storage)

Overrides:

createSharedContext in class OrientDBEmbedded

newSessionInstance

protected ODatabaseDocumentEmbedded newSessionInstance(OAbstractPaginatedStorage storage)

Overrides:

newSessionInstance in class OrientDBEmbedded

newPooledSessionInstance

protected ODatabaseDocumentEmbedded newPooledSessionInstance(ODatabasePoolInternal pool,
                                                             OAbstractPaginatedStorage storage)

Overrides:

newPooledSessionInstance in class OrientDBEmbedded

setPlugin

public void setPlugin(OHazelcastPlugin plugin)

fullSync

public OStorage fullSync(String dbName,
                         InputStream backupStream,
                         OrientDBConfig config)

Specified by:

fullSync in interface OrientDBInternal

poolOpen

public ODatabaseDocumentInternal poolOpen(String name,
                                          String user,
                                          String password,
                                          ODatabasePoolInternal pool)

Description copied from interface: OrientDBInternal

Internal api for request to open a database with a pool

Specified by:

poolOpen in interface OrientDBInternal

Overrides:

poolOpen in class OrientDBEmbedded

drop

public void drop(String name,
                 String user,
                 String password)

Description copied from interface: OrientDBInternal

Drop a database

Specified by:

drop in interface OrientDBInternal

Overrides:

drop in class OrientDBEmbedded

Parameters:

name - database name

user - the username of a user allowed to drop a database, in case of remote is a server user for embedded it can be left empty

password - the password relative to the user

coordinatedRequest

public void coordinatedRequest(OClientConnection connection,
                               int requestType,
                               int clientTxId,
                               OChannelBinary channel)
                        throws IOException

Specified by:

coordinatedRequest in interface OServerAware

Throws:

IOException