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
static class	QueryExecutor.DataTableCreated
static class	QueryExecutor.ErrorCatched
static class	QueryExecutor.FetchFinished
static class	QueryExecutor.FetchStarted
static class	QueryExecutor.Finished
static class	QueryExecutor.Holdability
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.Holdability	holdability
protected ListenersHelper<QueryExecutor.QueryExecutorListener,QueryExecutor.QueryExecutorEvent>	listeners
protected Reciver<SQLWarning>	messageConsumer
protected MessageReader	messageReader
protected PropertyChangeSupport	psupport
protected String	query
protected QueryExecutor.ResultSetType	resultSetType
protected Statement	statement
protected Reciver<Integer>	updateCountConsumer

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 ResultSetFetcher	createFetcher()
void	firePropertyChange(String propertyName, Object oldValue, Object newValue)
void	fireQueryExecutorEvent(QueryExecutor.QueryExecutorEvent event)
QueryExecutor.Concurrency	getConcurrency()
Connection	getConnection()
QueryExecutor.Holdability	getHoldability()
Reciver<SQLWarning>	getMessageConsumer()
MessageReader	getMessageReader()
PropertyChangeListener[]	getPropertyChangeListeners()
PropertyChangeListener[]	getPropertyChangeListeners(String propertyName)
String	getQuery()
Set<QueryExecutor.QueryExecutorListener>	getQueryExecutorListeners()
QueryExecutor.ResultSetType	getResultSetType()
Statement	getStatement()
Reciver<Integer>	getUpdateCountConsumer()
boolean	hasListeners(String propertyName)
boolean	hasQueryExecutorListener(QueryExecutor.QueryExecutorListener listener)
boolean	isCloseResultSet()
boolean	isCloseStatement()
void	removePropertyChangeListener(PropertyChangeListener listener)
void	removePropertyChangeListener(String propertyName, PropertyChangeListener listener)
void	removeQueryExecutorListener(QueryExecutor.QueryExecutorListener listener)
void	run()
void	setCloseResultSet(boolean closeResultSet)
void	setCloseStatement(boolean closeStatement)
void	setConcurrency(QueryExecutor.Concurrency concurrency)
void	setConnection(Connection connection)
void	setHoldability(QueryExecutor.Holdability holdability)
void	setMessageConsumer(Reciver<SQLWarning> messageConsumer)
protected void	setMessageReader(MessageReader messageReader)
void	setQuery(String query)
void	setResultSetType(QueryExecutor.ResultSetType resultSetType)
void	setStatement(Statement statement)
void	setUpdateCountConsumer(Reciver<Integer> updateCountConsumer)
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

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

messageConsumer

protected Reciver<SQLWarning> messageConsumer

updateCountConsumer

protected Reciver<Integer> updateCountConsumer

messageReader

protected MessageReader messageReader

Constructor Detail

QueryExecutor

public QueryExecutor(Connection conn,
                     String 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()

setConnection

public void setConnection(Connection connection)

getQuery

public String getQuery()

setQuery

public void setQuery(String query)

getStatement

public Statement getStatement()

setStatement

public void setStatement(Statement statement)

isCloseStatement

public boolean isCloseStatement()

setCloseStatement

public void setCloseStatement(boolean closeStatement)

isCloseResultSet

public boolean isCloseResultSet()

setCloseResultSet

public void setCloseResultSet(boolean closeResultSet)

getResultSetType

public QueryExecutor.ResultSetType getResultSetType()

setResultSetType

public void setResultSetType(QueryExecutor.ResultSetType resultSetType)

getConcurrency

public QueryExecutor.Concurrency getConcurrency()

setConcurrency

public void setConcurrency(QueryExecutor.Concurrency concurrency)

getHoldability

public QueryExecutor.Holdability getHoldability()

setHoldability

public void setHoldability(QueryExecutor.Holdability holdability)

createFetcher

protected ResultSetFetcher createFetcher()

getMessageConsumer

public Reciver<SQLWarning> getMessageConsumer()

setMessageConsumer

public void setMessageConsumer(Reciver<SQLWarning> messageConsumer)

getUpdateCountConsumer

public Reciver<Integer> getUpdateCountConsumer()

setUpdateCountConsumer

public void setUpdateCountConsumer(Reciver<Integer> updateCountConsumer)

getMessageReader

public MessageReader getMessageReader()

setMessageReader

protected void setMessageReader(MessageReader messageReader)

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()