Package org.teichert.databaseexplorer.database

Class DatabaseModel

java.lang.Object

org.teichert.databaseexplorer.database.DatabaseModel

All Implemented Interfaces:

Serializable

Direct Known Subclasses:

H2SQLModel, InformixSQLModel, MariaDBModel, MSSQLModel, MySQLModel, PostgreSQLModel, SQLiteModel

public abstract class DatabaseModel
extends Object
implements Serializable

Base-Class of all database-types.
This class is the procides all methods to access to a database and load any information and more.
Most of the methods are abstract so that all database-variants has to implement their own implementations.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
static long	serialVersionUID
List<SQLDataType>	types

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	DatabaseModel()

Method Summary

Modifier and Type	Method	Description
abstract void	addTableColumn(SQLTable table, SQLTableColumn newColumn, Object defaultValue, IDoingAfterThread d)
abstract boolean	checkIfIsSelect(String sql, Map<Object,Object> mapOfData)
abstract Object	convertObject(SQLTableColumn column, Object value)
abstract SQLTableColumn	convertSQLTableColumns(SQLTableColumn column)
abstract void	copyRows(DatabaseModel model, SQLTable from, SQLTable to)
Connection	createConnection(String url, String user, String password)
abstract Exception	createForeignKey(SQLForeignInfo foreignInfo, String addition)
abstract StringBuilder	createLimitSQL(String sql, int limit, StringBuilder b)
abstract void	createNewSQLIndexes(SQLTable table)
abstract void	createNewSQLTable(SQLTable table)
String	createTableName(String catalog, String schema, String table)
String	createTableName(SQLTable table)
String	createWhere(List<SQLTableColumn> columns, SQLTableValue[] line)	Creates the where clause with the given columns and the line which should be selected!
abstract void	deleteTableValue(SQLTableValue[] oldValues)
abstract void	dropColumn(SQLTableColumn column, SQLTextEditor<?> editor, IDoingAfterThread d)
void	dropDatabase(SQLDatabase database, SQLTextEditor<?> editor, IDoingAfterThread d)
abstract void	dropIndex(SQLIndex index, IDoingAfterThread d)
void	dropTable(SQLTable table, SQLTextEditor<?> editor, IDoingAfterThread d)
Exception	executeInternalSQL(SQLDatabase database, String sql, SQLTextEditor<?> editor, IDoingAfterThread d)
abstract Exception	executePreparedSQL(int connectionPoolId, SQLDatabase database, String sql, Object... values)
abstract KeyValue<String,SQLTable>	executePreparedSQL_SELECT(int connectionPoolId, SQLDatabase database, String sql, Object... values)
abstract Exception	executeSQL(int connectionPoolId, SQLDatabase database, String sql, SQLTextEditor<?> editor, IDoingAfterThread d)
abstract KeyValue<String,SQLTable>	executeSQL_SELECT(int connectionPoolId, SQLTextEditor<?> editor, SQLDatabase db, String sql, int limit, Map<Object,Object> mapOfData)
abstract KeyValue<String,SQLTable>	executeSQL_SELECT(int connectionPoolId, SQLTextEditor<?> editor, SQLTable table, int limit, Map<Object,Object> mapOfData)
abstract String	export(String sql, SQLDatabase db)
abstract String	getAddForeignKeyString(SQLForeignInfo foreignInfo, String addition)
abstract String	getAddTableColumnString(SQLTableColumn newColumn, Object defaultValue)
abstract String	getColumnFullname(SQLTableColumn column)
abstract String	getColumnNameForConversion(SQLTableColumn column)
abstract String	getColumnSelectSQL(SQLTable table)
abstract String	getConnectionString(String db, String ip, String port, String parameter)
abstract String	getConnectionStringQuerys()
String	getCreateIndexString(SQLTable table, String indexName, boolean nonUnique, boolean withSchema, String... columns)	Returns the string for creating a index with the given values.
String	getDeleteString(SQLTable table, boolean whereCondition)
abstract String	getDialect()
abstract String	getDriver()
abstract String	getDropColumnString(SQLTableColumn column)
String	getDropDatabaseString(SQLDatabase database)
abstract String	getDropIndexString(SQLIndex index)
String	getDropTableString(SQLTable table)
abstract String	getForeignKeyConstraintCheckString(boolean disabling)
String	getInsertIntoString(String columnName, SQLTable table)
String	getInsertIntoString(String columnName, SQLTable table, SQLTableValue newValue)
String	getInsertIntoString(String columnName, SQLTableValue newValue)
String	getInsertIntoString(SQLTable table)
String	getInsertIntoString(SQLTableValue[] newValues, boolean withSimicolon)
String	getInternalSystemDatabaseName()	Returns the name for another (internal) system database for getting Trigger information. For Example, for MySQL and MariaDB it would be the database "INFORMATION_SCHEMA". If the the trigger-information-table is in the same database, we has to return null. has to be overwritten in the child class if it deviates!
abstract String	getLoadSQLTriggersSQL(SQLTable table, String aliasTrgId, String aliasTrgCondition, String aliasTrgName, String aliasTrgEvent, String aliasTrgContent, String aliasTrgType)
abstract String	getModifyTableColumnString(SQLTableColumn column)
String	getName()
abstract String	getRenameTableColumnString(SQLTableColumn oldColumn, SQLTableColumn newColumn)
abstract String	getRenameTableString(SQLTable oldTable, SQLTable newTable)
abstract String	getSelectTableSQL(SQLTable table, int limit)
abstract String	getSelectUserQuery()
String	getTableCreationString(SQLTable table, boolean withSchema)
abstract String	getTransactionStartEndString(boolean start)
abstract String	getTriggerEventTranslation(String type)
SQLTableValue	getValueByColumn(SQLTableColumn column, SQLTableValue[] values)
protected abstract void	initTypes()
abstract void	insertNewTableValue(String columnName, SQLTableValue newValue)
abstract SQLDatabase	loadSQLDatabase(String id, String grouping, String customName, String sshConnId, String sshForwardingId, String user, String pwd, String ip, String port, String databaseName, String parameter, boolean isLazyLoaded, Class<? extends DatabaseModel> databaseClass, Map<String,Object> map)
abstract void	modifyTableColumn(SQLTableColumn column, IDoingAfterThread d)
abstract boolean	needSize(SQLDataType dataType)
String	prepareDeletionSQL(String sql)
String	prepareSQL(String sql)
protected abstract Object	registerDriver()
abstract void	reloadTable(int connectionPoolId, SQLTable table, int limit)
abstract void	renameTable(SQLTable oldTable, SQLTable newTable, IDoingAfterThread d)
abstract void	renameTableColumn(SQLTableColumn oldColumn, SQLTableColumn newColumn, IDoingAfterThread d)
DatabaseModel	setName(String name)
String	toString()
abstract SQLDataType	translateDataTypeString(String columnType)
abstract void	updateTableValue(SQLTableColumn column, SQLTableValue[] oldValues, SQLTableValue newValue)

