How to create and insert data into Big Objects

February 14, 2018March 3, 2018 konaguru Leave a comment

Use Case:

Company A stores credit card transaction data in Salesforce. Data is stored as Person Accounts all the transaction data is stored in the person account. Number of transactions can grow to more than 10 million to 100 million depends upon the member base of the Company A

Solution:

Say for instance we are interested in

Capturing transaction data under person account
Processing transaction data for further processing ( like the redemption of the user acquired commissions )
Letting Customer support team filter the transaction data
Running reports on transaction data

Why can’t we use Salesforce provided Big Objects to attain above functionality. Wait.. before we design the solution let’s understand the Big Object limitations

You can’t create Big Objects using Salesforce Setup, instead use Salesforce Metadata API to create these objects
No triggers can be implemented on Big Objects
No Page Layouts
Querying data using SOQL is comes with limitation, you can query data on Index fields
You can’t design Workflows, Process Builders etc
You can’t run reports on the Transaction data

Instead of looking into the negativities of the Big Objects I looked into the beauty that can bring with these limitations. I trust Salesforce Architect team designed few of these limitations on purpose due to its multi-tenant architecture. Designing triggers, querying data on non-index fields, running reports , designing workflows, process builders all have a risk when not properly handled by an architect/developer when doing things.

Creating Big Object

Field Name	Type	Length	Index
Transaction Date	Date		Index
Transaction Amount	Number	5,2
Merchant Name	Text	50	Index
Transaction Location	Text	25
CustomerId	Lookup(Account)

Big Object can’t be created from Salesforce setup. In order to create Big Object you have to use Salesforce Metadata API. Let’s create a package and deploy to Salesforce using workbench.

Create file : Customer_Transaction__B.object

<CustomObject xmlns="http://soap.sforce.com/2006/04/metadata">
   <deploymentStatus>Deployed</deploymentStatus>
   <fields>
      <fullName>Transaction_No__c</fullName>
      <label>Transaction No</label>
      <length>9</length>
      <required>true</required>
      <type>Text</type>
   </fields>
   <fields>
      <fullName>Transaction_Date__c</fullName>
      <label>Transaction Date</label>
      <required>true</required>
      <type>DateTime</type>
   </fields>
   <fields>
      <fullName>Transaction_Amount__c</fullName>
      <label>Transaction Amount</label>
      <scale>9</scale>
      <precision>11</precision>
      <required>false</required>
      <type>Number</type>
   </fields>
   <fields>
      <fullName>Merchant_Name__c</fullName>
      <label>Merchant Name</label>
      <length>30</length>
      <required>false</required>
      <type>Text</type>
   </fields>
   <indexes>
      <type>PRIMARY</type>
      <fullName>Transaction_No_idx_c</fullName>
      <fields>
         <name>Transaction_No__c</name>
         <sortDirection>DESC</sortDirection>
      </fields>
<fields>
         <name>Transaction_Date__c</name>
         <sortDirection>DESC</sortDirection>
      </fields>
   </indexes>
   <label>Transaction</label>
   <pluralLabel>Transactions</pluralLabel>
</CustomObject>

<deploymentStatus>Deployed</deploymentStatus>

<fullName>Transaction_No__c</fullName>

<label>Transaction No</label>

</fields>

<fullName>Transaction_Date__c</fullName>

<label>Transaction Date</label>

<type>DateTime</type>

</fields>

<fullName>Transaction_Amount__c</fullName>

<label>Transaction Amount</label>

<required>false</required>

<type>Number</type>

</fields>

<fullName>Merchant_Name__c</fullName>

<label>Merchant Name</label>

<required>false</required>

</fields>

<type>PRIMARY</type>

<fullName>Transaction_No_idx_c</fullName>

<name>Transaction_No__c</name>

</fields>

<name>Transaction_Date__c</name>

</fields>

</indexes>

<label>Transaction</label>

<pluralLabel>Transactions</pluralLabel>

</CustomObject>

Step #2 : Create Permission set

Customer_Transaction.permissionset

<PermissionSet xmlns="http://soap.sforce.com/2006/04/metadata">
<description>Transaction Big Object PermissionSet</description>
<hasActivationRequired>false</hasActivationRequired>
<label>Transaction Big Object PermissionSet</label>
<fieldPermissions>
  <editable>true</editable>
  <field>Customer_Transaction__b.Transaction_Amount__c</field>
  <readable>true</readable>
</fieldPermissions>
<fieldPermissions>
  <editable>true</editable>
  <field>Customer_Transaction__b.Merchant_Name__c</field>
  <readable>true</readable>
</fieldPermissions>
</PermissionSet>

<description>Transaction Big Object PermissionSet</description>

<hasActivationRequired>false</hasActivationRequired>

<label>Transaction Big Object PermissionSet</label>

<field>Customer_Transaction__b.Transaction_Amount__c</field>

</fieldPermissions>

<field>Customer_Transaction__b.Merchant_Name__c</field>

</fieldPermissions>

</PermissionSet>

Step #3 : Create Package.xml file

<Package xmlns="http://soap.sforce.com/2006/04/metadata">
<types>
 <members>*</members>
 <name>CustomObject</name>
</types>
<types>
 <members>*</members>
 <name>PermissionSet</name>
