irpas技术客

《童虎学习笔记》15分钟ShardingSphere搭建PostgreSQL分库分表_童虎学习笔记_pg数据库分库分表

大大的周 758

本文章配套视频https://·/7077056019024904717?id=7082741456641163790本专栏全部文章https://blog.csdn.net/tonghu_note/category_11713514.html总目录https://blog.csdn.net/tonghu_note/article/details/124333034

来我的dou音 aa10246666, 看配套视频


一、实战环境 角色版本机器名IP地址shard1pg 14node110.211.55.9shard2pg 14node210.211.55.4ShardingSphere-Proxy5.1.0node310.211.55.6用于测试连接ShardingSphere-Proxypg 14node410.211.55.7

二、 shard1和shard2上准备环境 1、创建ShardingSphere连接pg所使用的帐号

create user appuser with password '123'; grant appuser to postgres ;

vim?/etc/postgresql/14/main/pg_hba.conf

host ? ?all ? ? ? ? ? ? appuser ? ? ? ?0.0.0.0/0 ? ? ? ? ? ? ? ?md5?

重载访问控制文件?select pg_reload_conf();

postgres=# select pg_reload_conf(); ?pg_reload_conf? ---------------- ?t (1 row)

2、创建ShardingSphere连接pg所使用的数据库

shard1上创建数据库 shard1

create database shard1;

shard2上创建数据库 shard2

create database shard2;

三、ShardingSphere-Proxy上准备环境 1、安装ShardingSphere-Proxy

安装及配置jdk(jdk的版本要依据你cpu来选择,我用的是mac虚出来的虚机)

tar xzf jdk-8u202-linux-arm64-vfp-hflt.tar.gz

mv jdk1.8.0_202 /usr/local/

/etc/profile最后添加如下配置

PATH=/usr/local/jdk1.8.0_202/bin:$PATH

source /etc/profile

?安装及配置ShardingSphere-Proxy

tar xzf apache-shardingsphere-5.1.0-shardingsphere-proxy-bin.tar.gz

mv apache-shardingsphere-5.1.0-shardingsphere-proxy-bin /usr/local/

2、修改配置文件?server.yaml

rules: ? - !AUTHORITY ? ? users: ? ? ? - root@%:123 ? ? provider: ? ? ? type: ALL_PRIVILEGES_PERMITTED

props: ? sql-show: true

3、修改配置文件?config-sharding.yaml

schemaName: testdb

dataSources: ? ds_0: ? ? url: jdbc:postgresql://10.211.55.9:5432/shard1 ? ? username: appuser ? ? password: 123 ? ? connectionTimeoutMilliseconds: 30000 ? ? idleTimeoutMilliseconds: 60000 ? ? maxLifetimeMilliseconds: 1800000 ? ? maxPoolSize: 50 ? ? minPoolSize: 1 ? ds_1: ? ? url: jdbc:postgresql://10.211.55.4:5432/shard2 ? ? username: appuser ? ? password: 123 ? ? connectionTimeoutMilliseconds: 30000 ? ? idleTimeoutMilliseconds: 60000 ? ? maxLifetimeMilliseconds: 1800000 ? ? maxPoolSize: 50 ? ? minPoolSize: 1

