Class ExecuteSQL

java.lang.Object

ru.bgcrm.dao.CommonDAO

org.bgerp.app.dist.inst.call.ExecuteSQL

All Implemented Interfaces:

InstallationCall

public class ExecuteSQL
extends CommonDAO
implements InstallationCall

Executer of SQL queries for updating DB structure. Running as InstallationCall and also directly.

Nested Class Summary

Nested classes/interfaces inherited from class CommonDAO

CommonDAO.ObjectExtractor<T>, CommonDAO.RecordUpdater<T>

Field Summary

Fields inherited from class CommonDAO

con, SQL_AND, SQL_DELETE, SQL_DELETE_FROM, SQL_DESC, SQL_DISTINCT, SQL_FROM, SQL_GROUP_BY, SQL_INNER_JOIN, SQL_INSERT_IGNORE_INTO, SQL_INSERT_INTO, SQL_LEFT_JOIN, SQL_LIMIT, SQL_ON_DUP_KEY_UPDATE, SQL_ORDER_BY, SQL_REPLACE, SQL_SELECT, SQL_SELECT_ALL_FROM, SQL_SELECT_COUNT_ROWS, SQL_SET, SQL_UNION_ALL, SQL_UPDATE, SQL_VALUES, SQL_VALUES_1, SQL_VALUES_2, SQL_VALUES_3, SQL_VALUES_4, SQL_VALUES_5, SQL_WHERE

Constructor Summary

Constructors

Constructor	Description
ExecuteSQL()	Default constructor

Method Summary

Modifier and Type	Method	Description
protected void	addHashes(Connection con, Set<String> hashes)	Stores executed queries hashes.
void	call(Connection con, String query)	Executes multiline SQL script.
void	call(Setup setup, File zip, String param)	Executes the call.
static void	clearHashes()	Clears all stored applied-update hashes.
protected void	doQuery(Statement st, String query, boolean useHash, Set<String> existingHashes, Set<String> newHashes)	Executes SQL query.
protected Set<String>	getQueryHashes(Connection con)	Loads applied query hashes.
static void	skipHash(String hash)	Marks a query hash as applied so the query is skipped.

Methods inherited from class CommonDAO

deleteById, foundRows, getById, getGroupedIds, getGroupedIds, getIds, getIds, getPageLimit, getPeriodSql, lastInsertId, setPeriodParamValue, setRecordCount, update, updateColumn, updateIds, updateIds, updateOrInsert

Methods inherited from class Object

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

Constructor Details

ExecuteSQL

public ExecuteSQL()

Default constructor

Method Details

clearHashes

public static void clearHashes()
                        throws SQLException

Clears all stored applied-update hashes.

Throws:

SQLException - on a database error

skipHash

public static void skipHash(String hash)
                     throws SQLException

Marks a query hash as applied so the query is skipped.

Parameters:

hash - query hash

Throws:

SQLException - on a database error

call

public void call(Setup setup,
 File zip,
 String param)
          throws Exception

Description copied from interface: InstallationCall

Executes the call.

Specified by:

call in interface InstallationCall

Parameters:

setup - application setup

zip - the module ZIP file

param - call parameter from module.properties

Throws:

Exception - on a call error

call

public void call(Connection con,
 String query)
          throws SQLException

Executes multiline SQL script.

Parameters:

con - connection.

query - SQL script, tokenized to commands by ;.

Throws:

SQLException - on a database error

doQuery

protected void doQuery(Statement st,
 String query,
 boolean useHash,
 Set<String> existingHashes,
 Set<String> newHashes)
                throws SQLException

Executes SQL query.

Parameters:

st - SQL statement, running the query.

query - the query.

useHash - use executed query hash to prevent re-execution.

existingHashes - hashes of already applied queries.

newHashes - set there added hash of executed query if it wasn't presented in hashes.

Throws:

SQLException - on a database error

getQueryHashes

protected Set<String> getQueryHashes(Connection con)
                              throws SQLException

Loads applied query hashes.

Parameters:

con - SQL connection.

Returns:

set with hashes.

Throws:

SQLException - on a database error

addHashes

protected void addHashes(Connection con,
 Set<String> hashes)
                  throws SQLException

Stores executed queries hashes.

Parameters:

con - SQL connection.

hashes - set with hashes.

Throws:

SQLException - on a database error