Package com.inductiveautomation.ignition.gateway.expressions

Class DefaultDBExpressionFunctionProvider

java.lang.Object

com.inductiveautomation.ignition.gateway.expressions.DefaultDBExpressionFunctionProvider

All Implemented Interfaces:

DBExpressionFunctionProvider

public class DefaultDBExpressionFunctionProvider
extends Object
implements DBExpressionFunctionProvider

This class implements DBExpressionFunctionProvider by executing the functions against a given data source name using the gateway context.

Constructor Summary

Constructors

Constructor	Description
DefaultDBExpressionFunctionProvider(GatewayContext context, String dataSource)

Method Summary

Modifier and Type	Method	Description
Dataset	executeQuery(String query, String dsName)
Object	executeScalarQuery(String query, String dsName)
int	executeUpdateQuery(String query, String dsName)
int	getCachedDataCount(String dsName, boolean quarantined)
protected String	getDSName(String passedIn)	Returns the correct ds name to use- either the default, or the provided value.
boolean	isConnectionAvailable(String dsName)

Methods inherited from class java.lang.Object

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

Constructor Details

DefaultDBExpressionFunctionProvider

public DefaultDBExpressionFunctionProvider(GatewayContext context,
 String dataSource)

Method Details

getDSName

protected String getDSName(String passedIn)

Returns the correct ds name to use- either the default, or the provided value.

executeQuery

public Dataset executeQuery(String query,
 String dsName)
                     throws SQLException

Specified by:

executeQuery in interface DBExpressionFunctionProvider

Throws:

SQLException

executeScalarQuery

public Object executeScalarQuery(String query,
 String dsName)
                          throws SQLException

Specified by:

executeScalarQuery in interface DBExpressionFunctionProvider

Throws:

SQLException

executeUpdateQuery

public int executeUpdateQuery(String query,
 String dsName)
                       throws SQLException

Specified by:

executeUpdateQuery in interface DBExpressionFunctionProvider

Throws:

SQLException

isConnectionAvailable

public boolean isConnectionAvailable(String dsName)

Specified by:

isConnectionAvailable in interface DBExpressionFunctionProvider

getCachedDataCount

public int getCachedDataCount(String dsName,
 boolean quarantined)

Specified by:

getCachedDataCount in interface DBExpressionFunctionProvider