Package org.teichert.databaseexplorer.models

Class MySQLModel

java.lang.Object

org.teichert.databaseexplorer.database.DatabaseModel

org.teichert.databaseexplorer.models.MySQLModel

All Implemented Interfaces:

Serializable

public class MySQLModel
extends DatabaseModel

See Also:

Serialized Form

Field Summary

Fields inherited from class org.teichert.databaseexplorer.database.DatabaseModel

types

Constructor Summary

Constructors

Constructor	Description
MySQLModel()

Method Summary

Modifier and Type	Method	Description
void	addTableColumn(SQLTable table, SQLTableColumn newColumn, Object defaultValue, IDoingAfterThread d)
boolean	checkIfIsSelect(String sql, Map<Object,Object> mapOfData)
Object	convertObject(SQLTableColumn column, Object value)
SQLTableColumn	convertSQLTableColumns(SQLTableColumn column)
void	copyRows(DatabaseModel model, SQLTable from, SQLTable to)
Exception	createForeignKey(SQLForeignInfo foreignInfo, String addition)
StringBuilder	createLimitSQL(String sql, int limit, StringBuilder b)
void	createNewSQLIndexes(SQLTable table)
void	createNewSQLTable(SQLTable table)
void	deleteTableValue(SQLTableValue[] oldValues)
void	dropColumn(SQLTableColumn column, SQLTextEditor<?> editor, IDoingAfterThread d)
void	dropIndex(SQLIndex index, IDoingAfterThread d)
Exception	executePreparedSQL(int connectionPoolId, SQLDatabase database, String sql, Object... values)
KeyValue<String,SQLTable>	executePreparedSQL_SELECT(int connectionPoolId, SQLDatabase database, String sql, Object... values)
Exception	executeSQL(int connectionPoolId, SQLDatabase database, String sql, SQLTextEditor<?> editor, IDoingAfterThread d)
KeyValue<String,SQLTable>	executeSQL_SELECT(int connectionPoolId, SQLTextEditor<?> editor, SQLDatabase db, String sql, int limit, Map<Object,Object> mapOfData)
KeyValue<String,SQLTable>	executeSQL_SELECT(int connectionPoolId, SQLTextEditor<?> editor, SQLTable table, int limit, Map<Object,Object> mapOfData)
String	export(String sql, SQLDatabase db)
String	getAddForeignKeyString(SQLForeignInfo foreignInfo, String addition)
String	getAddTableColumnString(SQLTableColumn newColumn, Object defaultValue)
String	getColumnFullname(SQLTableColumn column)
String	getColumnNameForConversion(SQLTableColumn column)
String	getColumnSelectSQL(SQLTable table)
String	getConnectionString(String db, String ip, String port, String parameter)
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	getDialect()
String	getDriver()
String	getDropColumnString(SQLTableColumn column)
String	getDropIndexString(SQLIndex index)
String	getForeignKeyConstraintCheckString(boolean disabling)
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!
String	getLoadSQLTriggersSQL(SQLTable table, String aliasTrgId, String aliasTrgCondition, String aliasTrgName, String aliasTrgEvent, String aliasTrgContent, String aliasTrgType)
String	getModifyTableColumnString(SQLTableColumn column)
String	getRenameTableColumnString(SQLTableColumn oldColumn, SQLTableColumn newColumn)
String	getRenameTableString(SQLTable oldTable, SQLTable newTable)
String	getSelectTableSQL(SQLTable table, int limit)
String	getSelectUserQuery()
String	getTransactionStartEndString(boolean start)
String	getTriggerEventTranslation(String type)
protected void	initTypes()
void	insertNewTableValue(String columnName, SQLTableValue newValue)
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)
void	modifyTableColumn(SQLTableColumn column, IDoingAfterThread d)
boolean	needSize(SQLDataType dataType)
String	prepareSQL(String sql)
protected Object	registerDriver()
void	reloadTable(int connectionPoolId, SQLTable table, int limit)
void	renameTable(SQLTable oldTable, SQLTable newTable, IDoingAfterThread d)
void	renameTableColumn(SQLTableColumn oldColumn, SQLTableColumn newColumn, IDoingAfterThread d)
SQLDataType	translateDataTypeString(String columnType)
void	updateTableValue(SQLTableColumn column, SQLTableValue[] oldValues, SQLTableValue newValue)

Methods inherited from class org.teichert.databaseexplorer.database.DatabaseModel

createConnection, createTableName, createTableName, createWhere, dropDatabase, dropTable, executeInternalSQL, getDeleteString, getDropDatabaseString, getDropTableString, getInsertIntoString, getInsertIntoString, getInsertIntoString, getInsertIntoString, getInsertIntoString, getName, getTableCreationString, getValueByColumn, prepareDeletionSQL, setName, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

MySQLModel

public MySQLModel()

Method Detail

initTypes

protected void initTypes()

Specified by:

initTypes in class DatabaseModel

getDriver

public String getDriver()

Specified by:

getDriver in class DatabaseModel

getDialect

public String getDialect()

Specified by:

getDialect in class DatabaseModel

registerDriver

protected Object registerDriver()
                         throws Exception

Specified by:

registerDriver in class DatabaseModel

Throws:

Exception

executeSQL

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

Specified by:

executeSQL in class DatabaseModel

executePreparedSQL

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

Specified by:

executePreparedSQL in class DatabaseModel

executeSQL_SELECT

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

Specified by:

executeSQL_SELECT in class DatabaseModel

executeSQL_SELECT

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

Specified by:

executeSQL_SELECT in class DatabaseModel

createForeignKey

public Exception createForeignKey(SQLForeignInfo foreignInfo,
                                  String addition)

Specified by:

createForeignKey in class DatabaseModel

getAddForeignKeyString

