springboot mybatis调用多个数据源引发的错误问题

针对“springboot mybatis调用多个数据源引发的错误问题”,我可以提供如下的攻略过程:

问题背景

在使用SpringBoot和Mybatis框架进行数据源操作时,可能会遇到需要多个数据源的情况,比如:读取或写入的数据源不同,或者需要连接不同的数据库等情况。在这种情况下,我们需要自定义DataSource,同时配置多个SqlSessionFactory和TransactionManager,并且需要在Mapper类上指定使用的数据源名称。但是很多开发者在操作时可能会遇到相关的错误问题,这也是我们本次攻略的重点。

解决方案

1. 自定义多数据源

自定义多数据源需要做如下几点准备:

  1. 定义多个DataSource,可以通过@Configuration和@Bean的方式注入;
  2. 分别配置多个SqlSessionFactory,并且指定使用的DataSource;
  3. 分别配置多个TransactionManager,并且指定使用的DataSource;
  4. 使用MapperScannerConfigurer扫描指定包下的Mapper类,并指定使用的SqlSessionFactory;
  5. 在Mapper类上使用@Qualifier注解指定使用的DataSource名称。

示例代码如下:

@Configuration
@MapperScan(basePackages = "com.example.demo.mapper.test1", sqlSessionTemplateRef = "test1SqlSessionTemplate")
public class DataSource1Config {

    @Primary
    @Bean(name = "test1DataSource")
    @ConfigurationProperties(prefix = "spring.datasource.test1")
    public DataSource test1DataSource() {
        return DataSourceBuilder.create().build();
    }

    @Primary
    @Bean(name = "test1SqlSessionFactory")
    public SqlSessionFactory test1SqlSessionFactory(@Qualifier("test1DataSource") DataSource test1DataSource) throws Exception {
        SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
        bean.setDataSource(test1DataSource);
        return bean.getObject();
    }

    @Primary
    @Bean(name = "test1TransactionManager")
    public DataSourceTransactionManager test1TransactionManager(@Qualifier("test1DataSource") DataSource test1DataSource) {
        return new DataSourceTransactionManager(test1DataSource);
    }

    @Primary
    @Bean(name = "test1SqlSessionTemplate")
    public SqlSessionTemplate test1SqlSessionTemplate(@Qualifier("test1SqlSessionFactory") SqlSessionFactory test1SqlSessionFactory) throws Exception {
        return new SqlSessionTemplate(test1SqlSessionFactory);
    }
}
@Configuration
@MapperScan(basePackages = "com.example.demo.mapper.test2", sqlSessionTemplateRef = "test2SqlSessionTemplate")
public class DataSource2Config {

    @Bean(name = "test2DataSource")
    @ConfigurationProperties(prefix = "spring.datasource.test2")
    public DataSource test2DataSource() {
        return DataSourceBuilder.create().build();
    }

    @Bean(name = "test2SqlSessionFactory")
    public SqlSessionFactory test2SqlSessionFactory(@Qualifier("test2DataSource") DataSource test2DataSource) throws Exception {
        SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
        bean.setDataSource(test2DataSource);
        return bean.getObject();
    }

    @Bean(name = "test2TransactionManager")
    public DataSourceTransactionManager test2TransactionManager(@Qualifier("test2DataSource") DataSource test2DataSource) {
        return new DataSourceTransactionManager(test2DataSource);
    }

    @Bean(name = "test2SqlSessionTemplate")
    public SqlSessionTemplate test2SqlSessionTemplate(@Qualifier("test2SqlSessionFactory") SqlSessionFactory test2SqlSessionFactory) throws Exception {
        return new SqlSessionTemplate(test2SqlSessionFactory);
    }
}

2. 指定Mapper使用的数据源

为了解决调用多个数据源引发的错误问题,我们需要在Mapper类上明确指定使用的数据源,这可以通过在Mapper类上添加@Qualifier注解实现,如下所示:

public interface TestMapper {
    @Qualifier("test1DataSource")
    @Select("SELECT * FROM test1 WHERE id = #{id}")
    Test1 getTest1ById(@Param("id") Integer id);

    @Qualifier("test2DataSource")
    @Select("SELECT * FROM test2 WHERE id = #{id}")
    Test2 getTest2ById(@Param("id") Integer id);
}

这样,每个方法都可以明确使用哪个数据源,Mybatis也可以正确地根据指定的DataSource进行数据源切换,避免错误的引用。

示例

