【达梦数据库】sharding-jdbc连接DM实现单库水平分表

04-10 1649阅读

sharding-jdbc连接DM实现单库水平分表

一、基于sharding-jdbc连接oracle实现单库水平分表

连接oracle的案例可以参考https://blog.csdn.net/qq_40102894/article/details/96302535

如果有想学习sharding-jdbc可以在B站上看https://www.bilibili.com/video/BV1jJ411M78w?t=431

sharding-jdbc官方文档http://shardingsphere.apache.org/index_zh.html

二、将源端数据库改成DM

1、建表

create table T_ADDRESS
(
	ID NUMBER(20) not null
		constraint T_ADDRESS_PK
			primary key,
	NAME VARCHAR2(64),
	ADDR VARCHAR2(32)
);
comment on column T_ADDRESS.ID is '主键';
comment on column T_ADDRESS.NAME is '名称';
comment on column T_ADDRESS.ADDR is '地址';
create table T_USER0
(
	ID NUMBER(20) not null
		constraint TABLE1_PK
			primary key,
	NAME VARCHAR2(64),
	TASK_ID NUMBER(12),
	CALL_MONTH VARCHAR2(20)
);
comment on column T_USER0.ID is '主键';
comment on column T_USER0.NAME is '名称';
comment on column T_USER0.TASK_ID is '任务id';
comment on column T_USER0.CALL_MONTH is '呼叫月份';
create table T_USER1
(
	ID NUMBER(20) not null
		constraint T_USER1_PK
			primary key,
	NAME VARCHAR2(64),
	TASK_ID NUMBER(12),
	CALL_MONTH VARCHAR2(20)
);
comment on column T_USER1.ID is '主键';
comment on column T_USER1.NAME is '名称';
comment on column T_USER1.TASK_ID is '任务id';
comment on column T_USER1.CALL_MONTH is '呼叫月份';

2.修改连接方式

在pom.xml中增加DM驱动

        
            com.dameng
            Dm8JdbcDriver18
            8.1.0.157

修改连接方式

sharding:
  jdbc:
    datasource:
      names: ds0
      # 数据源ds0
      ds0:
        type: com.alibaba.druid.pool.DruidDataSource
        driver-class-name: dm.jdbc.driver.DmDriver
        url: jdbc:dm://localhost:5236?compatibleMode=oracle
        username: test
        password: 123456789

三、插入验证

插入代码

 @Test
    public void testSave() {
        for (int i = 40; i  
分表规则如下,即根据t_user中task_id模于2，task_id为奇数就insert到t_user1表中，task_id为偶数就insert到t_user0表中 
  config:
      sharding:
        props:
          sql.show: true
        tables:
          t_user:  #t_user表
            key-generator-column-name: id  #主键
            actual-data-nodes: ds0.t_user${0..1}    #数据节点,均匀分布
            table-strategy:  #分表策略
              inline: #行表达式
                sharding-column: task_id
                algorithm-expression: t_user${task_id % 2}  #按模运算分配
 
查看task_id为偶数的插入日志,可以看到insert into t_user 在后台被转换成insert into t_user0中，即对逻辑表t_user中的操作会被转换成对物理表t_user0，t_user1的操作。 
 
查看task_id为奇数的插入日志,可以看到insert into t_user 在后台被转换成insert into t_user1中 
 
四、查询验证 
查看task_id为奇数的查询日志,可以看到select * from t_user 在后台被转换成select * from t_user1中，即对逻辑表t_user中的操作会被转换成对物理表t_user0，t_user1的操作。 
 
查看task_id为偶数的查询日志,可以看到select * from t_user 在后台被转换成select * from t_user0中 
物理表t_user0，t_user1的操作。 
[外链图片转存中…(img-88wpFZKp-1712633624519)] 
查看task_id为偶数的查询日志,可以看到select * from t_user 在后台被转换成select * from t_user0中