com.inubit.research.server.persistence

Class PostgreSQLDatabaseConnector

java.lang.Object

com.inubit.research.server.persistence.PersistenceConnector

com.inubit.research.server.persistence.SQLDatabaseConnector

com.inubit.research.server.persistence.PostgreSQLDatabaseConnector

All Implemented Interfaces:

DatabaseConnector

public class PostgreSQLDatabaseConnector
extends SQLDatabaseConnector

Nested Class Summary

Nested classes/interfaces inherited from class com.inubit.research.server.persistence.PersistenceConnector

PersistenceConnector.ImageType

Nested classes/interfaces inherited from interface com.inubit.research.server.persistence.DatabaseConnector

DatabaseConnector.EntityType

Field Summary

Fields inherited from class com.inubit.research.server.persistence.SQLDatabaseConnector

dbconn, MAPPING_ATTS, PROP_DB_NAME, PROP_HOST, PROP_PASSWD, PROP_PORT, PROP_SCHEMA_STMT_ACCESS, PROP_SCHEMA_STMT_COMMENTS, PROP_SCHEMA_STMT_CONNECTIONS, PROP_SCHEMA_STMT_EVOLUTION, PROP_SCHEMA_STMT_GROUPS, PROP_SCHEMA_STMT_ID, PROP_SCHEMA_STMT_MODELS, PROP_SCHEMA_STMT_PATHACCESS, PROP_SCHEMA_STMT_SUBGROUPS, PROP_SCHEMA_STMT_USER, PROP_SCHEMA_STMT_USER_IMAGE, PROP_SCHEMA_STMT_VERSIONS, PROP_USER, stmtProps, tableNames

Constructor Summary

Constructors

Constructor and Description
PostgreSQLDatabaseConnector()

Method Summary

Modifier and Type	Method and Description
int	addModelVersion(java.io.File f, java.lang.String id, SingleUser user, java.lang.String comment, java.lang.String date)
protected void	createTablesIfNotExist(java.sql.Connection conn, java.util.Properties props)
protected java.lang.String	getEnumQueryParameter(java.lang.Enum e)
protected java.lang.String	getStringCastParameter(java.lang.String attribute)
protected java.lang.String	getStringConcatenation(java.lang.String[] strings)
protected java.lang.String	getTableCreationStatement(java.lang.String tableName, java.lang.String schemaPart)
protected java.lang.String	getUserImageInsertStatement(java.lang.String id)
protected java.sql.Connection	openConnection(java.util.Properties dbprops)
protected void	setUserImageParameter(java.sql.PreparedStatement stmt, int parIndex, byte[] image)

Methods inherited from class com.inubit.research.server.persistence.SQLDatabaseConnector

addModel, addToIDMapping, addUser, checkConnection, deleteEntity, deleteModel, divestRight, execute, getAccessiblePaths, getAccessors, getAllMappedIDs, getComments, getConnection, getConnectionName, getIDMapping, getISConnections, getModel, getModelsWithAccess, getModelVersionCount, grantRight, insertEntity, loadUserImage, openNewDatabaseConnection, saveUserImage, selectAttributes, selectMultiValueSingleAttribute, selectMultiValueSingleAttributeWithMultipleIDs, selectSingleAttribute, selectSingleAttribute, selectSingleColumn, storeIDMapping, updateAttribute

Methods inherited from class com.inubit.research.server.persistence.PersistenceConnector

addToModelCache, clearModelCache, fetchFromModelCache

Methods inherited from class java.lang.Object

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

Constructor Detail

PostgreSQLDatabaseConnector

public PostgreSQLDatabaseConnector()

Method Detail

openConnection

protected java.sql.Connection openConnection(java.util.Properties dbprops)
                                      throws java.lang.Exception

Specified by:

openConnection in class SQLDatabaseConnector

Throws:

java.lang.Exception

createTablesIfNotExist

protected void createTablesIfNotExist(java.sql.Connection conn,
                                      java.util.Properties props)

Overrides:

createTablesIfNotExist in class SQLDatabaseConnector

getTableCreationStatement

protected java.lang.String getTableCreationStatement(java.lang.String tableName,
                                                     java.lang.String schemaPart)

Specified by:

getTableCreationStatement in class SQLDatabaseConnector

addModelVersion

public int addModelVersion(java.io.File f,
                           java.lang.String id,
                           SingleUser user,
                           java.lang.String comment,
                           java.lang.String date)
                    throws java.sql.SQLException,
                           java.io.IOException

Parameters:

f - the file containing the new model version

id - the model id

user - the commiting user

comment - the commit message

date - the creation date

Returns:

the model version number

Throws:

java.sql.SQLException - if an error occured while saving to the database

java.io.IOException - if an error occured while reading the file

setUserImageParameter

protected void setUserImageParameter(java.sql.PreparedStatement stmt,
                                     int parIndex,
                                     byte[] image)
                              throws java.sql.SQLException

Specified by:

setUserImageParameter in class SQLDatabaseConnector

Throws:

java.sql.SQLException

getUserImageInsertStatement

protected java.lang.String getUserImageInsertStatement(java.lang.String id)

Overrides:

getUserImageInsertStatement in class SQLDatabaseConnector

getEnumQueryParameter

protected java.lang.String getEnumQueryParameter(java.lang.Enum e)

Specified by:

getEnumQueryParameter in class SQLDatabaseConnector

getStringCastParameter

protected java.lang.String getStringCastParameter(java.lang.String attribute)

Specified by:

getStringCastParameter in class SQLDatabaseConnector

getStringConcatenation

protected java.lang.String getStringConcatenation(java.lang.String[] strings)

Specified by:

getStringConcatenation in class SQLDatabaseConnector