Package com.orientechnologies.orient.distributed.db

Class OrientDBDistributed

java.lang.Object

com.orientechnologies.orient.core.db.OrientDBEmbedded

com.orientechnologies.orient.distributed.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

Field Summary

Fields

Modifier and Type	Field	Description
protected final ConcurrentHashMap<String,ODistributedConfigurationManager>	configurations
protected final ConcurrentHashMap<String,ODistributedDatabaseImpl>	databases

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

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
ODatabasePoolInternal	cachedPool(String database, String user, String password, OrientDBConfig config)
void	close()	Close the factory with all related databases and pools.
<T> T	configOp(ODistributedConfigurationManager cm, String database, com.orientechnologies.orient.distributed.db.OrientDBDistributed.ConfigOp<T> op)
void	coordinatedRequest(OClientConnection connection, int requestType, int clientTxId, OChannelBinary channel)
void	create(String name, String user, String password, ODatabaseType type, OrientDBConfig config, ODatabaseTask<Void> createOps)
protected OSharedContext	createSharedContext(OAbstractPaginatedStorage storage)
boolean	deltaSync(String dbName, InputStream backupStream, OrientDBConfig config)
void	distributedPauseDatabase(String database)
void	distributedSetOnline(String database)
void	drop(String name, String user, String password)	Drop a database
static void	dropStorageFiles(OLocalPaginatedStorage storage)
OStorage	fullSync(String dbName, InputStream backupStream, OrientDBConfig config)
Set<String>	getActiveDatabases()
ODistributedConfigurationManager	getConfigurationManager(String database)
ODistributedDatabaseImpl	getDatabase(String iDatabaseName)
ODistributedConfiguration	getDistributedConfiguration(ODatabaseSession session)
ODistributedConfiguration	getDistributedConfiguration(String database)
Collection<ODistributedDatabaseImpl>	getDistributedDatabases()
ODistributedServerManager	getDistributedManager()
ODistributedConfiguration	getExistingDistributedConfiguration(String database)
ODistributedConfigurationManager	getOrInitConfigurationManager(String database)
ODistributedConfiguration	getOrInitDistributedConfiguration(ODatabaseSession session)
ODistributedConfiguration	getOrInitDistributedConfiguration(String database)
ODistributedPlugin	getPlugin()
void	init(OServer server)
void	internalDrop(String name)
void	loadAllDatabases()
protected ODatabaseDocumentEmbedded	newCreateSessionInstance(OAbstractPaginatedStorage storage, OrientDBConfig config, OSharedContext sharedContext)
protected ODatabaseDocumentEmbedded	newPooledSessionInstance(ODatabasePoolInternal pool, OAbstractPaginatedStorage storage, OSharedContext sharedContext)
protected ODatabaseDocumentEmbedded	newSessionInstance(OAbstractPaginatedStorage storage, OrientDBConfig config, OSharedContext sharedContext)
ODatabaseDocumentInternal	open(OAuthenticationInfo authenticationInfo, OrientDBConfig config)	Open a database specified by name using the authentication info provided, with specific configuration
ODatabaseDocumentInternal	open(String name, String user, String password, OrientDBConfig config)	Open a database specified by name using the username and password if needed, with specific configuration
ODatabaseDocumentEmbedded	openNoAuthenticate(String name, String user)
ODatabaseDocumentEmbedded	openNoAuthorization(String name)
ODatabasePoolInternal	openPool(String name, String user, String password, OrientDBConfig config)	Open a pool of databases, similar to open but with multiple instances.
ODatabaseDocumentInternal	poolOpen(String name, String user, String password, ODatabasePoolInternal pool)	Internal api for request to open a database with a pool
void	saveDatabaseConfiguration(String database)
void	setDistributedConfiguration(String database, OModifiableDistributedConfiguration distributedConfiguration)
void	setPlugin(ODistributedPlugin plugin)
boolean	tryUpdatingDatabaseConfigurationLocally(String database, OModifiableDistributedConfiguration cfg)
ODistributedDatabaseImpl	unregisterDatabase(String iDatabaseName)

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

