salesforce integration

Ketan Jetty
enthusiasm for technology

salesforce integration

Salesforce integration code in java. You can jar this code and use this from coldfusion to communicate with salesforce.

Salesforce integration code in Java
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.rmi.RemoteException;
import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Calendar;
import java.util.Date;
import java.util.GregorianCalendar;
import java.util.HashMap;
import java.util.Vector;
import javax.xml.rpc.ServiceException;
import org.apache.axis.message.MessageElement;
import org.apache.log4j.BasicConfigurator;
import org.apache.log4j.Level;
import org.apache.log4j.Logger;
import org.w3c.dom.Element;
import com.sforce.soap.partner.*;
import com.sforce.soap.partner.DeleteResult;
import com.sforce.soap.partner.DescribeGlobalResult;
import com.sforce.soap.partner.DescribeLayout;
import com.sforce.soap.partner.DescribeLayoutItem;
import com.sforce.soap.partner.DescribeLayoutResult;
import com.sforce.soap.partner.DescribeLayoutRow;
import com.sforce.soap.partner.DescribeLayoutSection;
import com.sforce.soap.partner.DescribeSObjectResult;
import com.sforce.soap.partner.DescribeSoftphoneLayoutCallType;
import com.sforce.soap.partner.DescribeSoftphoneLayoutInfoField;
import com.sforce.soap.partner.DescribeSoftphoneLayoutItem;
import com.sforce.soap.partner.DescribeSoftphoneLayoutResult;
import com.sforce.soap.partner.DescribeSoftphoneLayoutSection;
import com.sforce.soap.partner.DescribeTab;
import com.sforce.soap.partner.DescribeTabSetResult;
import com.sforce.soap.partner.Field;
import com.sforce.soap.partner.FieldType;
import com.sforce.soap.partner.GetDeletedResult;
import com.sforce.soap.partner.GetUpdatedResult;
import com.sforce.soap.partner.GetUserInfoResult;
import com.sforce.soap.partner.LeadConvert;
import com.sforce.soap.partner.LeadConvertResult;
import com.sforce.soap.partner.LoginResult;
import com.sforce.soap.partner.MergeRequest;
import com.sforce.soap.partner.MergeResult;
import com.sforce.soap.partner.PicklistEntry;
import com.sforce.soap.partner.ProcessRequest;
import com.sforce.soap.partner.ProcessResult;
import com.sforce.soap.partner.ProcessSubmitRequest;
import com.sforce.soap.partner.ProcessWorkitemRequest;
import com.sforce.soap.partner.QueryOptions;
import com.sforce.soap.partner.QueryResult;
import com.sforce.soap.partner.ResetPasswordResult;
import com.sforce.soap.partner.SaveResult;
import com.sforce.soap.partner.SearchRecord;
import com.sforce.soap.partner.SearchResult;
import com.sforce.soap.partner.SessionHeader;
import com.sforce.soap.partner.SetPasswordResult;
import com.sforce.soap.partner.SforceServiceLocator;
import com.sforce.soap.partner.SoapBindingStub;
import com.sforce.soap.partner.UndeleteResult;
import com.sforce.soap.partner.UpsertResult;
import com.sforce.soap.partner.fault.ApiFault;
import com.sforce.soap.partner.fault.InvalidQueryLocatorFault;
import com.sforce.soap.partner.fault.LoginFault;
import com.sforce.soap.partner.fault.UnexpectedErrorFault;
import com.sforce.soap.partner.sobject.SObject;
import com.sforce.soap.partner.AssignmentRuleHeader;