rules: - !SHARDING ? tables: ? ? t_order: ? ? ? actualDataNodes: ds_${0..1}.t_order_${0..15} ? ? ? tableStrategy: ? ? ? ? standard: ? ? ? ? ? shardingColumn: order_id ? ? ? ? ? shardingAlgorithmName: t_order_inline ? ? ? keyGenerateStrategy: ? ? ? ? ? column: order_id ? ? ? ? ? keyGeneratorName: snowflake # ? ?t_order_item: # ? ? ?actualDataNodes: ds_${0..1}.t_order_item_${0..1} # ? ? ?tableStrategy: # ? ? ? ?standard: # ? ? ? ? ?shardingColumn: order_id # ? ? ? ? ?shardingAlgorithmName: t_order_item_inline # ? ? ?keyGenerateStrategy: # ? ? ? ?column: order_item_id # ? ? ? ?keyGeneratorName: snowflake ? bindingTables: ? ? - t_order # ? ?- t_order,t_order_item ? defaultDatabaseStrategy: ? ? standard: ? ? ? shardingColumn: user_id ? ? ? shardingAlgorithmName: database_inline ? defaultTableStrategy: ? ? none: ?? ? shardingAlgorithms: ? ? database_inline: ? ? ? type: INLINE ? ? ? props: ? ? ? ? algorithm-expression: ds_${user_id % 2} ? ? t_order_inline: ? ? ? type: INLINE ? ? ? props: ? ? ? ? algorithm-expression: t_order_${order_id % 16} # ? ?t_order_item_inline: # ? ? ?type: INLINE # ? ? ?props: # ? ? ? ?algorithm-expression: t_order_item_${order_id % 2}

? keyGenerators: ? ? snowflake: ? ? ? type: SNOWFLAKE ? ? ? props: ? ? ? ? worker-id: 123


4、启动ShardingSphere-Proxy

root@node3:/usr/local/apache-shardingsphere-5.1.0-shardingsphere-proxy-bin/conf# ../bin/start.sh? we find java version: java8, full_version=1.8.0_202 Starting the ShardingSphere-Proxy ... The classpath is /usr/local/apache-shardingsphere-5.1.0-shardingsphere-proxy-bin/conf:.:/usr/local/apache-shardingsphere-5.1.0-shardingsphere-proxy-bin/lib/*:/usr/local/apache-shardingsphere-5.1.0-shardingsphere-proxy-bin/ext-lib/* Please check the STDOUT file: /usr/local/apache-shardingsphere-5.1.0-shardingsphere-proxy-bin/logs/stdout.log


四、测试 1、在node4上连接ShardingSphere-Proxy

postgres@node4:~$ psql -h 10.211.55.6 -U root -p 3307 testdb Password for user root:? psql (14.2 (Debian 14.2-1.pgdg110+1)) Type "help" for help.

testdb=>?

2、在node4上连接ShardingSphere-Proxy,并创建分片表?t_order

create table t_order(user_id int, order_id int primary key);

3、在ShardingSphere-Proxy上查看日志 stdout.log,可以看到分别在node1和node2上创建了16张表

