xyz.cofe.sql

Class QueryExecutor

java.lang.Object

java.lang.Thread

xyz.cofe.sql.QueryExecutor

All Implemented Interfaces:

Runnable

public class QueryExecutor
extends Thread

Выполянее запрос и пишет данные в соответ приемник

Author:

Kamnev Georgiy

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	QueryExecutor.Concurrency Тип данных в выборке read-only / read-write
static class	QueryExecutor.ErrorCatched
static class	QueryExecutor.ExecMethod Метод выполнения
static class	QueryExecutor.Finished
static class	QueryExecutor.Holdability Доступность данных в ResultSet
static class	QueryExecutor.QueryExecutorEvent
static interface	QueryExecutor.QueryExecutorListener
static class	QueryExecutor.ResultSetAccepted
static class	QueryExecutor.ResultSetType Направление выборки / Изменяемая или нет выборка
static class	QueryExecutor.Started

Nested classes/interfaces inherited from class java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	closeResultSet
protected boolean	closeStatement
protected QueryExecutor.Concurrency	concurrency
protected Connection	connection
protected QueryExecutor.ExecMethod	execMethod
protected Boolean	fetchGeneratedKeys
protected boolean	fetchGenKeysFirst
protected QueryExecutor.Holdability	holdability
protected ListenersHelper<QueryExecutor.QueryExecutorListener,QueryExecutor.QueryExecutorEvent>	listeners
protected MessageReader	messageReader
protected List	params
protected PropertyChangeSupport	psupport
protected String	query
protected QueryExecutor.ResultSetType	resultSetType
protected QueryWriter	resultWriter
protected boolean	skipGenKeysException
protected Statement	statement

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
QueryExecutor(Connection conn, String query) Конструктор

Method Summary

Modifier and Type	Method and Description
void	addPropertyChangeListener(PropertyChangeListener listener)
void	addPropertyChangeListener(String propertyName, PropertyChangeListener listener)
Closeable	addQueryExecutorListener(QueryExecutor.QueryExecutorListener listener)
Closeable	addQueryExecutorListener(QueryExecutor.QueryExecutorListener listener, boolean weakLink)
protected MessageReader	createMessageReader(Statement st, Reciver<SQLWarning> consumer)
void	firePropertyChange(String propertyName, Object oldValue, Object newValue)
void	fireQueryExecutorEvent(QueryExecutor.QueryExecutorEvent event)
QueryExecutor.Concurrency	getConcurrency() Указывает тип данных read-only/read-write в ResultSet
Connection	getConnection() Указывает соединение с БД
QueryExecutor.ExecMethod	getExecMethod() Указывает метод выполнения запроса
Boolean	getFetchGeneratedKeys() Указывает возвращаеть (или нет) сгенерированные ключи
QueryExecutor.Holdability	getHoldability() Указывает будут или нет доступны данные после закрытия транзакции
MessageReader	getMessageReader() Указыавает куда передавать текстовые сообщения
List	getParams() Указывает параметры запроса
PropertyChangeListener[]	getPropertyChangeListeners()
PropertyChangeListener[]	getPropertyChangeListeners(String propertyName)
String	getQuery() Указывает запрос к БД
Set<QueryExecutor.QueryExecutorListener>	getQueryExecutorListeners()
QueryExecutor.ResultSetType	getResultSetType() Указывает тип выборки
QueryWriter	getResultWriter() Указывает куда передавать данные
Statement	getStatement() Указывает объект запроса.
boolean	hasListeners(String propertyName)
boolean	hasQueryExecutorListener(QueryExecutor.QueryExecutorListener listener)
boolean	isCloseResultSet() Указывает закрывать resultSet при завершении чтения из него
boolean	isCloseStatement() Указывает при завершении запроса - закрывать Statement
boolean	isFetchGenKeysFirst() Указывает производить выборку сгененированных ключей перед выборкой данных.
boolean	isSkipGenKeysException() Пропускать или нет ошибки при чтении сгенерированных ключей.
void	removePropertyChangeListener(PropertyChangeListener listener)
void	removePropertyChangeListener(String propertyName, PropertyChangeListener listener)
void	removeQueryExecutorListener(QueryExecutor.QueryExecutorListener listener)
void	run()
void	setCloseResultSet(boolean closeResultSet) Указывает закрывать resultSet при завершении чтения из него
void	setCloseStatement(boolean closeStatement) Указывает при завершении запроса - закрывать Statement
void	setConcurrency(QueryExecutor.Concurrency concurrency) Указывает тип данных read-only/read-write в ResultSet
void	setConnection(Connection connection) Указывает соединение с БД
void	setExecMethod(QueryExecutor.ExecMethod execMethod) Указывает метод выполнения запроса
void	setFetchGeneratedKeys(Boolean fetchGeneratedKeys) Указывает возвращаеть (или нет) сгенерированные ключи
void	setFetchGenKeysFirst(boolean fetchGenKeysFirst) Указывает производить выборку сгененированных ключей перед выборкой данных
void	setHoldability(QueryExecutor.Holdability holdability) Указывает будут или нет доступны данные после закрытия транзакции
protected void	setMessageReader(MessageReader messageReader) Указыавает куда передавать текстовые сообщения
void	setParams(List params) Указывает параметры запроса.
void	setQuery(String query) Указывает запрос к БД
void	setResultSetType(QueryExecutor.ResultSetType resultSetType) Указывает тип выборки
void	setResultWriter(QueryWriter resultWriter) Указывает куда передавать данные
void	setSkipGenKeysException(boolean skipGenKeysException) Пропускать или нет ошибки при чтении сгенерированных ключей.
void	setStatement(Statement statement) Указывает объект запроса.
void	terminate(boolean withReader, long timeout, long sleep) Остановка выполнения.
void	terminate(long timeout, long sleep) Остановка выполнения.

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Field Detail