public class SalesForcePartnerAPI {
	public static void main(String[] args) {
		SalesForcePartnerAPI sfpObj = new SalesForcePartnerAPI();

		sfpObj.login("yourLogin@domain.com", "passworddYmtLvyz6TR4FVSoLCIdeBEmis");
		sfpObj.setDebug("yes");

		// sfpObj.getMappings("Account");
		// sfpObj.getMappings("Contact");
		// sfpObj.getMappings("Case");
		sfpObj.getMappings("Lead");
		// sfpObj.getMappings("Warranty_reg__c");
		// sfpObj.getMappings("Warranty_Equipment__c");

		// get all objects and relevant mappings
		// String[] tempObjects = sfpObj.getAllObjects(); if (!(tempObjects == null)) { for (int i = 0; i < tempObjects.length; i++) { sfpObj.getMappings(tempObjects[i].trim()); } }

		String strTemp = "";
		String opCompare = "like"; // like or equalto

		// Account
		strTemp = "Id=|Name=test10 account name 1|";
		// sfpObj.getRecord("Account", strTemp, opCompare);
		// sfpObj.checkRecord("Account", strTemp, opCompare);
		// sfpObj.upsertRecord("Account", strTemp);

		// Contact
		strTemp = "Id=|LastName=test10 contact last name 1|";
		// sfpObj.getRecord("Contact", strTemp, opCompare);
		// sfpObj.checkRecord("Contact", strTemp, opCompare);
		// sfpObj.upsertRecord("Contact", strTemp);

		// Case
		strTemp = "Id=|SuppliedName=test13 case SuppliedName 1|";
		// sfpObj.getRecord("Case", strTemp, opCompare);
		// sfpObj.checkRecord("Case", strTemp, opCompare);
		// sfpObj.upsertRecord("Case", strTemp);

		// Lead
		// strTemp = "Id=|LastName=test13 contact last name 1|company=test13|";
		// strTemp = "Id=|FirstName=Drew - form test
		// 5|LastName=sqa|Company=test|Email=test@test.com|Phone=123 456 7890| Description=Verify software|";
		//strTemp = "Id=|FirstName=testJul10_008 fn's|LastName=testJul10_008 ln's|Company=testJul10_008|Email=testJul10_008@test.com|Phone=1234567890|";
		 strTemp = "Id=|LastName=%Ketan's%|Company=|Email=|";
		try {
			sfpObj.getRecord("Lead", strTemp, opCompare);
		} catch (Exception ex) {
			ex.printStackTrace();
		}

		// strTemp = "FirstName=test| LastName=test |abc__CurrentGenerators__c=dfsrCustomPost | Company=test |";
		// sfpObj.getRecord("Lead", strTemp, opCompare);
		// sfpObj.checkRecord("Lead", strTemp, null);
		//sfpObj.upsertRecord("Lead", strTemp);

		// //////////////////
		// custom objects //
		// //////////////////
		opCompare = "equalto"; // cannot retrieve mutiple records for custom
		// objects

		// Warranty_reg__c
		// strTemp =
		// "Id=|Account__c=0015000000HupPPAAZ|Installer__c=0035000000O4NekAAF|Date_of_Installation__c=2007-02-01|";
		// sfpObj.getRecord("Warranty_reg__c", strTemp, opCompare);
		// sfpObj.checkRecord("Warranty_reg__c", strTemp, opCompare);
		// sfpObj.upsertRecord("Warranty_reg__c", strTemp);

		// Warranty_Equipment__c
		// strTemp =
		// "Id=|Warranty_Registration__c=a0R500000001j0EEAQ|Model_Number__c=test10
		// Warranty_Registration__c model number 1|Serial_Number__c=test10
		// Warranty_Registration__c serial number 1|";
		// sfpObj.getRecord("Warranty_Equipment__c", strTemp, opCompare);
		// sfpObj.checkRecord("Warranty_Equipment__c", strTemp, opCompare);
		// sfpObj.upsertRecord("Warranty_Equipment__c", strTemp);

		if (sfpObj.isDebug) {
			System.out.println("-- done");
		}
	}