[INFO ] 2022-04-03 22:55:29.138 [Connection-4-ThreadExecutor] ShardingSphere-SQL - Logic SQL: create table t_order(user_id int, order_id int primary key); [INFO ] 2022-04-03 22:55:29.138 [Connection-4-ThreadExecutor] ShardingSphere-SQL - SQLStatement: PostgreSQLCreateTableStatement(containsNotExistClause=false) [INFO ] 2022-04-03 22:55:29.138 [Connection-4-ThreadExecutor] ShardingSphere-SQL - Actual SQL: ds_1 ::: create table t_order_0(user_id int, order_id int primary key); [INFO ] 2022-04-03 22:55:29.138 [Connection-4-ThreadExecutor] ShardingSphere-SQL - Actual SQL: ds_1 ::: create table t_order_1(user_id int, order_id int primary key); [INFO ] 2022-04-03 22:55:29.138 [Connection-4-ThreadExecutor] ShardingSphere-SQL - Actual SQL: ds_1 ::: create table t_order_2(user_id int, order_id int primary key); [INFO ] 2022-04-03 22:55:29.138 [Connection-4-ThreadExecutor] ShardingSphere-SQL - Actual SQL: ds_1 ::: create table t_order_3(user_id int, order_id int primary key); [INFO ] 2022-04-03 22:55:29.138 [Connection-4-ThreadExecutor] ShardingSphere-SQL - Actual SQL: ds_1 ::: create table t_order_4(user_id int, order_id int primary key); [INFO ] 2022-04-03 22:55:29.138 [Connection-4-ThreadExecutor] ShardingSphere-SQL - Actual SQL: ds_1 ::: create table t_order_5(user_id int, order_id int primary key); [INFO ] 2022-04-03 22:55:29.138 [Connection-4-ThreadExecutor] ShardingSphere-SQL - Actual SQL: ds_1 ::: create table t_order_6(user_id int, order_id int primary key); [INFO ] 2022-04-03 22:55:29.138 [Connection-4-ThreadExecutor] ShardingSphere-SQL - Actual SQL: ds_1 ::: create table t_order_7(user_id int, order_id int primary key); [INFO ] 2022-04-03 22:55:29.138 [Connection-4-ThreadExecutor] ShardingSphere-SQL - Actual SQL: ds_1 ::: create table t_order_8(user_id int, order_id int primary key); [INFO ] 2022-04-03 22:55:29.138 [Connection-4-ThreadExecutor] ShardingSphere-SQL - Actual SQL: ds_1 ::: create table t_order_9(user_id int, order_id int primary key); [INFO ] 2022-04-03 22:55:29.138 [Connection-4-ThreadExecutor] ShardingSphere-SQL - Actual SQL: ds_1 ::: create table t_order_10(user_id int, order_id int primary key); [INFO ] 2022-04-03 22:55:29.138 [Connection-4-ThreadExecutor] ShardingSphere-SQL - Actual SQL: ds_1 ::: create table t_order_11(user_id int, order_id int primary key); [INFO ] 2022-04-03 22:55:29.138 [Connection-4-ThreadExecutor] ShardingSphere-SQL - Actual SQL: ds_1 ::: create table t_order_12(user_id int, order_id int primary key); [INFO ] 2022-04-03 22:55:29.138 [Connection-4-ThreadExecutor] ShardingSphere-SQL - Actual SQL: ds_1 ::: create table t_order_13(user_id int, order_id int primary key); [INFO ] 2022-04-03 22:55:29.138 [Connection-4-ThreadExecutor] ShardingSphere-SQL - Actual SQL: ds_1 ::: create table t_order_14(user_id int, order_id int primary key); [INFO ] 2022-04-03 22:55:29.138 [Connection-4-ThreadExecutor] ShardingSphere-SQL - Actual SQL: ds_1 ::: create table t_order_15(user_id int, order_id int primary key); [INFO ] 2022-04-03 22:55:29.138 [Connection-4-ThreadExecutor] ShardingSphere-SQL - Actual SQL: ds_0 ::: create table t_order_0(user_id int, order_id int primary key); [INFO ] 2022-04-03 22:55:29.138 [Connection-4-ThreadExecutor] ShardingSphere-SQL - Actual SQL: ds_0 ::: create table t_order_1(user_id int, order_id int primary key); [INFO ] 2022-04-03 22:55:29.138 [Connection-4-ThreadExecutor] ShardingSphere-SQL - Actual SQL: ds_0 ::: create table t_order_2(user_id int, order_id int primary key); [INFO ] 2022-04-03 22:55:29.138 [Connection-4-ThreadExecutor] ShardingSphere-SQL - Actual SQL: ds_0 ::: create table t_order_3(user_id int, order_id int primary key); [INFO ] 2022-04-03 22:55:29.138 [Connection-4-ThreadExecutor] ShardingSphere-SQL - Actual SQL: ds_0 ::: create table t_order_4(user_id int, order_id int primary key); [INFO ] 2022-04-03 22:55:29.138 [Connection-4-ThreadExecutor] ShardingSphere-SQL - Actual SQL: ds_0 ::: create table t_order_5(user_id int, order_id int primary key); [INFO ] 2022-04-03 22:55:29.138 [Connection-4-ThreadExecutor] ShardingSphere-SQL - Actual SQL: ds_0 ::: create table t_order_6(user_id int, order_id int primary key); [INFO ] 2022-04-03 22:55:29.138 [Connection-4-ThreadExecutor] ShardingSphere-SQL - Actual SQL: ds_0 ::: create table t_order_7(user_id int, order_id int primary key); [INFO ] 2022-04-03 22:55:29.138 [Connection-4-ThreadExecutor] ShardingSphere-SQL - Actual SQL: ds_0 ::: create table t_order_8(user_id int, order_id int primary key); [INFO ] 2022-04-03 22:55:29.138 [Connection-4-ThreadExecutor] ShardingSphere-SQL - Actual SQL: ds_0 ::: create table t_order_9(user_id int, order_id int primary key); [INFO ] 2022-04-03 22:55:29.138 [Connection-4-ThreadExecutor] ShardingSphere-SQL - Actual SQL: ds_0 ::: create table t_order_10(user_id int, order_id int primary key); [INFO ] 2022-04-03 22:55:29.138 [Connection-4-ThreadExecutor] ShardingSphere-SQL - Actual SQL: ds_0 ::: create table t_order_11(user_id int, order_id int primary key); [INFO ] 2022-04-03 22:55:29.138 [Connection-4-ThreadExecutor] ShardingSphere-SQL - Actual SQL: ds_0 ::: create table t_order_12(user_id int, order_id int primary key); [INFO ] 2022-04-03 22:55:29.138 [Connection-4-ThreadExecutor] ShardingSphere-SQL - Actual SQL: ds_0 ::: create table t_order_13(user_id int, order_id int primary key); [INFO ] 2022-04-03 22:55:29.138 [Connection-4-ThreadExecutor] ShardingSphere-SQL - Actual SQL: ds_0 ::: create table t_order_14(user_id int, order_id int primary key); [INFO ] 2022-04-03 22:55:29.138 [Connection-4-ThreadExecutor] ShardingSphere-SQL - Actual SQL: ds_0 ::: create table t_order_15(user_id int, order_id int primary key);

