org.teiid.resource.adapter.salesforce

Class SalesforceConnectionImpl

java.lang.Object

org.teiid.resource.spi.BasicConnection

org.teiid.resource.adapter.salesforce.SalesforceConnectionImpl

All Implemented Interfaces:

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

Constructor Detail

SalesforceConnectionImpl

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

Throws:

javax.resource.ResourceException

Method Detail

getCardinality

public Long getCardinality(String sobject)
                    throws TranslatorException

Specified by:

getCardinality in interface SalesforceConnection

Throws:

TranslatorException

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 TranslatorException

Specified by:

query in interface SalesforceConnection

Throws:

TranslatorException

queryMore

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

Specified by:

queryMore in interface SalesforceConnection

Throws:

TranslatorException

delete

public int delete(String[] ids)
           throws TranslatorException

Specified by:

delete in interface SalesforceConnection

Throws:

TranslatorException

upsert

public int upsert(DataPayload data)
           throws TranslatorException

Specified by:

upsert in interface SalesforceConnection

Throws:

TranslatorException

create

public int create(DataPayload data)
           throws TranslatorException

Specified by:

create in interface SalesforceConnection

Throws:

TranslatorException

update

public int update(List<DataPayload> updateDataList)
           throws TranslatorException

Specified by:

update in interface SalesforceConnection

Throws:

TranslatorException

getUpdated

public UpdatedResult getUpdated(String objectType,
                                Calendar startDate,
                                Calendar endDate)
                         throws TranslatorException

Specified by:

getUpdated in interface SalesforceConnection

Throws:

TranslatorException

getDeleted

public DeletedResult getDeleted(String objectName,
                                Calendar startCalendar,
                                Calendar endCalendar)
                         throws TranslatorException

Specified by:

getDeleted in interface SalesforceConnection

Throws:

TranslatorException

retrieve

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

Specified by:

retrieve in interface SalesforceConnection

Throws:

TranslatorException

getObjects

public com.sforce.soap.partner.DescribeGlobalResult getObjects()
                                                        throws TranslatorException

Specified by:

getObjects in interface SalesforceConnection

Throws:

TranslatorException

getObjectMetaData

public com.sforce.soap.partner.DescribeSObjectResult[] getObjectMetaData(String... objectName)
                                                                  throws TranslatorException

Specified by:

getObjectMetaData in interface SalesforceConnection

Throws:

TranslatorException

close

public void close()
           throws javax.resource.ResourceException

Specified by:

close in interface 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 TranslatorException

Specified by:

createBulkJob in interface SalesforceConnection

Throws:

TranslatorException

addBatch

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

Specified by:

addBatch in interface SalesforceConnection

Throws:

TranslatorException

addBatch

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

Specified by:

addBatch in interface SalesforceConnection

Throws:

TranslatorException

getBatchQueryResults

public SalesforceConnection.BulkBatchResult getBatchQueryResults(String jobId,
                                                                 SalesforceConnection.BatchResultInfo info)
                                                          throws TranslatorException

Specified by:

getBatchQueryResults in interface SalesforceConnection

Throws:

TranslatorException

closeJob

public com.sforce.async.JobInfo closeJob(String jobId)
                                  throws TranslatorException

Specified by:

closeJob in interface SalesforceConnection

Throws:

TranslatorException

getBulkResults

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

Specified by:

getBulkResults in interface SalesforceConnection

Throws:

TranslatorException

cancelBulkJob

public void cancelBulkJob(com.sforce.async.JobInfo job)
                   throws TranslatorException

Specified by:

cancelBulkJob in interface SalesforceConnection

Throws:

TranslatorException

getVersion

public String getVersion()

Specified by:

getVersion in interface SalesforceConnection