de.citunius.businesslogicapi.common.database

Class DatabaseConnection

java.lang.Object

de.citunius.businesslogicapi.common.database.DatabaseConnection

public class DatabaseConnection
extends java.lang.Object

DatabaseConnection is the class for all MySQL database related activities such as open and close the database connection, run the SQL query, check the data model version as well as initialize and commit transactions.

Since:

1.0

Constructor Summary

Constructors

Constructor and Description
DatabaseConnection(java.util.HashMap<java.lang.String,java.lang.String> pluginMap)

Method Summary

Modifier and Type	Method and Description
void	closeConnection() Close MySQL database connection
void	commitTransaction() Finish a transaction in MqSQL database and commit changes
java.lang.Boolean	executeQuery_NOTUSED(java.lang.String query)
java.lang.String[][]	executeQuery(java.lang.String query) Execute the SQL query
int	executeQueryUpdate(java.lang.String query) Execute the SQL query
int	getCountFromDatabase(java.lang.String query) Return the count of results for a SQL query
java.sql.PreparedStatement	getPreparedStatement(java.lang.String query) Get prepared statement
java.sql.PreparedStatement	getPreparedStatement(java.lang.String query, int flags) Get prepared statement with flags
java.lang.String[][]	getResultsFromDatabase(java.lang.String query) Execute SQL query in MySQL database
void	initTransaction() Initilize a transaction in MqSQL database
java.sql.ResultSet	runSqlQuery(java.lang.String query) Execute SQL query in MySQL database

Methods inherited from class java.lang.Object

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

Constructor Detail

DatabaseConnection

public DatabaseConnection(java.util.HashMap<java.lang.String,java.lang.String> pluginMap)

Method Detail

closeConnection

public void closeConnection()

Close MySQL database connection

runSqlQuery

public java.sql.ResultSet runSqlQuery(java.lang.String query)
                               throws java.sql.SQLException

Execute SQL query in MySQL database

Parameters:

query - the SQL query

Returns:

ResultSet object

Throws:

java.sql.SQLException - the SQL exception

executeQuery_NOTUSED

public java.lang.Boolean executeQuery_NOTUSED(java.lang.String query)
                                       throws java.sql.SQLException

Throws:

java.sql.SQLException

getPreparedStatement

public java.sql.PreparedStatement getPreparedStatement(java.lang.String query)
                                                throws java.sql.SQLException

Get prepared statement

Parameters:

query - the SQL query

Returns:

PreparedStatement object

Throws:

java.sql.SQLException - the SQL exception

getPreparedStatement

public java.sql.PreparedStatement getPreparedStatement(java.lang.String query,
                                                       int flags)
                                                throws java.sql.SQLException

Get prepared statement with flags

Parameters:

query - the SQL query

flags - the flag

Returns:

PreparedStatement object

Throws:

java.sql.SQLException - the SQL exception

initTransaction

public void initTransaction()
                     throws java.sql.SQLException

Initilize a transaction in MqSQL database

Throws:

java.sql.SQLException - if initialization fails

commitTransaction

public void commitTransaction()
                       throws java.sql.SQLException

Finish a transaction in MqSQL database and commit changes

Throws:

java.sql.SQLException - If a rollback fails

getResultsFromDatabase

public java.lang.String[][] getResultsFromDatabase(java.lang.String query)

Execute SQL query in MySQL database

The SQL query is execute in MySQL database and return the results as an multi-dimension string array

Parameters:

query - SQL query

Returns:

the database results

executeQuery

public java.lang.String[][] executeQuery(java.lang.String query)

Execute the SQL query

This function executes the SQL query in the database as prepared statement.

Parameters:

query - the SQL query

Returns:

the row data if execution was successful; null otherwise

executeQueryUpdate

public int executeQueryUpdate(java.lang.String query)

Execute the SQL query

This function executes the SQL query in the database as prepared statement and returns the generated keys.

Parameters:

query - the SQL query

Returns:

the generated key (identifier) of the table row if the execution was successful; -1 otherwise

getCountFromDatabase

public int getCountFromDatabase(java.lang.String query)

Return the count of results for a SQL query

The function execute the SQL query and return the count of itemsets that has been found in the database

Parameters:

query - SQL query

Returns:

count of database results