	private SoapBindingStub binding;
	private LoginResult loginResult = null;
	private String un = null;
	private String pwd = null;
	private boolean loggedIn = false;
	private GetUserInfoResult userInfo = null;
	private String[] tasks = null;
	private String PARTNER_SOBJECT_NS = "urn:sobject.partner.soap.sforce.com";
	private boolean logOn = false;
	private boolean isDebug = false;

	public SalesForcePartnerAPI() {
	}

	public String login(String un, String pwd) {
		String retVal = "";

		try {
			isDebug = false;
			loggedIn = false;
			this.un = un.trim();
			this.pwd = pwd.trim();

			binding = (SoapBindingStub) new SforceServiceLocator().getSoap();
			binding.setTimeout(60000);
			loginResult = binding.login(this.un, this.pwd);

			// set the session header for subsequent call authentication
			binding._setProperty(SoapBindingStub.ENDPOINT_ADDRESS_PROPERTY, loginResult.getServerUrl());

			// Create a new session header object and set the session id to that
			// returned by the login
			SessionHeader sh = new SessionHeader();
			sh.setSessionId(loginResult.getSessionId());
			binding.setHeader(new SforceServiceLocator().getServiceName().getNamespaceURI(), "SessionHeader", sh);

			// Use the following in your login method, before you make your
			// login call to the service. set the call option for client id and
			// bind it to the current soap session
			// String clientID = "KetanJetty/";
			// CallOptions co = new CallOptions();
			// co.setClient(clientID);
			// binding.setHeader("SforceService", "CallOptions", co);

			setAssignmentRules();

			// assignrule.useDefaultRule = True
			// binding.AssignmentRuleHeaderValue = assignrule
			// 'end setting bindings to use current rules

			loggedIn = true;

			// retVal = loginResult.getUserId().getValue();
			retVal = loginResult.getUserId();
		} catch (Exception ex) {
			ex.printStackTrace();
			retVal = "Error [SalesForce]: " + retVal + ex.toString();
			System.err.println(retVal);
		}

		// System.out.println(retVal);
		return retVal;
	}

	public void setAssignmentRules() {

		/*
		 * // lead assignment rules AssignmentRuleHeader arh = new AssignmentRuleHeader(); binding.setHeader(new SforceServiceLocator().getServiceName().getNamespaceURI(), "AssignmentRuleHeader", arh); arh.setUseDefaultRule(new Boolean(true));
		 */

		try {
			String asgnRule = "Test Assignment Rule";
			QueryResult ar = binding.query("SELECT Id FROM AssignmentRule");
			for (int i = 0; i < ar.getSize(); i++) {

				SObject temp = ar.getRecords(i);

				// AssignmentRule rule = (AssignmentRule)ar.getRecords(i);
				// logger.debug("\tID: " + rule.getId() + " Name: " +
				// rule.getName()
				// + " Type: " + rule.getRuleType());
			}

			AssignmentRuleHeader arh = new AssignmentRuleHeader();
			arh.setUseDefaultRule(new Boolean(true));
			// arh.setAssignmentRuleId(ar.getRecords(0).getId());
			binding.setHeader(new SforceServiceLocator().getServiceName().getNamespaceURI(), "AssignmentRuleHeader", arh);
		} catch (Exception ex) {
			ex.printStackTrace();
		}

	}

	public void setDebug(String val) {
		isDebug = false;
		if (val != null) {
			if (val.trim().equalsIgnoreCase("1") || val.trim().equalsIgnoreCase("yes") || val.trim().equalsIgnoreCase("true")) {
				isDebug = true;
			}
		}
	}