</types>
<version>40.0</version>
</Package>

<types>

<name>CustomObject</name>

</types>

<types>

<name>PermissionSet</name>

</types>

</Package>

Step #4 : Create zip file for deployment

Customer_Transaction__B.object, package.xml, Customer_Transaction.permissionset

Download zip file customer_transaction

Step #5: use workbench to deploy the code

Upload zip file and click Next , follow the instruction to deploy the code

Step #6 : Use Bulk Api Java Code for data Migration into Big Object

/* Author : Rangesh Kona
*/
import java.io.*;
import java.util.*;

import com.sforce.async.*;
import com.sforce.soap.partner.PartnerConnection;
import com.sforce.ws.ConnectionException;
import com.sforce.ws.ConnectorConfig;


public class BulkLoadBigObject {

   public static void main(String[] args) throws AsyncApiException, ConnectionException, IOException {

	BulkLoadBigObject bo = new BulkLoadBigObject();
	bo.createRecords("RK_CLOUD__Customer_Interaction__b", "rangeshsecure@gmail.com","Ritman$1234", "customerInteraction.csv");
   }

   public void createRecords(String sobjectType, String userName, String password, String sampleFileName) 
		throws ConnectionException, IOException, AsyncApiException { 
	
	// get SFDC connection using partner WSDL 
	BulkConnection 		connection  = getBulkConnection(userName, password);

	// Create Job
	JobInfo 		job = createJob(sobjectType, connection);


	// Create Batch
	BatchInfo 		batchInfo  = createBatchFromCSVFile(connection, job, sampleFileName);
	
	// Close Job
 	closeJob(connection, job.getId());	
	
	// Await Completion
	awaitCompletion(connection, job, batchInfo); 

	// Check Results
	checkResults(connection, job, batchInfo);
   }



	private void checkResults(BulkConnection connection, JobInfo job,
                                BatchInfo batchInfo)
                throws AsyncApiException, IOException {
                CSVReader rdr = new CSVReader(connection.getBatchResultStream (job.getId(), batchInfo.getId()));
                List<String> resultHeader = rdr.nextRecord();
                int resultCols = resultHeader.size();
                List<String> row;

                while((row = rdr.nextRecord()) != null) {
                   Map<String, String> resultInfo = new HashMap<String, String>();
                   for(int i = 0; i<resultCols;i++) {
                      resultInfo.put(resultHeader.get(i), row.get(i));
                }
                boolean success = Boolean.valueOf(resultInfo.get("Success"));
                boolean created = Boolean.valueOf(resultInfo.get("Created"));
                String id = resultInfo.get("Id");
                String error = resultInfo.get("Error");
                if (success && created ) {
                   System.out.println("Created row with id " + id );
                }
                else if (!success) {
                   System.out.println("Failed with error: " + error);
                }
                }
          }


  private void awaitCompletion(BulkConnection connection, JobInfo job, BatchInfo batchInfo) throws AsyncApiException {

	long sleepTime = 0L;
	Set<String> incomplete = new HashSet<String>();
	incomplete.add(batchInfo.getId());
	while (!incomplete.isEmpty()) {
	   try {
	      Thread.sleep(sleepTime);
	   }
	   catch(InterruptedException e) {}
	   System.out.println("Awaiting results...." + incomplete.size());
	   sleepTime = 10000L;
	   BatchInfo[] statusList = connection.getBatchInfoList(job.getId()).getBatchInfo();
	   for(BatchInfo b : statusList) {
		if(b.getState() == BatchStateEnum.Completed || b.getState() == BatchStateEnum.Failed) {
		   if (incomplete.remove(b.getId())) {
                       System.out.println("Batch Status : \n" + b);
                   }
		}	
           }

	}
  } 
 

  private void closeJob(BulkConnection connection, String jobId) throws AsyncApiException {
	JobInfo job = new JobInfo();
	job.setId(jobId);
	job.setState(JobStateEnum.Closed);
	connection.updateJob(job);
  }



  private BatchInfo createBatchFromCSVFile(BulkConnection connection, JobInfo jobInfo, String sampleFileName) throws IOException, AsyncApiException {


	FileInputStream tmpInputStream	= new FileInputStream(sampleFileName);
 
	BatchInfo batchInfo;

	try {
	    batchInfo = connection.createBatchFromStream(jobInfo, tmpInputStream);
	    System.out.println("Batch Info " + batchInfo);
	}
	finally {
	    tmpInputStream.close();
	}
	return batchInfo;
  }

   private JobInfo createJob(String sobjectType, BulkConnection connection) throws AsyncApiException {

	JobInfo job = new JobInfo();
	job.setObject(sobjectType);
	job.setOperation(OperationEnum.insert);
	job.setContentType(ContentType.CSV);
	job = connection.createJob(job);
	System.out.println("Created Job " + job );
	return job;

   }

