spring-data 一统江湖,玩转多种数据源

news2024/10/7 4:23:56

1、起因

因为要在项目中同时访问redis,mongo和mysql三种数据库,而且因为偏向spring-data,所以都使用了spring-data

在使用的过程中如果不做配置发现会有冲突,这篇文章也是解决这个问题,避免以后遇到同样的问题不知所措

2、项目实战

2.1 创建springboot项目

没啥好说的,直接一路next,使用maven管理项目

2.2 加入spring-data的配置

这里使用了mongo和mysql,也是工作中常用的两个数据库,pom中配置如下

<dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-jpa</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-mongodb</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

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

2.3 配置数据源

application.yml中主要是数据库的链接信息,mysql 和mongo的

server:
  port: 9099
spring:
  data:
    mongodb:
      uri: mongodb://172.26.1.152:27017/ccp_test
  datasource:
    driver-class-name: com.mysql.cj.jdbc.Driver
    type: com.zaxxer.hikari.HikariDataSource
    url: jdbc:mysql://172.26.1.152:3306/cx_test?characterEncoding=utf8&serverTimezone=UTC
    username: root
    password: 123456
    hikari:
      minimum-idle: 10
      maximum-pool-size: 150
      connection-test-query: SELECT 1 FROM DUAL
      connection-timeout: 600
      idleTimeout: 30000
      maxLifetime: 40000
      validation-timeout: 300
      login-timeout: 10
  jpa:
    show-sql: true

2.4 配置entity

这里是使用mysql的entity,mongo中直接复用同样的entity,

@Data
@Entity
@Table(name = "test_table")
@Document(collection = "test_table")
public class TestTable implements Serializable {

    private static final long serialVersionUID = 1L;    
    @Id    
    @Column(name = "id", nullable = false)
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    private Integer id;    
    @Column(name = "name")
    private String name;}

2.5 分别创建Repository

mysql的Repository,操作mysql 数据

package com.xin.mongoandmysql.dao.mysql;

import com.xin.mongoandmysql.entity.TestTable;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.data.jpa.repository.JpaSpecificationExecutor;

public interface TestTableRepository extends JpaRepository<TestTable, Integer>, JpaSpecificationExecutor<TestTable> {

}

mongo的Repository,操作mongo 数据

package com.xin.mongoandmysql.dao.mongo;

import com.xin.mongoandmysql.entity.TestTable;
import org.springframework.data.mongodb.repository.MongoRepository;

public interface MongoTableRepository extends MongoRepository<TestTable, String> {
}

注:上面两个repo 放在不同的包下面,不同数据库集成的repo不同

 

2.6 配置扫描的包

@SpringBootApplication
@EnableMongoRepositories(basePackages = {"com.xin.mongoandmysql.dao.mongo"})
@EnableJpaRepositories(basePackages = "com.xin.mongoandmysql.dao.mysql")
public class MongoAndMysqlApplication {
    public static void main(String[] args) {
        SpringApplication.run(MongoAndMysqlApplication.class, args);    }
}

这里很重要,配置mysql 和mongo的扫描路径,也是这里的难点,后面会讲原理和为什么

2.7 测试

创建一个简单的controller就行

@RestController
public class TestController {
    @Resource
    MongoTableRepository mongoTableRepository;
    @Resource
    TestTableRepository testTableRepository;
    @GetMapping("/test")
    public void test(){
        TestTable testTable = new TestTable();
        testTable.setName("香菜");
        testTable.setId(1);
        mongoTableRepository.save(testTable);
        testTableRepository.save(testTable);
    }
}

直接调用接口,就可以看到数据存入数据库,OK,实验结束。

2.8 看下结果

可以看到mysql和mongo 都存入了数据

3、打怪之旅

3.1 服务器启动不了,bean注册失败

最初的时候因为没有分包扫描,导致服务器启动失败,之前没怎么注意过这件事

原因是因为jpa和mongo都会去根路径下扫描所有的repo,然后生成动态代理,

mysql 扫描到testRepo会生成代理

mongo扫描到testRepo也会生成代理

两者都会想容器进行注册,这就导致bean出现重名的现象

源码:

org.springframework.data.repository.config.RepositoryConfigurationDelegate#registerRepositoriesIn

这里可以看到,RepositoryConfigurationDelegate来自spring-data-commons的包,mysql和mongo都会调用

在源码中可以看到有个basePackages的属性,如果不配置,默认是从根路径进行扫描,就会出现被代理多次注册的问题

3.2 spring-data 是如何实现repo中的接口的

在一个项目中有多个 spring-data 模块时,尝试为特定实体创建一个接口,该接口没有使用特定的持久性技术注释进行注释