我们假设我们需要创建两个数据库test1和test2,每个数据库中都有一个表,分别是test1和test2。下面我们就演示如何通过上述的自定义多数据源和指定Mapper使用的数据源方案,来实现多数据源的操作。

1. 环境搭建

  • 创建两个数据库test1和test2,分别创建test1数据源和test2数据源,并在两个数据源中分别插入一些测试数据。
  • 在Maven工程中添加如下依赖:
<dependency>
    <groupId>org.mybatis.spring.boot</groupId>
    <artifactId>mybatis-spring-boot-starter</artifactId>
    <version>2.2.0</version>
</dependency>

2. 创建实体类和Mapper类

为了演示需要,我们需要在test1和test2中,各创建一个实体类和Mapper类。

test1实体类:

@Data
public class Test1 {
    private Integer id;
    private String name;
}

test1 Mapper类:

public interface Test1Mapper {
    @Select("SELECT * FROM test1 WHERE id = #{id}")
    Test1 getTest1ById(@Param("id") Integer id);
}

test2实体类:

@Data
public class Test2 {
    private Integer id;
    private String name;
}

test2 Mapper类:

public interface Test2Mapper {
    @Select("SELECT * FROM test2 WHERE id = #{id}")
    Test2 getTest2ById(@Param("id") Integer id);
}

3. 创建Controller类

我们创建一个TestController类,提供如下接口:

  • /test1/{id}:获取test1中指定id的数据;
  • /test2/{id}:获取test2中指定id的数据。
@RestController
public class TestController {

    @Autowired
    private Test1Mapper test1Mapper;
    @Autowired
    private Test2Mapper test2Mapper;

    @GetMapping("/test1/{id}")
    public Test1 getTest1ById(@PathVariable Integer id) {
        return test1Mapper.getTest1ById(id);
    }

    @GetMapping("/test2/{id}")
    public Test2 getTest2ById(@PathVariable Integer id) {
        return test2Mapper.getTest2ById(id);
    }
}

4. 配置多数据源

在我们的application.properties文件中添加如下配置:

# DataSource1
spring.datasource.test1.type=com.alibaba.druid.pool.DruidDataSource
spring.datasource.test1.driver-class-name=com.mysql.cj.jdbc.Driver
spring.datasource.test1.url=jdbc:mysql://localhost:3306/test1?useUnicode=true&characterEncoding=utf-8&useSSL=false
spring.datasource.test1.username=root
spring.datasource.test1.password=root
spring.datasource.test1.initialSize=10
spring.datasource.test1.minIdle=5
spring.datasource.test1.maxActive=50
spring.datasource.test1.validationQuery=SELECT 1 FROM DUAL
spring.datasource.test1.testWhileIdle=true
spring.datasource.test1.testOnBorrow=false
spring.datasource.test1.testOnReturn=false
spring.datasource.test1.poolPreparedStatements=true
spring.datasource.test1.maxPoolPreparedStatementPerConnectionSize=20
spring.datasource.test1.filters=wall,stat

# DataSource2
spring.datasource.test2.type=com.alibaba.druid.pool.DruidDataSource
spring.datasource.test2.driver-class-name=com.mysql.cj.jdbc.Driver
spring.datasource.test2.url=jdbc:mysql://localhost:3306/test2?useUnicode=true&characterEncoding=utf-8&useSSL=false
spring.datasource.test2.username=root
spring.datasource.test2.password=root
spring.datasource.test2.initialSize=10
spring.datasource.test2.minIdle=5
spring.datasource.test2.maxActive=50
spring.datasource.test2.validationQuery=SELECT 1 FROM DUAL
spring.datasource.test2.testWhileIdle=true
spring.datasource.test2.testOnBorrow=false
spring.datasource.test2.testOnReturn=false
spring.datasource.test2.poolPreparedStatements=true
spring.datasource.test2.maxPoolPreparedStatementPerConnectionSize=20
spring.datasource.test2.filters=wall,stat

5. 启动运行

现在,我们可以直接运行应用程序,并使用如下地址进行访问:

  • http://localhost:8080/test1/1
  • http://localhost:8080/test2/1

分别对test1和test2进行获取数据操作,验证我们的多数据源操作是否生效。

总结

以上就是相关攻略的详细讲解,需要特别注意的是,在实际应用中,可能还需要配置多个数据库连接池,并且需要考虑到安全性、性能等因素,需要根据实际情况进行调整。同时也需要指出的是,Mybatis-plus等工具类在多数据源环境下的使用会更加简单方便,可以考虑使用相应的工具类来进行操作。

