DataWorks：TiDB資料來源

準備工作1：確認TiDB版本

Data Integration對TiDB版本有7.x或8.x的版本要求，需要您確認前待同步的TiDB是否符合版本要求。您可以在TiDB資料庫通過如下語句查看當前TiDB資料庫版本。

SELECT TIDB_VERSION()\G

*************************** 1. row ***************************
TIDB_VERSION(): Release Version: v8.1.1
Edition: Community
Git Commit Hash: 821e491a20fbab36604b36b647b5bae26a2c1418
Git Branch: HEAD
UTC Build Time: 2024-08-27 19:16:25
GoVersion: go1.21.10
Race Enabled: false
Check Table Before Drop: false
Store: tikv
1 row in set (0.00 sec)

準備工作2：配置帳號許可權

可提前規劃並建立一個專用於DataWorks訪問資料來源的TiDB帳號，操作如下：

1. （可選）建立帳號，操作詳情請參見：TiDB 使用者賬戶管理。

2. 配置許可權。

   在離線讀TiDB資料時，此帳號需擁有同步表的讀（SELECT）許可權。

   可以參考以下命令為帳號添加許可權，或直接給帳號賦予SUPER許可權。如下執行語句在實際使用時，請替換'同步帳號'為上述建立的帳號。

   -- CREATE USER '同步帳號'@'%' IDENTIFIED BY '密碼'; //建立同步帳號並設定密碼，使其可以通過任意主機登入資料庫。%表示任意主機。
   GRANT SELECT ON *.* TO '同步帳號'@'%'; //授權同步帳號資料庫的 SELECT許可權。

   *.*表示授權同步帳號對所有資料庫的所有表擁有上述許可權。您也可以指定授權同步帳號對目標資料庫的指定表擁有上述許可權。例如，授權同步帳號對test資料庫的user表擁有上述許可權，則可以使用GRANT SELECT ON test.user TO '同步帳號'@'%';語句。

   說明

   REPLICATION SLAVE語句為全域許可權，不能指定授權同步帳號對目標資料庫的指定表擁有相關許可權。

離線任務指令碼配置方式

如果您配置離線任務時使用指令碼模式的方式進行配置，您需要按照統一的指令碼格式要求，在任務指令碼中編寫相應的參數，詳情請參見通過指令碼模式配置離線同步任務，以下為您介紹指令碼模式下資料來源的參數配置詳情。

Reader指令碼Demo

本文為您提供單庫單表和分庫分表的配置樣本：

{
  "type": "job",
  "version": "2.0",
  "steps":
  [
    {
      "stepType": "tidb",
      "parameter":
      {
        "column":
        [
          "id",
          "name"
        ],
        "where": "",
        "splitPk": "id",
        "connection":
        [
          {
            "selectedDatabase": "test_database",
            "datasource": "test_datasource",
            "table":
            [
              "test_table"
            ]
          }
        ]
      },
      "name": "Reader",
      "category": "reader"
    },
    {
      "stepType": "odps",
      "parameter":
      {
      },
      "name": "Writer",
      "category": "writer"
    }
  ],
  "setting":
  {
    "errorLimit":
    {
      "record": "0"
    },
    "speed":
    {
      "throttle": false,
      "concurrent": 3
    }
  },
  "order":
  {
    "hops":
    [
      {
        "from": "Reader",
        "to": "Writer"
      }
    ]
  }
}

Reader指令碼參數