Methods inherited from class java.lang.Object

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

Field Detail

serialVersionUID

public static final long serialVersionUID

See Also:

Constant Field Values

types

public List<SQLDataType> types

Constructor Detail

DatabaseModel

protected DatabaseModel()

Method Detail

initTypes

protected abstract void initTypes()

registerDriver

protected abstract Object registerDriver()
                                  throws Exception

Throws:

Exception

getColumnSelectSQL

public abstract String getColumnSelectSQL(SQLTable table)

getDriver

public abstract String getDriver()

getDialect

public abstract String getDialect()

executeSQL

public abstract Exception executeSQL(int connectionPoolId,
                                     SQLDatabase database,
                                     String sql,
                                     SQLTextEditor<?> editor,
                                     IDoingAfterThread d)
                              throws Exception

Throws:

Exception

executePreparedSQL

public abstract Exception executePreparedSQL(int connectionPoolId,
                                             SQLDatabase database,
                                             String sql,
                                             Object... values)
                                      throws Exception

Throws:

Exception

executeSQL_SELECT

public abstract KeyValue<String,SQLTable> executeSQL_SELECT(int connectionPoolId,
                                                                  SQLTextEditor<?> editor,
                                                                  SQLTable table,
                                                                  int limit,
                                                                  Map<Object,Object> mapOfData)
                                                           throws SQLException

Throws:

SQLException

executeSQL_SELECT

public abstract KeyValue<String,SQLTable> executeSQL_SELECT(int connectionPoolId,
                                                                  SQLTextEditor<?> editor,
                                                                  SQLDatabase db,
                                                                  String sql,
                                                                  int limit,
                                                                  Map<Object,Object> mapOfData)
                                                           throws SQLException

Throws:

SQLException

