Package lu.kbra.pclib.db.base

Class DataBase

java.lang.Object

lu.kbra.pclib.db.base.DataBase

Direct Known Subclasses:

DeferredDataBase

public class DataBase
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	DataBase.AbstractTableTransaction

Field Summary

Fields

Modifier and Type	Field	Description
protected DataBaseConnector	connector
protected DataBaseEntryUtils	dataBaseEntryUtils
protected final String	dataBaseName
protected DataBaseStructure	dataBaseStructure
protected String	migrationSchemaName
protected final List<AbstractDBTable<? extends DataBaseEntry>>	tables
protected final List<AbstractDBView<? extends DataBaseEntry>>	views

Constructor Summary

Constructors

Constructor	Description
DataBase(DataBaseConnector connector, String name)
DataBase(DataBaseConnector connector, String name, Map<String,Object> baseHints, DataBaseEntryUtils dbEntryUtils)
DataBase(DataBaseConnector connector, String name, DataBaseEntryUtils dbEntryUtils)

Method Summary

Modifier and Type	Method	Description
protected Connection	connect()
DataBaseStatus	create()
Connection	createConnection()
DBTransaction	createTransaction()
DataBase	drop()
boolean	exists()
Supplier<AbstractConnection>	getConnectionSupplier()	Deprecated.
protected DataBase	getDataBase()
void	migrate(Collection<? extends DataBaseMigration> migrations)
void	migrate(Collection<? extends DataBaseMigration> migrations, Collection<AbstractDBTable> tables, SchemaMigrationOptions schemaOptions)
void	migrateTables(Collection<AbstractDBTable> tables, SchemaMigrationOptions schemaOptions)
<B extends AbstractDBTable<T>, T extends DataBaseEntry> void	registerTable(B table)
<B extends AbstractDBView<T>, T extends DataBaseEntry> void	registerView(B view)
void	requestHook(SQLRequestType type, Object query)
void	setMigrationSchemaName(String migrationSchemaName)
String	toString()
void	updateDataBaseConnector()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Details

connector

protected DataBaseConnector connector

dataBaseEntryUtils

protected DataBaseEntryUtils dataBaseEntryUtils

dataBaseName

protected final String dataBaseName

migrationSchemaName

protected String migrationSchemaName

dataBaseStructure

protected DataBaseStructure dataBaseStructure

tables

protected final List<AbstractDBTable<? extends DataBaseEntry>> tables

views

protected final List<AbstractDBView<? extends DataBaseEntry>> views

Constructor Details

DataBase

public DataBase(DataBaseConnector connector,
 String name)

DataBase

public DataBase(DataBaseConnector connector,
 String name,
 DataBaseEntryUtils dbEntryUtils)

DataBase

public DataBase(DataBaseConnector connector,
 String name,
 Map<String,Object> baseHints,
 DataBaseEntryUtils dbEntryUtils)

Method Details

registerTable

public <B extends AbstractDBTable<T>,
T extends DataBaseEntry>
void registerTable(B table)

registerView

public <B extends AbstractDBView<T>,
T extends DataBaseEntry>
void registerView(B view)

create

public DataBaseStatus create()
                      throws DBException

Throws:

DBException

createTransaction

public DBTransaction createTransaction()

drop

public DataBase drop()
              throws DBException

Throws:

DBException

exists

public boolean exists()
               throws DBException

Throws:

DBException

getConnectionSupplier

@Deprecated
public Supplier<AbstractConnection> getConnectionSupplier()

Deprecated.

migrate

public void migrate(Collection<? extends DataBaseMigration> migrations)
             throws DBException

Throws:

DBException

migrate

public void migrate(Collection<? extends DataBaseMigration> migrations,
 Collection<AbstractDBTable> tables,
 SchemaMigrationOptions schemaOptions)
             throws DBException

Throws:

DBException

migrateTables

public void migrateTables(Collection<AbstractDBTable> tables,
 SchemaMigrationOptions schemaOptions)
                   throws DBException

Throws:

DBException

requestHook

public void requestHook(SQLRequestType type,
 Object query)

setMigrationSchemaName

public void setMigrationSchemaName(String migrationSchemaName)

updateDataBaseConnector

public void updateDataBaseConnector()
                             throws DBException

Throws:

DBException

connect

protected Connection connect()
                      throws DBException

Throws:

DBException

createConnection

public Connection createConnection()
                            throws DBException

Throws:

DBException

getDataBase

protected DataBase getDataBase()

toString

public String toString()

Overrides:

toString in class Object