   private BulkConnection getBulkConnection(String userName, String password) throws ConnectionException, AsyncApiException {

   	ConnectorConfig partnerConfig = new ConnectorConfig();
	partnerConfig.setUsername(userName);
	partnerConfig.setPassword(password);
	partnerConfig.setAuthEndpoint("https://rangesh-dev-ed.my.salesforce.com/services/Soap/u/41.0");
	new PartnerConnection(partnerConfig);
	ConnectorConfig config = new ConnectorConfig();
	config.setSessionId(partnerConfig.getSessionId());
	String soapEndpoint	= partnerConfig.getServiceEndpoint();
	String apiVersion	= "41.0";
	String restEndpoint    = soapEndpoint.substring(0, soapEndpoint.indexOf("Soap/")) + "async/" + apiVersion;
	config.setRestEndpoint(restEndpoint);
	config.setCompression(true);
	config.setTraceMessage(false);
	BulkConnection connection = new BulkConnection(config);
	return connection;
	
   }
}

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

122

123

124

125

126

127

128

129

130

131

132

133

134

135

136

137

138

139

140

141

142

143

144

145

146

147

148

149

150

151

152

153

154

/* Author : Rangesh Kona

import java.io.*;

import java.util.*;

import com.sforce.async.*;

import com.sforce.soap.partner.PartnerConnection;

import com.sforce.ws.ConnectionException;

import com.sforce.ws.ConnectorConfig;

public class BulkLoadBigObject {

public static void main(String[] args) throws AsyncApiException, ConnectionException, IOException {

BulkLoadBigObject bo = new BulkLoadBigObject();

bo.createRecords("RK_CLOUD__Customer_Interaction__b", "rangeshsecure@gmail.com","Ritman$1234", "customerInteraction.csv");

}

public void createRecords(String sobjectType, String userName, String password, String sampleFileName)

throws ConnectionException, IOException, AsyncApiException {

// get SFDC connection using partner WSDL

BulkConnection connection = getBulkConnection(userName, password);

// Create Job

JobInfo job = createJob(sobjectType, connection);

// Create Batch

BatchInfo batchInfo = createBatchFromCSVFile(connection, job, sampleFileName);

// Close Job

closeJob(connection, job.getId());

// Await Completion

awaitCompletion(connection, job, batchInfo);

// Check Results

checkResults(connection, job, batchInfo);

}

private void checkResults(BulkConnection connection, JobInfo job,

BatchInfo batchInfo)

throws AsyncApiException, IOException {

CSVReader rdr = new CSVReader(connection.getBatchResultStream (job.getId(), batchInfo.getId()));

List<String> resultHeader = rdr.nextRecord();

int resultCols = resultHeader.size();

List<String> row;

while((row = rdr.nextRecord()) != null) {

Map<String, String> resultInfo = new HashMap<String, String>();

for(int i = 0; i<resultCols;i++) {

resultInfo.put(resultHeader.get(i), row.get(i));

}

boolean success = Boolean.valueOf(resultInfo.get("Success"));

boolean created = Boolean.valueOf(resultInfo.get("Created"));

String id = resultInfo.get("Id");

String error = resultInfo.get("Error");

if (success && created ) {

System.out.println("Created row with id " + id );

}

else if (!success) {

System.out.println("Failed with error: " + error);

}

private void awaitCompletion(BulkConnection connection, JobInfo job, BatchInfo batchInfo) throws AsyncApiException {

long sleepTime = 0L;

Set<String> incomplete = new HashSet<String>();

incomplete.add(batchInfo.getId());

while (!incomplete.isEmpty()) {

try {

Thread.sleep(sleepTime);

}

catch(InterruptedException e) {}

System.out.println("Awaiting results...." + incomplete.size());

sleepTime = 10000L;

BatchInfo[] statusList = connection.getBatchInfoList(job.getId()).getBatchInfo();

for(BatchInfo b : statusList) {

if(b.getState() == BatchStateEnum.Completed || b.getState() == BatchStateEnum.Failed) {

if (incomplete.remove(b.getId())) {

System.out.println("Batch Status : \n" + b);

}

private void closeJob(BulkConnection connection, String jobId) throws AsyncApiException {

JobInfo job = new JobInfo();

job.setId(jobId);

job.setState(JobStateEnum.Closed);

connection.updateJob(job);

}

private BatchInfo createBatchFromCSVFile(BulkConnection connection, JobInfo jobInfo, String sampleFileName) throws IOException, AsyncApiException {

FileInputStream tmpInputStream = new FileInputStream(sampleFileName);

BatchInfo batchInfo;

try {

batchInfo = connection.createBatchFromStream(jobInfo, tmpInputStream);

System.out.println("Batch Info " + batchInfo);

}

finally {

tmpInputStream.close();

}

return batchInfo;

}

private JobInfo createJob(String sobjectType, BulkConnection connection) throws AsyncApiException {

JobInfo job = new JobInfo();

job.setObject(sobjectType);

job.setOperation(OperationEnum.insert);

job.setContentType(ContentType.CSV);

job = connection.createJob(job);

System.out.println("Created Job " + job );

return job;

}

private BulkConnection getBulkConnection(String userName, String password) throws ConnectionException, AsyncApiException {

ConnectorConfig partnerConfig = new ConnectorConfig();

partnerConfig.setUsername(userName);

partnerConfig.setPassword(password);

partnerConfig.setAuthEndpoint("https://rangesh-dev-ed.my.salesforce.com/services/Soap/u/41.0");

new PartnerConnection(partnerConfig);

ConnectorConfig config = new ConnectorConfig();

config.setSessionId(partnerConfig.getSessionId());

String soapEndpoint = partnerConfig.getServiceEndpoint();

String apiVersion = "41.0";

String restEndpoint = soapEndpoint.substring(0, soapEndpoint.indexOf("Soap/")) + "async/" + apiVersion;

config.setRestEndpoint(restEndpoint);

config.setCompression(true);

config.setTraceMessage(false);

BulkConnection connection = new BulkConnection(config);

return connection;

}

Poovar islands , Kerala

February 5, 2018February 5, 2018 konaguru Leave a comment

Poovar islands

Heroku postgres Integration with Force.com

February 5, 2018February 5, 2018 konaguru Leave a comment

Go to heroku Dashboard

Click ‘New’ to create Application

Create App

Enter App name: sfdc-heroku-integration

click ‘Create app’ button to continue

Click on App icon and select Elements

Select Heroku Postgres on the Heroku Elements page

Click on ‘Install Heroku Postgres’ and continue

Select your app name to install Postgres

select the free version and click on Provision button

You will landup on the below page after successfully installing Postgres on the Heroku platform

Installing Heroku Connect

Heroku connect helps you to synchronize data to Salesforce

Select app name to install Heroku Connect, in our case app name is sfdc-heroku-integration

Click on Provision button to continue

After successful installation, you will be landed on to the below page

Configuring Heroku Connect to Sync data from Salesforce

Click on Heroku Connect from Dashboard->App->Resources section

Click ‘Setup Connection’

Enter schema name and click Next

Click ‘Authorize’ and continue

Select your Salesforce org to install, After successful installatoin, you will see below screen

Synchronize Salesforce object data into Heroku Postgres

Click ‘Create Mapping’

select Objects you want to synchronize

Select Object Fields you want to Synchronize, you can also set Poll Frequency ( minimum poll frequency set at 10 minutes )

After you complete the setup you will see below screen. We can clearly see number of fields, number of records that are inserted into Postgres DB

Salesforce to Salesforce Integration using REST Webservice

February 2, 2018February 4, 2018 konaguru Leave a comment

Use Case:

An organization has two salesforce org ( Sales Org and R&D Org ). Sales Org user wants to create a support request in R&D org for a Sales Org opportunity. R&D org team has special skills to work on those Support Requests. Sales Org user is willing to share some of the opportunity field data and restrict sharing access to only for the opportunities that have Support Requests. Sales Org User is also interested to know the status and owner of the Support Request. R&D Org users should be able to run reports on Case/Support Request/Opportunity(Sales Org) data

Solution:

Providing a button on Opportunity UI to create a support request. Invoking a Visualforce page and using a controller class system can call Webservice on R&D Org to create a Case. Whenever a Support Request is created checkbox is updated in opportunity object, based on the checkbox opportunity information is shared with an integration user. Salesforce lightning connect is used to integrate Sales Org & R-&-D org. Check out my blog post on lightning connect. R&D Org can call webservice on Sales Org to update Support Request Owner and Status details in Sales Org system.

Implementation:

Below flow gives a top view of how the integration/data flow between the systems.

Step #1: Authentication

Sales Org calls Webservice on R&D Org

R&D Org authenticates Sales Org call

R&D lets Sales Org create Case after authentication

Salesforce configuration details:

Configure Connected App in R&D Org

Configure Authentical Provider in Sales Org

Configure Named Credentials in Sales Org

Use Named Credentials in Webservice Callout script

Follow blog post ‘How to configure Named Credentials‘

Step #2: Creating Webservice on R&D Org

@RestResource(urlMapping='/CaseSupportRequest/*')
global with sharing class CreateSalesSupportRequest {

    @HttpPost
    global static ID createCase() {
        
        String subject;
        String status;
        String origin;
        String priority;
        String Opportunity;
        String Service_Request_Type;
        Integer CPU_Count;
        String Support_Request;
        
        String jsonString = RestContext.request.requestBody.toString();
        JSonParser parser = JSON.createParser(jsonString);
        while (parser.nextToken() != null) {
            if (parser.getCurrentToken() == JSONToken.START_ARRAY)  {
                while(parser.nextToken() != null ) {
                    if (parser.getCurrentToken() == JSONToken.START_OBJECT) {
						caseobj co 				= 	(caseobj) parser.readValueAs(caseobj.class);
                        subject					=	co.Subject;
                        Opportunity				=	co.Opportunity;
                        Service_Request_Type  	= co.Service_Request_Type;
                        CPU_Count 				= co.CPU_Count;
                        Support_Request 		= co.Support_Request;
                        
                    }
                }
            }
              
        }
        
        System.debug('subject ' + subject);
        System.debug('Status ' + Status);
        Case thisCase = new Case(Subject=subject, Status='New', Origin='Email', Priority='Important',SMG_Opportunity__c=Opportunity, Service_Request_Type__c=Service_Request_Type,CPU_Count__C=CPU_Count,Support_Request__C=Support_Request  );
        insert thisCase;
        return thisCase.Id;
    }
    
       


public class caseobj {
        public String Subject;
        public String Opportunity;
        public String Service_Request_Type;
        public Integer CPU_Count;
    	public String Support_Request;
   
        public caseobj (String subject, String Opportunity, String Service_Request_Type, Integer CPU_Count, String Support_Request) {
            Subject 				= this.subject;
            Opportunity  			= this.Opportunity;
            Service_Request_Type  	= this.Service_Request_Type;
            CPU_Count 				= this.CPU_Count;
            Support_Request 		= this.Support_Request;
        }
    }
    
}

@RestResource(urlMapping='/CaseSupportRequest/*')

global with sharing class CreateSalesSupportRequest {

@HttpPost

global static ID createCase() {

String subject;

String status;

String origin;

String priority;

String Opportunity;

String Service_Request_Type;

Integer CPU_Count;

String Support_Request;

String jsonString = RestContext.request.requestBody.toString();

JSonParser parser = JSON.createParser(jsonString);

while (parser.nextToken() != null) {

if (parser.getCurrentToken() == JSONToken.START_ARRAY) {

while(parser.nextToken() != null ) {

if (parser.getCurrentToken() == JSONToken.START_OBJECT) {

caseobj co = (caseobj) parser.readValueAs(caseobj.class);

subject = co.Subject;

Opportunity = co.Opportunity;

Service_Request_Type = co.Service_Request_Type;

CPU_Count = co.CPU_Count;

Support_Request = co.Support_Request;

}

System.debug('subject ' + subject);

System.debug('Status ' + Status);

Case thisCase = new Case(Subject=subject, Status='New', Origin='Email', Priority='Important',SMG_Opportunity__c=Opportunity, Service_Request_Type__c=Service_Request_Type,CPU_Count__C=CPU_Count,Support_Request__C=Support_Request );

insert thisCase;

return thisCase.Id;

}

public class caseobj {

public String Subject;

public String Opportunity;

public String Service_Request_Type;

public Integer CPU_Count;

public String Support_Request;

public caseobj (String subject, String Opportunity, String Service_Request_Type, Integer CPU_Count, String Support_Request) {

Subject = this.subject;

Opportunity = this.Opportunity;

Service_Request_Type = this.Service_Request_Type;

CPU_Count = this.CPU_Count;

Support_Request = this.Support_Request;

}

Step #3: Controller class to create call R&D Webservice from Sales Org

public class CreateSSRController {
    
    public String Subject{get;set;}
    public String created_record_id{get;set;}
    public String opportunity_id {get;set;}
    public String opportunity_name {get;set;}
    
    public String description{get;set;}
    public String Service_Request_Type{get;set;}
    public Date Deadline{get;set;}
    
    public Integer CPU_Count{get;set;}
    public ID support_request_id{get;set;}
    
    public void create_SSR_in_DRD() {
               
         // Id support_record_id = Insert_Support_Request_Record();
        
        HttpRequest request = new HttpRequest();
        request.setEndpoint('callout:DRDConnect/services/apexrest/CaseSupportRequest/');
        request.setMethod('POST');
        request.setHeader('Content-Type', 'application/json;charset=UTF-8');
        String json_string = '{"caseobj":[ {"Support_Request":"' + support_request_id + '" , "Subject": "' + description + '", "Service_Request_Type": "' + Service_Request_Type + '", "Opportunity": "' + opportunity_id + '", "CPU_Count": '+ CPU_Count + '}]}'; 
        request.setBody(json_string);
        
        Http http = new Http();
        HTTPResponse response = http.send(request);
        System.debug(response.getBody());
 
        created_record_id = response.getBody();
        created_record_id =  created_record_id.removeStart('"');
        created_record_id =  created_record_id.removeEnd('"');
        
        System.debug('Record ID ' + created_record_id + ' ' );
        
    }
    
    public PageReference  Insert_Support_Request_Record() {
        
        Support_Request__c support_request_record = new Support_Request__c(Description__C=description,Opportunity__c=opportunity_id, Service_Request_Type__C=Service_Request_Type, CPU_Count__C=CPU_Count, DRD_Case__c=created_record_id);
        insert support_request_record;
        support_request_id = support_request_record.ID;
        
        return null;        
        
    }
    
    
    public CreateSSRController() {
        
        opportunity_id = ApexPages.currentPage().getParameters().get('id');
        if(opportunity_id == null) {
            opportunity_id = '0066A000002ZgZ2';
        }
        Opportunity opty = [select Id, name, account.Name  from Opportunity where Id = :opportunity_id];
        opportunity_name = opty.Name;
        opportunity_id = opty.Id;
        
    }
    
    // display picklist value in VF Page
    public List<SelectOption> getService_Request_Type_Picklist_Values()
    {
        List<SelectOption> options = new List<SelectOption>();
        
        Schema.DescribeFieldResult fieldResult =
            Support_Request__c.Service_Request_Type__c.getDescribe();
        List<Schema.PicklistEntry> ple = fieldResult.getPicklistValues();
        
        for( Schema.PicklistEntry f : ple)
        {
            options.add(new SelectOption(f.getLabel(), f.getValue()));
        }       
        return options;
    }
    
}

public class CreateSSRController {

public String Subject{get;set;}

public String created_record_id{get;set;}

public String opportunity_id {get;set;}

public String opportunity_name {get;set;}

public String description{get;set;}

public String Service_Request_Type{get;set;}

public Date Deadline{get;set;}

public Integer CPU_Count{get;set;}

public ID support_request_id{get;set;}

public void create_SSR_in_DRD() {

// Id support_record_id = Insert_Support_Request_Record();

HttpRequest request = new HttpRequest();

request.setEndpoint('callout:DRDConnect/services/apexrest/CaseSupportRequest/');

request.setMethod('POST');

request.setHeader('Content-Type', 'application/json;charset=UTF-8');

String json_string = '{"caseobj":[ {"Support_Request":"' + support_request_id + '" , "Subject": "' + description + '", "Service_Request_Type": "' + Service_Request_Type + '", "Opportunity": "' + opportunity_id + '", "CPU_Count": '+ CPU_Count + '}]}';

request.setBody(json_string);

Http http = new Http();

HTTPResponse response = http.send(request);

System.debug(response.getBody());

created_record_id = response.getBody();

created_record_id = created_record_id.removeStart('"');

created_record_id = created_record_id.removeEnd('"');

System.debug('Record ID ' + created_record_id + ' ' );

}

public PageReference Insert_Support_Request_Record() {

Support_Request__c support_request_record = new Support_Request__c(Description__C=description,Opportunity__c=opportunity_id, Service_Request_Type__C=Service_Request_Type, CPU_Count__C=CPU_Count, DRD_Case__c=created_record_id);

insert support_request_record;

support_request_id = support_request_record.ID;

return null;

}

public CreateSSRController() {

opportunity_id = ApexPages.currentPage().getParameters().get('id');

if(opportunity_id == null) {

opportunity_id = '0066A000002ZgZ2';

}

Opportunity opty = [select Id, name, account.Name from Opportunity where Id = :opportunity_id];

opportunity_name = opty.Name;

opportunity_id = opty.Id;

}

// display picklist value in VF Page

public List<SelectOption> getService_Request_Type_Picklist_Values()

{

List<SelectOption> options = new List<SelectOption>();

Schema.DescribeFieldResult fieldResult =

Support_Request__c.Service_Request_Type__c.getDescribe();

List<Schema.PicklistEntry> ple = fieldResult.getPicklistValues();

for( Schema.PicklistEntry f : ple)

{

options.add(new SelectOption(f.getLabel(), f.getValue()));

}

return options;

}

Step #4: VF Page to create Support Request

<apex:page controller="CreateSSRController" id="createssrpage" >
    <script>
    jQuery(function() {
        jQuery("[id='{!$Component.datepicker}']").datepicker();
    });
    </script>
    <apex:form id="createssrform">
        <apex:pageBlock title="Create Sales Support Request" >
            <apex:Messages ></apex:Messages>
            <apex:pageBlockSection columns="1" >
                
                <apex:pageBlockSectionItem >
                    <apex:outputLabel value="Opportunity Name"></apex:outputLabel>
                    <apex:outputText value="{!opportunity_name}"></apex:outputText>
                 </apex:pageBlockSectionItem>
                
                <apex:pageBlockSectionItem >
                    <apex:outputLabel value="Service Request Type"></apex:outputLabel>
                    <apex:selectList id="countries" value="{!Service_Request_Type}" size="1" required="true">
                        <apex:selectOptions value="{!Service_Request_Type_Picklist_Values}"/>
                    </apex:selectList>
                </apex:pageBlockSectionItem>
                
                <apex:pageBlockSectionItem >
                    <apex:outputLabel value="CPU Count"></apex:outputLabel>
                    <apex:inputText value="{!CPU_Count}"></apex:inputText> 
                </apex:pageBlockSectionItem>
                
              <apex:pageBlockSectionItem >
                    <apex:outputLabel value="Description"></apex:outputLabel>
                    <apex:inputTextarea rows="10" cols="100" value="{!description}" id="description" label="description" />
                </apex:pageBlockSectionItem>
           </apex:pageBlockSection>
            
            <apex:outputPanel id="msg">
                <apex:pageMessages />
            </apex:outputPanel>
            
            <apex:actionFunction action="{!Insert_Support_Request_Record}" name="InsertRecord_JS" Rerender="statuses" status="Status1" oncomplete="CallWebService_JS();"/>
            <apex:actionFunction action="{!create_SSR_in_DRD}" name="CallWebService_JS" status="Status2" reRender="statuses, msg"/>
            <apex:outputPanel id="statuses">
                <apex:actionStatus id="Status1" startText="...Inserting Record Into DB..." />
                <apex:actionStatus id="Status2" startText="...Calling Web Service..." />
            </apex:outputPanel>
            
            <div><input name="DoAction" class="btn" type="button" value="Create DRD Request" onclick="InsertRecord_JS();return false;"/></div>
           <apex:outputText value="{!created_record_id}"></apex:outputText>
            
            
            
        </apex:pageBlock>
    </apex:form>
</apex:page>

<apex:page controller="CreateSSRController" id="createssrpage" >

jQuery(function() {

jQuery("[id='{!$Component.datepicker}']").datepicker();

});

</script>

<apex:form id="createssrform">

<apex:pageBlock title="Create Sales Support Request" >

<apex:Messages ></apex:Messages>

<apex:pageBlockSection columns="1" >

<apex:pageBlockSectionItem >

<apex:outputLabel value="Opportunity Name"></apex:outputLabel>

<apex:outputText value="{!opportunity_name}"></apex:outputText>

</apex:pageBlockSectionItem>

<apex:pageBlockSectionItem >

<apex:outputLabel value="Service Request Type"></apex:outputLabel>

<apex:selectList id="countries" value="{!Service_Request_Type}" size="1" required="true">

<apex:selectOptions value="{!Service_Request_Type_Picklist_Values}"/>

</apex:selectList>

</apex:pageBlockSectionItem>

<apex:pageBlockSectionItem >

<apex:outputLabel value="CPU Count"></apex:outputLabel>

<apex:inputText value="{!CPU_Count}"></apex:inputText>

</apex:pageBlockSectionItem>

<apex:pageBlockSectionItem >

<apex:outputLabel value="Description"></apex:outputLabel>

<apex:inputTextarea rows="10" cols="100" value="{!description}" id="description" label="description" />

</apex:pageBlockSectionItem>

</apex:pageBlockSection>

<apex:outputPanel id="msg">

<apex:pageMessages />

</apex:outputPanel>

<apex:actionFunction action="{!Insert_Support_Request_Record}" name="InsertRecord_JS" Rerender="statuses" status="Status1" oncomplete="CallWebService_JS();"/>

<apex:actionFunction action="{!create_SSR_in_DRD}" name="CallWebService_JS" status="Status2" reRender="statuses, msg"/>

<apex:outputPanel id="statuses">

<apex:actionStatus id="Status1" startText="...Inserting Record Into DB..." />

<apex:actionStatus id="Status2" startText="...Calling Web Service..." />

</apex:outputPanel>

<apex:outputText value="{!created_record_id}"></apex:outputText>

</apex:pageBlock>

</apex:form>

</apex:page>

Step #5 : Create Support Request button configuration on Opportunity Page

go to Setup->Opportunity->Buttons to create Button

Step : #6: Add button to Layout

Sample @future code – ready to process when resources are available

February 2, 2018February 2, 2018 konaguru Leave a comment

public class AccountProcessor {
        
 	@future
        public static void countContacts(Set setId) {
            
            List lstAccount = [select id, Number_of_Contacts__C, (select id from contacts) from account where id in :setId ];
            
            for (Account acc: lstAccount) {
                
                List lstCon = acc.contacts;
                acc.Number_of_contacts__C = lstCon.size();
                
            }
            update lstAccount;
        }
}

public class AccountProcessor {

@future

public static void countContacts(Set setId) {

List lstAccount = [select id, Number_of_Contacts__C, (select id from contacts) from account where id in :setId ];

for (Account acc: lstAccount) {

List lstCon = acc.contacts;

acc.Number_of_contacts__C = lstCon.size();

}

update lstAccount;

}

When to use?
Long-running processes or external calls
When it’s not batchable

Advantages:
Asynchronous process without concurrent limit
Easier and quicker to implement as opposed to batch

Disadvantages:
Parameters passed in can be only of primitive types
Can’t chain @future methods
Difficult to access job id

Batchable code to update Contact address with Account Address

February 2, 2018February 2, 2018 konaguru Leave a comment

Simple code to write Batchable code in Apex

/* update Contact Billing Address with Account Billing Address */

