Creating and Updating Objects with the Salesforce REST API Writer

#   _____           _              _____        __      
#  |  __ \         (_)            |_   _|      / _|     
#  | |__) |___  ___ _ _ __   ___    | |  _ __ | |_ ___  
#  |  _  // _ \/ __| | '_ \ / _ \   | | | '_ \|  _/ _ \ 
#  | | \ \  __/ (__| | |_) |  __/  _| |_| | | | || (_) |
#  |_|  \_\___|\___|_| .__/ \___| |_____|_| |_|_| \___/ 
#                    | |                                
#                    |_|

# Project Name -  CREATING AND UPDATING OBJECTS WITH THE SALESFORCE REST API WRITER

# Recipe ID - 
# Recipe URL - https://app.lingk.io/a/10932/tf/17439

# Description - This recipe demonstrates creating and updating data with the Salesforce REST API. The recipe will create an account, retrieve it's ID and then use the ID to update the name of the same account.
              # To run this recipe, configure a Salesforce connector in your environment and click "Run".

# Industry - Higher Ed
# Business Process - Graduate Reporting

# Systems - Salesforce
# Connectors - 
# Data Flows - Single Direction
# Connection Type - API to API

# Data Models
## Salesforce Models Used:
#1. Account

# Data Sets
# Accounts

# Add Recipe notes / Change log information here!

#    _____                            _                 
#   / ____|                          | |                
#  | |     ___  _ __  _ __   ___  ___| |_ ___  _ __ ___ 
#  | |    / _ \| '_ \| '_ \ / _ \/ __| __/ _ \| '__/ __|
#  | |___| (_) | | | | | | |  __/ (__| || (_) | |  \__ \
#   \_____\___/|_| |_|_| |_|\___|\___|\__\___/|_|  |___/
#

# CONNECTORS specify what data will be pulled into the in-memory database during processing

connectors:

# Configure Salesforce credentials in your Environment before running this recipe
  # Salesforce Setup - https://help.lingk.io/en/articles/267-salesforce-connector-setup-guide

###### Start - Salesforce Reader connectors ######

# Retrieve the ID of the new Account
-
    name: accountReader
    type: salesforceReader
    properties:
      query: SELECT Id, Name FROM Account
      useBearerToken: true

###### End - Salesforce Reader connectors ######

###### Start - Salesforce API writer connectors ######

# Write an Account
-
    name: sfAccountWriterA
    type: salesforceRestAPIWriter
    properties:
      path: /services/data/v20.0/sobjects/Account
      useBearerToken: true
      sfObject: Account
      isSObjectTree: false

# Update the Account
-
    name: sfAccountWriterUpdate
    type: salesforceRestAPIWriter
    properties:
      path: /services/data/v20.0/sobjects/Account/{{executionContext.accountId.Id}}
      sfObject: Account
      useBearerToken: true
      isSObjectTree: false

# optionally use composite tree updates
-
    name: sfAccountWriterB
    type: salesforceRestAPIWriter
    properties:
      path: /services/data/v34.0/composite/tree/Account
      useBearerToken: true
      sfObject: Account
      isSObjectTree: true

###### End - Salesforce API writer connectors ######

#    _____ _        _                            _       
#   / ____| |      | |                          | |      
#  | (___ | |_ __ _| |_ ___ _ __ ___   ___ _ __ | |_ ___ 
#   \___ \| __/ _` | __/ _ \ '_ ` _ \ / _ \ '_ \| __/ __|
#   ____) | || (_| | ||  __/ | | | | |  __/ | | | |_\__ \
#  |_____/ \__\__,_|\__\___|_| |_| |_|\___|_| |_|\__|___/

# STATEMENTS specify how the data should be processed while in memory

statements:

#******************************************************************** D I S C L A I M E R ***********************************************************************************************
#                                                                                                                                                                                       * 
# Note that in an effort to keep recipes optimized for DPH (Data Processing Hours), print statements should be commented out after development has concluded for a recipe.              *
# For more information on DPH optimization, please visit the following help article - https://help.lingk.io/en/articles/212-minimizing-data-processing-hours-on-the-lingk-platform      *
#                                                                                                                                                                                       * 
#******************************************************************** D I S C L A I M E R ***********************************************************************************************

# GET the Id and Name from the account reader
  - statement: (accountReaderData) Select * From accountReader WHERE Name = 'InsertedNameForSalesforceRestAPI_Before'

#### Start - Insert Contacts to Exectution Context ####

# GET just the ID of the new account
  - statement: (accountId) => SELECT Id FROM accountReaderData
# - statement: PRINT accountId
  # Insert the account Id into executioncontext so that the value can be retrieved by itself
  - statement: INSERT accountId INTO executionContext

#### End - Insert Contacts to Exectution Context ####

#### Start - Update Contacts in SF ####

# create the update payload
  - statement: (payload) => SELECT "InsertedNameForSalesforceRestAPI_After" Name FROM accountReader
  - statement: UPDATE payload into sfAccountWriterUpdate

# statement: print payload

#### End - Update Contacts in SF ####

# Add more statements to convert, join, aggregrate, transform, and integrate your data