4、在node1上查看新建表的情况

postgres@node1:~$ psql psql (14.2 (Debian 14.2-1.pgdg110+1)) Type "help" for help.

postgres=# \c shard1 You are now connected to database "shard1" as user "postgres". shard1=# \d ? ? ? ? ? ?List of relations ?Schema | ? ?Name ? ?| Type ?| ?Owner ? --------+------------+-------+--------- ?public | t_order_0 ?| table | appuser ?public | t_order_1 ?| table | appuser ?public | t_order_10 | table | appuser ?public | t_order_11 | table | appuser ?public | t_order_12 | table | appuser ?public | t_order_13 | table | appuser ?public | t_order_14 | table | appuser ?public | t_order_15 | table | appuser ?public | t_order_2 ?| table | appuser ?public | t_order_3 ?| table | appuser ?public | t_order_4 ?| table | appuser ?public | t_order_5 ?| table | appuser ?public | t_order_6 ?| table | appuser ?public | t_order_7 ?| table | appuser ?public | t_order_8 ?| table | appuser ?public | t_order_9 ?| table | appuser (16 rows)

5、在node2上查看新建表的情况

postgres@node2:~$ psql shard2 psql (14.2 (Debian 14.2-1.pgdg110+1)) Type "help" for help.

shard2=# \d ? ? ? ? ? ?List of relations ?Schema | ? ?Name ? ?| Type ?| ?Owner ? --------+------------+-------+--------- ?public | t_order_0 ?| table | appuser ?public | t_order_1 ?| table | appuser ?public | t_order_10 | table | appuser ?public | t_order_11 | table | appuser ?public | t_order_12 | table | appuser ?public | t_order_13 | table | appuser ?public | t_order_14 | table | appuser ?public | t_order_15 | table | appuser ?public | t_order_2 ?| table | appuser ?public | t_order_3 ?| table | appuser ?public | t_order_4 ?| table | appuser ?public | t_order_5 ?| table | appuser ?public | t_order_6 ?| table | appuser ?public | t_order_7 ?| table | appuser ?public | t_order_8 ?| table | appuser ?public | t_order_9 ?| table | appuser (16 rows)

