org.teiid.translator.salesforce

Interface SalesforceConnection

All Superinterfaces:

Connection

All Known Implementing Classes:

SalesforceConnectionImpl

public interface SalesforceConnection
extends Connection

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	SalesforceConnection.BatchResultInfo
static interface	SalesforceConnection.BulkBatchResult

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)
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 id, 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 objectName, Calendar startCalendar, Calendar endCalendar)
String	getVersion()
boolean	isValid()
com.sforce.soap.partner.QueryResult	query(String queryString, int maxBatchSize, 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 interface org.teiid.resource.api.Connection

close

Method Detail

query

com.sforce.soap.partner.QueryResult query(String queryString,
                                          int maxBatchSize,
                                          boolean queryAll)
                                   throws TranslatorException

Throws:

TranslatorException

queryMore

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

Throws:

TranslatorException

isValid

boolean isValid()

delete

int delete(String[] ids)
    throws TranslatorException

Throws:

TranslatorException

create

int create(DataPayload data)
    throws TranslatorException

Throws:

TranslatorException

upsert

int upsert(DataPayload data)
    throws TranslatorException

Throws:

TranslatorException

update

int update(List<DataPayload> updateDataList)
    throws TranslatorException

Throws:

TranslatorException

getUpdated

UpdatedResult getUpdated(String objectName,
                         Calendar startCalendar,
                         Calendar endCalendar)
                  throws TranslatorException

Throws:

TranslatorException

getDeleted

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

Throws:

TranslatorException

retrieve

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

Throws:

TranslatorException

getObjects

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

Throws:

TranslatorException

getObjectMetaData

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

Throws:

TranslatorException

getBulkResults

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

Throws:

TranslatorException

cancelBulkJob

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

Throws:

TranslatorException

closeJob

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

Throws:

TranslatorException

addBatch

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

Throws:

TranslatorException

createBulkJob

com.sforce.async.JobInfo createBulkJob(String objectName,
                                       com.sforce.async.OperationEnum operation,
                                       boolean usePkChunking)
                                throws TranslatorException

Throws:

TranslatorException

getCardinality

Long getCardinality(String sobject)
             throws TranslatorException

Throws:

TranslatorException

getVersion

String getVersion()

addBatch

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

Throws:

TranslatorException

getBatchQueryResults

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

Throws:

TranslatorException