net.windward.datasource.abstract_datasource.salesforce

Class SalesForceQueryHelper

java.lang.Object

net.windward.datasource.abstract_datasource.salesforce.SalesForceQueryHelper

All Implemented Interfaces:

DataSourceQueryHelper

public class SalesForceQueryHelper
extends java.lang.Object
implements DataSourceQueryHelper

This class actually sends a SOQL query off to the SF instance, and flattens the returned results into a SalesForceResultSet that we can work with.

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	SUBQUERY_DELIMINATOR

Constructor Summary

Constructors

Constructor and Description
SalesForceQueryHelper(com.sforce.soap.partner.PartnerConnection connection)

Method Summary

Modifier and Type	Method and Description
SalesForceResultSet	buildResultSetForSubquery(com.sforce.soap.partner.PartnerConnection connection, com.sforce.ws.bind.XmlObject subQueryResults, java.lang.String query, java.util.HashMap<java.lang.String,com.sforce.soap.partner.DescribeSObjectResult> metadataHash)
java.lang.String	fixQuery(java.lang.String query, DataSourceResultRow resultRow)
SalesForceResultSet	getQueryResults(java.lang.String query) 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.List	selectNodes(DataSourceResultSet resultSet)
java.lang.String	substituteVariables(java.lang.String[] queryParts, java.lang.Object[] toInsert, java.lang.String querytext) Called by the AbstractDataSource to substitute values into a select statement.
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

Field Detail

SUBQUERY_DELIMINATOR

public static final java.lang.String SUBQUERY_DELIMINATOR

See Also:

Constant Field Values

Constructor Detail

SalesForceQueryHelper

public SalesForceQueryHelper(com.sforce.soap.partner.PartnerConnection connection)
                      throws DataConnectionException

Throws:

DataConnectionException

Method Detail

substituteVariables

public java.lang.String substituteVariables(java.lang.String[] queryParts,
                                            java.lang.Object[] toInsert,
                                            java.lang.String querytext)

Description copied from interface: DataSourceQueryHelper

Called by the AbstractDataSource to substitute values into a select statement. Given select: SELECT ${var1} FROM Accounts WHERE Name = ${var2} we create the query parts array: ["SELECT ", " FROM Accounts WHERE Name = ", ""] and the toInsert array: ["Id", "Frank"] This function then returns: SELECT Id FROM Accounts WHERE name = 'Frank'

Specified by:

substituteVariables in interface DataSourceQueryHelper

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)

Returns:

valueToString

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

Description copied from interface: DataSourceQueryHelper

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

Specified by:

valueToString in interface DataSourceQueryHelper

Parameters:

object - returned from getValue() call in AbstractDataSource

Returns:

object converted into a string value

Throws:

DataSourceException

selectNodes

public java.util.List selectNodes(DataSourceResultSet resultSet)

Specified by:

selectNodes in interface DataSourceQueryHelper

Returns:

isValidSet

public boolean isValidSet(java.lang.Object value)

Specified by:

isValidSet in interface DataSourceQueryHelper

getValueFromKey

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

Specified by:

getValueFromKey in interface DataSourceQueryHelper

isValidQuery

public boolean isValidQuery(java.lang.String query)

Specified by:

isValidQuery in interface DataSourceQueryHelper

fixQuery

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

Specified by:

fixQuery in interface DataSourceQueryHelper

resultSetToString

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

Specified by:

resultSetToString in interface DataSourceQueryHelper

getQueryResults

public SalesForceResultSet getQueryResults(java.lang.String query)
                                    throws DataSourceException

Description copied from interface: DataSourceQueryHelper

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

Specified by:

getQueryResults in interface DataSourceQueryHelper

Returns:

Throws:

DataSourceException

buildResultSetForSubquery

public SalesForceResultSet buildResultSetForSubquery(com.sforce.soap.partner.PartnerConnection connection,
                                                     com.sforce.ws.bind.XmlObject subQueryResults,
                                                     java.lang.String query,
                                                     java.util.HashMap<java.lang.String,com.sforce.soap.partner.DescribeSObjectResult> metadataHash)
                                              throws DataSourceException

Throws:

DataSourceException