(如 javax.persistence 中的@Entity,或 mongo 中的@Document),通过从 spring-data-commons 模块(即 Repository 或 CrudRepository)扩展接口 - 这根本不起作用,因为 spring 基本上不知道你的实体与哪个数据存储相关联。

在 Spring 内部有一个抽象,称为RepositoryFactoryBeanSupport。尝试将 spring data jdbc starter 和 spring data mongodb starter 添加到您的项目中。你会注意到,在类路径中有2 个不同的 RepositoryFactoryBeanSupport 实现:

  1. JdbcRepositoryFactoryBean(来自spring data jdbc starter)
  2. MongoRepositoryFactoryBean(来自spring data mongo starter)

如何让不同的repo关联相应的数据库

  1. 扩展特定于技术的存储库。例如,如果希望实体 A 与 PostgreSQL 关联,则不要使用 CrudRepository - 应该使用 JpaRepository。如果希望实体 B 与 Redis 相关联,请使用 RedisRepository 等。
  2. 使用注释对您的实体进行注释,表明它隶属于特定的数据存储。如@Entity、@Document、@Table 等。

总结

注:分包扫描是解决问题的重点

很久之前写的文章了,在看之前回想一下,依然没有清晰的理解

复习一遍就掌握了,学而时习之不亦乐乎

关注点赞,一键三连,感谢支持

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.coloradmin.cn/o/554388.html

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

【SAM系列】CAN SAM COUNT ANYTHING? AN EMPIRICAL STUDY ON SAM COUNTING

论文链接&#xff1a;https://arxiv.org/abs/2304.10817 代码链接&#xff1a;https://github.com/vision-intelligence-and-robots-group/count-anything 目的 探索SAM在few-shot setting的object counting的能力。 结论 它目前落后于最先进的few-shot object counting方法…

出门没带本子记的单词|10:20~10:40

susceptible adj 易受影响的 unify v 统一 auditory adj 听觉的 / ˈɔːdətɔːri / combat v 与...搏斗、防止 comfort n 舒适 constrain v 约束、迫使 fringe …

Swift 周报 第二十九期

文章目录 前言新闻和社区担心泄密&#xff01;外媒&#xff1a;苹果公司限制员工使用ChatGPT苹果公司大幅削减其MR头显销售预期&#xff0c;不足百万台 提案通过的提案正在审查的提案 Swift 论坛1、讨论 SwiftUI 图表、超大数据集和图表叠加2、讨论带有线程安全属性包装器的可发…

【SpringBoot知识点预备】| Xml 和 JavaConfig

目录 一&#xff1a;Xml 和 JavaConfig 1. JavaConfig 2. ImportResource注解 3. PropertyResource注解 一&#xff1a;Xml 和 JavaConfig 1. JavaConfig &#xff08;1&#xff09;为什么要使用 Spring Boot&#xff1f; ①因为Spring、SpringMVC 的使用需要大量的配置文…

【Java EE】Springboot

Springboot Springboot 核心功能SpringBoot的相关好处 Springboot 核心功能 1、 可独立运行的Spring项目&#xff1a;Spring Boot可以以jar包的形式独立运行。 2、 内嵌的Servlet容器&#xff1a;Spring Boot可以选择内嵌Tomcat、Jetty或者Undertow&#xff0c;无须以war包形…

python cuda torch验证是否成功安装,版本是否匹配

1 、首先查看自己的显卡型号 根据nvcc-smi查到自己的显卡型号,如下图所示。 本人的电脑显卡型号为:GeForce GT 730 2、查看显卡算力 可以通过以下链接查找 http://www.5ityx.com/cate100/155907.html 可以看到我的显卡算力是3.5 备注:你的显卡计算力必须保证在3.5以上。如…

Kali-linux破解纯文本密码工具mimikatz

mimikatz是一款强大的系统密码破解获取工具。该工具有段时间是作为一个独立程序运行。现在已被添加到Metasploit框架中&#xff0c;并作为一个可加载的Meterpreter模块。当成功的获取到一个远程会话时&#xff0c;使用mimikatz工具可以很快的恢复密码。本节将介绍使用mimikatz工…

使用Python获取公众号下所有的文章

我比较喜欢看公众号&#xff0c;有时遇到一个感兴趣的公众号时&#xff0c;都会感觉相逢恨晚&#xff0c;想一口气看完所有历史文章。本文主要介绍了使用Python获取公众号下所有的文章&#xff0c;感兴趣的可以了解一下 导出公众号所有文章 随着互联网的不断发展&#xff0c;网…

【源码篇】基于SpringBoot+Jsp的日记记录系统

1、项目介绍 基于SpringBootJsp的日记记录系统所有功能均对用户开放&#xff0c;只有用户角色。 是一款面向用户的系统&#xff0c;用户可以自己注册账号进行登录&#xff0c;管理自己的信息(个人中心)、自由添加日记分类、发布日记来记录自己所遇到有趣的人和事、也可以发表…

