public class SalesforceConnectionImpl extends BasicConnection implements SalesforceConnection
SalesforceConnection.BatchResultInfo, SalesforceConnection.BulkBatchResult
Constructor and Description |
---|
SalesforceConnectionImpl(SalesForceManagedConnectionFactory mcf) |
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) |
cleanUp, createInteraction, getLocalTransaction, getMetaData, getResultSetInfo, getXAResource
public SalesforceConnectionImpl(SalesForceManagedConnectionFactory mcf) throws javax.resource.ResourceException
javax.resource.ResourceException
public Long getCardinality(String sobject) throws TranslatorException
getCardinality
in interface SalesforceConnection
TranslatorException
public boolean isValid()
isValid
in interface SalesforceConnection
public com.sforce.soap.partner.QueryResult query(String queryString, int batchSize, boolean queryAll) throws TranslatorException
query
in interface SalesforceConnection
TranslatorException
public com.sforce.soap.partner.QueryResult queryMore(String queryLocator, int batchSize) throws TranslatorException
queryMore
in interface SalesforceConnection
TranslatorException
public int delete(String[] ids) throws TranslatorException
delete
in interface SalesforceConnection
TranslatorException
public int upsert(DataPayload data) throws TranslatorException
upsert
in interface SalesforceConnection
TranslatorException
public int create(DataPayload data) throws TranslatorException
create
in interface SalesforceConnection
TranslatorException
public int update(List<DataPayload> updateDataList) throws TranslatorException
update
in interface SalesforceConnection
TranslatorException
public UpdatedResult getUpdated(String objectType, Calendar startDate, Calendar endDate) throws TranslatorException
getUpdated
in interface SalesforceConnection
TranslatorException
public DeletedResult getDeleted(String objectName, Calendar startCalendar, Calendar endCalendar) throws TranslatorException
getDeleted
in interface SalesforceConnection
TranslatorException
public com.sforce.soap.partner.sobject.SObject[] retrieve(String fieldList, String sObjectType, List<String> ids) throws TranslatorException
retrieve
in interface SalesforceConnection
TranslatorException
public com.sforce.soap.partner.DescribeGlobalResult getObjects() throws TranslatorException
getObjects
in interface SalesforceConnection
TranslatorException
public com.sforce.soap.partner.DescribeSObjectResult[] getObjectMetaData(String... objectName) throws TranslatorException
getObjectMetaData
in interface SalesforceConnection
TranslatorException
public void close() throws javax.resource.ResourceException
close
in interface Connection
javax.resource.ResourceException
public boolean isAlive()
BasicConnection
isAlive
in class BasicConnection
public com.sforce.async.JobInfo createBulkJob(String objectName, com.sforce.async.OperationEnum operation, boolean usePkChunking) throws TranslatorException
createBulkJob
in interface SalesforceConnection
TranslatorException
public String addBatch(List<com.sforce.async.SObject> payload, com.sforce.async.JobInfo job) throws TranslatorException
addBatch
in interface SalesforceConnection
TranslatorException
public SalesforceConnection.BatchResultInfo addBatch(String query, com.sforce.async.JobInfo job) throws TranslatorException
addBatch
in interface SalesforceConnection
TranslatorException
public SalesforceConnection.BulkBatchResult getBatchQueryResults(String jobId, SalesforceConnection.BatchResultInfo info) throws TranslatorException
getBatchQueryResults
in interface SalesforceConnection
TranslatorException
public com.sforce.async.JobInfo closeJob(String jobId) throws TranslatorException
closeJob
in interface SalesforceConnection
TranslatorException
public com.sforce.async.BatchResult[] getBulkResults(com.sforce.async.JobInfo job, List<String> ids) throws TranslatorException
getBulkResults
in interface SalesforceConnection
TranslatorException
public void cancelBulkJob(com.sforce.async.JobInfo job) throws TranslatorException
cancelBulkJob
in interface SalesforceConnection
TranslatorException
public String getVersion()
getVersion
in interface SalesforceConnection
Copyright © 2019. All rights reserved.