public class RepositoryPostgreSQLConnection extends java.lang.Object implements RepositoryConnectivity
Modifier and Type | Field and Description |
---|---|
protected SQLConfig |
Config |
protected java.sql.Connection |
Connection |
Constructor and Description |
---|
RepositoryPostgreSQLConnection(ReposConfig config,
java.lang.String repos) |
RepositoryPostgreSQLConnection(ReposConfig config,
java.lang.String repos,
boolean connect) |
Modifier and Type | Method and Description |
---|---|
void |
close()
Closes the connection fo the repository.
|
void |
commit() |
void |
createAndTransferStorageThreaded(RepositoryStorage storage)
Creates (if not exists) the storage on this connectivity and
then transfers it.
|
boolean |
createSkeleton()
Create all tables within the database specified by the given repository.
|
java.sql.Statement |
createStatement()
Create an SQL statement.
|
boolean |
createStorage(java.lang.Class iface,
java.lang.String storagename)
Creates a storage instance on the repository.
|
boolean |
createStorage(java.lang.String storagename) |
boolean |
databaseExists() |
java.lang.Class |
determineClassOf(java.lang.String storagename)
Returns a Class object for the type of storage that would result
from instantiating the named storage.
|
boolean |
getAutoCommit() |
RepositoryMaintenance |
getCustodian()
Gets an instance appropriate for the creation, deletion or other
privilaged or atypical operations on the storages housed within a
reporitory.
|
java.lang.String |
getDatabase() |
java.util.Vector |
getFields(java.lang.String table) |
java.lang.Class |
getFindNameDialogForClass(java.lang.Class storageclass) |
java.lang.String |
getLastInsertID(java.lang.String table)
Get the output from `SELECT LAST_INSERT_ID() FROM `;
|
RepositoryMaintenance |
getManager() |
java.lang.String |
getMySQLFormat() |
java.lang.String |
getRepository()
Returns the name associated with the repository to which the connection
is established.
|
SQLDatabase |
getSkeleton() |
RepositoryStorage |
getStorage(java.lang.String storagename)
Gets the storage having the given nickname from the currently connected
repository.
|
RepositoryStorageNameQuery |
getStorageNameQuery()
Returns a name query instance appropriate for searching the repository
contents for storages matching various search criteria.
|
void |
getStorageThreaded(java.util.concurrent.ConcurrentHashMap out,
java.lang.String storagename) |
java.util.Vector |
getTables() |
int |
getThreadedTransfers() |
boolean |
isEmptyRepository()
Verify that the database specified in the given repository is a valid
pHtools database.
|
boolean |
isValidRepository()
Verify that the database specified in the given repository is a valid
pHtools database.
|
java.lang.String |
mySQLFormat() |
void |
openConnection() |
java.sql.PreparedStatement |
prepareStatement(java.lang.String s) |
void |
releaseSavepoint(java.sql.Savepoint sp) |
java.lang.Class |
resolveStorageFor(java.lang.Class iface)
For the given interface (or less typically class) return the RepositoryStorage
class extension for this repsoitory.
|
void |
rollback() |
void |
rollback(java.sql.Savepoint sp) |
void |
setAutoCommit(boolean f) |
java.sql.Savepoint |
setSavepoint() |
java.sql.Savepoint |
setSavepoint(java.lang.String sp) |
void |
setThreadedTransfers(int n) |
boolean |
storageExists(java.lang.String storagename)
Determines if the named storage already exists in the possibly remote
repository.
|
void |
tearDownSkeleton()
Removes the skeleton from the database.
|
protected java.sql.Connection Connection
protected SQLConfig Config
public RepositoryPostgreSQLConnection(ReposConfig config, java.lang.String repos)
public RepositoryPostgreSQLConnection(ReposConfig config, java.lang.String repos, boolean connect)
public void releaseSavepoint(java.sql.Savepoint sp)
public void rollback()
public void rollback(java.sql.Savepoint sp)
public java.sql.Savepoint setSavepoint()
public java.sql.Savepoint setSavepoint(java.lang.String sp)
public void openConnection()
public java.lang.String getRepository()
RepositoryConnectivity
getRepository
in interface RepositoryConnectivity
public java.lang.String getMySQLFormat()
public java.lang.Class resolveStorageFor(java.lang.Class iface)
RepositoryConnectivity
resolveStorageFor
in interface RepositoryConnectivity
public java.lang.String getDatabase()
public boolean createStorage(java.lang.Class iface, java.lang.String storagename)
RepositoryConnectivity
createStorage
in interface RepositoryConnectivity
public RepositoryMaintenance getCustodian()
RepositoryConnectivity
getCustodian
in interface RepositoryConnectivity
public boolean createStorage(java.lang.String storagename)
public java.sql.PreparedStatement prepareStatement(java.lang.String s)
public boolean getAutoCommit()
public void setAutoCommit(boolean f)
public void commit()
public void close()
RepositoryConnectivity
close
in interface RepositoryConnectivity
public java.sql.Statement createStatement()
public void tearDownSkeleton()
public java.lang.String getLastInsertID(java.lang.String table)