6、在node4上连接ShardingSphere-Proxy,插入几条数据

postgres@node4:~$ psql -h 10.211.55.6 -U root -p 3307 testdb Password for user root:? psql (14.2 (Debian 14.2-1.pgdg110+1)) Type "help" for help.

testdb=>?

insert into t_order values(1, 1); insert into t_order values(2, 1); insert into t_order values(1, 2); insert into t_order values(2, 2); insert into t_order values(1, 3); insert into t_order values(2, 3); testdb=>?

?在ShardingSphere-Proxy上,查看日志stdout.log,观察数据分布式插入的情况

[INFO ] 2022-04-03 23:04:57.311 [Connection-4-ThreadExecutor] ShardingSphere-SQL - Logic SQL: insert into t_order values(1, 1); [INFO ] 2022-04-03 23:04:57.311 [Connection-4-ThreadExecutor] ShardingSphere-SQL - SQLStatement: PostgreSQLInsertStatement(withSegment=Optional.empty) [INFO ] 2022-04-03 23:04:57.311 [Connection-4-ThreadExecutor] ShardingSphere-SQL - Actual SQL: ds_1 ::: insert into t_order_1 values(1, 1); [INFO ] 2022-04-03 23:05:14.515 [Connection-4-ThreadExecutor] ShardingSphere-SQL - Logic SQL: insert into t_order values(2, 1); [INFO ] 2022-04-03 23:05:14.515 [Connection-4-ThreadExecutor] ShardingSphere-SQL - SQLStatement: PostgreSQLInsertStatement(withSegment=Optional.empty) [INFO ] 2022-04-03 23:05:14.515 [Connection-4-ThreadExecutor] ShardingSphere-SQL - Actual SQL: ds_0 ::: insert into t_order_1 values(2, 1); [INFO ] 2022-04-03 23:05:20.018 [Connection-4-ThreadExecutor] ShardingSphere-SQL - Logic SQL: insert into t_order values(1, 2); [INFO ] 2022-04-03 23:05:20.018 [Connection-4-ThreadExecutor] ShardingSphere-SQL - SQLStatement: PostgreSQLInsertStatement(withSegment=Optional.empty) [INFO ] 2022-04-03 23:05:20.018 [Connection-4-ThreadExecutor] ShardingSphere-SQL - Actual SQL: ds_1 ::: insert into t_order_2 values(1, 2); [INFO ] 2022-04-03 23:05:23.546 [Connection-4-ThreadExecutor] ShardingSphere-SQL - Logic SQL: insert into t_order values(2, 2); [INFO ] 2022-04-03 23:05:23.547 [Connection-4-ThreadExecutor] ShardingSphere-SQL - SQLStatement: PostgreSQLInsertStatement(withSegment=Optional.empty) [INFO ] 2022-04-03 23:05:23.547 [Connection-4-ThreadExecutor] ShardingSphere-SQL - Actual SQL: ds_0 ::: insert into t_order_2 values(2, 2); [INFO ] 2022-04-03 23:06:47.975 [Connection-4-ThreadExecutor] ShardingSphere-SQL - Logic SQL: insert into t_order values(1, 3); [INFO ] 2022-04-03 23:06:47.976 [Connection-4-ThreadExecutor] ShardingSphere-SQL - SQLStatement: PostgreSQLInsertStatement(withSegment=Optional.empty) [INFO ] 2022-04-03 23:06:47.976 [Connection-4-ThreadExecutor] ShardingSphere-SQL - Actual SQL: ds_1 ::: insert into t_order_3 values(1, 3); [INFO ] 2022-04-03 23:06:50.604 [Connection-4-ThreadExecutor] ShardingSphere-SQL - Logic SQL: insert into t_order values(2, 3); [INFO ] 2022-04-03 23:06:50.605 [Connection-4-ThreadExecutor] ShardingSphere-SQL - SQLStatement: PostgreSQLInsertStatement(withSegment=Optional.empty) [INFO ] 2022-04-03 23:06:50.605 [Connection-4-ThreadExecutor] ShardingSphere-SQL - Actual SQL: ds_0 ::: insert into t_order_3 values(2, 3);

