org.eclipse.scada.da.server.jdbc

Class AbstractQuery

java.lang.Object

org.eclipse.scada.da.server.jdbc.AbstractQuery

Direct Known Subclasses:

Query, TabularQuery

public abstract class AbstractQuery
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
protected Map<Integer,String>	columnAliases
protected Connection	connection
protected FolderItemFactory	itemFactory
protected String	sql

Constructor Summary

Constructors

Constructor and Description
AbstractQuery(String id, int period, String sql, Connection connection, Integer timeout, Map<Integer,String> columnAliases)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	applyTimeout(PreparedStatement stmt)
protected abstract void	doQuery()
protected Integer	getTimeout()
protected String	mapFieldName(int i, ResultSet result)
void	register(ScheduledExecutorService timer, DefaultChainItemFactory parentItemFactory)
protected abstract void	setGlobalError(Throwable e)
void	tick()
void	unregister()

Methods inherited from class java.lang.Object

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

Field Detail

sql

protected final String sql

connection

protected final Connection connection

itemFactory

protected FolderItemFactory itemFactory

columnAliases

protected final Map<Integer,String> columnAliases

Constructor Detail

AbstractQuery

public AbstractQuery(String id,
             int period,
             String sql,
             Connection connection,
             Integer timeout,
             Map<Integer,String> columnAliases)

Method Detail

register

public void register(ScheduledExecutorService timer,
            DefaultChainItemFactory parentItemFactory)

getTimeout

protected Integer getTimeout()

unregister

public void unregister()

tick

public void tick()

setGlobalError

protected abstract void setGlobalError(Throwable e)

doQuery

protected abstract void doQuery()
                         throws Exception

Throws:

Exception

mapFieldName

protected String mapFieldName(int i,
                  ResultSet result)
                       throws SQLException

Throws:

SQLException

applyTimeout

protected void applyTimeout(PreparedStatement stmt)
                     throws SQLException

Throws:

SQLException