Spring整合Mycat2的具體過程詳解

更新時間：2023年05月24日 11:48:56 作者：Lonely Faith

這篇文章主要給大家介紹Springboot整合Mycat2的具體過程，文中有詳細的圖解過程，感興趣的小伙伴可以跟著小編一起來學習

Springboot連接Mycat2

環(huán)境準備：

http://t.csdn.cn/zRO5v

創(chuàng)建Springboot項目

在這里插入圖片描述

1.新建項目：

配置好對應的選項：

在這里插入圖片描述

選擇好對應的springboot版本，和項目自帶的默認依賴：

如果你的環(huán)境搭建的時候是按照上面的教程搭建，那么請選擇MySQL Drive驅(qū)動

在這里插入圖片描述

配置Maven：

$[外鏈圖片轉(zhuǎn)存失敗,源站可能有防盜鏈機制,建議將圖片保存下來直接上傳(img-GxCupYk1-1684724379377)(C:\Users\ubunt\AppData\Roaming\Typora\typora-user-images\1684720903155.png)]$

如果下載速度慢，請在Maven的/conf/settings.xml文件中配置國內(nèi)鏡像源

在這里插入圖片描述

等待Mave依賴同步完成。。。。。

在這里插入圖片描述

將配置文件改為yml后綴

在這里插入圖片描述

pom.xml

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>druid-spring-boot-starter</artifactId>
            <version>1.1.10</version>
        </dependency>
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>5.1.42</version>
            <scope>runtime</scope>
        </dependency>
        <dependency>
            <groupId>org.mybatis.spring.boot</groupId>
            <artifactId>mybatis-spring-boot-starter</artifactId>
            <version>2.1.0</version>
        </dependency>

修改配置文件.yml

server:
  port: 8080
spring:
  main:
    allow-bean-definition-overriding: true
  application:
    name: mycat
  # Mycat配置信息
  datasource:
    url: jdbc:mysql://192.168.174.138:8066/TESTDB?useUnicode=true&characterEncoding=utf-8&autoReconnect=true&zeroDateTimeBehavior=convertToNull&useSSL=false&serverTimezone=GMT%2B8
    username: root
    password: 123456
    # mybatis是依賴5.*的版本，所以相對于8.*的少個cj；
    driver-class-name: com.mysql.jdbc.Driver
# MyBatis
mybatis:
  type-aliases-package: com.example.bootmycat.dao
  mapper-locations: classpath:/mapper/*.xml
  configuration:
    map-underscore-to-camel-case: true

新建一個實體類

/**
 * @author jigua
 * @version 1.0
 * @className Enterprise
 * @description
 * @create 2022/9/27 16:14
 */
public class Enterprise {
    private Long id;
    private String phone;
    private String name;
    public Long getId() {
        return id;
    }
    public void setId(Long id) {
        this.id = id;
    }
    public String getPhone() {
        return phone;
    }
    public void setPhone(String phone) {
        this.phone = phone;
    }
    public String getName() {
        return name;
    }
    public void setName(String name) {
        this.name = name;
    }
}

新建一個dao

import com.example.bootmycat.pojo.Enterprise;
import org.apache.ibatis.annotations.Insert;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Select;
import java.util.List;
/**
 * @author jigua
 * @version 1.0
 * @className TestDao
 * @description
 * @create 2022/9/27 16:13
 */
@Mapper
public interface TestDao {
    @Select("select * from enterprise")
    List<Enterprise> selectAll();
    @Insert("insert into enterprise(phone,name) values(#{phone},#{name})")
    int add(Enterprise enterprise);
}

新建一個controller
- 示例提供一個查詢和一個插入方法

import com.example.bootmycat.dao.TestDao;
import com.example.bootmycat.pojo.Enterprise;
import org.springframework.beans.factory.annotation.Autowired;
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 java.util.List;
import java.util.UUID;
/**
 * @author jigua
 * @version 1.0
 * @className TestController
 * @description
 * @create 2022/9/27 16:15
 */
@RestController
@RequestMapping("/test")
public class TestController {
    @Autowired
    private TestDao testDao;
    @GetMapping("/selectAll")
    @ResponseBody
    public List<Enterprise> selectAll() {
        List<Enterprise> enterprises = testDao.selectAll();
        return enterprises;
    }
    @GetMapping("/insert")
    @ResponseBody
    public String insert() {
        Enterprise enterprise = new Enterprise();
        String name = UUID.randomUUID().toString().replaceAll("-", "");
        enterprise.setName(name);
        enterprise.setPhone(name.substring(0, 3));
        int i = testDao.add(enterprise);
        if (i > 0) {
            return "success";
        }
        return "fail";
    }
}

最終文件目錄結(jié)構(gòu)圖：

在這里插入圖片描述