?在node1上,查看表的情况,以便确认数据插入情况,红色部分大小为8192的,即为有数据插入的

postgres@node1:~$ psql shard1 psql (14.2 (Debian 14.2-1.pgdg110+1)) Type "help" for help.

shard1=# \d+ ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ?List of relations ?Schema | ? ?Name ? ?| Type ?| ?Owner ?| Persistence | Access method | ? ?Size ? ?| Description? --------+------------+-------+---------+-------------+---------------+------------+------------- ?public | t_order_0 ?| table | appuser | permanent ? | heap ? ? ? ? ?| 0 bytes ? ?|? ?public | t_order_1 ?| table | appuser | permanent ? | heap ? ? ? ? ?| 8192 bytes |? ?public | t_order_10 | table | appuser | permanent ? | heap ? ? ? ? ?| 0 bytes ? ?|? ?public | t_order_11 | table | appuser | permanent ? | heap ? ? ? ? ?| 0 bytes ? ?|? ?public | t_order_12 | table | appuser | permanent ? | heap ? ? ? ? ?| 0 bytes ? ?|? ?public | t_order_13 | table | appuser | permanent ? | heap ? ? ? ? ?| 0 bytes ? ?|? ?public | t_order_14 | table | appuser | permanent ? | heap ? ? ? ? ?| 0 bytes ? ?|? ?public | t_order_15 | table | appuser | permanent ? | heap ? ? ? ? ?| 0 bytes ? ?|? ?public | t_order_2 ?| table | appuser | permanent ? | heap ? ? ? ? ?| 8192 bytes |? ?public | t_order_3 ?| table | appuser | permanent ? | heap ? ? ? ? ?| 8192 bytes |? ?public | t_order_4 ?| table | appuser | permanent ? | heap ? ? ? ? ?| 0 bytes ? ?|? ?public | t_order_5 ?| table | appuser | permanent ? | heap ? ? ? ? ?| 0 bytes ? ?|? ?public | t_order_6 ?| table | appuser | permanent ? | heap ? ? ? ? ?| 0 bytes ? ?|? ?public | t_order_7 ?| table | appuser | permanent ? | heap ? ? ? ? ?| 0 bytes ? ?|? ?public | t_order_8 ?| table | appuser | permanent ? | heap ? ? ? ? ?| 0 bytes ? ?|? ?public | t_order_9 ?| table | appuser | permanent ? | heap ? ? ? ? ?| 0 bytes ? ?|? (16 rows)

shard1=#?

?在node2上,查看表的情况,以便确认数据插入情况,红色部分大小为8192的,即为有数据插入的?

postgres@node2:~$ psql shard2 psql (14.2 (Debian 14.2-1.pgdg110+1)) Type "help" for help.

