欧美一级特黄大片做受成人-亚洲成人一区二区电影-激情熟女一区二区三区-日韩专区欧美专区国产专区

怎么用ShardingSphere5.0.0-alpha實(shí)現(xiàn)mysql數(shù)據(jù)分表分片

本篇內(nèi)容主要講解“怎么用ShardingSphere5.0.0-alpha實(shí)現(xiàn)MySQL數(shù)據(jù)分表分片”，感興趣的朋友不妨來(lái)看看。本文介紹的方法操作簡(jiǎn)單快捷，實(shí)用性強(qiáng)。下面就讓小編來(lái)帶大家學(xué)習(xí)“怎么用ShardingSphere5.0.0-alpha實(shí)現(xiàn)mysql數(shù)據(jù)分表分片”吧!

創(chuàng)新互聯(lián)公司于2013年開(kāi)始，先為甕安等服務(wù)建站，甕安等地企業(yè)，進(jìn)行企業(yè)商務(wù)咨詢(xún)服務(wù)。為甕安企業(yè)網(wǎng)站制作PC+手機(jī)+微官網(wǎng)三網(wǎng)同步一站式服務(wù)解決您的所有建站問(wèn)題。

聲明

  • 本文會(huì)基于 Springboot + mybatis + shardingsphere + mysql5.6 + druid 進(jìn)行實(shí)戰(zhàn)講解

  • 本文的實(shí)戰(zhàn)內(nèi)容為分表、以及數(shù)據(jù)分片, 不涉及分庫(kù), 讀寫(xiě)分離之類(lèi)的

  • 本文不會(huì)介紹 shardingsphere 的歷史、概念以及分庫(kù)分表的相關(guān)理論

  • 本文采用的 shardingsphere 版本是 5.0.0-alpha, 具體見(jiàn) pom 文件

  • 本文涉及的源碼請(qǐng)參考 碼云地址

  • 如果看 官方文檔 時(shí), 請(qǐng)選對(duì)版本 !!!

正文

實(shí)現(xiàn)目標(biāo)

我們有一張邏輯用戶(hù)表 user_info, 我們把它水平拆分成 user_info0 和 user_info1 兩張物理表 當(dāng)我們往用戶(hù)表插數(shù)據(jù)時(shí), 數(shù)據(jù)會(huì)按照一定的規(guī)則(根據(jù)id取模), 寫(xiě)入到其中一張 user_info 表中.

準(zhǔn)備工作

1. 數(shù)據(jù)庫(kù)表
create database miaosha;

