Package com.activeviam.directquery.internal

Class Database

java.lang.Object

com.activeviam.directquery.internal.Database

All Implemented Interfaces:

IDatabase, IDirectQueryDatabase, IJmxable, IInternalCompositeDatabaseProvider

public final class Database
extends Object
implements IDirectQueryDatabase, IJmxable, IInternalCompositeDatabaseProvider

The class representing the local database.

Author:

ActiveViam

Constructor Summary

Constructors

Constructor	Description
Database(CompositeDatabase db, SchemaDescription userSchema, ISqlDatabase externalDb, IDatabaseMBeanProvider databaseJmxProvider)	Constructor.

Method Summary

Modifier and Type	Method	Description
CompositeDatabase	getCompositeDatabase()
SchemaDescription	getCurrentSchema()	Returns the schema of the database.
IDataStreamer	getDataStreamer()	Returns the component responsible for managing streaming from this Database.
CompositeDatabase	getDb()
IDatabaseVersion	getHead(String branchName)	Gets the latest version in the given branch.
Map<String,IDatabaseVersion>	getHeads()	Returns the latest version of each branch.
IDatastore	getInMemoryDatastore()	Returns the bundled datastore.
ITransactionManager	getInMemoryTransactionManager()	Returns the in-memory transaction manager.
IQueryManager	getQueryManager()	Returns a component capable of compiling queries to run in the future or registering subscriptions to data.
SchemaDescription	getUserSchema()	-- GETTER -- Returns the initially provided database schema.
IDatabaseVersion	getVersion(long epochId)	Retrieves the version at the given epoch if there is one available.
Object	toMBean()	Returns the object compatible with ActiveViam JMX tooling.
String	toString()

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface com.activeviam.database.api.IDatabase

getMasterHead

Constructor Details

Database

public Database(CompositeDatabase db,
 SchemaDescription userSchema,
 ISqlDatabase externalDb,
 @Nullable
 IDatabaseMBeanProvider databaseJmxProvider)

Constructor.

Method Details

getInMemoryDatastore

public IDatastore getInMemoryDatastore()

Description copied from interface: IDirectQueryDatabase

Returns the bundled datastore.

Specified by:

getInMemoryDatastore in interface IDirectQueryDatabase

getInMemoryTransactionManager

public ITransactionManager getInMemoryTransactionManager()

Description copied from interface: IDirectQueryDatabase

Returns the in-memory transaction manager.

Specified by:

getInMemoryTransactionManager in interface IDirectQueryDatabase

getCurrentSchema

public SchemaDescription getCurrentSchema()

Description copied from interface: IDatabase

Returns the schema of the database.

Specified by:

getCurrentSchema in interface IDatabase

Specified by:

getCurrentSchema in interface IDirectQueryDatabase

getQueryManager

public IQueryManager getQueryManager()

Description copied from interface: IDatabase

Returns a component capable of compiling queries to run in the future or registering subscriptions to data.

Specified by:

getQueryManager in interface IDatabase

getDataStreamer

public IDataStreamer getDataStreamer()

Description copied from interface: IDatabase

Returns the component responsible for managing streaming from this Database.

Specified by:

getDataStreamer in interface IDatabase

getHeads

public Map<String,IDatabaseVersion> getHeads()

Description copied from interface: IDatabase

Returns the latest version of each branch.

The keys are the names of the branches.

Specified by:

getHeads in interface IDatabase

getHead

public IDatabaseVersion getHead(String branchName)
                         throws UnknownBranchException

Description copied from interface: IDatabase

Gets the latest version in the given branch.

Specified by:

getHead in interface IDatabase

Parameters:

branchName - the name of a branch, null to retrieve the most recent versions across heads

Throws:

UnknownBranchException - if the branch cannot be found

getVersion

public IDatabaseVersion getVersion(long epochId)
                            throws UnknownEpochException

Description copied from interface: IDatabase

Retrieves the version at the given epoch if there is one available.

Specified by:

getVersion in interface IDatabase

Parameters:

epochId - the id of the epoch at which to retrieve the version

Throws:

UnknownEpochException - if this version is no more available

toMBean

public Object toMBean()

Description copied from interface: IJmxable

Returns the object compatible with ActiveViam JMX tooling.

Specified by:

toMBean in interface IJmxable

toString

public String toString()

Overrides:

toString in class Object

getCompositeDatabase

public CompositeDatabase getCompositeDatabase()

Specified by:

getCompositeDatabase in interface IInternalCompositeDatabaseProvider

getDb

public CompositeDatabase getDb()

getUserSchema

public SchemaDescription getUserSchema()

-- GETTER -- Returns the initially provided database schema.