本文共 2539 字，大约阅读时间需要 8 分钟。

mycat下载

conf下的schema.xml的配置

:表示的是在mycat中的逻辑库配置，逻辑库名称为:TESTDB

:表示数据库节点,这个节点不一定是单节点，可以配置成读写分离.

:真实的数据库的地址配置

:用户心跳检测

:写库的配置

   
       
                
     			 
       			
         
    	        
          
          
               
          
                  
     
      select user()
                   
           
     
   

分配规则

• 分片枚举

• 固定分片 hash 算法

• 范围约定

• 取模 mod-long

• 按日期（天）分片

• 取模范围约束

• 截取数字做 hash 求模范围约束

• 应用指定

• 截取数字 hash 解析

• 一致性 hash

• 按单月小时拆分

• 范围求模分片

• 日期范围 hash 分片

• 冷热数据分片

• 自然月分片

conf/rule.xml 配置

   
       
            
                 
      
       id
                  
      
       mod-long
              
         
    	
            
                 
      
       id
                  
      
       mod-long2
              
         
        
            
             
     
      2
         
    			    
            
             
     
      1
         
    	
   

在两个物理数据库的创建表

CREATE TABLE user(id int PRIMARY KEY ,name VARCHAR(10))

springbootd的配置文件 这里连接的是mycat

#配置数据源spring.datasource.druid.driver-class-name=com.mysql.jdbc.Driver#这里配置的是Mycat中server.xml中配置账号密码，不是数据库的密码。spring.datasource.druid.username=rootspring.datasource.druid.password=123456#mycat的逻辑库 端口也是mycat的spring.datasource.druid.url=jdbc:mysql://172.18.9.166:8066/TESTDB

批量插入数据

@Test    void addList() {
           List
   
     users = new ArrayList<>();        for (int i = 3; i < 100; i++) {
               User user = new User();            //必须设置id，即使物理数据库的id设置为自增长都不行            user.setId(i);            user.setName("xiaobu" + i);            users.add(user);        }        int count = userMapper.insertList(users);        System.out.println("count = " + count);    }
   

查询

package com.xiaobu.controller;import com.xiaobu.mapper.UserMapper;import org.springframework.web.bind.annotation.GetMapping;import org.springframework.web.bind.annotation.RequestMapping;import org.springframework.web.bind.annotation.ResponseBody;import org.springframework.web.bind.annotation.RestController;import javax.annotation.Resource;/** * @author xiaobu * @version JDK1.8.0_171 * @date on  2019/12/6 10:33 * @description */@RestController@RequestMapping("user")public class UserController {
       @Resource    private UserMapper userMapper;    @GetMapping("insert")    @ResponseBody    public String insert(){
           return null;    }    @GetMapping("selectAll")    @ResponseBody    public String selectAll(){
           return userMapper.selectAll().toString();    }}

可以看到数据插入成功了

mycat 连接属性

数据查询

两个物理表数据存储情况

springboot_demo.user

ssm.user

参考:

转载地址：http://swgai.baihongyu.com/