global class UpdateContactAddress implements Database.Batchable, Database.Stateful {
    
    global Integer recordsProcessed = 0;
    
    global Database.QueryLocator start(Database.BatchableContext bc ) {
        
        return Database.getQueryLocator(
            'SELECT ID, BillingStreet, BillingCity, BillingState, ' +
            'BillingPostalCode, (SELECT ID, MailingStreet, MailingCity, ' +
            'MailingState, MailingPostalCode FROM Contacts) FROM Account ' + 
            'Where BillingCountry = \'USA\''
        );
    }
    
    global void execute(Database.BatchableContext bc, List scope ) {
        
        // Process each batch of records
        List contacts = new List();
        
        for (Account account: scope) {
            
            for (Contact contact : account.contacts ) {
                
                contact.MailingStreet = account.BillingStreet;
                contact.MailingCity		= account.BillingCity;
                contact.MailingState	= account.BillingState;
                contact.MailingPostalCode	= account.BillingPostalCode;
                // add contact to the list to be updated
                contacts.add(contact);
                // increment the instance member counter
                recordsProcessed = recordsProcessed + 1;
                
            }
        }
        update contacts;   
    }
    
    global void finish(Database.BatchableContext bc) {
        
        System.debug(recordsProcessed + ' records processed. Shazam !! ');
        AsyncApexJob job = [Select ID, status, NumberOfErrors, JobItemsProcessed, TotalJobItems, CreatedBy.Email FROM AsyncApexJob
                            WHERE ID = :bc.getJobId()];
        
    }
}

