org.teiid.resource.adapter.salesforce

Class SalesforceConnectionImpl

java.lang.Object

org.teiid.resource.spi.BasicConnection

org.teiid.resource.adapter.salesforce.SalesforceConnectionImpl

All Implemented Interfaces:

javax.resource.cci.Connection, SalesforceConnection

public class SalesforceConnectionImpl
extends BasicConnection
implements SalesforceConnection

Nested Class Summary

Nested classes/interfaces inherited from interface org.teiid.translator.salesforce.SalesforceConnection

SalesforceConnection.BatchResultInfo, SalesforceConnection.BulkBatchResult

Constructor Summary

Constructors

Constructor and Description
SalesforceConnectionImpl(SalesForceManagedConnectionFactory mcf)

Method Summary

Modifier and Type	Method and Description
String	addBatch(List<com.sforce.async.SObject> payload, com.sforce.async.JobInfo job)
SalesforceConnection.BatchResultInfo	addBatch(String query, com.sforce.async.JobInfo job)
void	cancelBulkJob(com.sforce.async.JobInfo job)
void	close()
com.sforce.async.JobInfo	closeJob(String jobId)
int	create(DataPayload data)
com.sforce.async.JobInfo	createBulkJob(String objectName, com.sforce.async.OperationEnum operation, boolean usePkChunking)
int	delete(String[] ids)
SalesforceConnection.BulkBatchResult	getBatchQueryResults(String jobId, SalesforceConnection.BatchResultInfo info)
com.sforce.async.BatchResult[]	getBulkResults(com.sforce.async.JobInfo job, List<String> ids)
Long	getCardinality(String sobject)
DeletedResult	getDeleted(String objectName, Calendar startCalendar, Calendar endCalendar)
com.sforce.soap.partner.DescribeSObjectResult[]	getObjectMetaData(String... objectName)
com.sforce.soap.partner.DescribeGlobalResult	getObjects()
UpdatedResult	getUpdated(String objectType, Calendar startDate, Calendar endDate)
String	getVersion()
boolean	isAlive() Tests the connection to see if it is still valid.
boolean	isValid()
com.sforce.soap.partner.QueryResult	query(String queryString, int batchSize, boolean queryAll)
com.sforce.soap.partner.QueryResult	queryMore(String queryLocator, int batchSize)
com.sforce.soap.partner.sobject.SObject[]	retrieve(String fieldList, String sObjectType, List<String> ids)
int	update(List<DataPayload> updateDataList)
int	upsert(DataPayload data)

Methods inherited from class org.teiid.resource.spi.BasicConnection

cleanUp, createInteraction, getLocalTransaction, getMetaData, getResultSetInfo, getXAResource

Methods inherited from class java.lang.Object

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

Methods inherited from interface javax.resource.cci.Connection

createInteraction, getLocalTransaction, getMetaData, getResultSetInfo

Constructor Detail

SalesforceConnectionImpl

public SalesforceConnectionImpl(SalesForceManagedConnectionFactory mcf)
                         throws javax.resource.ResourceException

Throws:

javax.resource.ResourceException

Method Detail

getCardinality

public Long getCardinality(String sobject)
                    throws javax.resource.ResourceException

Specified by:

getCardinality in interface SalesforceConnection

Throws:

javax.resource.ResourceException

isValid

public boolean isValid()

Specified by:

isValid in interface SalesforceConnection

query

public com.sforce.soap.partner.QueryResult query(String queryString,
                                                 int batchSize,
                                                 boolean queryAll)
                                          throws javax.resource.ResourceException

Specified by:

query in interface SalesforceConnection

Throws:

javax.resource.ResourceException

queryMore

public com.sforce.soap.partner.QueryResult queryMore(String queryLocator,
                                                     int batchSize)
                                              throws javax.resource.ResourceException

Specified by:

queryMore in interface SalesforceConnection

Throws:

javax.resource.ResourceException

delete

public int delete(String[] ids)
           throws javax.resource.ResourceException

Specified by:

delete in interface SalesforceConnection

Throws:

javax.resource.ResourceException

upsert

public int upsert(DataPayload data)
           throws javax.resource.ResourceException