DROP TABLE IF EXISTS `user_info0`;
CREATE TABLE `user_info0` (
  `id` bigint(20) NOT NULL AUTO_INCREMENT,
  `user_label` varchar(32) COLLATE utf8_bin DEFAULT NULL,
  `username` varchar(64) COLLATE utf8_bin DEFAULT NULL,
  `email` varchar(64) COLLATE utf8_bin DEFAULT NULL,
  `phone` varchar(64) COLLATE utf8_bin DEFAULT NULL,
  `password` varchar(128) COLLATE utf8_bin NOT NULL,
  `active` tinyint(4) NOT NULL DEFAULT '1',
   PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=7 DEFAULT CHARSET=utf8 COLLATE=utf8_bin;


DROP TABLE IF EXISTS `user_info1`;
CREATE TABLE `user_info1` (
  `id` bigint(20) NOT NULL AUTO_INCREMENT,
  `user_label` varchar(32) COLLATE utf8_bin DEFAULT NULL,
  `username` varchar(64) COLLATE utf8_bin DEFAULT NULL,
  `email` varchar(64) COLLATE utf8_bin DEFAULT NULL,
  `phone` varchar(64) COLLATE utf8_bin DEFAULT NULL,
  `password` varchar(128) COLLATE utf8_bin NOT NULL,
  `active` tinyint(4) NOT NULL DEFAULT '1',
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=6 DEFAULT CHARSET=utf8 COLLATE=utf8_bin;
2. pom 依賴(lài)
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.3.2.RELEASE</version>
        <relativePath/>
    </parent>
    <groupId>com.nimo</groupId>
    <artifactId>shardingsphere-demo</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>shardingsphere-demo</name>

    <properties>
        <java.version>1.8</java.version>
    </properties>
  
    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
      
        <dependency>
            <groupId>org.mybatis.spring.boot</groupId>
            <artifactId>mybatis-spring-boot-starter</artifactId>
            <version>2.1.4</version>
        </dependency>

        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <scope>runtime</scope>
        </dependency>
      
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>
      
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>

        <!-- shardingsphere -->
        <dependency>
            <groupId>org.apache.shardingsphere</groupId>
            <artifactId>shardingsphere-jdbc-core-spring-boot-starter</artifactId>
            <version>5.0.0-alpha</version>
        </dependency>

        <!-- 阿里數(shù)據(jù)源 -->
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>druid</artifactId>
            <version>1.2.3</version>
        </dependency>

    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
                <configuration>
                    <excludes>
                        <exclude>
                            <groupId>org.projectlombok</groupId>
                            <artifactId>lombok</artifactId>
                        </exclude>
                    </excludes>
                </configuration>
            </plugin>
        </plugins>
    </build>

</project>
3. application.yml

再次強(qiáng)調(diào)下, 本文采用的 shardingsphere 版本是 5.0.0-alpha. 不同版本配置會(huì)有差異.

填寫(xiě)配置文件時(shí),一定要小心, 坑死了; 不信你不配置 com.alibaba.druid.pool.DruidDataSource試試,

或者你用默認(rèn)的數(shù)據(jù)源替換試試 om.zaxxer.hikari.HikariDataSource

server:
  port: 8777

spring:
  shardingsphere:
 
    props:
      sql-show: true
      
    datasource:
      names: ds0
      # 注意這里的數(shù)據(jù)源配置用的是 druid
      common:
        type: com.alibaba.druid.pool.DruidDataSource
      ds0:
        url: jdbc:mysql://127.0.0.1:3306/miaosha?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=GMT%2b8
        username: root
        password: '123456'
        driver-class-name: com.mysql.cj.jdbc.Driver
    rules:
      sharding:
        key-generators:
          # 此處必須要配置，否則會(huì)導(dǎo)致報(bào)錯(cuò)，因?yàn)閟hardingsphere-jdbc-core-spring-boot-starter需要加載此項(xiàng)配置，官網(wǎng)的demo例子有錯(cuò)
          snowflake:
            type: SNOWFLAKE
            props:
              worker-id: 123
        sharding-algorithms:
          table-inline:
            type: INLINE
            props:
              # 不要漏掉 $ 或 ->
              algorithm-expression: user_info$->{id % 2}
        tables:
          user_info:
            # 配置 user_info 的分表的規(guī)則
            actual-data-nodes: ds0.user_info$->{0..1}
            table-strategy:
              standard:
                sharding-column: id
                sharding-algorithm-name: table-inline
    enabled: true

mybatis:
  typeAliasesPackage: com.nimo.shardingspheredemo.entity
  mapperLocations: classpath:mapper/*.xml
4. 主要代碼
// sql 
<insert id="addUser" parameterType="com.nimo.shardingdemo.entity.UserInfo">
   insert into user_info(id, username, password) values (#{id}, #{username}, #{password})
</insert>
 
 // 新增一個(gè)用戶(hù)信息
@PostMapping("userinfo")
public Object addUserInfo(@RequestBody UserInfo userInfo) {
   return userInfoMapper.addUser(userInfo);
}
5. 測(cè)試命令
curl -X POST --location "http://localhost:8777/userinfo" \
    -H "Content-Type: application/json" \
    -d "{
          \"id\": 18,
          \"username\": \"wangbadan\",
          \"password\": \"123456\"
        }"
問(wèn)題

我們創(chuàng)建表時(shí)設(shè)置的 主鍵id是自增的, 理論上是不用傳的, 但是我們往表中插數(shù)據(jù), 是根據(jù) 主鍵id 取模來(lái)決定具體往哪張表中插的. 所以這個(gè)主鍵 id 此時(shí)必須得有.

另外, 如果我們的服務(wù)有多個(gè), 那么這個(gè) id 如何生成?

如何解決

首先把 sql 改寫(xiě)為如下方式:

// sql 
<insert id="addUser" parameterType="com.nimo.shardingdemo.entity.UserInfo">
   insert into user_info(username, password)
    values ( #{username}, #{password})
</insert>

然后在原有配置的基礎(chǔ)上, 追加如下配置信息(通過(guò)雪花算法生成id)

spring:
  shardingsphere:
    rules:
      sharding: 
        tables:
          user_info:
            key-generate-strategy:
              key-generator-name: snowflake
              column: id

怎么用ShardingSphere5.0.0-alpha實(shí)現(xiàn)mysql數(shù)據(jù)分表分片

測(cè)試

curl -X POST --location "http://localhost:8777/userinfo" \
    -H "Content-Type: application/json" \
    -d "{
          \"username\": \"wangbadan\",
          \"password\": \"123456\"
        }"

總結(jié)

本文強(qiáng)調(diào)的是 分表, 分片的實(shí)戰(zhàn) demo 配置, 后面會(huì)逐漸更新 分庫(kù)、讀寫(xiě)分離的實(shí)戰(zhàn) demo, 跟之前的 Spring Secutiry 的實(shí)戰(zhàn)教程一樣, 講究循序漸進(jìn).

到此，相信大家對(duì)“怎么用ShardingSphere5.0.0-alpha實(shí)現(xiàn)mysql數(shù)據(jù)分表分片”有了更深的了解，不妨來(lái)實(shí)際操作一番吧！這里是創(chuàng)新互聯(lián)網(wǎng)站，更多相關(guān)內(nèi)容可以進(jìn)入相關(guān)頻道進(jìn)行查詢(xún)，關(guān)注我們，繼續(xù)學(xué)習(xí)！

新聞名稱(chēng)：怎么用ShardingSphere5.0.0-alpha實(shí)現(xiàn)mysql數(shù)據(jù)分表分片
URL地址：http://aaarwkj.com/article40/pjcdho.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供響應(yīng)式網(wǎng)站、動(dòng)態(tài)網(wǎng)站、軟件開(kāi)發(fā)、域名注冊(cè)、網(wǎng)站維護(hù)、ChatGPT

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶(hù)投稿、用戶(hù)轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請(qǐng)盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng)，如需處理請(qǐng)聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來(lái)源： 創(chuàng)新互聯(lián)

成都定制網(wǎng)站建設(shè)
99热这里有精品久久| 日本大胆高清人体艺术| 成人在线午夜免费视频| 三级视频一区二区三区| 国产一区二区高清不卡| 国产午夜男人天堂手机| 欧美福利在线观看视频| 黄色亚洲大片免费在线观看| 婷婷av一区二区三区| 欧美黄片高清免费播放| 久久伊人亚洲精品中文字幕| 国产精品中文第一字幕| 精品人妻av区天天看片| 中高龄夫妇五十路六十路| 99精品欧美一区二区三区视频| 亚洲国产欧美日韩在线一区| 特别黄的日本免费视频| 国产日韩欧美一区综合| 日本欧美三级一二三区| 日韩欧美一区二区大片| 成人又黄又爽大片在线观看| 亚洲天堂av一区二区在线| 日韩精品在线免费观看了| 亚洲av成人噜噜网站| 69国产精品久久久久久人| 亚洲巨人精品福利导航| 国产系列在线播放一区二区三区| 国产精品传媒在线观看网站| 国产日本福利在线综合网| 久久夜色精品国产高清不卡| 人妻一少妇一区二区三区| 精品国产av一区二区麻豆| 日韩亚洲欧美不卡在线| 五月天久久开心激情网| 午夜激情视频在线网站| 免费看男人添女人无遮挡| 日韩精品少妇一区二区在线看| 九九九热在线观看视频| 日本成人午夜电影网站| 欧美成人精品免费在线| 日韩欧美中文字幕综合网|