/* update Contact Billing Address with Account Billing Address */

global class UpdateContactAddress implements Database.Batchable, Database.Stateful {

global Integer recordsProcessed = 0;

global Database.QueryLocator start(Database.BatchableContext bc ) {

return Database.getQueryLocator(

'SELECT ID, BillingStreet, BillingCity, BillingState, ' +

'BillingPostalCode, (SELECT ID, MailingStreet, MailingCity, ' +

'MailingState, MailingPostalCode FROM Contacts) FROM Account ' +

'Where BillingCountry = \'USA\''

);

}

global void execute(Database.BatchableContext bc, List scope ) {

// Process each batch of records

List contacts = new List();

for (Account account: scope) {

for (Contact contact : account.contacts ) {

contact.MailingStreet = account.BillingStreet;

contact.MailingCity = account.BillingCity;

contact.MailingState = account.BillingState;

contact.MailingPostalCode = account.BillingPostalCode;

// add contact to the list to be updated

contacts.add(contact);

// increment the instance member counter

recordsProcessed = recordsProcessed + 1;

}

update contacts;

}

global void finish(Database.BatchableContext bc) {

System.debug(recordsProcessed + ' records processed. Shazam !! ');

AsyncApexJob job = [Select ID, status, NumberOfErrors, JobItemsProcessed, TotalJobItems, CreatedBy.Email FROM AsyncApexJob

WHERE ID = :bc.getJobId()];

}

Advantages of Batchable Apex:

Can process millions of records using Batchable approach

Can schedule a job to run at a Particular time

Advantages of Batchable Apex:

Can process millions of records using Batchable approach

Can schedule a job to run at a Particular time

Disadvantages:

Only 5 concurrent jobs are allowed

It's difficult to troubleshoot

Execution depends on the server resources availability

@future methods are not allowed

...

Disadvantages:

Only 5 concurrent jobs are allowed

It's difficult to troubleshoot

Execution depends on the server resources availability

@future methods are not allowed

...

References: https://developer.salesforce.com/docs/atlas.en-us.apexcode.meta/apexcode/apex_interface_database_batchable.htm

A simple Webservice callout script

February 1, 2018February 1, 2018 konaguru Leave a comment



		
		
			
			

			
			public class WeatherCallout {

    public static HttpResponse makeGetCallout() { 
        Http http = new Http();
        HttpRequest request = new HttpRequest();
        request.setEndpoint('http://api.openweathermap.org/data/2.5/weather?q=Bangalore,IN&appid=0b25f3800cd38ba852567039d1d364d4');
        request.setMethod('GET');
        HttpResponse response = http.send(request);
        // if the request is successful, parse the JSON response
        if (response.getStatusCode() == 200 ) {
            System.debug('Response Code Details ' + response.getBody() );
            Map<String, Object> m =(Map<String, Object>) JSON.deserializeUntyped(response.getBody());
          	Map<String, Object> dim =    (Map<String, Object>)m.get('main');
            Decimal temp_str = (Decimal) dim.get('temp');
            Decimal  temp_f = temp_str*9/5 - 459.67;
            Decimal  temp_c = temp_str - 273.15;
                 System.debug('Celcius  ' + temp_c);
            System.debug('Fahrenheit  ' + temp_f);
            
        }
        return response;
    }   
}
			
				
					
				
					1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
				
						public class WeatherCallout {
 
    public static HttpResponse makeGetCallout() { 
        Http http = new Http();
        HttpRequest request = new HttpRequest();
        request.setEndpoint('http://api.openweathermap.org/data/2.5/weather?q=Bangalore,IN&appid=0b25f3800cd38ba852567039d1d364d4');
        request.setMethod('GET');
        HttpResponse response = http.send(request);
        // if the request is successful, parse the JSON response
        if (response.getStatusCode() == 200 ) {
            System.debug('Response Code Details ' + response.getBody() );
            Map<String, Object> m =(Map<String, Object>) JSON.deserializeUntyped(response.getBody());
          	Map<String, Object> dim =    (Map<String, Object>)m.get('main');
            Decimal temp_str = (Decimal) dim.get('temp');
            Decimal  temp_f = temp_str*9/5 - 459.67;
            Decimal  temp_c = temp_str - 273.15;
                 System.debug('Celcius  ' + temp_c);
            System.debug('Fahrenheit  ' + temp_f);
            
        }
        return response;
    }   
}

Must Reads

January 30, 2018January 30, 2018 konaguru Leave a comment

Performance and Tuning

https://developer.salesforce.com/blogs/engineering/2013/03/long-and-short-term-approaches-for-tuning-force-com-performance.html

You have uncommitted work pending. Please commit or rollback before calling out

January 30, 2018January 30, 2018 konaguru Leave a comment

So Stuck there with “You have uncommitted work pending. Please commit or rollback before calling out”

na!! na!! don’t say the problem I know that!! Tell me the solution?

Not every problem has one solution, Let’s go thru those multiple solutions. You are the boss, select the solution that fits your use case

Solution #1:

Do DML operations with REST API after a Callout

Configuring Named credentials using OAuth

June 29, 2017February 3, 2018 konaguru 1 Comment

If in any use case user wants to connect from one salesforce org to another salesforce and doesn’t want to store salesforce username/password then below configuration procedure helps.

Highlevel steps

Configure Authentication App in Salesforce ( Here Salesforce Org serves as Authentication Provider )
Configure Auth Provider in Salesforce Client Org ( From here you will be connecting to other salesforce org , for instance via web service call )
Create Named credentials

Salesforce (Client) -> Salesforce(Authorization Server)

Salesforce Configuration as Authorization Server

Click on App->Go to Connected Apps Section ->