executePreparedSQL_SELECT

public abstract KeyValue<String,SQLTable> executePreparedSQL_SELECT(int connectionPoolId,
                                                                          SQLDatabase database,
                                                                          String sql,
                                                                          Object... values)
                                                                   throws SQLException

Throws:

SQLException

reloadTable

public abstract void reloadTable(int connectionPoolId,
                                 SQLTable table,
                                 int limit)
                          throws Exception

Throws:

Exception

loadSQLDatabase

public abstract SQLDatabase loadSQLDatabase(String id,
                                            String grouping,
                                            String customName,
                                            String sshConnId,
                                            String sshForwardingId,
                                            String user,
                                            String pwd,
                                            String ip,
                                            String port,
                                            String databaseName,
                                            String parameter,
                                            boolean isLazyLoaded,
                                            Class<? extends DatabaseModel> databaseClass,
                                            Map<String,Object> map)
                                     throws InstantiationException,
                                            IllegalAccessException,
                                            SQLException

Throws:

InstantiationException

IllegalAccessException

SQLException

getConnectionString

public abstract String getConnectionString(String db,
                                           String ip,
                                           String port,
                                           String parameter)

getConnectionStringQuerys

public abstract String getConnectionStringQuerys()

createLimitSQL

public abstract StringBuilder createLimitSQL(String sql,
                                             int limit,
                                             StringBuilder b)

updateTableValue

public abstract void updateTableValue(SQLTableColumn column,
                                      SQLTableValue[] oldValues,
                                      SQLTableValue newValue)
                               throws Exception

Throws:

Exception

renameTable

public abstract void renameTable(SQLTable oldTable,
                                 SQLTable newTable,
                                 IDoingAfterThread d)
                          throws Exception

Throws:

Exception

addTableColumn

public abstract void addTableColumn(SQLTable table,
                                    SQLTableColumn newColumn,
                                    Object defaultValue,
                                    IDoingAfterThread d)
                             throws Exception

Throws:

Exception

renameTableColumn

public abstract void renameTableColumn(SQLTableColumn oldColumn,
                                       SQLTableColumn newColumn,
                                       IDoingAfterThread d)
                                throws Exception

Throws:

Exception

modifyTableColumn

public abstract void modifyTableColumn(SQLTableColumn column,
                                       IDoingAfterThread d)
                                throws Exception

Throws:

Exception

createForeignKey

public abstract Exception createForeignKey(SQLForeignInfo foreignInfo,
                                           String addition)
                                    throws Exception

Throws:

Exception

deleteTableValue

public abstract void deleteTableValue(SQLTableValue[] oldValues)
                               throws Exception

Throws:

Exception

dropColumn

public abstract void dropColumn(SQLTableColumn column,
                                SQLTextEditor<?> editor,
                                IDoingAfterThread d)
                         throws Exception

Throws:

Exception

dropIndex

public abstract void dropIndex(SQLIndex index,
                               IDoingAfterThread d)
                        throws Exception

Throws:

Exception

insertNewTableValue

public abstract void insertNewTableValue(String columnName,
                                         SQLTableValue newValue)
                                  throws SQLException

Throws:

SQLException

copyRows

public abstract void copyRows(DatabaseModel model,
                              SQLTable from,
                              SQLTable to)
                       throws Exception

Throws:

Exception

createNewSQLTable

public abstract void createNewSQLTable(SQLTable table)
                                throws SQLException

Throws:

SQLException

createNewSQLIndexes

public abstract void createNewSQLIndexes(SQLTable table)
                                  throws SQLException

Throws:

SQLException

convertObject

public abstract Object convertObject(SQLTableColumn column,
                                     Object value)

convertSQLTableColumns

public abstract SQLTableColumn convertSQLTableColumns(SQLTableColumn column)

translateDataTypeString

public abstract SQLDataType translateDataTypeString(String columnType)

export

public abstract String export(String sql,
                              SQLDatabase db)
                       throws Exception

Throws:

Exception

getSelectTableSQL

public abstract String getSelectTableSQL(SQLTable table,
                                         int limit)

checkIfIsSelect

public abstract boolean checkIfIsSelect(String sql,
                                        Map<Object,Object> mapOfData)

getSelectUserQuery

public abstract String getSelectUserQuery()

getAddForeignKeyString

public abstract String getAddForeignKeyString(SQLForeignInfo foreignInfo,
                                              String addition)

