com.orientechnologies.orient.core.db

Class OrientDBRemote

java.lang.Object

com.orientechnologies.orient.core.db.OrientDBRemote

All Implemented Interfaces:

OrientDBInternal, OSchedulerInternal, AutoCloseable

public class OrientDBRemote
extends Object
implements OrientDBInternal

Created by tglman on 08/04/16.

Field Summary

Fields

Modifier and Type	Field and Description
protected ORemoteConnectionManager	connectionManager
protected Map<String,OSharedContext>	sharedContexts

Constructor Summary

Constructors

Constructor and Description
OrientDBRemote(String[] hosts, OrientDBConfig configurations, Orient orient)

Method Summary

Modifier and Type	Method and Description
ODatabasePoolInternal	cachedPool(String database, String user, String password)
ODatabasePoolInternal	cachedPool(String database, String user, String password, OrientDBConfig config)
void	close() Close the factory with all related databases and pools.
void	closeStorage(OStorageRemote remote)
void	create(String name, String user, String password, ODatabaseType databaseType) Create a new database
void	create(String name, String user, String password, ODatabaseType databaseType, OrientDBConfig config) Create a new database
protected OCachedDatabasePoolFactory	createCachedDatabasePoolFactory(OrientDBConfig config)
void	drop(String name, String user, String password) Drop a database
<X> Future<X>	execute(String database, String user, ODatabaseTask<X> task)
<X> Future<X>	executeNoAuthorization(String database, ODatabaseTask<X> task)
boolean	exists(String name, String user, String password) Check if a database exists
void	forceDatabaseClose(String databaseName)
ODocument	getClusterStatus(String username, String password)
ORemoteConnectionManager	getConnectionManager()
String	getGlobalConfiguration(String username, String password, OGlobalConfiguration config)
Map<String,String>	getGlobalConfigurations(String username, String password)
protected OSharedContext	getOrCreateSharedContext(OStorage storage)
ODocument	getServerInfo(String username, String password)
Collection<OStorage>	getStorages()
void	initCustomStorage(String name, String baseUrl, String userName, String userPassword)
void	internalClose() Should be called only by shutdown listeners
boolean	isEmbedded()
boolean	isOpen() Check if the current instance is open
Set<String>	listDatabases(String user, String password) List of database exiting in the current environment
void	loadAllDatabases()
ODatabaseDocumentInternal	open(String name, String user, String password) Open a database specified by name using the username and password if needed
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
ODatabaseDocumentInternal	openNoAuthenticate(String iDbUrl, String user)
ODatabaseDocumentInternal	openNoAuthorization(String name)
ODatabasePoolInternal	openPool(String name, String user, String password) Open a pool of databases, similar to open but with multiple instances.
ODatabasePoolInternal	openPool(String name, String user, String password, OrientDBConfig config) Open a pool of databases, similar to open but with multiple instances.
ODatabaseDocumentRemotePooled	poolOpen(String name, String user, String password, ODatabasePoolInternal pool) Internal api for request to open a database with a pool
void	removePool(ODatabasePoolInternal pool) Internal API for pool close
void	removeShutdownHook()
void	restore(String name, InputStream in, Map<String,Object> options, Callable<Object> callable, OCommandOutputListener iListener)
void	restore(String name, String user, String password, ODatabaseType type, String path, OrientDBConfig config)
void	schedule(TimerTask task, long delay, long period)
void	scheduleOnce(TimerTask task, long delay)
void	setGlobalConfiguration(String username, String password, OGlobalConfiguration config, String iConfigValue)

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, fullSync, getScriptManager, listLodadedDatabases, networkRestore, newOrientDB, remote

Field Detail

sharedContexts

protected final Map<String,OSharedContext> sharedContexts

connectionManager

protected volatile ORemoteConnectionManager connectionManager

Constructor Detail

OrientDBRemote

public OrientDBRemote(String[] hosts,
                      OrientDBConfig configurations,
                      Orient orient)

Method Detail

createCachedDatabasePoolFactory

protected OCachedDatabasePoolFactory createCachedDatabasePoolFactory(OrientDBConfig config)

open

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

Description copied from interface: OrientDBInternal

Open a database specified by name using the username and password if needed

Specified by:

open in interface OrientDBInternal

Parameters:

name - of the database to open

user - the username allowed to open the database

password - related to the specified username

Returns:

the opened database

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

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

create

public void create(String name,
                   String user,
                   String password,
                   ODatabaseType databaseType)

Description copied from interface: OrientDBInternal

Create a new database

Specified by:

create in interface OrientDBInternal

Parameters:

name - database name

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

password - the password relative to the user

databaseType - can be plocal or memory

create

public void create(String name,
                   String user,
                   String password,
                   ODatabaseType databaseType,
                   OrientDBConfig config)

Description copied from interface: OrientDBInternal

Create a new database

Specified by:

create in interface OrientDBInternal

