public class SalesforceConnectionImpl
extends org.teiid.spring.data.BaseConnection
implements org.teiid.translator.salesforce.SalesforceConnection
Constructor and Description |
---|
SalesforceConnectionImpl(SalesforceConfiguration sfc) |
Modifier and Type | Method and Description |
---|---|
String |
addBatch(List<com.sforce.async.SObject> payload,
com.sforce.async.JobInfo job) |
org.teiid.translator.salesforce.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(org.teiid.translator.salesforce.execution.DataPayload data) |
com.sforce.async.JobInfo |
createBulkJob(String objectName,
com.sforce.async.OperationEnum operation,
boolean usePkChunking) |
int |
delete(String[] ids) |
org.teiid.translator.salesforce.SalesforceConnection.BulkBatchResult |
getBatchQueryResults(String jobId,
org.teiid.translator.salesforce.SalesforceConnection.BatchResultInfo info) |
com.sforce.async.BatchResult[] |
getBulkResults(com.sforce.async.JobInfo job,
List<String> ids) |
Long |
getCardinality(String sobject) |
org.teiid.translator.salesforce.execution.DeletedResult |
getDeleted(String objectName,
Calendar startCalendar,
Calendar endCalendar) |
com.sforce.soap.partner.DescribeSObjectResult[] |
getObjectMetaData(String... objectName) |
com.sforce.soap.partner.DescribeGlobalResult |
getObjects() |
org.teiid.translator.salesforce.execution.UpdatedResult |
getUpdated(String objectType,
Calendar startDate,
Calendar endDate) |
String |
getVersion() |
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<org.teiid.translator.salesforce.execution.DataPayload> updateDataList) |
int |
upsert(org.teiid.translator.salesforce.execution.DataPayload data) |
public SalesforceConnectionImpl(SalesforceConfiguration sfc) throws Exception
Exception
public Long getCardinality(String sobject) throws org.teiid.translator.TranslatorException
getCardinality
in interface org.teiid.translator.salesforce.SalesforceConnection
org.teiid.translator.TranslatorException
public boolean isValid()
isValid
in interface org.teiid.translator.salesforce.SalesforceConnection
public com.sforce.soap.partner.QueryResult query(String queryString, int batchSize, boolean queryAll) throws org.teiid.translator.TranslatorException
query
in interface org.teiid.translator.salesforce.SalesforceConnection
org.teiid.translator.TranslatorException
public com.sforce.soap.partner.QueryResult queryMore(String queryLocator, int batchSize) throws org.teiid.translator.TranslatorException
queryMore
in interface org.teiid.translator.salesforce.SalesforceConnection
org.teiid.translator.TranslatorException
public int delete(String[] ids) throws org.teiid.translator.TranslatorException
delete
in interface org.teiid.translator.salesforce.SalesforceConnection
org.teiid.translator.TranslatorException
public int upsert(org.teiid.translator.salesforce.execution.DataPayload data) throws org.teiid.translator.TranslatorException
upsert
in interface org.teiid.translator.salesforce.SalesforceConnection
org.teiid.translator.TranslatorException
public int create(org.teiid.translator.salesforce.execution.DataPayload data) throws org.teiid.translator.TranslatorException
create
in interface org.teiid.translator.salesforce.SalesforceConnection
org.teiid.translator.TranslatorException
public int update(List<org.teiid.translator.salesforce.execution.DataPayload> updateDataList) throws org.teiid.translator.TranslatorException
update
in interface org.teiid.translator.salesforce.SalesforceConnection
org.teiid.translator.TranslatorException
public org.teiid.translator.salesforce.execution.UpdatedResult getUpdated(String objectType, Calendar startDate, Calendar endDate) throws org.teiid.translator.TranslatorException
getUpdated
in interface org.teiid.translator.salesforce.SalesforceConnection
org.teiid.translator.TranslatorException
public org.teiid.translator.salesforce.execution.DeletedResult getDeleted(String objectName, Calendar startCalendar, Calendar endCalendar) throws org.teiid.translator.TranslatorException
getDeleted
in interface org.teiid.translator.salesforce.SalesforceConnection
org.teiid.translator.TranslatorException
public com.sforce.soap.partner.sobject.SObject[] retrieve(String fieldList, String sObjectType, List<String> ids) throws org.teiid.translator.TranslatorException
retrieve
in interface org.teiid.translator.salesforce.SalesforceConnection
org.teiid.translator.TranslatorException
public com.sforce.soap.partner.DescribeGlobalResult getObjects() throws org.teiid.translator.TranslatorException
getObjects
in interface org.teiid.translator.salesforce.SalesforceConnection
org.teiid.translator.TranslatorException
public com.sforce.soap.partner.DescribeSObjectResult[] getObjectMetaData(String... objectName) throws org.teiid.translator.TranslatorException
getObjectMetaData
in interface org.teiid.translator.salesforce.SalesforceConnection
org.teiid.translator.TranslatorException
public void close() throws Exception
close
in interface org.teiid.resource.api.Connection
Exception
public com.sforce.async.JobInfo createBulkJob(String objectName, com.sforce.async.OperationEnum operation, boolean usePkChunking) throws org.teiid.translator.TranslatorException
createBulkJob
in interface org.teiid.translator.salesforce.SalesforceConnection
org.teiid.translator.TranslatorException
public String addBatch(List<com.sforce.async.SObject> payload, com.sforce.async.JobInfo job) throws org.teiid.translator.TranslatorException
addBatch
in interface org.teiid.translator.salesforce.SalesforceConnection
org.teiid.translator.TranslatorException
public org.teiid.translator.salesforce.SalesforceConnection.BatchResultInfo addBatch(String query, com.sforce.async.JobInfo job) throws org.teiid.translator.TranslatorException
addBatch
in interface org.teiid.translator.salesforce.SalesforceConnection
org.teiid.translator.TranslatorException
public org.teiid.translator.salesforce.SalesforceConnection.BulkBatchResult getBatchQueryResults(String jobId, org.teiid.translator.salesforce.SalesforceConnection.BatchResultInfo info) throws org.teiid.translator.TranslatorException
getBatchQueryResults
in interface org.teiid.translator.salesforce.SalesforceConnection
org.teiid.translator.TranslatorException
public com.sforce.async.JobInfo closeJob(String jobId) throws org.teiid.translator.TranslatorException
closeJob
in interface org.teiid.translator.salesforce.SalesforceConnection
org.teiid.translator.TranslatorException
public com.sforce.async.BatchResult[] getBulkResults(com.sforce.async.JobInfo job, List<String> ids) throws org.teiid.translator.TranslatorException
getBulkResults
in interface org.teiid.translator.salesforce.SalesforceConnection
org.teiid.translator.TranslatorException
public void cancelBulkJob(com.sforce.async.JobInfo job) throws org.teiid.translator.TranslatorException
cancelBulkJob
in interface org.teiid.translator.salesforce.SalesforceConnection
org.teiid.translator.TranslatorException
public String getVersion()
getVersion
in interface org.teiid.translator.salesforce.SalesforceConnection
Copyright © 2019. All rights reserved.