public String getAddForeignKeyString(SQLForeignInfo foreignInfo,
                                     String addition)

Specified by:

getAddForeignKeyString in class DatabaseModel

createLimitSQL

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

Specified by:

createLimitSQL in class DatabaseModel

executePreparedSQL_SELECT

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

Specified by:

executePreparedSQL_SELECT in class DatabaseModel

reloadTable

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

Specified by:

reloadTable in class DatabaseModel

Throws:

Exception

renameTable

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

Specified by:

renameTable in class DatabaseModel

Throws:

Exception

getRenameTableString

public String getRenameTableString(SQLTable oldTable,
                                   SQLTable newTable)

Specified by:

getRenameTableString in class DatabaseModel

addTableColumn

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

Specified by:

addTableColumn in class DatabaseModel

Throws:

Exception

getAddTableColumnString

public String getAddTableColumnString(SQLTableColumn newColumn,
                                      Object defaultValue)

Specified by:

getAddTableColumnString in class DatabaseModel

renameTableColumn

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

Specified by:

renameTableColumn in class DatabaseModel

Throws:

Exception

getRenameTableColumnString

public String getRenameTableColumnString(SQLTableColumn oldColumn,
                                         SQLTableColumn newColumn)

Specified by:

getRenameTableColumnString in class DatabaseModel

modifyTableColumn

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

Specified by:

modifyTableColumn in class DatabaseModel

Throws:

Exception

getModifyTableColumnString

public String getModifyTableColumnString(SQLTableColumn column)

Specified by:

getModifyTableColumnString in class DatabaseModel

dropIndex

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

Specified by:

dropIndex in class DatabaseModel

Throws:

Exception

getDropIndexString

public String getDropIndexString(SQLIndex index)

Specified by:

getDropIndexString in class DatabaseModel

dropColumn

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

Specified by:

dropColumn in class DatabaseModel

Throws:

Exception

getDropColumnString

public String getDropColumnString(SQLTableColumn column)

Specified by:

getDropColumnString in class DatabaseModel

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.

Overrides:

getCreateIndexString in class DatabaseModel

Parameters:

table -

indexName -

nonUnique -

withSchema -

columns -

Returns:

getColumnNameForConversion

public String getColumnNameForConversion(SQLTableColumn column)

Specified by:

getColumnNameForConversion in class DatabaseModel

getColumnFullname

public String getColumnFullname(SQLTableColumn column)

Specified by:

getColumnFullname in class DatabaseModel

needSize

public boolean needSize(SQLDataType dataType)

Specified by:

needSize in class DatabaseModel

createNewSQLTable

public void createNewSQLTable(SQLTable table)
                       throws SQLException

Specified by:

createNewSQLTable in class DatabaseModel

Throws:

SQLException

createNewSQLIndexes

public void createNewSQLIndexes(SQLTable table)
                         throws SQLException

Specified by:

createNewSQLIndexes in class DatabaseModel

Throws:

SQLException

updateTableValue

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

Specified by:

updateTableValue in class DatabaseModel

Throws:

SQLException

insertNewTableValue

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

Specified by:

insertNewTableValue in class DatabaseModel

Throws:

SQLException

copyRows

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

Specified by:

copyRows in class DatabaseModel

Throws:

Exception

deleteTableValue

public void deleteTableValue(SQLTableValue[] oldValues)
                      throws SQLException

Specified by:

deleteTableValue in class DatabaseModel

Throws:

SQLException

loadSQLDatabase

public 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

Specified by:

loadSQLDatabase in class DatabaseModel

Throws:

InstantiationException

IllegalAccessException

SQLException

export

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

Specified by:

export in class DatabaseModel

Throws:

Exception

getForeignKeyConstraintCheckString

public String getForeignKeyConstraintCheckString(boolean disabling)

Specified by:

getForeignKeyConstraintCheckString in class DatabaseModel

getTransactionStartEndString

public String getTransactionStartEndString(boolean start)

Specified by:

getTransactionStartEndString in class DatabaseModel

convertObject

public Object convertObject(SQLTableColumn column,
                            Object value)

Specified by:

convertObject in class DatabaseModel

convertSQLTableColumns

public SQLTableColumn convertSQLTableColumns(SQLTableColumn column)

Specified by:

convertSQLTableColumns in class DatabaseModel

translateDataTypeString

public SQLDataType translateDataTypeString(String columnType)

Specified by:

translateDataTypeString in class DatabaseModel

getColumnSelectSQL

public String getColumnSelectSQL(SQLTable table)

Specified by:

getColumnSelectSQL in class DatabaseModel

getConnectionString

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

Specified by:

getConnectionString in class DatabaseModel

getConnectionStringQuerys

public String getConnectionStringQuerys()

Specified by:

getConnectionStringQuerys in class DatabaseModel

getSelectTableSQL

public String getSelectTableSQL(SQLTable table,
                                int limit)

Specified by:

getSelectTableSQL in class DatabaseModel

checkIfIsSelect

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

Specified by:

checkIfIsSelect in class DatabaseModel

prepareSQL

public String prepareSQL(String sql)

Overrides:

prepareSQL in class DatabaseModel

getSelectUserQuery

public String getSelectUserQuery()

Specified by:

getSelectUserQuery in class DatabaseModel

getLoadSQLTriggersSQL

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

Specified by:

getLoadSQLTriggersSQL in class DatabaseModel

getTriggerEventTranslation

public String getTriggerEventTranslation(String type)

Specified by:

getTriggerEventTranslation in class DatabaseModel

getInternalSystemDatabaseName

public String getInternalSystemDatabaseName()

Description copied from class: DatabaseModel

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!

Overrides:

getInternalSystemDatabaseName in class DatabaseModel

Returns: