日本免费高清视频-国产福利视频导航-黄色在线播放国产-天天操天天操天天操天天操|www.shdianci.com

學無先后,達者為師

網站首頁 編程語言 正文

Dynamic-DataSource多數據源配置mybatis/mybatis-plus

作者:PH = 7 更新時間: 2022-09-25 編程語言

參考資料:

  • 參考視頻(講述多數據源實現原理,以及原生的多數據源實現方式,Dynamic-DataSource的基本使用)
  • 官方github(dynamic-datasource-spring-boot-starter的源碼,用處不大)
  • 官方文檔(具有很高的參考價值,你想要的這里都有,不過是要收費的)
  • 個人demo及視頻參考資料

內容簡介:

  1. Dynamic-DataSource 可以和絕大多是連接層插件搭配使用,比如:mybatis,mybatis-plus,hibernate等
  2. 如果公司不允許使用Dynamic-DataSource,可以參考上述視頻進行原生代碼的編寫
  3. 本示例僅講就基本的使用(多數據源及事務),如果還需要更多功能,可參考上述官方文檔進行編碼

搭建示例(mybatis):

  • 首先搭建一個springBoot框架,參考
  • 然后創建兩個數據庫,模擬讀寫分離,每個數據庫有個user表
CREATE TABLE `user`  (
  `id` int(0) NOT NULL AUTO_INCREMENT,
  `userName` varchar(32) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL,
  `passWord` varchar(50) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL,
  `realName` varchar(32) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
  PRIMARY KEY (`id`) USING BTREE,
  INDEX `userName_index`(`userName`) USING BTREE
) ENGINE = InnoDB AUTO_INCREMENT = 975224 CHARACTER SET = utf8 COLLATE = utf8_general_ci ROW_FORMAT = Dynamic;

  • ?導入數據庫

        <dependency>
            <groupId>com.baomidou</groupId>
            <artifactId>dynamic-datasource-spring-boot-starter</artifactId>
            <version>3.5.2</version>
        </dependency>
  • 配置數據源?
server:
  port: 8088
spring:
  datasource:
    dynamic:
      #設置默認的數據源或者數據源組,默認值即為master
      primary: master
      #嚴格匹配數據源,默認false. true未匹配到指定數據源時拋異常,false使用默認數據源
      strict: false
      datasource:
        master:
          url: jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=utf-8&useSSL=true&serverTimezone=UTC
          username: root
          password: 123888
          driver-class-name: com.mysql.jdbc.Driver
        slave_1:
          url: jdbc:mysql://localhost:3306/user?useUnicode=true&characterEncoding=utf-8&useSSL=true&serverTimezone=UTC
          username: root
          password: 123888
          driver-class-name: com.mysql.jdbc.Driver


mybatis:
  mapper-locations: classpath:mapper/*.xml
  type-aliases-package: com.example.demo.model

#idea配置文件默認不允許有中文注釋
logging:
  level:
    com.example.demo.dao: debug
  • 其他的MVC層,正嘗寫就行,只需要在對應的類,方法或接口上添加@DS注解來進行數據源的切換即可?,關于DS注解詳情,可參考上面的官方文檔

@DS?可以注解在方法上或類上,同時存在就近原則 方法上注解 優先于 類上注解

注解 結果
沒有@DS 默認數據源
@DS("dsName") dsName可以為組名也可以為具體某個庫的名稱
  • UserMapping.xml
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.example.dynamicdatasourcemybatis.dao.UserMapper">

    <resultMap id="BaseResultMap" type="com.example.dynamicdatasourcemybatis.model.User">
        <result column="id" jdbcType="INTEGER" property="id" />
        <result column="userName" jdbcType="VARCHAR" property="userName" />
        <result column="passWord" jdbcType="VARCHAR" property="passWord" />
        <result column="realName" jdbcType="VARCHAR" property="realName" />
    </resultMap>

    <select id="Sel" resultType="com.example.dynamicdatasourcemybatis.model.User">
        select * from user where id = #{id}
    </select>

    <insert id="insertUser" parameterType="com.example.dynamicdatasourcemybatis.model.User">
        insert into user(id,userName,passWord,realName) values(#{id},#{userName},#{passWord},#{realName})
    </insert>

</mapper>
  • dao層? ?(這里通過@DS來選擇數據源)
package com.example.dynamicdatasourcemybatis.dao;

import com.baomidou.dynamic.datasource.annotation.DS;
import com.example.dynamicdatasourcemybatis.model.User;
import org.apache.ibatis.annotations.Mapper;


@Mapper
public interface UserMapper {

    //通過@DS  來選擇  配置文件中的master  數據源
    @DS("master")
    User Sel(int id);

    //通過@DS  來選擇  配置文件中的master  數據源
    @DS("slave_1")
    Integer insertUser(User u);
}
  • service層,這里也可以在方法上加@DS 來選擇數據源,這里就不演示了
package com.example.dynamicdatasourcemybatis.service;


import com.baomidou.dynamic.datasource.annotation.DS;
import com.example.dynamicdatasourcemybatis.dao.UserMapper;
import com.example.dynamicdatasourcemybatis.model.User;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.Random;
import java.util.UUID;


@Service
//@DS("master")   這里指定整個類使用的數據源
public class UserService {
    @Autowired
    UserMapper userMapper;

    //分庫分表  中 從 test 庫中查找
    //@DS("master")   這里指定整個方法使用的數據源
    public User Sel(int id){
        return userMapper.Sel(id);
    }


    //分庫分表  中 存入 user 庫
    //@DS("master")   這里指定整個方法使用的數據源
    public Integer insertUser(){
        User user = new User();
        user.setId(1000+new Random().nextInt());
        user.setPassWord(UUID.randomUUID().toString());
        user.setUserName("張老三");
        user.setRealName("張三");
        return userMapper.insertUser(user);
    }

    //@DS("master")   這里指定整個方法使用的數據源
    public Integer testTrans(){
        User user = new User();
        user.setId(1000+new Random().nextInt());
        user.setPassWord(UUID.randomUUID().toString());
        user.setUserName("李老四");
        user.setRealName("李四");
        userMapper.insertUser(user);
        System.out.println("==========構建錯誤,測試回滾==============");
        System.out.println(1/0);
        return 0;


    }


}

  • controller層? 這里也可以在方法或者類上 使用@DS來選擇數據源
package com.example.dynamicdatasourcemybatis.controller;

import com.example.dynamicdatasourcemybatis.model.User;
import com.example.dynamicdatasourcemybatis.service.UserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.ui.Model;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;


/**
 * @Author:wjup
 * @Date: 2018/9/26 0026
 * @Time: 14:42
 * 用多數據源來模擬分庫分表   master 負責  讀  操作  slave_1   負責  寫操作
 */

@Controller
@RequestMapping("/testBoot")
public class UserController {

    @Autowired
    private UserService userService;

    @RequestMapping("getUser/{id}")
    public String GetUser(@PathVariable int id,Model model){
        User user =  userService.Sel(id);
        model.addAttribute("user", user);
        System.out.println("xxxxxxxxxxxxxxxxxx"+user.toString());
        return "index";
    }

    @RequestMapping("getUser/insert")
    @ResponseBody
    public String GetUser(){
        return String.valueOf(userService.insertUser());
    }


    //測試事務
    @RequestMapping("getUser/testTrans")
    @Transactional
    @ResponseBody
    public String testTrans(){
        return String.valueOf(userService.testTrans());
    }



}
  • 如果需要事務的話,用@Transactional? ?即可,同上
  • 然后最后的就是上面的參考demo


功能擴展(mybatis-plus):

  • 關于mybatis-plus的多數據源切換,同樣也是導入依賴,然后使用@DS在類或者方法上控制數據源即可
  • 實在不會參考上述官方文檔

原文鏈接:https://blog.csdn.net/qq_23095607/article/details/127031349

欄目分類
最近更新