Package com.lucidworks.apollo.blob.sql

Class SQLHelper

java.lang.Object

com.lucidworks.apollo.blob.sql.SQLHelper

public class SQLHelper
extends Object

Helper class for common SQL tasks like getting data sources, etc. Mainly used by JDBC*Stage

Field Summary

Fields

Modifier and Type	Field	Description
protected final DataSourceProvider	dataSourceProvider
static final String	ROWS_RETRIEVED_KEY

Constructor Summary

Constructors

Constructor	Description
SQLHelper(DataSourceProvider dataSourceProvider)

Method Summary

Modifier and Type	Method	Description
long	addResultsToContext(ResultSet rs, String pre, com.lucidworks.apollo.pipeline.Context context)
long	addResultsToRequest(ResultSet rs, String pre, com.lucidworks.apollo.common.pipeline.PipelineDocument doc)
void	bindStatement(PreparedStatement stmt, List<String> keys, com.lucidworks.apollo.pipeline.Context context, com.lucidworks.apollo.common.pipeline.PipelineDocument doc)	First check the context and then check the field.
protected String	constructPropertyName(String pre, String colName, int rowId)
Connection	getConnection(DataSourceDescriptor dsd)	Given a data source description, return a JDBC connection from the cache based off of the DBCP DataSource
void	setFetchSize(Statement stmt, int size)
void	setRows(Statement stmt, int rows)

Methods inherited from class java.lang.Object

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

Field Details

ROWS_RETRIEVED_KEY

public static final String ROWS_RETRIEVED_KEY

See Also:

• Constant Field Values

dataSourceProvider

protected final DataSourceProvider dataSourceProvider

Constructor Details

SQLHelper

public SQLHelper(DataSourceProvider dataSourceProvider)

Method Details

getConnection

public Connection getConnection(DataSourceDescriptor dsd)
                         throws ExecutionException,
SQLException

Given a data source description, return a JDBC connection from the cache based off of the DBCP DataSource

Parameters:

dsd -

Returns:

Throws:

ExecutionException

SQLException

bindStatement

public void bindStatement(PreparedStatement stmt,
 List<String> keys,
 com.lucidworks.apollo.pipeline.Context context,
 com.lucidworks.apollo.common.pipeline.PipelineDocument doc)
                   throws SQLException

First check the context and then check the field. If the field matches, use the first value

Parameters:

stmt -

keys -

context -

doc -

Throws:

SQLException

setRows

public void setRows(Statement stmt,
 int rows)
             throws SQLException

Throws:

SQLException

setFetchSize

public void setFetchSize(Statement stmt,
 int size)
                  throws SQLException

Throws:

SQLException

addResultsToContext

public long addResultsToContext(ResultSet rs,
 String pre,
 com.lucidworks.apollo.pipeline.Context context)
                         throws SQLException

Throws:

SQLException

addResultsToRequest

public long addResultsToRequest(ResultSet rs,
 String pre,
 com.lucidworks.apollo.common.pipeline.PipelineDocument doc)
                         throws SQLException

Throws:

SQLException

constructPropertyName

protected String constructPropertyName(String pre,
 String colName,
 int rowId)