diff --git a/src/external-services/salesforce/salesforce.service.ts b/src/external-services/salesforce/salesforce.service.ts
index 500ae1b2..ec20faee 100644
--- a/src/external-services/salesforce/salesforce.service.ts
+++ b/src/external-services/salesforce/salesforce.service.ts
@@ -50,6 +50,7 @@ import {
 } from './salesforce.types';
 
 import {
+  escapeQuery,
   executeBulkAction,
   formatBusinessLines,
   formatCompanyName,
@@ -459,7 +460,7 @@ export class SalesforceService {
       await this.salesforce.query(
         `SELECT Id
          FROM ${ObjectNames.CONTACT}
-         WHERE Email = '${email}' ${
+         WHERE Email = '${escapeQuery(email)}' ${
           recordType ? `AND RecordTypeId = '${recordType}'` : ''
         } LIMIT 1`
       );
@@ -472,7 +473,7 @@ export class SalesforceService {
       await this.salesforce.query(
         `SELECT Id
          FROM ${ObjectNames.LEAD}
-         WHERE Email = '${email}'
+         WHERE Email = '${escapeQuery(email)}'
            AND RecordTypeId = '${recordType}' LIMIT 1
         `
       );
@@ -501,7 +502,7 @@ export class SalesforceService {
         `SELECT Id
          FROM ${ObjectNames.CAMPAIGN_MEMBER}
          WHERE ${leadId ? `LeadId = '${leadId}'` : `ContactId = '${contactId}'`}
-           AND CampaignId = '${infoCoId}' Limit 1`
+           AND CampaignId = '${escapeQuery(infoCoId)}' Limit 1`
       );
     return records[0]?.Id;
   }
diff --git a/src/external-services/salesforce/salesforce.utils.ts b/src/external-services/salesforce/salesforce.utils.ts
index 83c19ea9..d11f4771 100644
--- a/src/external-services/salesforce/salesforce.utils.ts
+++ b/src/external-services/salesforce/salesforce.utils.ts
@@ -352,7 +352,6 @@ export function mapSalesforceLeadFields<T extends LeadRecordType>(
   leadProps: LeadProp<T>,
   recordType: AnyCantFix
 ): SalesforceLeads[T] {
-
   const { firstName, lastName, email, phone, zone } = leadProps;
 
   const commonFields = {
@@ -593,3 +592,7 @@ export function executeBulkAction<T extends ObjectName>(
     });
   });
 }
+
+export function escapeQuery(query: string) {
+  return query.replace(/'/g, "\\'");
+}