net.windward.datasource.jdbc

Class JdbcQueryHelper

java.lang.Object

net.windward.datasource.jdbc.JdbcQueryHelper

All Implemented Interfaces:

IDataSourceQueryHelper

public class JdbcQueryHelper
extends java.lang.Object
implements IDataSourceQueryHelper

Created by mattb on 2/1/2017.

Constructor Summary

Constructors

Constructor and Description
JdbcQueryHelper(ConnectionWrapper conn, Logger log, int timeout, int resultSetType, JdbcDataSource dsp)

Method Summary

Modifier and Type	Method and Description
void	addSelectListener(JdbcSelectListener listener) Adds a select Listener which is notified whenever a select has been executed.
void	closeConnection() Close the connection.
java.lang.String	fixQuery(java.lang.String query, IDataSourceResultRow resultRow)
java.sql.Connection	getConn()
IDataSourceResultSet	getQueryResults(java.lang.String query, java.lang.String tagType) Given a select statement.
java.lang.String	getValueFromKey(java.lang.Object o)
boolean	isValidQuery(java.lang.String query)
boolean	isValidSet(java.lang.Object value)
java.lang.Object	resultSetToString(java.lang.String query)
java.util.Iterator	selectNodes(IDataSourceResultSet resultSet)
java.lang.String	substituteVariables(java.lang.String[] queryParts, java.lang.Object[] toInsert, java.lang.String query, java.util.List<VarResults> parameters) we do this a little different for jdbc we just throw question marks into the query and let the sql statement class make the substitutions.
java.lang.String	valueToString(java.lang.Object object) Called by AbstractDataSource to return string value of obj returned from getValue(tag, stack) method.

Methods inherited from class java.lang.Object

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

Constructor Detail

JdbcQueryHelper

public JdbcQueryHelper(ConnectionWrapper conn,
                       Logger log,
                       int timeout,
                       int resultSetType,
                       JdbcDataSource dsp)

Method Detail

getConn

public java.sql.Connection getConn()

closeConnection

public void closeConnection()

Close the connection. Ok to call if already closed.

getQueryResults

public IDataSourceResultSet getQueryResults(java.lang.String query,
                                            java.lang.String tagType)
                                     throws DataSourceException

Description copied from interface: IDataSourceQueryHelper

Given a select statement. We create a IDataSourceResultSet and return it.

Specified by:

getQueryResults in interface IDataSourceQueryHelper

Returns:

Throws:

DataSourceException

substituteVariables

public java.lang.String substituteVariables(java.lang.String[] queryParts,
                                            java.lang.Object[] toInsert,
                                            java.lang.String query,
                                            java.util.List<VarResults> parameters)

we do this a little different for jdbc we just throw question marks into the query and let the sql statement class make the substitutions.

Specified by:

substituteVariables in interface IDataSourceQueryHelper

Parameters:

queryParts - - The query string broken up into parts such that between each element, an element of toInsert is inserted (possibly with formatting).

toInsert - - The array of items to insert. toInsert.length is equal to (queryParts.length - 2)

query -

parameters -

Returns:

valueToString

public java.lang.String valueToString(java.lang.Object object)
                               throws DataSourceException

Description copied from interface: IDataSourceQueryHelper

Called by AbstractDataSource to return string value of obj returned from getValue(tag, stack) method.

Specified by:

valueToString in interface IDataSourceQueryHelper

Parameters:

object - returned from getValue() call in AbstractDataSource

Returns:

object converted into a string value

Throws:

DataSourceException

addSelectListener

public void addSelectListener(JdbcSelectListener listener)

Adds a select Listener which is notified whenever a select has been executed. Note adding a select listener will cause every select to be executed twice.

selectNodes

public java.util.Iterator selectNodes(IDataSourceResultSet resultSet)

Specified by:

selectNodes in interface IDataSourceQueryHelper

isValidSet

public boolean isValidSet(java.lang.Object value)

Specified by:

isValidSet in interface IDataSourceQueryHelper

getValueFromKey

public java.lang.String getValueFromKey(java.lang.Object o)

Specified by:

getValueFromKey in interface IDataSourceQueryHelper

isValidQuery

public boolean isValidQuery(java.lang.String query)

Specified by:

isValidQuery in interface IDataSourceQueryHelper

fixQuery

public java.lang.String fixQuery(java.lang.String query,
                                 IDataSourceResultRow resultRow)

Specified by:

fixQuery in interface IDataSourceQueryHelper

resultSetToString

public java.lang.Object resultSetToString(java.lang.String query)

Specified by:

resultSetToString in interface IDataSourceQueryHelper