The workflow JSON
Copy or download the full n8n JSON below. Paste it into a new n8n workflow, add your credentials, activate. Full import guide →
{
"id": 65,
"name": "Two Way Sync Pipedrive and MySQL",
"tags": [],
"nodes": [
{
"id": "7355c5ac-a9a6-4fa5-8036-71fd09e95cd4",
"name": "Compare Datasets",
"type": "n8n-nodes-base.compareDatasets",
"position": [
1220,
480
],
"parameters": {
"options": {},
"resolve": "includeBoth",
"mergeByFields": {
"values": [
{
"field1": "email",
"field2": "email"
}
]
}
},
"typeVersion": 1
},
{
"id": "7a422493-94d4-4f94-b39c-f6c3980a967c",
"name": "Schedule Trigger",
"type": "n8n-nodes-base.scheduleTrigger",
"position": [
800,
320
],
"parameters": {
"rule": {
"interval": [
{}
]
}
},
"typeVersion": 1
},
{
"id": "b3a0e831-7030-43dd-863a-0c2a4697a14d",
"name": "MySQL",
"type": "n8n-nodes-base.mySql",
"position": [
1000,
320
],
"parameters": {
"query": "SELECT id, name, email, phone, updated_on FROM contact",
"operation": "executeQuery"
},
"credentials": {
"mySql": {
"name": "<your credential>"
}
},
"typeVersion": 1,
"alwaysOutputData": true
},
{
"id": "a3a64bb5-8a6f-4011-bc2d-3996a823012c",
"name": "Pipedrive",
"type": "n8n-nodes-base.pipedrive",
"position": [
800,
620
],
"parameters": {
"resource": "person",
"operation": "getAll",
"additionalFields": {}
},
"credentials": {
"pipedriveApi": {
"name": "<your credential>"
}
},
"typeVersion": 1
},
{
"id": "089e91df-abf7-4de9-b088-357cffce6949",
"name": "Create Person",
"type": "n8n-nodes-base.pipedrive",
"position": [
1420,
300
],
"parameters": {
"name": "={{ $json[\"name\"] }}",
"resource": "person",
"additionalFields": {
"email": [
"={{ $json[\"email\"] }}"
],
"phone": [
"={{ $json[\"phone\"] }}"
]
}
},
"credentials": {
"pipedriveApi": {
"name": "<your credential>"
}
},
"typeVersion": 1
},
{
"id": "a99c3242-8263-4a92-a1f2-dcce7a9a6d81",
"name": "Create Contact",
"type": "n8n-nodes-base.mySql",
"position": [
1420,
620
],
"parameters": {
"table": {
"__rl": true,
"mode": "list",
"value": "contact",
"cachedResultName": "contact"
},
"columns": "name, email, phone",
"options": {}
},
"credentials": {
"mySql": {
"name": "<your credential>"
}
},
"typeVersion": 1
},
{
"id": "7697d03a-7bc4-40b3-9e06-e38c13ccaaf3",
"name": "Date & Time",
"type": "n8n-nodes-base.dateTime",
"position": [
1760,
460
],
"parameters": {
"value": "={{ $json[\"different\"][\"updated_on\"][\"input1\"] }}",
"custom": true,
"options": {},
"toFormat": "YYYY-MM-DD HH:mm:ss",
"dataPropertyName": "different.updated_on.input1"
},
"typeVersion": 1
},
{
"id": "f882a2e7-a8cf-4683-abe3-77a5b7376bb2",
"name": "Update Contact",
"type": "n8n-nodes-base.mySql",
"position": [
2340,
620
],
"parameters": {
"query": "=UPDATE contact\nSET name = '{{$json[\"name\"]}}', phone= '{{$json[\"phone\"]}}'\nWHERE id = {{$json[\"id\"]}};",
"operation": "executeQuery"
},
"credentials": {
"mySql": {
"name": "<your credential>"
}
},
"typeVersion": 1
},
{
"id": "d7549678-5d35-4a8a-b440-5c347b4434f4",
"name": "Set Input2",
"type": "n8n-nodes-base.set",
"position": [
2120,
620
],
"parameters": {
"values": {
"string": [
{
"name": "id",
"value": "={{ $json[\"different\"][\"id\"] ? $json[\"different\"][\"id\"][\"input1\"] : $json[\"same\"][\"id\"] }}"
},
{
"name": "name",
"value": "={{ $json[\"different\"][\"name\"] ? $json[\"different\"][\"name\"][\"input2\"] : $json[\"same\"][\"name\"] }}"
},
{
"name": "phone",
"value": "={{ $json[\"different\"][\"phone\"] ? $json[\"different\"][\"phone\"][\"input2\"] : $json[\"same\"][\"phone\"] }}"
}
]
},
"options": {}
},
"typeVersion": 1
},
{
"id": "0018751e-c295-4f8d-b9df-257b9538eedc",
"name": "Set Input1",
"type": "n8n-nodes-base.set",
"position": [
2120,
300
],
"parameters": {
"values": {
"string": [
{
"name": "id",
"value": "={{ $json[\"different\"][\"id\"] ? $json[\"different\"][\"id\"][\"input2\"] : $json[\"same\"][\"id\"] }}"
},
{
"name": "name",
"value": "={{ $json[\"different\"][\"name\"] ? $json[\"different\"][\"name\"][\"input1\"] : $json[\"same\"][\"name\"] }}"
},
{
"name": "phone",
"value": "={{ $json[\"different\"][\"phone\"] ? $json[\"different\"][\"phone\"][\"input1\"] : $json[\"same\"][\"phone\"] }}"
}
]
},
"options": {}
},
"typeVersion": 1
},
{
"id": "89af3385-4788-4693-ad02-917b927e7384",
"name": "Update Person",
"type": "n8n-nodes-base.pipedrive",
"position": [
2340,
300
],
"parameters": {
"personId": "={{ $json[\"id\"] }}",
"resource": "person",
"operation": "update",
"updateFields": {
"name": "={{ $json[\"name\"] }}",
"phone": [
"={{ $json[\"phone\"] }}"
]
}
},
"credentials": {
"pipedriveApi": {
"name": "<your credential>"
}
},
"typeVersion": 1
},
{
"id": "8ffbbb4b-7c2f-457e-ae73-464620aa1588",
"name": "IF Data Changed",
"type": "n8n-nodes-base.if",
"position": [
1560,
480
],
"parameters": {
"conditions": {
"boolean": [
{
"value1": "={{ !!$json[\"different\"][\"name\"] || !!$json[\"different\"][\"phone\"] }}",
"value2": true
}
]
}
},
"typeVersion": 1
},
{
"id": "f8d60404-942d-4bb3-96e7-a247a9447a32",
"name": "IF Updated On",
"type": "n8n-nodes-base.if",
"position": [
1940,
460
],
"parameters": {
"conditions": {
"dateTime": [
{
"value1": "={{ $json[\"different\"][\"updated\"][\"input1\"] }} {{ $json[\"different\"][\"updated_on\"][\"input1\"] }}",
"value2": "={{ $json[\"different\"][\"updated\"][\"input2\"] }} {{ $json[\"different\"][\"updated_on\"][\"input2\"] }}"
}
]
}
},
"typeVersion": 1
},
{
"id": "6965e281-10bd-4e8a-b016-f788030a6d9f",
"name": "Set",
"type": "n8n-nodes-base.set",
"position": [
1000,
620
],
"parameters": {
"values": {
"string": [
{
"name": "id",
"value": "={{ $json[\"id\"] }}"
},
{
"name": "name",
"value": "={{ $json[\"name\"] }}"
},
{
"name": "email",
"value": "={{ $json[\"primary_email\"] }}"
},
{
"name": "phone",
"value": "={{ $json[\"phone\"][0][\"value\"] }}"
},
{
"name": "updated_on",
"value": "={{ $json[\"update_time\"] }}"
}
]
},
"options": {},
"keepOnlySet": true
},
"typeVersion": 1
}
],
"active": false,
"settings": {},
"connections": {
"Set": {
"main": [
[
{
"node": "Compare Datasets",
"type": "main",
"index": 1
}
]
]
},
"MySQL": {
"main": [
[
{
"node": "Compare Datasets",
"type": "main",
"index": 0
}
]
]
},
"Pipedrive": {
"main": [
[
{
"node": "Set",
"type": "main",
"index": 0
}
]
]
},
"Set Input1": {
"main": [
[
{
"node": "Update Person",
"type": "main",
"index": 0
}
]
]
},
"Set Input2": {
"main": [
[
{
"node": "Update Contact",
"type": "main",
"index": 0
}
]
]
},
"Date & Time": {
"main": [
[
{
"node": "IF Updated On",
"type": "main",
"index": 0
}
]
]
},
"IF Updated On": {
"main": [
[
{
"node": "Set Input1",
"type": "main",
"index": 0
}
],
[
{
"node": "Set Input2",
"type": "main",
"index": 0
}
]
]
},
"IF Data Changed": {
"main": [
[
{
"node": "Date & Time",
"type": "main",
"index": 0
}
]
]
},
"Compare Datasets": {
"main": [
[
{
"node": "Create Person",
"type": "main",
"index": 0
}
],
[],
[
{
"node": "IF Data Changed",
"type": "main",
"index": 0
}
],
[
{
"node": "Create Contact",
"type": "main",
"index": 0
}
]
]
},
"Schedule Trigger": {
"main": [
[
{
"node": "MySQL",
"type": "main",
"index": 0
}
]
]
}
}
}
Credentials you'll need
Each integration node will prompt for credentials when you import. We strip credential IDs before publishing — you'll add your own.
mySqlpipedriveApi
For the full experience including quality scoring and batch install features for each workflow upgrade to Pro
How this works
This workflow ensures seamless two-way synchronisation between Pipedrive and MySQL, keeping your CRM contacts and database records perfectly aligned without manual intervention. It's ideal for sales teams or businesses relying on Pipedrive for customer management and MySQL for backend data storage, saving hours of tedious data entry and reducing errors from outdated information. The key step involves the Compare Datasets node, which identifies discrepancies before triggering updates or creations in both Pipedrive and MySQL via their respective integrations.
Use this workflow when you need reliable, automated syncing for contact details across systems on a regular schedule, such as daily or hourly, to maintain data consistency in growing operations. Avoid it for one-off data migrations or if your datasets are too large, as it may require optimisation for performance. Common variations include syncing only specific fields like emails or phone numbers, or extending to organisations instead of persons.
About this workflow
Two Way Sync Pipedrive and MySQL. Uses compareDatasets, scheduleTrigger, mySql, pipedrive. Scheduled trigger; 14 nodes.
Source: https://github.com/Zie619/n8n-workflows — original creator credit. Request a take-down →
Related workflows
Workflows that share integrations, category, or trigger type with this one. All free to copy and import.
This workflow is designed for B2B/SaaS teams who want to secure renewals before it’s too late.
Sync Local Falcon rankings to Pipedrive deals. Uses @local-falcon/n8n-nodes-localfalcon, pipedrive. Scheduled trigger; 11 nodes.
Bring your Eventbrite attendee data into Pipedrive automatically—no spreadsheets, CSVs, or manual uploads. Polls Eventbrite on a schedule (default 30 min) for new registrations. Creates or updates mat
This workflow synchronizes data both ways between Pipedrive and HubSpot. Cron node schedules the workflow to run every minute. Pipedrive and Hubspot nodes pull in both lists of persons from Pipedrive
This workflow synchronizes data one-way from Pipedrive to HubSpot. Cron node schedules the workflow to run every minute. Pipedrive and Hubspot1 nodes pull in both lists of persons from Pipedrive and c