public class RepositorySQLiteConnection extends java.lang.Object implements RepositoryConnectivity
| Modifier and Type | Field and Description |
|---|---|
protected SQLConfig |
Config |
protected java.sql.Connection |
Connection |
| Constructor and Description |
|---|
RepositorySQLiteConnection(ReposConfig config,
java.lang.String repos) |
RepositorySQLiteConnection(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 |
getPostgreSQLFormat() |
java.lang.String |
getRepository()
Returns the name associated with the repository to which the connection
is established.
|
SQLDatabase |
getSkeleton() |
java.lang.String |
getSQLiteFormat() |
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.
|
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 RepositorySQLiteConnection(ReposConfig config, java.lang.String repos)
public RepositorySQLiteConnection(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()
RepositoryConnectivitygetRepository in interface RepositoryConnectivitypublic java.lang.String getMySQLFormat()
public java.lang.String getSQLiteFormat()
public java.lang.String getPostgreSQLFormat()
public java.lang.Class resolveStorageFor(java.lang.Class iface)
RepositoryConnectivityresolveStorageFor in interface RepositoryConnectivitypublic java.lang.String getDatabase()
public boolean createStorage(java.lang.Class iface,
java.lang.String storagename)
RepositoryConnectivitycreateStorage in interface RepositoryConnectivitypublic RepositoryMaintenance getCustodian()
RepositoryConnectivitygetCustodian in interface RepositoryConnectivitypublic 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()
RepositoryConnectivityclose in interface RepositoryConnectivitypublic java.sql.Statement createStatement()
public void tearDownSkeleton()
public java.lang.String getLastInsertID(java.lang.String table)