shard2=# \d+ ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ?List of relations ?Schema | ? ?Name ? ?| Type ?| ?Owner ?| Persistence | Access method | ? ?Size ? ?| Description? --------+------------+-------+---------+-------------+---------------+------------+------------- ?public | t_order_0 ?| table | appuser | permanent ? | heap ? ? ? ? ?| 0 bytes ? ?|? ?public | t_order_1 ?| table | appuser | permanent ? | heap ? ? ? ? ?| 8192 bytes |? ?public | t_order_10 | table | appuser | permanent ? | heap ? ? ? ? ?| 0 bytes ? ?|? ?public | t_order_11 | table | appuser | permanent ? | heap ? ? ? ? ?| 0 bytes ? ?|? ?public | t_order_12 | table | appuser | permanent ? | heap ? ? ? ? ?| 0 bytes ? ?|? ?public | t_order_13 | table | appuser | permanent ? | heap ? ? ? ? ?| 0 bytes ? ?|? ?public | t_order_14 | table | appuser | permanent ? | heap ? ? ? ? ?| 0 bytes ? ?|? ?public | t_order_15 | table | appuser | permanent ? | heap ? ? ? ? ?| 0 bytes ? ?|? ?public | t_order_2 ?| table | appuser | permanent ? | heap ? ? ? ? ?| 8192 bytes |? ?public | t_order_3 ?| table | appuser | permanent ? | heap ? ? ? ? ?| 8192 bytes |? ?public | t_order_4 ?| table | appuser | permanent ? | heap ? ? ? ? ?| 0 bytes ? ?|? ?public | t_order_5 ?| table | appuser | permanent ? | heap ? ? ? ? ?| 0 bytes ? ?|? ?public | t_order_6 ?| table | appuser | permanent ? | heap ? ? ? ? ?| 0 bytes ? ?|? ?public | t_order_7 ?| table | appuser | permanent ? | heap ? ? ? ? ?| 0 bytes ? ?|? ?public | t_order_8 ?| table | appuser | permanent ? | heap ? ? ? ? ?| 0 bytes ? ?|? ?public | t_order_9 ?| table | appuser | permanent ? | heap ? ? ? ? ?| 0 bytes ? ?|? (16 rows)

?7、在node4上连接ShardingSphere-Proxy,发起2条查询语句

testdb=> select * from t_order where order_id=1; ?user_id | order_id? ---------+---------- ? ? ? ?2 | ? ? ? ?1 ? ? ? ?1 | ? ? ? ?1 (2 rows)

testdb=> select * from t_order where order_id=2; ?user_id | order_id? ---------+---------- ? ? ? ?2 | ? ? ? ?2 ? ? ? ?1 | ? ? ? ?2 (2 rows)

?在ShardingSphere-Proxy上,查看日志stdout.log,观察数据分布式查询的情况

[INFO ] 2022-04-03 23:20:38.118 [Connection-4-ThreadExecutor] ShardingSphere-SQL - Logic SQL: select * from t_order where order_id=1; [INFO ] 2022-04-03 23:20:38.118 [Connection-4-ThreadExecutor] ShardingSphere-SQL - SQLStatement: PostgreSQLSelectStatement(limit=Optional.empty, lock=Optional.empty, window=Optional.empty) [INFO ] 2022-04-03 23:20:38.118 [Connection-4-ThreadExecutor] ShardingSphere-SQL - Actual SQL: ds_0 ::: select * from t_order_1 where order_id=1; [INFO ] 2022-04-03 23:20:38.118 [Connection-4-ThreadExecutor] ShardingSphere-SQL - Actual SQL: ds_1 ::: select * from t_order_1 where order_id=1; [INFO ] 2022-04-03 23:20:46.669 [Connection-4-ThreadExecutor] ShardingSphere-SQL - Logic SQL: select * from t_order where order_id=2; [INFO ] 2022-04-03 23:20:46.669 [Connection-4-ThreadExecutor] ShardingSphere-SQL - SQLStatement: PostgreSQLSelectStatement(limit=Optional.empty, lock=Optional.empty, window=Optional.empty) [INFO ] 2022-04-03 23:20:46.669 [Connection-4-ThreadExecutor] ShardingSphere-SQL - Actual SQL: ds_0 ::: select * from t_order_2 where order_id=2; [INFO ] 2022-04-03 23:20:46.669 [Connection-4-ThreadExecutor] ShardingSphere-SQL - Actual SQL: ds_1 ::: select * from t_order_2 where order_id=2;


1.本站遵循行业规范,任何转载的稿件都会明确标注作者和来源;2.本站的原创文章,会注明原创字样,如未注明都非原创,如有侵权请联系删除!;3.作者投稿可能会经我们编辑修改或补充;4.本站不提供任何储存功能只提供收集或者投稿人的网盘链接。

标签: #pg数据库分库分表 #1