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

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	SalesforceConnectionImpl(com.sforce.soap.partner.Soap soap)
	SalesforceConnectionImpl(String username, String password, URL url, SalesForceManagedConnectionFactory mcf)

Method Summary

Methods

Modifier and Type	Method and Description
void	cancelBulkJob(com.sforce.async.JobInfo job)
void	close()
int	create(DataPayload data)
int	delete(String[] ids)
com.sforce.async.JobInfo	executeBulkJob(String objectName, List<com.sforce.async.SObject> payload)
com.sforce.async.BatchResult	getBulkResults(com.sforce.async.JobInfo job)
DeletedResult	getDeleted(String objectName, XMLGregorianCalendar startCalendar, XMLGregorianCalendar endCalendar)
com.sforce.soap.partner.DescribeSObjectResult	getObjectMetaData(String objectName)
com.sforce.soap.partner.DescribeGlobalResult	getObjects()
UpdatedResult	getUpdated(String objectType, XMLGregorianCalendar startDate, XMLGregorianCalendar endDate)
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.QueryResult	retrieve(String fieldList, String sObjectType, List<String> ids)
int	update(List<DataPayload> updateDataList)

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(String username,
                        String password,
                        URL url,
                        SalesForceManagedConnectionFactory mcf)
                         throws javax.resource.ResourceException

Throws:

javax.resource.ResourceException

SalesforceConnectionImpl

protected SalesforceConnectionImpl(com.sforce.soap.partner.Soap soap)

Method Detail

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

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,
                       XMLGregorianCalendar startDate,
                       XMLGregorianCalendar endDate)
                         throws javax.resource.ResourceException

Specified by:

getUpdated in interface SalesforceConnection

Throws:

javax.resource.ResourceException

getDeleted

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

Specified by:

getDeleted in interface SalesforceConnection

Throws:

javax.resource.ResourceException

retrieve

public com.sforce.soap.partner.QueryResult 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:

executeBulkJob

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

Specified by:

executeBulkJob in interface SalesforceConnection

Throws:

javax.resource.ResourceException

getBulkResults

public com.sforce.async.BatchResult getBulkResults(com.sforce.async.JobInfo job)
                                            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