public class SfdcConnector extends AbstractConnector implements Connector
DATE_LENGTH_UNRESTRICTED, projectId, schema
Modifier | Constructor and Description |
---|---|
protected |
SfdcConnector()
Creates a new SFDC connector
|
Modifier and Type | Method and Description |
---|---|
protected static SoapBindingStub |
connect(String host,
String usr,
String psw,
String token,
String clientID)
Connect the SFDC
|
static SfdcConnector |
createConnector()
Creates a new SFDC connector
|
protected static Map<String,Field> |
describeObject(SoapBindingStub c,
String name)
Retrieves the object's metadata
|
protected static SObject |
executeQueryFirstRow(SoapBindingStub binding,
String sfdcQuery,
String clientID)
Executes the SFDC query, returns one row only.
|
void |
extract(String file,
boolean transform)
Extract rows
|
String |
getClientID() |
protected static String |
getColumnType(Map<String,Field> fields,
String fieldName)
Derives the LDM type from the SFDC type
|
String |
getSfdcHostname() |
String |
getSfdcPassword()
SFDC password getter
|
String |
getSfdcQuery()
SFDC query getter
|
String |
getSfdcToken()
SFDC security token getter
|
String |
getSfdcUsername()
SFDC username getter
|
boolean |
processCommand(Command c,
CliParams cli,
ProcessingContext ctx)
Processes single command
|
static void |
saveConfigTemplate(String name,
String configFileName,
String sfdcHostname,
String sfdcUsr,
String sfdcPsw,
String sfdcToken,
String partnerId,
String query)
Saves a template of the config file
|
void |
setClientID(String clientID) |
void |
setSfdcHostname(String sfdcHostname) |
void |
setSfdcPassword(String sfdcPassword)
SFDC password setter
|
void |
setSfdcQuery(String sfdcQuery)
SFDC query setter
|
void |
setSfdcToken(String sfdcToken)
SFDC security token setter
|
void |
setSfdcUsername(String sfdcUsername)
SFDC username setter
|
checkLoadingStatus, copyAndTransform, deploy, dump, dumpData, expandDates, extract, extractAndTransfer, generateMaqlCreate, getProjectId, getResult, getSchema, initSchema, populateColumnsFromSchema, setIncremental, setProjectId, setProjectId, setSchema, transferData
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
deploy, dump, extract, extractAndTransfer, generateMaqlCreate, getSchema, setSchema
public static SfdcConnector createConnector()
protected static SObject executeQueryFirstRow(SoapBindingStub binding, String sfdcQuery, String clientID) throws SfdcException
binding
- SFDC stubsfdcQuery
- SFDC SOOL queryclientID
- SFDC partner client IDSfdcException
- in case of SFDC communication errorsprotected static Map<String,Field> describeObject(SoapBindingStub c, String name) throws RemoteException
c
- SFDC stubname
- SFDC object nameRemoteException
- communication errorpublic static void saveConfigTemplate(String name, String configFileName, String sfdcHostname, String sfdcUsr, String sfdcPsw, String sfdcToken, String partnerId, String query) throws IOException
name
- new schema nameconfigFileName
- config file namesfdcUsr
- SFDC usernamesfdcPsw
- SFDC passwordsfdcToken
- SFDC security tokenquery
- SFDC querypartnerId
- SFDC partner IDIOException
- if there is a problem with writing the config fileprotected static String getColumnType(Map<String,Field> fields, String fieldName)
fields
- SFDC object metadatafieldName
- the field namepublic void extract(String file, boolean transform) throws IOException
extract
in class AbstractConnector
file
- name of the target filetransform
- perform transformationsIOException
protected static SoapBindingStub connect(String host, String usr, String psw, String token, String clientID) throws SfdcException
usr
- SFDC usernamepsw
- SFDC paswordtoken
- SFDC security tokenSfdcException
- in case of connection issuespublic String getSfdcUsername()
public void setSfdcUsername(String sfdcUsername)
sfdcUsername
- SFDC usernamepublic String getSfdcPassword()
public void setSfdcPassword(String sfdcPassword)
sfdcPassword
- SFDC passwordpublic String getSfdcQuery()
public void setSfdcQuery(String sfdcQuery)
sfdcQuery
- SFDC querypublic String getSfdcToken()
public void setSfdcToken(String sfdcToken)
sfdcToken
- SFDC security tokenpublic String getSfdcHostname()
public void setSfdcHostname(String sfdcHostname)
sfdcHostname
- the sfdcHostname to setpublic String getClientID()
public void setClientID(String clientID)
public boolean processCommand(Command c, CliParams cli, ProcessingContext ctx) throws ProcessingException
processCommand
in interface Executor
processCommand
in class AbstractConnector
c
- command to be processedcli
- parameters (commandline params)ctx
- processing contextProcessingException
- in case of issues during the command processingCopyright © 2014. All rights reserved.