Parameters:

name - database name

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

password - the password relative to the user

databaseType - can be plocal or memory

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

poolOpen

public ODatabaseDocumentRemotePooled 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

closeStorage

public void closeStorage(OStorageRemote remote)

getServerInfo

public ODocument getServerInfo(String username,
                               String password)

getClusterStatus

public ODocument getClusterStatus(String username,
                                  String password)

getGlobalConfiguration

public String getGlobalConfiguration(String username,
                                     String password,
                                     OGlobalConfiguration config)

setGlobalConfiguration

public void setGlobalConfiguration(String username,
                                   String password,
                                   OGlobalConfiguration config,
                                   String iConfigValue)

getGlobalConfigurations

public Map<String,String> getGlobalConfigurations(String username,
                                                  String password)

getConnectionManager

public ORemoteConnectionManager getConnectionManager()

exists

public boolean exists(String name,
                      String user,
                      String password)

Description copied from interface: OrientDBInternal

Check if a database exists

Specified by:

exists in interface OrientDBInternal

Parameters:

name - database name to check

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

password - the password relative to the user

Returns:

boolean true if exist false otherwise.

drop

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

Description copied from interface: OrientDBInternal

Drop a database

Specified by:

drop in interface OrientDBInternal

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

listDatabases

public Set<String> listDatabases(String user,
                                 String password)

Description copied from interface: OrientDBInternal

List of database exiting in the current environment

Specified by:

listDatabases in interface OrientDBInternal

Parameters:

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

password - the password relative to the user

Returns:

a set of databases names.

restore

public void restore(String name,
                    String user,
                    String password,
                    ODatabaseType type,
                    String path,
                    OrientDBConfig config)

Specified by:

restore in interface OrientDBInternal

openPool

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

Description copied from interface: OrientDBInternal

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

Specified by:

openPool in interface OrientDBInternal

Parameters:

name - database name

user - the username allowed to open the database

password - the password relative to the user

Returns:

a new pool of databases.

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

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)

Specified by:

cachedPool in interface OrientDBInternal

cachedPool

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

Specified by:

cachedPool in interface OrientDBInternal

removePool

public void removePool(ODatabasePoolInternal pool)

Description copied from interface: OrientDBInternal

Internal API for pool close

Specified by:

removePool in interface OrientDBInternal

close

public void close()

Description copied from interface: OrientDBInternal

Close the factory with all related databases and pools.

Specified by:

close in interface OrientDBInternal

Specified by:

close in interface AutoCloseable

internalClose

public void internalClose()

Description copied from interface: OrientDBInternal

Should be called only by shutdown listeners

Specified by:

internalClose in interface OrientDBInternal

isOpen

public boolean isOpen()

Description copied from interface: OrientDBInternal

Check if the current instance is open

Specified by:

isOpen in interface OrientDBInternal

isEmbedded

public boolean isEmbedded()

Specified by:

isEmbedded in interface OrientDBInternal

removeShutdownHook

public void removeShutdownHook()

Specified by:

removeShutdownHook in interface OrientDBInternal

loadAllDatabases

public void loadAllDatabases()

Specified by:

loadAllDatabases in interface OrientDBInternal

openNoAuthenticate

public ODatabaseDocumentInternal openNoAuthenticate(String iDbUrl,
                                                    String user)

Specified by:

openNoAuthenticate in interface OrientDBInternal

initCustomStorage

public void initCustomStorage(String name,
                              String baseUrl,
                              String userName,
                              String userPassword)

Specified by:

initCustomStorage in interface OrientDBInternal

getStorages

public Collection<OStorage> getStorages()

Specified by:

getStorages in interface OrientDBInternal

forceDatabaseClose

public void forceDatabaseClose(String databaseName)

Specified by:

forceDatabaseClose in interface OrientDBInternal

restore

public void restore(String name,
                    InputStream in,
                    Map<String,Object> options,
                    Callable<Object> callable,
                    OCommandOutputListener iListener)

Specified by:

restore in interface OrientDBInternal

openNoAuthorization

public ODatabaseDocumentInternal openNoAuthorization(String name)

Specified by:

openNoAuthorization in interface OrientDBInternal

getOrCreateSharedContext

protected OSharedContext getOrCreateSharedContext(OStorage storage)

schedule

public void schedule(TimerTask task,
                     long delay,
                     long period)

Specified by:

schedule in interface OSchedulerInternal

scheduleOnce

public void scheduleOnce(TimerTask task,
                         long delay)

Specified by:

scheduleOnce in interface OSchedulerInternal

executeNoAuthorization

public <X> Future<X> executeNoAuthorization(String database,
                                            ODatabaseTask<X> task)

Specified by:

executeNoAuthorization in interface OrientDBInternal

execute

public <X> Future<X> execute(String database,
                             String user,
                             ODatabaseTask<X> task)

Specified by:

execute in interface OrientDBInternal