BiFormer 实验记录

代码来自文中地址 目录 一、前向传播过程 1、Path Embedding 2、BiFormer Block BRA模块 网络结构 一、前向传播过程 1、Path Embedding 见网络结构部分&#xff0c;4倍下采样 2、BiFormer Block 对应 x x self.pos_embed(x) 对应 x x self.drop_path(self.attn(…

【5.22】七、移动App测试

目录 7.1 移动App测试概述 1. 移动App特性 2. 移动App测试与传统软件测试的区别 7.2 移动App测试要点 7.2.1 UI测试 7.2.2 功能测试 7.2.3 专项测试 7.2.4 性能测试 7.3 移动App测试流程 第三方测试平台 7.4 移动App测试工具 7.1 移动App测试概述 移动App&#xff…

就业内推 | 应届生专场,有华为、思科认证优先,六险一金

01 金科 &#x1f537;招聘岗位&#xff1a;网络工程师 &#x1f537;职责描述&#xff1a; 1、为银行、企业客户提供技术服务&#xff08;包括驻场支持和现场技术支持&#xff09;&#xff1b; 2、驻客户现场配合客户完成思科、华三、华为主流网络设备的配置、管理&#xff1…

基于C++的类UNIX文件系统

访问【WRITE-BUG数字空间】_[内附完整源码和文档] 一、题目要求 使用一个普通的大文件&#xff08;如 c:\myDisk.img &#xff0c;称之为一级文件&#xff09;模拟 UNIX V6的一个文件卷&#xff0c;一个文件卷实际上就是一张逻辑磁盘&#xff0c;磁盘中存储的信息以块为单位。…

小航助学2023年3月GESP_C++一级试卷(含题库答题软件账号)

GESP在线模拟训练系统请点击 电子学会-全国青少年编程等级考试真题Scratch一级&#xff08;2019年3月&#xff09;在线答题_程序猿下山的博客-CSDN博客_小航答题助手 答案:B 第1题以下不属于计算机输入设备的有&#xff08; &#xff09;。 A、键盘B、音箱C、鼠标D、传感器 …

如何使用Python和wxPython构建一个HTML Title提取工具

以下代码可以用于以下场景&#xff1a; 在Web开发中&#xff0c;获取网页中的Title内容&#xff0c;以用于页面SEO。在数据挖掘和分析中&#xff0c;获取包含Title信息的HTML页面&#xff0c;以进行进一步的文本处理和分析。在一些需要从HTML源代码中获取元数据的应用中&#…

STM32单片机语音识别家庭灯光控制系统

实践制作DIY- GC0132-语音识别家庭灯光控制系统 一、功能说明&#xff1a; 基于STM32单片机设计-语音识别家庭灯光控制系统 二、功能介绍&#xff1a; STM32F103C系列最小系统板语音识别模块18650锂电池太阳能充电板LCD1602显示器4个LED灯板对应卧室、厨房、客厅、厕所…

Springboot +spring security,自定义认证器实现验证码功能

一.简介 SpringSecurity 默认是不支持验证码功能的&#xff0c;但是可以自己扩展&#xff0c;这也是使用SpringSecurity的好处之一&#xff0c;原生不支持&#xff0c;我们就自己扩展。 二.思路分析 因为系统默认的有一个DaoAuthenticationProvider 认证处理器&#xff0c;但…

springboot+java高校学生学分置换系统安全开发

本选题具有以下5个方面的意义&#xff1a; &#xff08;1&#xff09;减少人工的繁琐宣传组织统计时间&#xff0c;提高工作效率和工作精确度以扩大比赛的规模[4]。 &#xff08;2&#xff09;将人工阶段难以实现的公开、公正、公平&#xff0c;通过多方监督的方法进行解决。 &…

美陆军面向战场物联网的边缘智能发展综述

欢迎关注博主 Mindtechnist 或加入【Linux C/C/Python社区】一起学习和分享Linux、C、C、Python、Matlab&#xff0c;机器人运动控制、多机器人协作&#xff0c;智能优化算法&#xff0c;滤波估计、多传感器信息融合&#xff0c;机器学习&#xff0c;人工智能等相关领域的知识和…

UVC调用过程部分细节分析

UVC调用过程部分细节分析 文章目录 UVC调用过程部分细节分析概括分析UVC驱动调用过程1.open:ioctl 2.VIDIOC_QUERYCAP3.VIDIOC_ENUM_FMT4.VIDIOC_G_FMT5.VIDIOC_TRY_FMT6.VIDIOC_S_FMT /7.VIDIOC_REQBUFS8.VIDIOC_QUERYBUF9.mmap10.VIDIOC_QBUF11.VIDIOC_STREAMON12.poll13.VID…