1.22实验功能

    JDBC源

    1. /*+ mycat:MIGRATE{
    2.     "input":{
    3.         "count":64,
    4.         "password":"123456",
    5.         "properties":{},
    6.         "sql":"select * from db1.input",
    7.         "url":"jdbc:mysql://localhost:8066/mysql?username=root&password=123456&useUnicode=true&characterEncoding=utf8&useSSL=false&serverTimezone=Asia/Shanghai&allowPublicKeyRetrieval=true",
    8.         "username":"root"
    9.     },
    10.     "name":"testNormalToNormal",
    11.     "output":{
    12.         "batch":1000,
    13.         "parallelism":1,
    14.         "properties":{},
    15.         "schemaName":"db1",
    16.         "tableName":"output"
    17.     }
    18. } */;

    count:数据源读取的行数
    username:连接数据源账户的名字
    password:连接数据源账户的密码
    name:是迁移任务名字,起区分作用
    sql:读取结果集的sql
    url:JDBC连接字符串
    batch:批量插入的批量
    parallelism:用于查询,插入的线程数,这里不生效
    schemaName:逻辑库名
    tableName:逻辑表名

    输出目标是单表

    1. /*+ mycat:MIGRATE{
    2.     "input":{
    3.         "count":1000,
    4.         "properties":{},
    5.         "schemaName":"db1",//输入的逻辑库名
    6.         "tableName":"input"//输入的逻辑表名
    7.     },
    8.     "name":"testNormalToNormal",
    9.     "output":{
    10.         "batch":1000,
    11.         "parallelism":1,
    12.         "properties":{},
    13.         "schemaName":"db1",//输出到逻辑库名
    14.         "tableName":"output"//输出到逻辑库名
    15.     }
    16. } */;

    count是表的数据行数,mycat计数输出行数到达此数值就会停止.

    输出目标是全局表

    1. /*+ mycat:MIGRATE{
    2.     "input":{
    3.         "count":1000,
    4.         "properties":{},
    5.         "schemaName":"db1",
    6.         "tableName":"input"
    7.     },
    8.     "name":"testNormalToGlobal",
    9.     "output":{
    10.         "batch":16,
    11.         "parallelism":4,//并行插入
    12.         "properties":{},
    13.         "schemaName":"db1",
    14.         "tableName":"output"
    15.     }
    16. } */;

    输出目标是分片表

    1. /*+ mycat:MIGRATE{
    2.     "input":{
    3.         "count":1000,
    4.         "properties":{},
    5.         "schemaName":"db1",
    6.         "tableName":"input"
    7.     },
    8.     "name":"testShardingToSharding",
    9.     "output":{
    10.         "batch":16,
    11.         "parallelism":2,
    12.         "properties":{},
    13.         "schemaName":"db1",
    14.         "tableName":"output"
    15.     }
    16. } */;

    查看任务进度

    1. /*+ mycat:MIGRATE_LIST{} */;

    停止迁移

    1. /*+ mycat:MIGRATE_STOP{
    2.     "id":"0dcfd5c4-450e-4379-b975-de802aee15a1"
    3. } */;