Package org.bgerp.app.dist.inst.call

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 ru.bgcrm.dao.CommonDAO

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

Field Summary

Fields inherited from class ru.bgcrm.dao.CommonDAO

con, SQL_AND, SQL_DELETE, SQL_DELETE_FROM, SQL_DESC, SQL_DISTINCT, SQL_FROM, SQL_GROUP_BY, SQL_INNER_JOIN, SQL_INSERT_IGNORE, 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_WHERE

Constructor Summary

Constructors

Constructor	Description
ExecuteSQL()

Method Summary

Modifier and Type	Method	Description
void	call(Connection con, String query)	Executes multiline SQL script.
boolean	call(Setup setup, File zip, String param)
static void	clearHashes()
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.

Methods inherited from class ru.bgcrm.dao.CommonDAO

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

Methods inherited from class java.lang.Object

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

Constructor Details

ExecuteSQL

public ExecuteSQL()

Method Details

call

public boolean call(Setup setup,
 File zip,
 String param)

Specified by:

call in interface InstallationCall

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

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

getQueryHashes

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

Loads applied query hashes.

Parameters:

con - SQL connection.

Returns:

set with hashes.

Throws:

SQLException

clearHashes

public static void clearHashes()