Package tigase.db.converter
Class DataRepoPool
- java.lang.Object
-
- tigase.db.converter.DataRepoPool
-
- All Implemented Interfaces:
tigase.db.DataRepository
,tigase.db.DataSource
,tigase.db.DataSourcePool<tigase.db.DataRepository>
,tigase.db.Repository
,tigase.db.RepositoryPool<tigase.db.DataRepository>
public class DataRepoPool extends java.lang.Object implements tigase.db.DataRepository, tigase.db.DataSourcePool<tigase.db.DataRepository>
-
-
Constructor Summary
Constructors Constructor Description DataRepoPool()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
addRepo(tigase.db.DataRepository repo)
boolean
automaticSchemaManagement()
void
checkConnectivity(java.time.Duration watchdogTime)
boolean
checkSchemaVersion(tigase.db.DataSourceAware<? extends tigase.db.DataSource> datasource, boolean shutdownServer)
boolean
checkTable(java.lang.String tableName)
boolean
checkTable(java.lang.String tableName, java.lang.String createTableQuery)
void
commit()
java.sql.Statement
createStatement(tigase.xmpp.jid.BareJID user_id)
void
endTransaction()
tigase.db.DataRepository.dbTypes
getDatabaseType()
int
getPoolSize()
java.sql.PreparedStatement
getPreparedStatement(int hashCode, java.lang.String stIdKey)
java.sql.PreparedStatement
getPreparedStatement(tigase.xmpp.jid.BareJID user_id, java.lang.String stIdKey)
java.lang.String
getResourceUri()
java.util.Optional<tigase.util.Version>
getSchemaVersion(java.lang.String component)
void
initialize(java.lang.String resource_uri)
void
initPreparedStatement(java.lang.String stIdKey, java.lang.String query)
void
initPreparedStatement(java.lang.String stIdKey, java.lang.String query, int autoGeneratedKeys)
void
release(java.sql.Statement stmt, java.sql.ResultSet rs)
void
releaseRepoHandle(tigase.db.DataRepository repo)
void
rollback()
void
startTransaction()
tigase.db.DataRepository
takeRepoHandle(tigase.xmpp.jid.BareJID user_id)
-
-
-
Method Detail
-
addRepo
public void addRepo(tigase.db.DataRepository repo)
- Specified by:
addRepo
in interfacetigase.db.RepositoryPool<tigase.db.DataRepository>
-
takeRepoHandle
public tigase.db.DataRepository takeRepoHandle(tigase.xmpp.jid.BareJID user_id)
- Specified by:
takeRepoHandle
in interfacetigase.db.DataRepository
-
releaseRepoHandle
public void releaseRepoHandle(tigase.db.DataRepository repo)
- Specified by:
releaseRepoHandle
in interfacetigase.db.DataRepository
-
automaticSchemaManagement
public boolean automaticSchemaManagement()
- Specified by:
automaticSchemaManagement
in interfacetigase.db.DataSource
-
checkConnectivity
public void checkConnectivity(java.time.Duration watchdogTime)
- Specified by:
checkConnectivity
in interfacetigase.db.DataSource
-
checkSchemaVersion
public boolean checkSchemaVersion(tigase.db.DataSourceAware<? extends tigase.db.DataSource> datasource, boolean shutdownServer)
- Specified by:
checkSchemaVersion
in interfacetigase.db.DataSource
-
getSchemaVersion
public java.util.Optional<tigase.util.Version> getSchemaVersion(java.lang.String component)
- Specified by:
getSchemaVersion
in interfacetigase.db.DataSource
-
checkTable
public boolean checkTable(java.lang.String tableName) throws java.sql.SQLException
- Specified by:
checkTable
in interfacetigase.db.DataRepository
- Throws:
java.sql.SQLException
-
checkTable
public boolean checkTable(java.lang.String tableName, java.lang.String createTableQuery) throws java.sql.SQLException
- Specified by:
checkTable
in interfacetigase.db.DataRepository
- Throws:
java.sql.SQLException
-
createStatement
public java.sql.Statement createStatement(tigase.xmpp.jid.BareJID user_id) throws java.sql.SQLException
- Specified by:
createStatement
in interfacetigase.db.DataRepository
- Throws:
java.sql.SQLException
-
getPreparedStatement
public java.sql.PreparedStatement getPreparedStatement(tigase.xmpp.jid.BareJID user_id, java.lang.String stIdKey) throws java.sql.SQLException
- Specified by:
getPreparedStatement
in interfacetigase.db.DataRepository
- Throws:
java.sql.SQLException
-
getPreparedStatement
public java.sql.PreparedStatement getPreparedStatement(int hashCode, java.lang.String stIdKey) throws java.sql.SQLException
- Specified by:
getPreparedStatement
in interfacetigase.db.DataRepository
- Throws:
java.sql.SQLException
-
getResourceUri
public java.lang.String getResourceUri()
- Specified by:
getResourceUri
in interfacetigase.db.DataRepository
- Specified by:
getResourceUri
in interfacetigase.db.DataSource
-
getDatabaseType
public tigase.db.DataRepository.dbTypes getDatabaseType()
- Specified by:
getDatabaseType
in interfacetigase.db.DataRepository
-
initPreparedStatement
public void initPreparedStatement(java.lang.String stIdKey, java.lang.String query) throws java.sql.SQLException
- Specified by:
initPreparedStatement
in interfacetigase.db.DataRepository
- Throws:
java.sql.SQLException
-
initPreparedStatement
public void initPreparedStatement(java.lang.String stIdKey, java.lang.String query, int autoGeneratedKeys) throws java.sql.SQLException
- Specified by:
initPreparedStatement
in interfacetigase.db.DataRepository
- Throws:
java.sql.SQLException
-
initialize
public void initialize(java.lang.String resource_uri) throws tigase.db.DBInitException
- Specified by:
initialize
in interfacetigase.db.DataSource
- Throws:
tigase.db.DBInitException
-
release
public void release(java.sql.Statement stmt, java.sql.ResultSet rs)
- Specified by:
release
in interfacetigase.db.DataRepository
-
startTransaction
public void startTransaction() throws java.sql.SQLException
- Specified by:
startTransaction
in interfacetigase.db.DataRepository
- Throws:
java.sql.SQLException
-
commit
public void commit() throws java.sql.SQLException
- Specified by:
commit
in interfacetigase.db.DataRepository
- Throws:
java.sql.SQLException
-
rollback
public void rollback() throws java.sql.SQLException
- Specified by:
rollback
in interfacetigase.db.DataRepository
- Throws:
java.sql.SQLException
-
endTransaction
public void endTransaction() throws java.sql.SQLException
- Specified by:
endTransaction
in interfacetigase.db.DataRepository
- Throws:
java.sql.SQLException
-
getPoolSize
public int getPoolSize()
- Specified by:
getPoolSize
in interfacetigase.db.DataRepository
-
-