	public String[] getMappings(String type) {
		String[] sourceVal = new String[10000];
		String[] retVal = null;

		try {
			DescribeSObjectResult[] rslts = binding.describeSObjects(new String[] { type });

			int k = 0;
			for (int i = 0; i < rslts.length; i++) {
				Field[] flds = rslts[i].getFields();

				for (int j = 0; j < flds.length; j++) {
					if (flds[j].isUpdateable()) {
						sourceVal[k] = rslts[i].getLabel() + "|" + flds[j].getName() + "|" + flds[j].getLabel();
						k++;

						if (isDebug) {
							System.out.println(rslts[i].getLabel() + " [" + rslts[i].getName() + "]: " + flds[j].getLabel() + " [" + flds[j].getName() + "]");
						}
					}
				}
			}

			// resize the array
			retVal = new String[k];
			System.arraycopy(sourceVal, 0, retVal, 0, k);
			sourceVal = null;
		} catch (Exception ex) {
			ex.printStackTrace();
			System.err.println("Error [SalesForce]:" + ex.getMessage());
		}

		return retVal;
	}

	private MessageElement newMessageElement(String name, Object value) throws Exception {
		MessageElement me = new MessageElement("", name.trim()); // , value);
		me.setObjectValue(value);
		Element e = me.getAsDOM();
		e.removeAttribute("xsi:type");
		e.removeAttribute("xmlns:ns1");
		e.removeAttribute("xmlns:xsd");
		e.removeAttribute("xmlns:xsi");
		me = new MessageElement(e);
		return me;
	}

	private String getFieldValue(MessageElement[] value, String name) {
		for (int i = 0; i < value.length; i++) {
			if (value[i].getName().toLowerCase().equals(name.toLowerCase()))
				return value[i].getValue();
		}
		return " ";
	}

	public String createDynamicSql(String recordType, String dataKeyValues, String comparer) {
		String retVal = "";
		StringBuffer sb = new StringBuffer();
		SimpleDateFormat sdf = null;
		Date tempDate = null;
		Date tempDate2000 = null;
		boolean putAND = false;

		String[] avoidKeys = { "Description" };

		try {
			if (dataKeyValues != null && dataKeyValues.length() > 0) {
				sdf = new SimpleDateFormat("yyyy-MM-dd");
				tempDate2000 = sdf.parse("2000-01-01");
				String[] aryKeyValues = dataKeyValues.split("\\|");
				sb.append("select ");

				if (dataKeyValues != null && dataKeyValues.length() > 0) {
					for (int j = 0; j < aryKeyValues.length; j++) {
						if (aryKeyValues[j].length() > 0 && aryKeyValues[j].indexOf("=", 0) > 0) {
							String[] aryKeyValue = aryKeyValues[j].split("\\=");
							if (aryKeyValue != null) {
								// System.out.println(aryKeyValue[0].toString());
								for (int k = 0; k < avoidKeys.length; k++) {
									if (!aryKeyValue[0].toString().trim().equalsIgnoreCase(avoidKeys[k].toString().trim())) {
										if (j > 0) {
											sb.append(", ");
										}

										sb.append(aryKeyValue[0]);
									}
								}
							}
						}
					}
				}

				sb.append(" from " + recordType + " where ");

				// System.out.println(sb.toString());

				for (int i = 0; i < aryKeyValues.length; i++) {
					if (aryKeyValues[i].length() > 0 && aryKeyValues[i].indexOf("=", 0) > 0) {
						String[] aryKeyValue = aryKeyValues[i].split("\\=");
						if (aryKeyValue != null) {
							for (int k = 0; k < avoidKeys.length; k++) {
								if (!aryKeyValue[0].toString().trim().equalsIgnoreCase(avoidKeys[k].toString().trim())) {

									if (aryKeyValue.length > 1 && (aryKeyValue[0].trim().length() > 0 && aryKeyValue[1].trim().length() > 0)) {
										try {
											tempDate = sdf.parse(aryKeyValue[1].trim());
										} catch (Exception exDate) {
											tempDate = null;
										}

										if (tempDate != null) {
											if (tempDate.after(tempDate2000) && aryKeyValue[1].trim().length() == 10) {
												if (putAND) {
													sb.append(" and ");
												}

												sb.append(aryKeyValue[0] + " = " + aryKeyValue[1]);
											}
										} else {
											if (putAND) {
												sb.append(" and ");
											}

											// escape the single quote
											String tempAryKeyValue1 = aryKeyValue[1].toString().trim();

											if (tempAryKeyValue1.contains("'")) {
												tempAryKeyValue1 = tempAryKeyValue1.replaceAll("'", "\\\\'");
											}

											if (comparer != null && comparer.trim().equalsIgnoreCase("like")) {
												sb.append(aryKeyValue[0] + " like '" + tempAryKeyValue1 + "%'");
											} else {
												sb.append(aryKeyValue[0] + " = '" + tempAryKeyValue1 + "'");
											}
										}

										putAND = true;
									}

								}
							}
						}
					}
				}

				retVal = sb.toString();
			}
		} catch (Exception ex) {
			ex.printStackTrace();
			retVal = "Error [SalesForce]: " + retVal + ex.toString();
			System.err.println(retVal);
		}

		if (isDebug) {
			System.out.println("from createDynamicSql(): " + retVal);
		}

		return retVal;
	}