psupport

protected final PropertyChangeSupport psupport

listeners

protected final ListenersHelper<QueryExecutor.QueryExecutorListener,QueryExecutor.QueryExecutorEvent> listeners

connection

protected Connection connection

query

protected String query

params

protected List params

statement

protected Statement statement

closeStatement

protected boolean closeStatement

closeResultSet

protected boolean closeResultSet

resultSetType

protected QueryExecutor.ResultSetType resultSetType

concurrency

protected QueryExecutor.Concurrency concurrency

holdability

protected QueryExecutor.Holdability holdability

messageReader

protected MessageReader messageReader

fetchGeneratedKeys

protected Boolean fetchGeneratedKeys

fetchGenKeysFirst

protected boolean fetchGenKeysFirst

skipGenKeysException

protected boolean skipGenKeysException

resultWriter

protected QueryWriter resultWriter

execMethod

protected volatile QueryExecutor.ExecMethod execMethod

Constructor Detail

QueryExecutor

public QueryExecutor(Connection conn,
                     String query)

Конструктор

Parameters:

conn - соединение с базой данных

query - запрос

Method Detail

addPropertyChangeListener

public void addPropertyChangeListener(PropertyChangeListener listener)

removePropertyChangeListener

public void removePropertyChangeListener(PropertyChangeListener listener)

getPropertyChangeListeners

public PropertyChangeListener[] getPropertyChangeListeners()

addPropertyChangeListener

public void addPropertyChangeListener(String propertyName,
                                      PropertyChangeListener listener)

removePropertyChangeListener

public void removePropertyChangeListener(String propertyName,
                                         PropertyChangeListener listener)

getPropertyChangeListeners

public PropertyChangeListener[] getPropertyChangeListeners(String propertyName)

firePropertyChange

public void firePropertyChange(String propertyName,
                               Object oldValue,
                               Object newValue)

hasListeners

public boolean hasListeners(String propertyName)

hasQueryExecutorListener

public boolean hasQueryExecutorListener(QueryExecutor.QueryExecutorListener listener)

getQueryExecutorListeners

public Set<QueryExecutor.QueryExecutorListener> getQueryExecutorListeners()

addQueryExecutorListener

public Closeable addQueryExecutorListener(QueryExecutor.QueryExecutorListener listener)

addQueryExecutorListener

public Closeable addQueryExecutorListener(QueryExecutor.QueryExecutorListener listener,
                                          boolean weakLink)

removeQueryExecutorListener

public void removeQueryExecutorListener(QueryExecutor.QueryExecutorListener listener)

fireQueryExecutorEvent

public void fireQueryExecutorEvent(QueryExecutor.QueryExecutorEvent event)

getConnection

public Connection getConnection()

Указывает соединение с БД

Returns:

Соединение с БД

setConnection

public void setConnection(Connection connection)

Указывает соединение с БД

Parameters:

connection - Соединение с БД

getQuery

public String getQuery()

Указывает запрос к БД

Returns:

запрос к БД

setQuery

public void setQuery(String query)

Указывает запрос к БД

Parameters:

query - запрос к БД

getParams

public List getParams()

Указывает параметры запроса

Returns:

параметры запроса

setParams

public void setParams(List params)

Указывает параметры запроса.

Актульано при автоматическом создании запроса

Parameters:

params - параметры запроса

See Also:

getStatement()

getStatement

public Statement getStatement()

Указывает объект запроса.

Создается автоматически (если не создан) ври выполнеии run(). и если надо, то добавляются параметры запроса

Returns:

объект заапроса

setStatement

public void setStatement(Statement statement)

Указывает объект запроса.

Parameters:

statement - запрос

isCloseStatement

public boolean isCloseStatement()

Указывает при завершении запроса - закрывать Statement

Returns:

true (по умолчанию) - при завершении закрывать statement

setCloseStatement

public void setCloseStatement(boolean closeStatement)

Указывает при завершении запроса - закрывать Statement

Parameters:

closeStatement - true (по умолчанию) - при завершении закрывать statement

isCloseResultSet

public boolean isCloseResultSet()

Указывает закрывать resultSet при завершении чтения из него

Returns:

true (по умолчанию) - закрывать resultSet

setCloseResultSet

public void setCloseResultSet(boolean closeResultSet)

Указывает закрывать resultSet при завершении чтения из него

Parameters:

closeResultSet - true (по умолчанию) - закрывать resultSet

getResultSetType

public QueryExecutor.ResultSetType getResultSetType()

Указывает тип выборки

Returns:

тип выборки

setResultSetType

public void setResultSetType(QueryExecutor.ResultSetType resultSetType)

Указывает тип выборки

Parameters:

resultSetType - тип выборки

getConcurrency

public QueryExecutor.Concurrency getConcurrency()

Указывает тип данных read-only/read-write в ResultSet

Returns:

тип данных read-only/read-write

setConcurrency

public void setConcurrency(QueryExecutor.Concurrency concurrency)

Указывает тип данных read-only/read-write в ResultSet

Parameters:

concurrency - тип данных read-only/read-write

getHoldability

public QueryExecutor.Holdability getHoldability()

Указывает будут или нет доступны данные после закрытия транзакции

Returns:

доступность данных

setHoldability

public void setHoldability(QueryExecutor.Holdability holdability)

Указывает будут или нет доступны данные после закрытия транзакции

Parameters:

holdability - доступность данных

getMessageReader

public MessageReader getMessageReader()

Указыавает куда передавать текстовые сообщения

Returns:

приемник текстовых сообщений

setMessageReader

protected void setMessageReader(MessageReader messageReader)

Указыавает куда передавать текстовые сообщения

Parameters:

messageReader - приемник текстовых сообщений

getFetchGeneratedKeys

public Boolean getFetchGeneratedKeys()

Указывает возвращаеть (или нет) сгенерированные ключи

Returns:

true - возвращает сгенерированные ключи

setFetchGeneratedKeys

public void setFetchGeneratedKeys(Boolean fetchGeneratedKeys)

Указывает возвращаеть (или нет) сгенерированные ключи

Parameters:

fetchGeneratedKeys - true - возвращает сгенерированные ключи

isFetchGenKeysFirst

public boolean isFetchGenKeysFirst()

Указывает производить выборку сгененированных ключей перед выборкой данных.

Значение актуально для mssql драйвера.

Returns:

true (по умолчанию) - сначала выборка ключей, потом данные /
false - сначала данные, потом ключи

setFetchGenKeysFirst

public void setFetchGenKeysFirst(boolean fetchGenKeysFirst)

Указывает производить выборку сгененированных ключей перед выборкой данных

Parameters:

fetchGenKeysFirst - true (по умолчанию) - сначала выборка ключей, потом данные /
false - сначала данные, потом ключи

See Also:

isFetchGenKeysFirst()

isSkipGenKeysException

public boolean isSkipGenKeysException()

Пропускать или нет ошибки при чтении сгенерированных ключей.

Значение актуально для mssql драйвера.

Returns:

false (по умолчанию) - генерировать ошибки /
false - пропускать ошибки

setSkipGenKeysException

public void setSkipGenKeysException(boolean skipGenKeysException)

Пропускать или нет ошибки при чтении сгенерированных ключей.

Значение актуально для mssql драйвера.

Parameters:

skipGenKeysException - false (по умолчанию) - генерировать ошибки /
false - пропускать ошибки

See Also:

isFetchGenKeysFirst()

createMessageReader

protected MessageReader createMessageReader(Statement st,
                                            Reciver<SQLWarning> consumer)

getResultWriter

public QueryWriter getResultWriter()

Указывает куда передавать данные

Returns:

приемник данных

setResultWriter

public void setResultWriter(QueryWriter resultWriter)

Указывает куда передавать данные

Parameters:

resultWriter - приемник данных

getExecMethod

public QueryExecutor.ExecMethod getExecMethod()

Указывает метод выполнения запроса

Returns:

метод выполнения запроса

setExecMethod

public void setExecMethod(QueryExecutor.ExecMethod execMethod)

Указывает метод выполнения запроса

Parameters:

execMethod - метод

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread

terminate

public void terminate(boolean withReader,
                      long timeout,
                      long sleep)

Остановка выполнения.

Нельзя вызывать только в самом же треде.

Parameters:

withReader - true - Остановить также MessageReader

timeout - макс. время (мс) за которое должна произойти остановка

sleep - время (мс) паузы, при значении < 0 - передает управление другому потоку Thread.yield()

terminate

public void terminate(long timeout,
                      long sleep)

Остановка выполнения.

Нельзя вызывать только в самом же треде.

Parameters:

timeout - макс. время (мс) за которое должна произойти остановка

sleep - время (мс) паузы, при значении < 0 - передает управление другому потоку Thread.yield()