buildName, cachedPool, checkOpen, create, create, createCachedDatabasePoolFactory, endCommand, execute, execute, execute, executeNoAuthorization, executeNoDb, executeServerStatement, executeServerStatement, exists, forceDatabaseClose, generateStorageId, getBasePath, getConfigurations, getConnectionUrl, getDatabasePath, getIoExecutor, getOrCreateSharedContext, getOrInitStorage, getScriptManager, getSecuritySystem, getStorage, getStorages, getSystemDatabase, initAutoClose, initCustomStorage, internalClose, internalCreate, isEmbedded, isMemoryOnly, isOpen, listDatabases, listLodadedDatabases, networkRestore, open, openPool, preClose, removePool, removeShutdownHook, restore, restore, schedule, scheduleOnce, solveConfig, startCommand

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

newOrientDB, newOrientDBNoClose

Field Details

databases

protected final ConcurrentHashMap<String,ODistributedDatabaseImpl> databases

configurations

protected final ConcurrentHashMap<String,ODistributedConfigurationManager> configurations

Constructor Details

OrientDBDistributed

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

Method Details

init

public void init(OServer server)

Specified by:

init in interface OServerAware

loadAllDatabases

public void loadAllDatabases()

Specified by:

loadAllDatabases in interface OrientDBInternal

Overrides:

loadAllDatabases in class OrientDBEmbedded

setPlugin

public void setPlugin(ODistributedPlugin plugin)

getPlugin

public ODistributedPlugin getPlugin()

createSharedContext

protected OSharedContext createSharedContext(OAbstractPaginatedStorage storage)

Overrides:

createSharedContext in class OrientDBEmbedded

newSessionInstance

protected ODatabaseDocumentEmbedded newSessionInstance(OAbstractPaginatedStorage storage,
 OrientDBConfig config,
 OSharedContext sharedContext)

Overrides:

newSessionInstance in class OrientDBEmbedded

newCreateSessionInstance

protected ODatabaseDocumentEmbedded newCreateSessionInstance(OAbstractPaginatedStorage storage,
 OrientDBConfig config,
 OSharedContext sharedContext)

Overrides:

newCreateSessionInstance in class OrientDBEmbedded

newPooledSessionInstance

protected ODatabaseDocumentEmbedded newPooledSessionInstance(ODatabasePoolInternal pool,
 OAbstractPaginatedStorage storage,
 OSharedContext sharedContext)

Overrides:

newPooledSessionInstance in class OrientDBEmbedded

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

create

public void create(String name,
 String user,
 String password,
 ODatabaseType type,
 OrientDBConfig config,
 ODatabaseTask<Void> createOps)

Specified by:

create in interface OrientDBInternal

Overrides:

create in class OrientDBEmbedded

internalDrop

public void internalDrop(String name)

Specified by:

internalDrop in interface OrientDBInternal

Overrides:

internalDrop 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

open

public ODatabaseDocumentInternal open(String name,
 String user,
 String password,
 OrientDBConfig config)

Description copied from interface: OrientDBInternal

Open a database specified by name using the username and password if needed, with specific configuration

Specified by:

open in interface OrientDBInternal

Overrides:

open in class OrientDBEmbedded

Parameters:

name - of the database to open

user - the username allowed to open the database

password - related to the specified username

config - database specific configuration that override the factory global settings where needed.

Returns:

the opened database

open

public ODatabaseDocumentInternal open(OAuthenticationInfo authenticationInfo,
 OrientDBConfig config)

Description copied from interface: OrientDBInternal

Open a database specified by name using the authentication info provided, with specific configuration

Specified by:

open in interface OrientDBInternal

Overrides:

open in class OrientDBEmbedded

Parameters:

authenticationInfo - authentication informations provided for the authentication.

config - database specific configuration that override the factory global settings where needed.

Returns:

the opened database

openNoAuthenticate

public ODatabaseDocumentEmbedded openNoAuthenticate(String name,
 String user)

Specified by:

openNoAuthenticate in interface OrientDBInternal

Overrides:

openNoAuthenticate in class OrientDBEmbedded

openNoAuthorization

public ODatabaseDocumentEmbedded openNoAuthorization(String name)

Specified by:

openNoAuthorization in interface OrientDBInternal

Overrides:

openNoAuthorization in class OrientDBEmbedded

openPool

public ODatabasePoolInternal openPool(String name,
 String user,
 String password,
 OrientDBConfig config)

Description copied from interface: OrientDBInternal

Open a pool of databases, similar to open but with multiple instances.

Specified by:

openPool in interface OrientDBInternal

Overrides:

openPool in class OrientDBEmbedded

Parameters:

name - database name

user - the username allowed to open the database

password - the password relative to the user

config - database specific configuration that override the factory global settings where needed.

Returns:

a new pool of databases.

cachedPool

public ODatabasePoolInternal cachedPool(String database,
 String user,
 String password,
 OrientDBConfig config)

Specified by:

cachedPool in interface OrientDBInternal

Overrides:

cachedPool in class OrientDBEmbedded

coordinatedRequest

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

Specified by:

coordinatedRequest in interface OServerAware

Throws:

IOException

dropStorageFiles

public static void dropStorageFiles(OLocalPaginatedStorage storage)

getDistributedManager

public ODistributedServerManager getDistributedManager()

Specified by:

getDistributedManager in interface OServerAware

deltaSync

public boolean deltaSync(String dbName,
 InputStream backupStream,
 OrientDBConfig config)

Specified by:

deltaSync in interface OrientDBInternal

getDatabase

public ODistributedDatabaseImpl getDatabase(String iDatabaseName)

unregisterDatabase

public ODistributedDatabaseImpl unregisterDatabase(String iDatabaseName)

distributedSetOnline

public void distributedSetOnline(String database)

Specified by:

distributedSetOnline in interface OrientDBInternal

distributedPauseDatabase

public void distributedPauseDatabase(String database)

getActiveDatabases

public Set<String> getActiveDatabases()

getDistributedDatabases

public Collection<ODistributedDatabaseImpl> getDistributedDatabases()

getOrInitDistributedConfiguration

public ODistributedConfiguration getOrInitDistributedConfiguration(ODatabaseSession session)

getOrInitConfigurationManager

public ODistributedConfigurationManager getOrInitConfigurationManager(String database)

getConfigurationManager

public ODistributedConfigurationManager getConfigurationManager(String database)

getDistributedConfiguration

public ODistributedConfiguration getDistributedConfiguration(ODatabaseSession session)

configOp

public <T> T configOp(ODistributedConfigurationManager cm,
 String database,
 com.orientechnologies.orient.distributed.db.OrientDBDistributed.ConfigOp<T> op)

getExistingDistributedConfiguration

public ODistributedConfiguration getExistingDistributedConfiguration(String database)

getDistributedConfiguration

public ODistributedConfiguration getDistributedConfiguration(String database)

setDistributedConfiguration

public void setDistributedConfiguration(String database,
 OModifiableDistributedConfiguration distributedConfiguration)

saveDatabaseConfiguration

public void saveDatabaseConfiguration(String database)

getOrInitDistributedConfiguration

public ODistributedConfiguration getOrInitDistributedConfiguration(String database)

tryUpdatingDatabaseConfigurationLocally

public boolean tryUpdatingDatabaseConfigurationLocally(String database,
 OModifiableDistributedConfiguration cfg)

close

public void close()

Description copied from interface: OrientDBInternal

Close the factory with all related databases and pools.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface OrientDBInternal

Overrides:

close in class OrientDBEmbedded