com.serotonin.mango.rt.dataSource.sql

Class SqlDataSourceRT

java.lang.Object

com.serotonin.mango.rt.dataSource.DataSourceRT

com.serotonin.mango.rt.dataSource.PollingDataSource

com.serotonin.mango.rt.dataSource.sql.SqlDataSourceRT

All Implemented Interfaces:

TimeoutClient, com.serotonin.util.ILifecycle

public class SqlDataSourceRT
extends PollingDataSource

Author:

Matthew Lohbihler

Field Summary

Fields

Modifier and Type	Field and Description
private java.sql.Connection	conn
static int	DATA_SOURCE_EXCEPTION_EVENT
private org.apache.commons.logging.Log	log
static int	STATEMENT_EXCEPTION_EVENT
private int	timeoutCount
private int	timeoutsToReconnect
private SqlDataSourceVO	vo

Fields inherited from class com.serotonin.mango.rt.dataSource.PollingDataSource

dataPoints, pointListChanged

Fields inherited from class com.serotonin.mango.rt.dataSource.DataSourceRT

addedChangedPoints, ATTR_DISCONNECTED_KEY, ATTR_UNRELIABLE_KEY, pointListChangeLock, removedPoints

Constructor Summary

Constructors

Constructor and Description
SqlDataSourceRT(SqlDataSourceVO vo)

Method Summary

Modifier and Type	Method and Description
private void	doColumnPollImpl(long time, java.sql.PreparedStatement stmt)
protected void	doPoll(long time)
private void	doRowPollImpl(long time, java.sql.PreparedStatement stmt)
private long	getTimeOverride(java.sql.ResultSetMetaData meta, int column, java.sql.ResultSet rs, long time)
private MangoValue	getValue(SqlPointLocatorVO locatorVO, java.sql.ResultSet rs, java.lang.String fieldName, long time)
void	initialize()
void	setPointValue(DataPointRT dataPoint, PointValueTime valueTime, SetPointSource source)
void	terminate()

Methods inherited from class com.serotonin.mango.rt.dataSource.PollingDataSource

beginPolling, joinTermination, scheduleTimeout, setPollingPeriod, updateChangedPoints

Methods inherited from class com.serotonin.mango.rt.dataSource.DataSourceRT

addDataPoint, forcePointRead, getExceptionMessage, getId, getName, getPersistentData, getSerialExceptionMessage, raiseEvent, relinquish, removeDataPoint, returnToNormal, setPersistentData

Methods inherited from class java.lang.Object

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

Field Detail

DATA_SOURCE_EXCEPTION_EVENT

public static final int DATA_SOURCE_EXCEPTION_EVENT

See Also:

Constant Field Values

STATEMENT_EXCEPTION_EVENT

public static final int STATEMENT_EXCEPTION_EVENT

See Also:

Constant Field Values

log

private final org.apache.commons.logging.Log log

vo

private final SqlDataSourceVO vo

conn

private java.sql.Connection conn

timeoutCount

private int timeoutCount

timeoutsToReconnect

private int timeoutsToReconnect

Constructor Detail

SqlDataSourceRT

public SqlDataSourceRT(SqlDataSourceVO vo)

Method Detail

setPointValue

public void setPointValue(DataPointRT dataPoint,
                          PointValueTime valueTime,
                          SetPointSource source)

Specified by:

setPointValue in class DataSourceRT

doPoll

protected void doPoll(long time)

Specified by:

doPoll in class PollingDataSource

doColumnPollImpl

private void doColumnPollImpl(long time,
                              java.sql.PreparedStatement stmt)
                       throws java.sql.SQLException

Throws:

java.sql.SQLException

doRowPollImpl

private void doRowPollImpl(long time,
                           java.sql.PreparedStatement stmt)
                    throws java.sql.SQLException

Throws:

java.sql.SQLException

getValue

private MangoValue getValue(SqlPointLocatorVO locatorVO,
                            java.sql.ResultSet rs,
                            java.lang.String fieldName,
                            long time)
                     throws java.sql.SQLException,
                            java.io.IOException

Throws:

java.sql.SQLException

java.io.IOException

getTimeOverride

private long getTimeOverride(java.sql.ResultSetMetaData meta,
                             int column,
                             java.sql.ResultSet rs,
                             long time)
                      throws java.sql.SQLException

Throws:

java.sql.SQLException

initialize

public void initialize()

Specified by:

initialize in interface com.serotonin.util.ILifecycle

Overrides:

initialize in class DataSourceRT

terminate

public void terminate()

Specified by:

terminate in interface com.serotonin.util.ILifecycle

Overrides:

terminate in class PollingDataSource