MySQL

MySQL relational database — query, insert, update, and delete data.

Overview

Property	Value
Type	database
Authentication	basic
Category	Generic

Configuration

Field	Type	Required	Description
host	string	Yes	Database server hostname
port	number	No	Port (default: 3306)
database	string	Yes	Database name
username	string	Yes	Username
password	string	Yes	Password
ssl	boolean	No	Enable SSL
connection_string	string	No	Full connection string (overrides individual fields)

Available actions

Query Rows

Execute a SELECT query with optional WHERE filters.

Endpoint	GET {table}
Method	GET

Insert Row

Insert a new row into a table.

Endpoint	POST {table}
Method	POST

Update Rows

Update rows matching WHERE conditions.

Endpoint	PUT {table}
Method	PUT

Delete Rows

Delete rows matching WHERE conditions.

Endpoint	DELETE {table}
Method	DELETE

Raw Query

Execute a parameterized SQL query directly (use ? for params).

Endpoint	POST raw
Method	POST

Example flow

flows/mysql-pending-orders-to-shopify.yaml

flow: mysql-pending-orders-to-shopify
version: 1
description: Query MySQL for pending orders on a schedule and push them to Shopify

source:
  connector: scheduler
  trigger: schedule
  cron: "*/15 * * * *"

steps:
  - name: fetch-pending-orders
    target: mysql-legacy
    action: query
    mapping:
      table: orders
      where:
        status: "pending"
        synced_to_shopify: false
      limit: 50
    store_as: pending_orders

  - name: create-shopify-orders
    target: shopify-prod
    action: create-order
    for_each: pending_orders
    mapping:
      email: item.customer_email
      line_items:
        - variant_id: item.shopify_variant_id
          quantity: item.quantity
          price: item.unit_price | decimal(2)
      shipping_address:
        address1: item.shipping_address
        city: item.shipping_city
        zip: item.shipping_zip
        country_code: item.shipping_country
    store_as: shopify_results

  - name: mark-synced
    target: mysql-legacy
    action: update
    for_each: pending_orders
    mapping:
      table: orders
      where:
        id: item.id
      set:
        synced_to_shopify: true
        synced_at: "" | now

on_error:
  retry: 3x exponential(30s)
  then: dead-letter