	public String getRecord(String recordType, String dataKeyValues, String comparer) throws Exception {
		String retVal = "";
		StringBuffer sb = new StringBuffer();

		try {
			if (dataKeyValues != null && dataKeyValues.trim().length() > 0) {
				String strSqlSelect = createDynamicSql(recordType, dataKeyValues, comparer);
				QueryResult qr = binding.query(strSqlSelect);

				if (qr.getSize() > 0) {
					for (int i = 0; i < qr.getRecords().length; i++) {
						SObject sobj = qr.getRecords(i);
						if (i > 0) {
							sb.append("|");
						}

						if (dataKeyValues != null && dataKeyValues.length() > 0) {
							String[] aryKeyValues = dataKeyValues.split("\\|");

							for (int j = 0; j < aryKeyValues.length; j++) {
								if (aryKeyValues[j].length() > 0 && aryKeyValues[j].indexOf("=", 0) > 0) {
									String[] aryKeyValue = aryKeyValues[j].split("\\=");
									if (aryKeyValue != null) {
										sb.append(recordType + aryKeyValue[0] + "=" + getFieldValue(sobj.get_any(), aryKeyValue[0]) + ";");
									}
								}
							}
						}
					}
				}
			}

			retVal = sb.toString();
		} catch (Exception ex) {
			ex.printStackTrace();
			retVal = "Error [SalesForce]: " + retVal + ex.toString();
			System.err.println(retVal);
		}

		if (isDebug) {
			System.out.println("from getRecord(): " + retVal);
		}

		return retVal;
	}

	public String checkRecord(String recordType, String dataKeyValues, String comparer) throws Exception {
		String retVal = "";

		try {
			if (dataKeyValues != null && dataKeyValues.trim().length() > 0) {
				String strSqlSelect = createDynamicSql(recordType, dataKeyValues, comparer);
				QueryResult qr = binding.query(strSqlSelect);

				if (qr.getSize() > 0) {
					for (int i = 0; i < qr.getRecords().length; i++) {
						SObject sobj = qr.getRecords(i);

						if (dataKeyValues != null && dataKeyValues.length() > 0) {
							String[] aryKeyValues = dataKeyValues.split("\\|");

							for (int j = 0; j < aryKeyValues.length; j++) {
								if (aryKeyValues[j].length() > 0 && aryKeyValues[j].indexOf("=", 0) > 0) {
									String[] aryKeyValue = aryKeyValues[j].split("\\=");
									if (aryKeyValue != null) {
										// sb.append(recordType + aryKeyValue[0]
										// + "=" + getFieldValue(sobj.get_any(),
										// aryKeyValue[0]) + ";");

										if (aryKeyValue[0].trim().equalsIgnoreCase("id")) {
											retVal = getFieldValue(sobj.get_any(), aryKeyValue[0]);
										}
									}
								}
							}
						}
					}
				}
			}
		} catch (Exception ex) {
			ex.printStackTrace();
			retVal = "Error [SalesForce]: " + retVal + ex.toString();
			System.err.println(retVal);
		}

		if (isDebug) {
			System.out.println("from checkRecord(): " + recordType + " " + retVal);
		}

		return retVal;
	}