getDropColumnString

public abstract String getDropColumnString(SQLTableColumn column)

getDropIndexString

public abstract String getDropIndexString(SQLIndex index)

getModifyTableColumnString

public abstract String getModifyTableColumnString(SQLTableColumn column)

getRenameTableColumnString

public abstract String getRenameTableColumnString(SQLTableColumn oldColumn,
                                                  SQLTableColumn newColumn)

getAddTableColumnString

public abstract String getAddTableColumnString(SQLTableColumn newColumn,
                                               Object defaultValue)

getRenameTableString

public abstract String getRenameTableString(SQLTable oldTable,
                                            SQLTable newTable)

getColumnFullname

public abstract String getColumnFullname(SQLTableColumn column)

getColumnNameForConversion

public abstract String getColumnNameForConversion(SQLTableColumn column)

needSize

public abstract boolean needSize(SQLDataType dataType)

getForeignKeyConstraintCheckString

public abstract String getForeignKeyConstraintCheckString(boolean disabling)

getTransactionStartEndString

public abstract String getTransactionStartEndString(boolean start)

getLoadSQLTriggersSQL

public abstract String getLoadSQLTriggersSQL(SQLTable table,
                                             String aliasTrgId,
                                             String aliasTrgCondition,
                                             String aliasTrgName,
                                             String aliasTrgEvent,
                                             String aliasTrgContent,
                                             String aliasTrgType)

getTriggerEventTranslation

public abstract String getTriggerEventTranslation(String type)

getName

public String getName()

setName

public DatabaseModel setName(String name)

toString

public String toString()

Overrides:

toString in class Object

createTableName

public String createTableName(String catalog,
                              String schema,
                              String table)

createTableName

public String createTableName(SQLTable table)

executeInternalSQL

public Exception executeInternalSQL(SQLDatabase database,
                                    String sql,
                                    SQLTextEditor<?> editor,
                                    IDoingAfterThread d)

dropDatabase

public void dropDatabase(SQLDatabase database,
                         SQLTextEditor<?> editor,
                         IDoingAfterThread d)
                  throws Exception

Throws:

Exception

dropTable

public void dropTable(SQLTable table,
                      SQLTextEditor<?> editor,
                      IDoingAfterThread d)
               throws Exception

Throws:

Exception

getDropTableString

public String getDropTableString(SQLTable table)

getDropDatabaseString

public String getDropDatabaseString(SQLDatabase database)

createWhere

public String createWhere(List<SQLTableColumn> columns,
                          SQLTableValue[] line)

Creates the where clause with the given columns and the line which should be selected!

Parameters:

columns - = columns of the table in which to search

line - = line values to search for.

Returns:

getValueByColumn

public SQLTableValue getValueByColumn(SQLTableColumn column,
                                      SQLTableValue[] values)

prepareSQL

public String prepareSQL(String sql)

getDeleteString

public String getDeleteString(SQLTable table,
                              boolean whereCondition)

getInsertIntoString

public String getInsertIntoString(SQLTable table)

getInsertIntoString

public String getInsertIntoString(String columnName,
                                  SQLTable table)

getInsertIntoString

public String getInsertIntoString(String columnName,
                                  SQLTableValue newValue)

getInsertIntoString

public String getInsertIntoString(SQLTableValue[] newValues,
                                  boolean withSimicolon)

getInsertIntoString

public String getInsertIntoString(String columnName,
                                  SQLTable table,
                                  SQLTableValue newValue)

createConnection

public Connection createConnection(String url,
                                   String user,
                                   String password)
                            throws SQLException

Throws:

SQLException

getTableCreationString

public String getTableCreationString(SQLTable table,
                                     boolean withSchema)

getInternalSystemDatabaseName

public String getInternalSystemDatabaseName()

Returns the name for another (internal) system database for getting Trigger information.
For Example, for MySQL and MariaDB it would be the database "INFORMATION_SCHEMA".
If the the trigger-information-table is in the same database, we has to return null.

has to be overwritten in the child class if it deviates!

Returns:

getCreateIndexString

public String getCreateIndexString(SQLTable table,
                                   String indexName,
                                   boolean nonUnique,
                                   boolean withSchema,
                                   String... columns)

Returns the string for creating a index with the given values.

Parameters:

table -

indexName -

nonUnique -

withSchema -

columns -

Returns:

prepareDeletionSQL

public String prepareDeletionSQL(String sql)