本站文章如无特殊说明,均为本站原创,如若转载,请注明出处:springboot mybatis调用多个数据源引发的错误问题 - Python技术站

(0)
上一篇 2023年5月18日
下一篇 2023年5月18日

相关文章

  • Mysql表的操作方法详细介绍

    我来为您详细讲解 Mysql 表的操作方法。下面将包含创建、修改、删除表格等操作。 创建表格 要创建一个表格,您需要使用 CREATE TABLE 语句。以下是创建表格的基本语法: CREATE TABLE table_name ( column1 datatype, column2 datatype, column3 datatype, …. ); 其…

    database 2023年5月22日
    00
  • idea中连接数据库时出现SSL错误的问题

    关于“idea中连接数据库时出现SSL错误的问题”,整理了以下攻略供大家参考: 问题描述 在使用idea连接MySQL数据库时,出现如下错误:SSL connection error: SSL is required but the server doesn’t support it 问题分析 出现该错误的主要原因是MySQL数据库需要SSL协议进行访问,但…

    database 2023年5月18日
    00
  • 关于对mysql语句进行监控的方法详解

    下面是关于对MySQL语句进行监控的方法详解: 监控MySQL语句的方法 在MySQL中,监控SQL语句的方式有多种。下面将介绍比较常用的两种方法。 1. 使用MySQL慢查询日志 MySQL慢查询日志是MySQL提供的一种记录执行时间超过指定阈值的SQL查询语句的日志。它能记录超过指定时间阈值的SQL语句,可以方便的监控SQL执行效率,从而找出影响性能的S…

    database 2023年5月21日
    00
  • MySql中的连接查询问题怎么解决

    本文小编为大家详细介绍“MySql中的连接查询问题怎么解决”,内容详细,步骤清晰,细节处理妥当,希望这篇“MySql中的连接查询问题怎么解决”文章能帮助大家解决疑惑,下面跟着小编的思路慢慢深入,一起来学习新知识吧。 连接查询 当进行多表连接查询时 需要指定字段所属的表 , 可以提高查询效率 , 如果不指定字段所属的表 , 数据库会从每个表中都找一下该字段 e…

    MySQL 2023年4月11日
    00
  • vscode内网访问服务器的方法

    下面是详细的“vscode内网访问服务器的方法”的攻略。 什么是vscode内网访问服务器? 通常情况下,我们的电脑和服务器一般都处于同一个局域网,如果我们直接在vscode上连接服务器,即使服务器开了对外映射的端口,也无法直接连接,这就是内网访问。 解决方法 要解决这个问题,我们可以通过在本地电脑与服务器之间建立一个SSH隧道,来实现内网访问。下面我们将具…

    database 2023年5月22日
    00
  • iis访问出现各种问题(Vs访问正常)的部分处理方法详细整理

    iis访问出现各种问题的处理方法详细整理 问题描述 在使用 IIS 进行网站搭建时,有时候会出现无法访问网站、网站响应慢、访问速度慢等问题,可能会对网站的正常运营造成一定的影响。而使用 Visual Studio 进行网站开发时,则不会出现类似的问题。那么如何解决 IIS 访问中出现的各种问题呢? 解决方法 1.检查 IIS 配置 首先,我们需要检查 IIS…

    database 2023年5月21日
    00
  • VMware下CentOS静默安装oracle12.2详细图文教程

    VMware下CentOS静默安装oracle12.2详细图文教程 前言 为了方便大家在VMware环境下快速完成Oracle12.2的安装,本教程提供VMware下CentOS静默安装oracle12.2的详细图文教程,供大家参考。 环境要求 VMware虚拟机 CentOS 7安装镜像 Oracle 12.2安装介质 步骤 1. 安装CentOS 7系统…

    database 2023年5月22日
    00
  • SQL 多表联合查询的几种方式详解

    SQL 多表联合查询的几种方式详解 SQL 中的多表联合查询常用于在多个相关表中查找数据,根据一些条件将它们连接起来,从而以一种更结构化和有意义的方式获取信息。 在本文中,将介绍多种实现多表联合查询的方法。 基础语法 首先,我们先来介绍一下 SQL 多表查询的基本语法: SELECT column_name(s) FROM table_name_1 JOIN…

    database 2023年5月22日
    00
合作推广
合作推广
分享本页
返回顶部