	public String upsertRecord(String recordType, String dataKeyValues) {
		String retVal = "";
		MessageElement[] me = null;
		SObject[] newSObject = null;
		SaveResult[] sr = null;

		try {
			if (dataKeyValues != null && dataKeyValues.trim().length() > 0) {
				String[] aryKeyValues = dataKeyValues.split("\\|");
				me = new MessageElement[aryKeyValues.length];

				for (int i = 0; i < aryKeyValues.length; i++) {
					if (aryKeyValues[i].trim().length() > 0 && aryKeyValues[i].indexOf("=", 0) > 0) {
						String[] aryKeyValue = aryKeyValues[i].split("\\=");
						if (aryKeyValue != null) {
							if (aryKeyValue.length > 1 && (aryKeyValue[0].trim().length() > 0 && aryKeyValue[1].trim().length() > 0)) {
								me[i] = newMessageElement(aryKeyValue[0], aryKeyValue[1]);
							} else if (aryKeyValue[0].trim().length() > 0) {
								me[i] = newMessageElement(aryKeyValue[0], "");
							}
						}
					}
				}

				// String result = getRecord(recordType, dataKeyValues, null);
				String result = checkRecord(recordType, dataKeyValues, null);
				retVal = result;

				if (result != null && result.trim().length() == 0) {
					newSObject = new SObject[1];
					newSObject[0] = new SObject();
					newSObject[0].setType(recordType);
					newSObject[0].set_any(me);

					sr = binding.create(newSObject);

					for (int j = 0; j < sr.length; j++) {
						if (sr[j].isSuccess()) {
							// retVal = recordType + " record is created with an
							// id of: "+ sr[j].getId();
							// retVal = sr[j].getId().getValue();
							retVal = sr[j].getId();
						} else {
							for (int k = 0; k < sr[j].getErrors().length; k++) {
								com.sforce.soap.partner.Error err = sr[j].getErrors()[k];
								retVal = "Error [SalesForce]: " + err.getMessage() + " [" + err.getStatusCode().toString() + "]";
							}
						}
					}
				}
			}
		} catch (Exception ex) {
			ex.printStackTrace();
			retVal = "Error [SalesForce]: " + retVal + ex.toString();
			System.err.println(retVal);
		}

		if (isDebug) {
			System.out.println("from upsertRecord(): " + recordType + " " + retVal);
		}

		return retVal;
	}

	public String[] getAllObjects() {
		String[] retVal = new String[0];

		try {
			DescribeGlobalResult describeGlobalResult = binding.describeGlobal();
			if (!(describeGlobalResult == null)) {
				retVal = describeGlobalResult.getTypes();
				if (isDebug) {
					if (!(retVal == null)) {
						for (int i = 0; i < retVal.length; i++) {
							System.out.println(retVal[i]);
						}
					}
				}
			}
		} catch (Exception ex) {
			ex.printStackTrace();
			retVal[0] = "Error [SalesForce]: " + retVal + ex.toString();
			System.err.println(retVal);
		}

		return retVal;
	}
}

coldfusion


CF Quick Reference


Ginger CMS
the future of cms, a simple, easy and intutive content management system ... more


CFTurbine
cf prototyping engine, generates boilerplate code and ... more


Jrun monitor
monitor and timely auto-restart to avoid Jrun hang ... more


Inheritance Config.
uses OOPs inheritance to create configuration file ... more


Real Estate App.
complete real estate application using data from MLS ... more


Search Engine Lite
create your own search engine for your web site ... more