Module io.github.tonywasher.joceanus.prometheus.core

Package io.github.tonywasher.joceanus.prometheus.database

Class PrometheusDataStore

java.lang.Object

io.github.tonywasher.joceanus.prometheus.database.PrometheusDataStore

public abstract class PrometheusDataStore
extends Object

Class that encapsulates a database connection.

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	PrometheusDataStore(PrometheusDBConfig pConfig)	Construct a new Database class.
protected	PrometheusDataStore(String pDatabase, PrometheusDBConfig pConfig)	Construct a new Database class.

Method Summary

Modifier and Type	Method	Description
protected void	addTable(PrometheusTableDataItem<?> pTable)	Add a table.
void	close()	Close the connection to the database rolling back any outstanding transaction.
void	createDatabase(TethysUIThreadStatusReport pReport, String pDatabase)	Create database.
void	createTables(TethysUIThreadStatusReport pReport)	Create tables.
(package private) void	executeStatement(String pStatement)	Execute the statement outside a transaction.
protected Connection	getConn()	Access the connection.
protected PrometheusJDBCDriver	getDriver()	Obtain the Driver.
String	getName()	Obtain the database name.
void	loadDatabase(TethysUIThreadStatusReport pReport, PrometheusDataSet pData)	Load data from the database.
void	purgeTables(TethysUIThreadStatusReport pReport)	Purge tables.
void	updateDatabase(TethysUIThreadStatusReport pReport, PrometheusDataSet pData)	Update data into database.

Methods inherited from class java.lang.Object

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

Constructor Details

PrometheusDataStore

protected PrometheusDataStore(String pDatabase,
 PrometheusDBConfig pConfig)
                       throws OceanusException

Construct a new Database class.

Parameters:

pDatabase - the database

pConfig - the config

Throws:

OceanusException - on error

PrometheusDataStore

protected PrometheusDataStore(PrometheusDBConfig pConfig)
                       throws OceanusException

Construct a new Database class.

Parameters:

pConfig - the config

Throws:

OceanusException - on error

Method Details

getName

public String getName()

Obtain the database name.

Returns:

the name

executeStatement

void executeStatement(String pStatement)
               throws OceanusException

Execute the statement outside a transaction.

Parameters:

pStatement - the statement

Throws:

OceanusException - on error

getDriver

protected PrometheusJDBCDriver getDriver()

Obtain the Driver.

Returns:

the driver

getConn

protected Connection getConn()

Access the connection.

Returns:

the connection

addTable

protected void addTable(PrometheusTableDataItem<?> pTable)

Add a table.

Parameters:

pTable - the Table to add

close

public void close()

Close the connection to the database rolling back any outstanding transaction.

loadDatabase

public void loadDatabase(TethysUIThreadStatusReport pReport,
 PrometheusDataSet pData)
                  throws OceanusException

Load data from the database.

Parameters:

pReport - the report

pData - the new DataSet

Throws:

OceanusException - on error

updateDatabase

public void updateDatabase(TethysUIThreadStatusReport pReport,
 PrometheusDataSet pData)
                    throws OceanusException

Update data into database.

Parameters:

pReport - the report

pData - the data

Throws:

OceanusException - on error

createDatabase

public void createDatabase(TethysUIThreadStatusReport pReport,
 String pDatabase)
                    throws OceanusException

Create database.

Parameters:

pReport - the report

pDatabase - the database to create

Throws:

OceanusException - on error

createTables

public void createTables(TethysUIThreadStatusReport pReport)
                  throws OceanusException

Create tables.

Parameters:

pReport - the report

Throws:

OceanusException - on error

purgeTables

public void purgeTables(TethysUIThreadStatusReport pReport)
                 throws OceanusException

Purge tables.

Parameters:

pReport - the report

Throws:

OceanusException - on error