Specified by:

upsert in interface SalesforceConnection

Throws:

javax.resource.ResourceException

create

public int create(DataPayload data)
           throws javax.resource.ResourceException

Specified by:

create in interface SalesforceConnection

Throws:

javax.resource.ResourceException

update

public int update(List<DataPayload> updateDataList)
           throws javax.resource.ResourceException

Specified by:

update in interface SalesforceConnection

Throws:

javax.resource.ResourceException

getUpdated

public UpdatedResult getUpdated(String objectType,
                                Calendar startDate,
                                Calendar endDate)
                         throws javax.resource.ResourceException

Specified by:

getUpdated in interface SalesforceConnection

Throws:

javax.resource.ResourceException

getDeleted

public DeletedResult getDeleted(String objectName,
                                Calendar startCalendar,
                                Calendar endCalendar)
                         throws javax.resource.ResourceException

Specified by:

getDeleted in interface SalesforceConnection

Throws:

javax.resource.ResourceException

retrieve

public com.sforce.soap.partner.sobject.SObject[] retrieve(String fieldList,
                                                          String sObjectType,
                                                          List<String> ids)
                                                   throws javax.resource.ResourceException

Specified by:

retrieve in interface SalesforceConnection

Throws:

javax.resource.ResourceException

getObjects

public com.sforce.soap.partner.DescribeGlobalResult getObjects()
                                                        throws javax.resource.ResourceException

Specified by:

getObjects in interface SalesforceConnection

Throws:

javax.resource.ResourceException

getObjectMetaData

public com.sforce.soap.partner.DescribeSObjectResult[] getObjectMetaData(String... objectName)
                                                                  throws javax.resource.ResourceException

Specified by:

getObjectMetaData in interface SalesforceConnection

Throws:

javax.resource.ResourceException

close

public void close()
           throws javax.resource.ResourceException

Specified by:

close in interface javax.resource.cci.Connection

Throws:

javax.resource.ResourceException

isAlive

public boolean isAlive()

Description copied from class: BasicConnection

Tests the connection to see if it is still valid.

Overrides:

isAlive in class BasicConnection

Returns:

createBulkJob

public com.sforce.async.JobInfo createBulkJob(String objectName,
                                              com.sforce.async.OperationEnum operation,
                                              boolean usePkChunking)
                                       throws javax.resource.ResourceException

Specified by:

createBulkJob in interface SalesforceConnection

Throws:

javax.resource.ResourceException

addBatch

public String addBatch(List<com.sforce.async.SObject> payload,
                       com.sforce.async.JobInfo job)
                throws javax.resource.ResourceException

Specified by:

addBatch in interface SalesforceConnection

Throws:

javax.resource.ResourceException

addBatch

public SalesforceConnection.BatchResultInfo addBatch(String query,
                                                     com.sforce.async.JobInfo job)
                                              throws javax.resource.ResourceException

Specified by:

addBatch in interface SalesforceConnection

Throws:

javax.resource.ResourceException

getBatchQueryResults

public SalesforceConnection.BulkBatchResult getBatchQueryResults(String jobId,
                                                                 SalesforceConnection.BatchResultInfo info)
                                                          throws javax.resource.ResourceException

Specified by:

getBatchQueryResults in interface SalesforceConnection

Throws:

javax.resource.ResourceException

closeJob

public com.sforce.async.JobInfo closeJob(String jobId)
                                  throws javax.resource.ResourceException

Specified by:

closeJob in interface SalesforceConnection

Throws:

javax.resource.ResourceException

getBulkResults

public com.sforce.async.BatchResult[] getBulkResults(com.sforce.async.JobInfo job,
                                                     List<String> ids)
                                              throws javax.resource.ResourceException

Specified by:

getBulkResults in interface SalesforceConnection

Throws:

javax.resource.ResourceException

cancelBulkJob

public void cancelBulkJob(com.sforce.async.JobInfo job)
                   throws javax.resource.ResourceException

Specified by:

cancelBulkJob in interface SalesforceConnection

Throws:

javax.resource.ResourceException

getVersion

public String getVersion()

Specified by:

getVersion in interface SalesforceConnection