springboot整合mybatis配置多数据源(mysql/oracle)

news/2024/9/24 21:28:43/

目录

  • 前言
  • 导入依赖坐标
  • 创建mysql/oracle数据源配置类
    • MySQLDataSourceConfig
    • OracleDataSourceConfig
  • application.yml配置文件配置mysql/oracle数据源
  • 编写Mapper接口
  • 编写Book实体类
  • 编写测试类

前言

springboot整合mybatis配置多数据源,可以都是mysql数据源,也可以都是oracle数据源,也可以mysql/oracle数据源都有,下面是配置多数据源的步骤(不局限与某一类数据库),之前配过都是oracle数据源的配置,下面是验证这个想法的实现,实现效果后,好像也可以同时配MongoDB、Redis等其他的数据源配置,但是好像也没碰到有人在一个项目里面这么干过…要么都是mysql数据源要么都是oracle数据源。

导入依赖坐标

<dependencies><!--springboot起步依赖--><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter</artifactId><version>${spring-boot.version}</version></dependency><!-- spring-boot-starter-web  --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><!--单元测试 包含junit-jupiter--><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency><!--springboot整合mybatis --><dependency><groupId>org.mybatis.spring.boot</groupId><artifactId>mybatis-spring-boot-starter</artifactId><version>${mybatis.version}</version></dependency><dependency><groupId>org.mybatis.spring.boot</groupId><artifactId>mybatis-spring-boot-starter-test</artifactId><version>${mybatis.version}</version><scope>test</scope></dependency><!--添加tk.mybatis用于对单表进行处理--><dependency><groupId>tk.mybatis</groupId><artifactId>mapper-spring-boot-starter</artifactId><version>${tk.mybatis.version}</version></dependency><!-- oracle驱动 --><dependency><groupId>com.oracle.database.jdbc</groupId><artifactId>ojdbc8</artifactId><version>${oracle.version}</version></dependency><!-- mysql驱动 --><dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><version>${mysql.version}</version></dependency><!-- alibaba/druid --><dependency><groupId>com.alibaba</groupId><artifactId>druid</artifactId><version>${druid.version}</version></dependency><!--c3p0连接池--><dependency><groupId>com.mchange</groupId><artifactId>c3p0</artifactId><version>${c3p0.version}</version></dependency>
</dependencies>

mysqloracle_69">创建mysql/oracle数据源配置类

MySQLDataSourceConfig

@Configuration
@MapperScan(basePackages = "com.example.dao.mysql", sqlSessionFactoryRef = "mysqlSessionFactory")
public class MySQLDataSourceConfig {@Primary // 表示这个数据源是默认数据源, 这个注解必须要加,因为不加的话spring将分不清楚那个为主数据源(默认数据源)@Bean("mysqlDataSource")//方式一:@ConfigurationProperties(prefix = "spring.datasource.mysql")@ConfigurationProperties(prefix = "spring.datasource.mysql") //读取application.yml中的配置参数映射成为一个对象public DataSource getMysqlDataSource() {return DataSourceBuilder.create().build();}//方式二:@Value注解方法 set方法注入yml数据源属性/*@Value("${spring.datasource.mysql.driver-class-name}")String driverClass;@Value("${spring.datasource.mysql.jdbc-url}")String url;@Value("${spring.datasource.mysql.username}")String userName;@Value("${spring.datasource.mysql.password}")String passWord;@Bean(name = "mysqlDataSource")@ConfigurationProperties("spring.datasource.mysql")public DataSource masterDataSource(){DriverManagerDataSource dataSource = new DriverManagerDataSource();dataSource.setDriverClass(driverClass);dataSource.setJdbcUrl(url);dataSource.setUser(userName);dataSource.setPassword(passWord);return dataSource;}*/@Primary@Bean("mysqlSessionFactory")public SqlSessionFactory mysqlSessionFactory(@Qualifier("mysqlDataSource") DataSource dataSource) throws Exception {SqlSessionFactoryBean bean = new SqlSessionFactoryBean();bean.setDataSource(dataSource);// mapper的xml形式文件位置必须要配置,不然将报错:no statement (这种错误也可能是mapper的xml中,namespace与项目的路径不一致导致)bean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath*:mapper/mysql/*.xml")); // 持久化.xml文件的地址return bean.getObject();}@Primary@Bean("mysqlSessionTemplate")public SqlSessionTemplate mysqlSessionTemplate(@Qualifier("mysqlSessionFactory") SqlSessionFactory sqlSessionFactory) {return new SqlSessionTemplate(sqlSessionFactory);}
}

OracleDataSourceConfig

