Package tigase.db
Interface DataRepository
- All Superinterfaces:
DataSource,Repository
- All Known Implementing Classes:
DataRepoPool,DataRepositoryImpl,DataRepositoryPool
The interface defines a generic data repository for storing arbitrary data in any application specific form. This
interface unifies database (repository) access allowing for easier way to create database connections pools or
database fail-over mechanisms.
Created: Jun 16, 2010 3:34:32 PM
Created: Jun 16, 2010 3:34:32 PM
- Author:
- Artur Hefczyc
-
Nested Class Summary
Nested ClassesModifier and TypeInterfaceDescriptionstatic enumHelper enumeration with types of supported databases.Nested classes/interfaces inherited from interface tigase.db.Repository
Repository.Meta, Repository.SchemaId -
Field Summary
FieldsFields inherited from interface tigase.db.DataSource
log -
Method Summary
Modifier and TypeMethodDescriptionbooleancheckTable(String tableName) The method checks whether a table for the given name exists in the database.booleancheckTable(String tableName, String createTableQuery) The method checks whether a table for the given name exists in the database and if it does not, it automatically creates it.voidcommit()Commits current transaction on the DataRepository connection.createStatement(BareJID user_id) Creates a SQL statement on which SQL queries can be executed later by the higher repository layer.voidEnds current transaction on the DataRepository connection.Returns type of DataRepository databaseintgetPreparedStatement(int hashCode, String stIdKey) Returns a prepared statement for a given key.getPreparedStatement(BareJID user_id, String stIdKey) Returns a prepared statement for a given key.Returns a DB connection string or DB connection URI.default TimestampgetTimestamp(ResultSet rs, int pos) Helper method to get timestamp from result set.default TimestampgetTimestamp(ResultSet rs, String field) Helper method to get timestamp from result set.voidinitPreparedStatement(String stIdKey, String query) Initializes a prepared statement for a given query and stores it internally under the given id key.voidinitPreparedStatement(String stIdKey, String query, int autoGeneratedKeys) Initializes a prepared statement for a given query and stores it internally under the given id key.voidA helper method to release resources from the statement and result set.voidvoidrollback()Rolls back started transaction on the DataRepository connection.default voidsetTimestamp(PreparedStatement stmt, int pos, Timestamp timestamp) Helper method to set timestamp into prepared statements.voidStarts transaction on the DataRepository connection.takeRepoHandle(BareJID user_id) ReturnsDataRepositoryinstance.Methods inherited from interface tigase.db.DataSource
automaticSchemaManagement, checkConnectivity, checkSchemaVersion, getSchemaVersion, initializeMethods inherited from interface tigase.db.Repository
initRepository
-
Field Details
-
UTC_CALENDAR
-
-
Method Details
-
checkTable
The method checks whether a table for the given name exists in the database.- Parameters:
tableName- is aStringvalue of the table name to check- Returns:
truebooleanvalue if the table exist in the database andfalseif the table was not found.- Throws:
SQLException- if there was a problem accessing database.
-
checkTable
The method checks whether a table for the given name exists in the database and if it does not, it automatically creates it.- Parameters:
tableName- is aStringvalue of the table name to checkcreateTableQuery- is aStringwith the query to create table- Returns:
truebooleanvalue if the table exist in the database andfalseif the table was not found.- Throws:
SQLException- if there was a problem accessing database.
-
commit
Commits current transaction on the DataRepository connection. Please note that calling this method on the repository pool has no effect. You have to obtain particular repository handle first, before you can start transaction.- Throws:
SQLException
-
createStatement
Creates a SQL statement on which SQL queries can be executed later by the higher repository layer.- Parameters:
user_id- user id for which the statement has to be created. This is an optional parameter and null can be provided. It is used mainly to group queries for the same user on the same DB connection.- Returns:
- a newly created
Statement - Throws:
SQLException- if a JDBC error occurs.
-
endTransaction
Ends current transaction on the DataRepository connection. Please note that calling this method on the repository pool has no effect. You have to obtain particular repository handle first, before you can start transaction.- Throws:
SQLException
-
initPreparedStatement
Initializes a prepared statement for a given query and stores it internally under the given id key. It can be retrieved later usinggetPreparedStatement(stIdKey)method.- Parameters:
stIdKey- is a statement identification key.query- is a query for the prepared statement.- Throws:
SQLException
-
initPreparedStatement
Initializes a prepared statement for a given query and stores it internally under the given id key. It can be retrieved later usinggetPreparedStatement(stIdKey)method.- Parameters:
stIdKey- is a statement identification key.query- is a query for the prepared statement.autoGeneratedKeys- defines if statement should return auto generated keys- Throws:
SQLException
-
release
A helper method to release resources from the statement and result set. This is most common operation for all database calls, therefore it does make sense to add such a utility method to the API.- Parameters:
stmt- aStatementvariable to release resources for. Might be null.rs- aResultSetvariable to release resources for. Might be null.
-
releaseRepoHandle
-
rollback
Rolls back started transaction on the DataRepository connection. Please note that calling this method on the repository pool has no effect. You have to obtain particular repository handle first, before you can start transaction.- Throws:
SQLException
-
startTransaction
Starts transaction on the DataRepository connection. Please note that calling this method on the repository pool has no effect. You have to obtain particular repository handle first, before you can start transaction.- Throws:
SQLException
-
takeRepoHandle
ReturnsDataRepositoryinstance. If this is a repository pool then it returns particular instance from the pool. It this is a real repository instance it returns itself. This is exclusive take, no other thread may use this handle until it is returned to the pool.- Parameters:
user_id- is user account ID for which we acquire the handle.- Returns:
- DataRepository instance.
-
getDatabaseType
DataRepository.dbTypes getDatabaseType()Returns type of DataRepository database- Returns:
- a value of
dbTypes
-
getPoolSize
int getPoolSize() -
getPreparedStatement
Returns a prepared statement for a given key.- Parameters:
user_id- user id for which the statement has to be created. This is an optional parameter and null can be provided. It is used mainly to group queries for the same user on the same DB connection.stIdKey- is a statement identification key.- Returns:
- a
PreparedStatementfor the given id key or null if such a statement does not exist. - Throws:
SQLException
-
getPreparedStatement
Returns a prepared statement for a given key.- Parameters:
hashCode- user for selection of connection to use. It is used mainly to group queries for the same user on the same DB connection.stIdKey- is a statement identification key.- Returns:
- a
PreparedStatementfor the given id key or null if such a statement does not exist. - Throws:
SQLException
-
getResourceUri
String getResourceUri()Returns a DB connection string or DB connection URI.- Specified by:
getResourceUriin interfaceDataSource- Returns:
- a
Stringvalue representing database connection string.
-
setTimestamp
Helper method to set timestamp into prepared statements. Provides proper calendar when needed to adjust timestamps so that they are stored in the database in proper time zone.- Throws:
SQLException
-
getTimestamp
Helper method to get timestamp from result set. Provides proper calendar when needed to adjust timestamps so that they are stored in the database in proper time zone.- Throws:
SQLException
-
getTimestamp
Helper method to get timestamp from result set. Provides proper calendar when needed to adjust timestamps so that they are stored in the database in proper time zone.- Throws:
SQLException
-