org.apache.marmotta.kiwi.persistence

Class KiWiPersistence

java.lang.Object

org.apache.marmotta.kiwi.persistence.KiWiPersistence

public class KiWiPersistence
extends Object

Add file description here!

Author: Sebastian Schaffert

Constructor Summary

Constructors

Constructor and Description
KiWiPersistence(KiWiConfiguration configuration)
KiWiPersistence(String name, String jdbcUrl, String db_user, String db_password, KiWiDialect dialect) Deprecated.

Method Summary

Methods

Modifier and Type	Method and Description
void	addNodeTableDependency(String tableName, String columnName) Add information about a dependency of a column in some table to the "nodes" table; this information is used when cleaning up unreferenced deleted entries in the nodes table.
void	addTripleTableDependency(String tableName, String columnName) Add information about a dependency of a column in some table to the "triples" table; this information is used when cleaning up unreferenced deleted entries in the triples table.
boolean	checkConsistency()
void	clearCache() Remove all elements from the cache
void	dropDatabase() Remove all KiWi base tables from the SQL database.
void	dropDatabase(String scriptName) Remove all KiWi tables from the SQL database.
void	garbageCollect()
CacheManager	getCacheManager()
KiWiConfiguration	getConfiguration()
KiWiConnection	getConnection() Return a connection from the connection pool which already has the auto-commit disabled.
KiWiDialect	getDialect()
IDGenerator	getIdGenerator()
Connection	getJDBCConnection() Return a raw JDBC connection from the connection pool, which already has the auto-commit disabled.
Connection	getJDBCConnection(boolean maintenance) Return a raw JDBC connection from the connection pool, which already has the auto-commit disabled.
KiWiValueFactory	getValueFactory()
void	initDatabase()
void	initDatabase(String scriptName, String[] checkTables) Initialise the database, creating or upgrading tables if they do not exist or are of the wrong version.
void	initialise()
void	logPoolInfo()
void	releaseJDBCConnection(Connection con) Release the JDBC connection passed as argument.
void	setValueFactory(KiWiValueFactory valueFactory)
void	shutdown()

Methods inherited from class java.lang.Object

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

Constructor Detail

KiWiPersistence

@Deprecated
public KiWiPersistence(String name,
                          String jdbcUrl,
                          String db_user,
                          String db_password,
                          KiWiDialect dialect)

Deprecated.

KiWiPersistence

public KiWiPersistence(KiWiConfiguration configuration)

Method Detail

initialise

public void initialise()

getDialect

public KiWiDialect getDialect()

getCacheManager

public CacheManager getCacheManager()

logPoolInfo

public void logPoolInfo()
                 throws SQLException

Throws:

SQLException

initDatabase

public void initDatabase()
                  throws SQLException

Throws:

SQLException

initDatabase

public void initDatabase(String scriptName,
                String[] checkTables)
                  throws SQLException

Initialise the database, creating or upgrading tables if they do not exist or are of the wrong version.

Parameters:

scriptName - the name of the script to use for create or update (e.g. "base" or "versioning")

Throws:

SQLException

dropDatabase

public void dropDatabase()
                  throws SQLException

Remove all KiWi base tables from the SQL database. This method will run the drop script of the respective dialect and return.

Throws:

SQLException

dropDatabase

public void dropDatabase(String scriptName)
                  throws SQLException

Remove all KiWi tables from the SQL database. This method will run the drop script of the respective dialect and return.

Parameters:

scriptName - the name of the script to use for drop (e.g. "base" or "versioning")

Throws:

SQLException

getConnection

public KiWiConnection getConnection()
                             throws SQLException

Return a connection from the connection pool which already has the auto-commit disabled.

Returns:

a fresh JDBC connection from the connection pool

Throws:

SQLException - in case a new connection could not be established

getJDBCConnection

public Connection getJDBCConnection()
                             throws SQLException

Return a raw JDBC connection from the connection pool, which already has the auto-commit disabled.

Returns:

Throws:

SQLException

getJDBCConnection

public Connection getJDBCConnection(boolean maintenance)
                             throws SQLException

Return a raw JDBC connection from the connection pool, which already has the auto-commit disabled.

Returns:

Throws:

SQLException

releaseJDBCConnection

public void releaseJDBCConnection(Connection con)
                           throws SQLException

Release the JDBC connection passed as argument. This method will close the connection and release any locks that might be held by the caller.

Parameters:

con -

Throws:

SQLException

addNodeTableDependency

public void addNodeTableDependency(String tableName,
                          String columnName)

Add information about a dependency of a column in some table to the "nodes" table; this information is used when cleaning up unreferenced deleted entries in the nodes table. In theory, we could get this information from the database, but each database has a very different way of doing this, so it is easier to simply let dependent modules register this information.

Parameters:

tableName -

columnName -

addTripleTableDependency

public void addTripleTableDependency(String tableName,
                            String columnName)

Add information about a dependency of a column in some table to the "triples" table; this information is used when cleaning up unreferenced deleted entries in the triples table. In theory, we could get this information from the database, but each database has a very different way of doing this, so it is easier to simply let dependent modules register this information.

Parameters:

tableName -

columnName -

shutdown

public void shutdown()

clearCache

public void clearCache()

Remove all elements from the cache

setValueFactory

public void setValueFactory(KiWiValueFactory valueFactory)

getValueFactory

public KiWiValueFactory getValueFactory()

getConfiguration

public KiWiConfiguration getConfiguration()

garbageCollect

public void garbageCollect()
                    throws SQLException

Throws:

SQLException

checkConsistency

public boolean checkConsistency()
                         throws SQLException

Throws:

SQLException

getIdGenerator

public IDGenerator getIdGenerator()