DRDS（PolarDB-X 1.0）数据源

离线读写

• 目前DRDS（PolarDB-X 1.0）的插件仅适配MySQL引擎的场景。DRDS（PolarDB-X 1.0）是一套分布式MySQL数据库，并且大部分通信协议遵循MySQL使用场景。

• DRDS（PolarDB-X 1.0）下的MySQL8.0版本支持使用Serverless资源组（推荐）和独享数据集成资源组。

• 在底层实现上，DRDS（PolarDB-X 1.0） Writer通过JDBC连接远程DRDS（PolarDB-X 1.0）数据库的Proxy，执行相应的replace into语句，将数据写入DRDS（PolarDB-X 1.0）。

  执行的SQL语句是replace into，为避免数据重复写入，需要您的表具备主键（Primary Key）或唯一索引（Unique index）。

• DRDS（PolarDB-X 1.0） Writer通过数据同步框架获取Reader生成的协议数据，通过replace into（没有遇到主键/唯一性索引冲突时，与insert into行为一致，冲突时会用新行替换原有行所有字段）语句写入数据至DRDS（PolarDB-X 1.0）。DRDS（PolarDB-X 1.0） Writer累积一定数据，提交给DRDS（PolarDB-X 1.0）的Proxy，该Proxy内部决定数据是写入一张还是多张表，以及多张表写入时如何路由数据。

  说明

  整个任务至少需要具备replace into的权限。是否需要其他权限，取决于您配置任务时在preSql和postSql中指定的语句。

• 支持读取视图表。

单表离线同步任务配置指导

• 操作流程请参见向导模式配置、脚本模式配置。

• 脚本模式配置的全量参数和脚本Demo请参见下文的附录：脚本Demo与参数说明。

整库离线读同步配置指导

操作流程请参见配置整库离线同步任务。

离线任务脚本配置方式

如果您配置离线任务时使用脚本模式的方式进行配置，您需要按照统一的脚本格式要求，在任务脚本中编写相应的参数，详情请参见脚本模式配置，以下为您介绍脚本模式下数据源的参数配置详情。

Reader脚本Demo

{
    "type":"job",
    "version":"2.0",//版本号
    "steps":[
        {
            "stepType":"drds",//插件名
            "parameter":{
                "datasource":"",//数据源名
                "column":[//列名
                    "id",
                    "name"
                ],
                "where":"",//过滤条件
                "table":"",//表名
                "splitPk": ""//切分键
            },
            "name":"Reader",
            "category":"reader"
        },
        {
            "stepType":"stream",//插件名
            "parameter":{},
            "name":"Writer",
            "category":"writer"
        }
    ],
    "setting":{
        "errorLimit":{
            "record":"0"//错误记录数
        },
        "speed":{
            "throttle":true,//当throttle值为false时，mbps参数不生效，表示不限流；当throttle值为true时,表示限流。
            "concurrent":1,//并发数
            "mbps":"12"//限流，此处1mbps = 1MB/s。
        }
    },
    "order":{
        "hops":[
            {
                "from":"Reader",
                "to":"Writer"
            }
        ]
    }
}

Reader脚本参数

Writer脚本Demo

{
    "type":"job",
    "version":"2.0",//版本号。
    "steps":[
        {
            "stepType":"stream",
            "parameter":{},
            "name":"Reader",
            "category":"reader"
                },
        {
            "stepType":"drds",//插件名。
            "parameter":{
                "postSql":[],//执行数据同步任务之后执行的SQL语句。
                "datasource":"",//数据源。
                "column":[//列名。
                "id"
                ],
                "writeMode":"insert ignore",
                "batchSize":"1024",//一次性批量提交的记录数大小。
                "table":"test",//表名。
                "preSql":[]//执行数据同步任务之前执行的SQL语句。
                },
            "name":"Writer",
            "category":"writer"
                }
                ],
    "setting":{
        "errorLimit":{
        "record":"0"//错误记录数。
            },
        "speed":{
            "throttle":true,//当throttle值为false时，mbps参数不生效，表示不限流；当throttle值为true时,表示限流。
            "concurrent":1, //作业并发数。
            "mbps":"12"//限流，此处1mbps = 1MB/s。
                }
            },
    "order":{
        "hops":[
            {
                "from":"Reader",
                "to":"Writer"
                }
            ]
        }
    }

Writer脚本参数