@Configuration
@MapperScan(basePackages = "com.example.dao.oracle", sqlSessionFactoryRef = "oracleSessionFactory")
public class OracleDataSourceConfig {@Bean("oracleDataSource")@ConfigurationProperties(prefix = "spring.datasource.oracle") //读取application.yml中的配置参数映射成为一个对象public DataSource getOracleDataSource() {return DataSourceBuilder.create().build();}@Bean("oracleSessionFactory")public SqlSessionFactory oracleSessionFactory(@Qualifier("oracleDataSource") DataSource dataSource) throws Exception {SqlSessionFactoryBean bean = new SqlSessionFactoryBean();bean.setDataSource(dataSource);// mapper的xml形式文件位置必须要配置,不然将报错:no statement (这种错误也可能是mapper的xml中,namespace与项目的路径不一致导致)bean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath*:mapper/oracle/*.xml")); // 持久化.xml文件的地址return bean.getObject();}@Bean("oracleSessionTemplate")public SqlSessionTemplate oracleSessionTemplate(@Qualifier("oracleSessionFactory") SqlSessionFactory sqlSessionFactory) {return new SqlSessionTemplate(sqlSessionFactory);}

mysqloracle_149">application.yml配置文件配置mysql/oracle数据源

spring:# 配置数据源datasource:#单一数据源配置driver-class-name: com.mysql.cj.jdbc.Driverurl: jdbc:mysql://rhel:3306/note_bootusername: rootpassword: Redhat1#多数据源配置mysql:driver-class-name: com.mysql.cj.jdbc.Driverjdbc-url: jdbc:mysql://rhel:3306/note_bootusername: rootpassword: Redhat1oracle:driver-class-name: oracle.jdbc.OracleDriverjdbc-url: jdbc:oracle:thin:@//rhel:1521/orclusername: testdbpassword: oraclepasshikari:connection-timeout: 3000idle-timeout: 60000maximum-pool-size: 50minimum-idle: 5connection-test-query: select 1 from dualvalidation-timeout: 2000

编写Mapper接口

在这里插入图片描述

//BookDao里面都是两个简单查询测试方法,注解实现...
//mysql数据库测试
public Book getById(Integer id);
//oracle数据库测试
public Book findById(Integer id);

编写Book实体类

public class Book {private Integer id;private String name;private String type;private String description;//get/set方法省略...
}

编写测试类

public class MybatisDemo {@Autowiredprivate BookDao bookDao;@Autowiredprivate BookDao1 bookDao1;@Autowiredprivate BookDao2 bookDao2;@Testvoid test() {//原始配置,单一数据库查询Book book = bookDao.getById(1);System.out.println(book);//多数据源配置 mysql查询Book book1 = bookDao1.getById(1);System.out.println(book1);//多数据源配置 oracle查询Book book2 = bookDao2.findById(1);System.out.println(book2);}
}

效果图:
在这里插入图片描述


http://www.ppmy.cn/news/1456845.html

相关文章

C++中auto关键字的用法详解

1.简介 auto作为一个C语言就存在的关键字&#xff0c;在C语言和C之间却有很大区别。 在C语言中auto修饰的变量&#xff0c;是具有自动存储器的局部变量&#xff0c;但因为局部变量默认类别默认是auto修饰导致一直没有人去使用它。 C11中&#xff0c;标准委员会赋予了auto全新…

模版进阶篇章

非类型模版参数 回顾&#xff1a;函数模版 &#xff1a;不用传类型&#xff0c;编译器会自动推导&#xff0c;和普通的函数调用一样 #include<iostream> using namespace std; template<typename T>// T是类型 bool Less(T a, T b)// a,b是T实例化的的对象 {retu…

spring框架学习记录(1)

前半个月一直在应付期中考试&#xff0c;快被折磨似了orz 文章目录 SpringIoC(Inversion of Control) 控制反转与DI(Dependency Injection)依赖注入bean相关bean配置bean实例化bean的生命周期 依赖注入相关依赖注入方式依赖自动装配 容器创建容器获取bean Spring IoC(Inversi…

电商平台遭遇DDOS、CC攻击有什么防护方案

电商平台遭遇DDOS、CC攻击有什么防护方案&#xff1f;在数字化浪潮的推动下&#xff0c;电商平台已成为现代商业的重要组成部分&#xff0c;为消费者提供便捷、多样的购物体验。然而&#xff0c;随着业务的发展&#xff0c;电商平台也面临着日益严峻的网络安全挑战&#xff0c;…

图片合称为视频

import cv2 import os def pic_video(args_input_path,folder_path,output_video_path): count 1 image_files [os.path.join(folder_path, file) for file in os.listdir(folder_path) if file.endswith(‘.png’)] img cv2.imread(image_files[0]) height img.shape[0] w…

单例、工厂、策略、装饰器设计模式

1. 单例模式&#xff08;Singleton Pattern&#xff09;&#xff1a; 单例模式是一种常用的设计模式&#xff0c;用于确保一个类只有一个实例&#xff0c;并提供一个全局访问点。这种模式的特点是类自己负责保存其唯一的实例&#xff0c;并控制其实例化过程。单例模式广泛应用…

GNU Radio FFT模块结合stream to vector应用及Rotator频偏模块使用

文章目录 前言一、FFT 模块应用1、stream to vector 介绍2、创建 grc 图测试3、运行结果 二、频偏模块1、Rotator 简介2、创建 grc 图测试3、运行结果 前言 写个博客记录一下自己的蠢劲儿&#xff0c;之前我想用 FFT 模块做一些信号分析的东西&#xff0c;官方的 FFT 模块必须…

Java使用JSch实现SSH远程执行命令

前言 有一个奇怪的需求&#xff0c;就是将本地的内容直接提交到远程服务器&#xff0c;并且需要针对文件夹进行处理。所以&#xff0c;这里就直接采用JSch来实现。在这里&#xff0c;感谢秀发浓密的程序猿的这篇博客&#xff0c;给了很大启发。 思路 既然是直接读取文件夹&am…