Sharding-proxy 跨库(不同实例) 关联查询时发生 "表不存在" 的错误

Apache ShardingSphere 提问
#1

使用环境：

  • os: rocky linux 8.5
  • jdk: openJDK 1.8
  • mysql: 5.7.30
  • SQL 工具：dbeaver 21.3.2

场景、问题：

当前有两个 MySQL 实例，各有一个数据库，具体结构如下：

10.8.2.72
    shardingdb_v20220307
        child_table
10.8.2.73
    shardingdb_v20220206
        main_table

当前期望能执行关联查询：

select * from main_table m join child_table c on m.original_id = c.original_id;

但在查询时发生错误：

  • SQL 工具反馈

    Table 'shardingdb_v20220206.child_table' doesn't exist

  • sharding-proxy 日志

    [ERROR] 2022-03-10 14:32:16.397 [ShardingSphere-Command-0] o.a.s.p.f.c.CommandExecutorTask - Exception occur: com.mysql.jdbc.exceptions.jdbc4.MySQLSyntaxErrorException: Table 'shardingdb_v20220206.child_table' doesn't exist

已进行操作：

  1. 已配置 server.yaml，并设置 sql-federation-enabled: true，详细内容如下：
rules:
  - !AUTHORITY
    users:
      - root@%:123456
    provider:
      type: ALL_PRIVILEGES_PERMITTED

props:
  check-duplicate-table-enabled: false
  check-table-metadata-enabled: false
  kernel-executor-size: 4
  max-connections-size-per-query: 1
  proxy-backend-driver-type: JDBC
  proxy-backend-executor-suitable: OLAP
  proxy-backend-query-fetch-size: -1
  proxy-frontend-executor-size: 0
  proxy-frontend-flush-threshold: 128
  proxy-frontend-max-connections: 0
  proxy-hint-enabled: false
  proxy-opentracing-enabled: false
  show-process-list-enabled: false
  sql-federation-enabled: true
  sql-show: true
  1. 已配置分片文件 config-sharding.yaml，具体内容如下：
schemaName: shardingdb

dataSources:
  shardingdb_v20220206:
    url: jdbc:mysql://10.8.2.73:3306/shardingdb_v20220206?useUnicode=true&characterEncoding=utf8&serverTimezone=Asia/Shanghai&useSSL=false
    username: sharding_user
    password: 123456
    connectionTimeoutMilliseconds: 30000
    idleTimeoutMilliseconds: 60000
    maxLifetimeMilliseconds: 1800000
    maxPoolSize: 50
    minPoolSize: 1
  shardingdb_v20220307:
    url: jdbc:mysql://10.8.2.72:3306/shardingdb_v20220307?useUnicode=true&characterEncoding=utf8&serverTimezone=Asia/Shanghai&useSSL=false
    username: sharding_user
    password: 123456
    connectionTimeoutMilliseconds: 30000
    idleTimeoutMilliseconds: 60000
    maxLifetimeMilliseconds: 1800000
    maxPoolSize: 50
    minPoolSize: 1

rules:
  - !SHARDING
    tables:
      main_table:
        actualDataNodes: shardingdb_v20220206.main_table
      child_table:
        actualDataNodes: shardingdb_v20220307.child_table

    bindingTables:
      - main_table,child_table

现状：

无法完成查询，并报表不存在错误。

#2

@华奇英 用的ShardingSphere 什么版本？

#3

sharding-proxy 5.1.0

#4

好的，我来试一下

#5

@tuichenchuxin 我把建表脚本发在这

CREATE TABLE `main_table` (
  `project_name_cn` varchar(150) DEFAULT NULL,
  `contract_no` varchar(50) DEFAULT NULL,
  `original_id` varchar(100) NOT null,
  PRIMARY KEY (`original_id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

CREATE TABLE `child_table` (
  `id_number` varchar(100) not NULL,
  `full_name` varchar(100) DEFAULT NULL,
  `original_id` varchar(100) NOT null,
  PRIMARY KEY (`id_number`,`original_id`)
 ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;
#6

好的 :+1: :100:

#7

@华奇英 可以将 config-sharding.yaml 中的 rules 规则去掉。看起来这两张表都是单表。ShardingSphere 中的 singleTableRule 可以直接处理。

#8

@tuichenchuxin 是将 rules: 节点全移除吗？

#9

@华奇英 嗯，是的

#10

@tuichenchuxin 非常感谢，单表方式下的跨库查询已实现，后序我将试试分表方式。

#11

好的，有问题欢迎反馈

京ICP备2021015875号