單庫單表的腳本示例如下，詳情請參見上述參數說明。

{
    "type": "job",
    "steps": [
        {
            "parameter": {
                "datasource": "test_005",//數據源名。
                "column": [//源端列名。
                    "id",
                    "name",
                    "age",
                    "sex",
                    "salary",
                    "interest"
                ],
                "where": "id=1001",//過濾條件。
                "splitPk": "id",//切分鍵。
                "table": "PolarDB_person",//源端表名。
              	"useReadonly": "false"http://是否從備庫讀取數據。
            },
            "name": "Reader",
            "category": "reader"
        },
        {
            "parameter": {}
    ],
    "version": "2.0",//版本號。
    "order": {
        "hops": [
            {
                "from": "Reader",
                "to": "Writer"
            }
        ]
    },
    "setting": {
        "errorLimit": {//錯誤記錄數。
            "record": ""
        },
        "speed": {
            "concurrent": 6,//并發數。
            "throttle": true//當throttle值為false時，mbps參數不生效，表示不限流；當throttle值為true時,表示限流。
      "mbps":"12",//限流，此處1mbps = 1MB/s。
        }
    }
}

腳本配置樣例如下，詳情請參見上述參數說明。

{
    "type": "job",
    "steps": [
        {
            "parameter": {},
            "name": "Reader",
            "category": "reader"
        },
        {
            "parameter": {
                "postSql": [],//導入后完成語句。
                "datasource": "test_005",//數據源名稱。
                "column": [//目標列名。
                    "id",
                    "name",
                    "age",
                    "sex",
                    "salary",
                    "interest"
                ],
                "writeMode": "insert",//寫入模式。
                "batchSize": 256,//一次性批量提交的記錄數大小。
                "table": "PolarDB_person_copy",//目標表名。
                "preSql": []//導入前準備語句。
            },
            "name": "Writer",
            "category": "writer"
        }
    ],
    "version": "2.0",//版本號。
    "order": {
        "hops": [
            {
                "from": "Reader",
                "to": "Writer"
            }
        ]
    },
    "setting": {
        "errorLimit": {//錯誤記錄數。
            "record": ""
        },
        "speed": {
            "throttle":true,//當throttle值為false時，mbps參數不生效，表示不限流；當throttle值為true時,表示限流。
            "concurrent":6, //作業并發數。
            "mbps":"12"http://限流，此處1mbps = 1MB/s。
        }
    }
}

• 全量參數說明

  參數	描述	必選	默認值
  datasource	數據源名稱，腳本模式支持添加數據源，此配置項填寫的內容必須要與添加的數據源名稱保持一致。	是	無
  table	選取的需要同步的表名稱。	是	無
  writeMode	選擇導入模式，可以支持： insert（即向導模式的insert into） update（即向導模式的on duplicate key update） replace（即向導模式的replace into） 不同方式的詳細介紹與場景示例請參見下文的writeMode（主鍵沖突）參數詳解。	否	insert
  column	目標表需要寫入數據的字段，字段之間用英文所逗號分隔。例如"column": ["id", "name", "age"]。如果要依次寫入全部列，使用（*）表示。 例如"column": [" *"]。	是	無
  preSql	執行數據同步任務之前率先執行的SQL語句。目前向導模式僅允許執行一條SQL語句，腳本模式可以支持多條SQL語句，例如清除舊數據。	否	無
  postSql	執行數據同步任務之后執行的SQL語句，目前向導模式僅允許執行一條SQL語句，腳本模式可以支持多條SQL語句，例如加上某一個時間戳。	否	無
  batchSize	一次性批量提交的記錄數大小，該值可以極大減少數據同步系統與PolarDB的網絡交互次數，并提升整體吞吐量。但是該值設置過大可能會造成數據同步運行進程OOM情況。	否	1,024
  updateColumn	當writeMode配置成update時，發生遇到主鍵/唯一性索引沖突時所更新的字段。字段之間用英文逗號所分隔，例如"updateColumn": ["name", "age"]。 說明 目前僅支持PolarDB for MySQL。	否	無

• writeMode（主鍵沖突）參數詳解

  對比介紹	insert（即向導模式的insert into）	update（即向導模式的on duplicate key update）	replace（即向導模式的replace into）
  處理策略	當主鍵或唯一性索引沖突時，沖突行不寫入目標表，以臟數據的形式體現。	沒有遇到主鍵或唯一性索引沖突時，與insert into行為一致。沖突時會用新行替換已經指定的字段的語句，寫入數據至目標表。	沒有遇到主鍵或唯一性索引沖突時，與insert into行為一致。沖突時會先刪除原有行，再插入新行。即新行會替換原有行的所有字段。
  數據示例	源表數據 +----+---------+-----+ | id | name | age | +----+---------+-----+ | 1 | zhangsan| 1 | | 2 | lisi | | +----+---------+-----+ 目標表原始數據 +----+---------+-----+ | id | name | age | +----+---------+-----+ | 2 | wangwu | | +----+---------+-----+ 運行任務后，成功寫入目標表1條數據，臟數據1條。 +----+---------+-----+ | id | name | age | +----+---------+-----+ | 1 | zhangsan| 1 | | 2 | wangwu | | +----+---------+-----+	場景1：任務配置部分字段："column": ["id","name"] 源表數據 +----+---------+-----+ | id | name | age | +----+---------+-----+ | 1 | zhangsan| 1 | | 2 | lisi | | +----+---------+-----+ 目標表原始數據 +----+---------+-----+ | id | name | age | +----+---------+-----+ | 2 | wangwu | 3 | +----+---------+-----+ 運行任務后，成功寫入目標表2條數據，臟數據0條。 +----+---------+-----+ | id | name | age | +----+---------+-----+ | 1 | zhangsan| 1 | | 2 | lisi | 3 | +----+---------+-----+ 場景2：任務配置所有字段，"column": ["id","name","age"] 源表數據 +----+---------+-----+ | id | name | age | +----+---------+-----+ | 1 | zhangsan| 1 | | 2 | lisi | | +----+---------+-----+ 目標表原始數據 +----+---------+-----+ | id | name | age | +----+---------+-----+ | 2 | wangwu | 3 | +----+---------+-----+ 運行任務后，成功寫入目標表2條數據，臟數據0條。 +----+---------+-----+ | id | name | age | +----+---------+-----+ | 1 | zhangsan| 1 | | 2 | lisi | | +----+---------+-----+	源表數據 +----+---------+-----+ | id | name | age | +----+---------+-----+ | 1 | zhangsan| 1 | | 2 | lisi | | +----+---------+-----+ 目標表原始數據 +----+---------+-----+ | id | name | age | +----+---------+-----+ | 2 | wangwu | 3 | +----+---------+-----+ 運行任務后，成功寫入目標表2條數據，臟數據0條。 +----+---------+-----+ | id | name | age | +----+---------+-----+ | 1 | zhangsan| 1 | | 2 | lisi | | +----+---------+-----+