com.inubit.research.server.persistence

Class MySQLDatabaseConnector

java.lang.Object

com.inubit.research.server.persistence.PersistenceConnector

com.inubit.research.server.persistence.SQLDatabaseConnector

com.inubit.research.server.persistence.MySQLDatabaseConnector

All Implemented Interfaces:

DatabaseConnector

public class MySQLDatabaseConnector
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
MySQLDatabaseConnector()

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 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.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, createTablesIfNotExist, deleteEntity, deleteModel, divestRight, execute, getAccessiblePaths, getAccessors, getAllMappedIDs, getComments, getConnection, getConnectionName, getIDMapping, getISConnections, getModel, getModelsWithAccess, getModelVersionCount, getUserImageInsertStatement, 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

MySQLDatabaseConnector

public MySQLDatabaseConnector()

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

getTableCreationStatement

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

Specified by:

getTableCreationStatement in class SQLDatabaseConnector

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

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

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