springboot 中整合mybatis多数据源不使用JPA
作者:青蛙与大鹅 发布时间:2023-03-01 08:43:02
前言:
小伙伴说能不能用springboot整合一下mybatis多数据源不使用JPA进行数据库连接操作。那么说干就干
创建一个springboot项目
流程就不介绍了,按图操作即可
创建项目后可能会发现,这个项目展示的有些不对劲啊,java类前面还有个小J号,这是由于maven包还没有下载成功,你只需
要去maven projects中重新加载一下就可以了。?maven project在哪。。看下图
项目创建成功了,那么开始说下整合mybatis
首先在我们的resources目录下存在一个application.properties文件,这是一个全局配置文件,先将两个数据源配置添加到这个文件中(如果你分环境了可以将数据源配置放在不同的目录下)
//数据源1
spring.datasource.druid.crmtest.driver-class-name=com.mysql.jdbc.Driver
spring.datasource.druid.crmtest.url=jdbc:mysql://xxxxx:3306/crm
spring.datasource.druid.crmtest.username=xxx
spring.datasource.druid.crmtest.password=xxx
spring.datasource.druid.crmtest.initial-size=2
spring.datasource.druid.crmtest.max-active=10
spring.datasource.druid.crmtest.min-idle=2
spring.datasource.druid.crmtest.max-wait=30000
spring.datasource.druid.crmtest.validation-query=SELECT 1
spring.datasource.druid.crmtest.validation-query-timeout=30000
spring.datasource.druid.crmtest.min-evictable-idle-time-millis=300000
spring.datasource.druid.crmtest.pool-prepared-statements=true
spring.datasource.druid.crmtest.max-pool-prepared-statement-per-connection-size=20
spring.datasource.druid.crmtest.test-on-borrow=false
spring.datasource.druid.crmtest.test-on-return=false
spring.datasource.druid.crmtest.test-while-idle=true
spring.datasource.druid.crmtest.time-between-eviction-runs-millis=60000
spring.datasource.druid.crmtest.filters=stat,wall
spring.datasource.druid.crmtest.connection-properties=druid.stat.slowSqlMillis=5000
spring.datasource.druid.crmtest.connection-init-sqls=set names utf8mb4;
#数据源2
spring.datasource.druid.paytest.driver-class-name=com.mysql.jdbc.Driver
spring.datasource.druid.paytest.url=jdbc:mysql://xxxxxxx:3306/pay
spring.datasource.druid.paytest.username=xxxx
spring.datasource.druid.paytest.password=xxxxxx
spring.datasource.druid.paytest.initial-size=2
spring.datasource.druid.paytest.max-active=10
spring.datasource.druid.paytest.min-idle=2
spring.datasource.druid.paytest.max-wait=30000
spring.datasource.druid.paytest.validation-query=SELECT 1
spring.datasource.druid.paytest.validation-query-timeout=30000
spring.datasource.druid.paytest.min-evictable-idle-time-millis=300000
spring.datasource.druid.paytest.pool-prepared-statements=true
spring.datasource.druid.paytest.max-pool-prepared-statement-per-connection-size=20
spring.datasource.druid.paytest.test-on-borrow=false
spring.datasource.druid.paytest.test-on-return=false
spring.datasource.druid.paytest.test-while-idle=true
spring.datasource.druid.paytest.time-between-eviction-runs-millis=60000
spring.datasource.druid.paytest.filters=stat,wall
spring.datasource.druid.paytest.connection-properties=druid.stat.slowSqlMillis=5000
spring.datasource.druid.paytest.connection-init-sqls=set names utf8mb4;
创建DataSourceConfig
import com.alibaba.druid.spring.boot.autoconfigure.DruidDataSourceBuilder;
import com.github.pagehelper.PageInterceptor;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.*;
import org.springframework.transaction.annotation.EnableTransactionManagement;
import javax.sql.DataSource;
import java.util.Properties;
/**
* @Auther: lqf
* @Date: 2018/5/22
* @Description:
*/
@Configuration
@EnableTransactionManagement
public class DevDataSourceConfig {
//数据源1 在springboot中做多中配置的时候需要 @Primary否则会报错,springboot需要知道主配置是什么
@Primary
@Bean("crmds")
@ConfigurationProperties("spring.datasource.druid.crmtest")
public DataSource crmDataSource() {
return DruidDataSourceBuilder.create().build();
}
//数据源2 @ConfigurationProperties("spring.datasource.druid.paytest")这个配置会自动引入你在配置文件中的配置
@Bean("payds")
@ConfigurationProperties("spring.datasource.druid.paytest")
public DataSource payDataSource() {
return DruidDataSourceBuilder.create().build();
}
}
上面是一个总的配置将不同的数据源都配置在了这一个configuration中。下面我们来建立单独的数据源配置(这里需要注意一点我们看上面引用的是druid,那么我们需要在pom文件中导入alibaba.druid包,在文章的最后面我会给大家展示一下pom文件)
数据源1
package com.mysql.test.demo.config;
import org.apache.ibatis.session.SqlSessionFactory;
import org.mybatis.spring.SqlSessionFactoryBean;
import org.mybatis.spring.SqlSessionTemplate;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.beans.BeansException;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.context.ApplicationContext;
import org.springframework.context.ApplicationContextAware;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.core.io.Resource;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import javax.sql.DataSource;
/**
* @Auther: lqf
* @Date: 2018/5/23
* @Description:
*/
@Configuration
@MapperScan(basePackages = {"com.mysql.test.demo.dao.crm"}, sqlSessionTemplateRef = "crmSqlSessionTemplate")
public class CrmMysqlConfig implements ApplicationContextAware {
private ApplicationContext ctx;
@Override
public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
this.ctx = applicationContext;
}
@Bean("crmSqlSessionFactory")
public SqlSessionFactoryBean crmSqlSessionFactory(@Qualifier("crmds") DataSource crmDataSource) throws Exception {
SqlSessionFactoryBean factoryBean = new SqlSessionFactoryBean();
factoryBean.setDataSource(crmDataSource);
factoryBean.setTypeAliasesPackage("com.mysql.test.demo.entity.crm");
Resource[] resources = ctx.getResources("classpath*:/mapper/crm/*.xml");
factoryBean.setMapperLocations(resources);
return factoryBean;
}
@Bean("crmSqlSessionTemplate")
public SqlSessionTemplate crmSqlSessionTemplate(@Qualifier("crmSqlSessionFactory") SqlSessionFactory
sqlSessionFactory) {
return new SqlSessionTemplate(sqlSessionFactory);
}
@Bean("crmTxManager")
public DataSourceTransactionManager crmTxManager(@Qualifier("crmds") DataSource crmDataSource) {
return new DataSourceTransactionManager(crmDataSource);
}
}
上面的配置可以直接使用
路径需要更换成你的项目路径这里就不多说了,注重提 * 解的含义吧。
@Configuration
: 用于定义配置类,可替换xml配置文件,被注解的类内部包含有一个或多个被@Bean注解的方法,这些方法将会被AnnotationConfigApplicationContext或AnnotationConfigWebApplicationContext类进行扫描,并用于构建bean定义,初始化Spring容器@MapperScan()
: 指定要扫描的Mapper类的包的路径,sqlSessionTemplateRef :SqlSessionTemplate实现了SqlSession,这就是说要对MyBatis的SqlSession进行简易替换。SqlSessionTemplate通常是被用来替代默认的MyBatis实现的DefaultSqlSession,因为它不能参与到Spring的事务中也不能被注入,因为它是线程不安全的。相同应用程序中两个类之间的转换可能会引起数据一致性的问题@Qualifier
:我的理解就是告诉指定具体引用那个bean,参考://www.jb51.net/article/220973.htm
数据源2
package com.mysql.test.demo.config;
import org.apache.ibatis.session.SqlSessionFactory;
import org.mybatis.spring.SqlSessionFactoryBean;
import org.mybatis.spring.SqlSessionTemplate;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.beans.BeansException;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.context.ApplicationContext;
import org.springframework.context.ApplicationContextAware;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.core.io.Resource;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import javax.sql.DataSource;
/**
* @Auther: lqf
* @Date: 2018/5/23
* @Description:
*/
@Configuration
@MapperScan(basePackages = {"com.mysql.test.demo.dao.pay"}, sqlSessionTemplateRef = "paySqlSessionTemplate")
public class PayMysqlConfig implements ApplicationContextAware {
private ApplicationContext ctx;
@Override
public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
this.ctx = applicationContext;
}
@Bean("paySqlSessionFactory")
public SqlSessionFactoryBean crmSqlSessionFactory(@Qualifier("payds") DataSource payDataSource) throws Exception {
SqlSessionFactoryBean factoryBean = new SqlSessionFactoryBean();
factoryBean.setDataSource(payDataSource);
factoryBean.setTypeAliasesPackage("com.mysql.test.demo.entity.pay");
Resource[] resources = ctx.getResources("classpath*:/mapper/pay/*.xml");
factoryBean.setMapperLocations(resources);
return factoryBean;
}
@Bean("paySqlSessionTemplate")
public SqlSessionTemplate crmSqlSessionTemplate(@Qualifier("paySqlSessionFactory") SqlSessionFactory
sqlSessionFactory) {
return new SqlSessionTemplate(sqlSessionFactory);
}
@Bean("payTxManager")
public DataSourceTransactionManager crmTxManager(@Qualifier("payds") DataSource crmDataSource) {
return new DataSourceTransactionManager(crmDataSource);
}
}
在pom文件中添加generator-maven插件让我们来测试一下(文章最后展示全部pom文件)
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
<plugin>
<groupId>org.mybatis.generator</groupId>
<artifactId>mybatis-generator-maven-plugin</artifactId>
<version>1.3.6</version>
<configuration>
<configurationFile>./src/main/resources/generatorConfig.xml</configurationFile>
<overwrite>true</overwrite>
<verbose>true</verbose>
</configuration>
<dependencies>
<!-- 数据库驱动 -->
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>${mysql.version}</version>
</dependency>
</dependencies>
</plugin>
</plugins>
<finalName>agentapi</finalName>
</build>
创建generatorConfig.properties文件放在resources目录下
//数据库连接路径
mysql.jdbc.connectionURL=jdbc:mysql://xxxxxx:3306/crm?useUnicode=true&characterEncoding=utf-8&zeroDateTimeBehavior=convertToNull
mysql.jdbc.userId=xxx
mysql.jdbc.password=xxx
//自动生成实体类路径包名
module.targetPackage=com.mysql.test.demo.entity.crm
//生成实体类路径位置
module.targetProject=src/main/java
//生成mapper.xml位置和包名
map.targetPackage=mapper
map.targetProject=src/main/resources
//生成DAO的包名和位置
client.targetPackage=com.mysql.test.demo.dao.crm
client.targetProject=src/main/java
创建generatorConfig.xml文件
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE generatorConfiguration
PUBLIC "-//mybatis.org//DTD MyBatis Generator Configuration 1.0//EN"
"http://mybatis.org/dtd/mybatis-generator-config_1_0.dtd">
<generatorConfiguration>
<properties resource="generatorConfig.properties"/>
<context id="bTables" targetRuntime="MyBatis3">
<plugin type="org.mybatis.generator.plugins.RowBoundsPlugin"></plugin>
<plugin type="org.mybatis.generator.plugins.CaseInsensitiveLikePlugin"></plugin>
<plugin type="org.mybatis.generator.plugins.ToStringPlugin"></plugin>
<plugin type="org.mybatis.generator.plugins.EqualsHashCodePlugin"></plugin>
<commentGenerator>
<property name="suppressDate" value="true"/>
<!-- 是否去除自动生成的注释 true:是 : false:否 -->
<property name="suppressAllComments" value="true"/>
</commentGenerator>
<!--数据库链接URL,用户名、密码 -->
<jdbcConnection driverClass="com.mysql.jdbc.Driver"
connectionURL="${mysql.jdbc.connectionURL}" userId="${mysql.jdbc.userId}"
password="${mysql.jdbc.password}">
</jdbcConnection>
<javaTypeResolver>
<property name="forceBigDecimals" value="false"/>
</javaTypeResolver>
<!-- 生成模型的包名和位置 -->
<javaModelGenerator targetPackage="${module.targetPackage}"
targetProject="${module.targetProject}">
<property name="enableSubPackages" value="true"/>
<property name="trimStrings" value="true"/>
</javaModelGenerator>
<!-- 生成映射文件的包名和位置 -->
<sqlMapGenerator targetPackage="${map.targetPackage}"
targetProject="${map.targetProject}">
<property name="enableSubPackages" value="true"/>
</sqlMapGenerator>
<!-- 生成DAO的包名和位置 -->
<javaClientGenerator
type="XMLMAPPER"
targetPackage="${client.targetPackage}" targetProject="${client.targetProject}">
<property name="enableSubPackages" value="true"/>
</javaClientGenerator>
<!--<table tableName="order_history_tab" domainObjectName="OrderHistoryTab" mapperName="OrderHistoryTabMapper">-->
<!--<generatedKey column="id" sqlStatement="JDBC"/>-->
<!--</table>-->
//你要生成的表
<table tableName="fy_advertisement" domainObjectName="FyAdvertisement" mapperName="FyAdvertisementMapper">
<generatedKey column="id" sqlStatement="JDBC"/>
</table>
</context>
</generatorConfiguration>
如果上面的配置都完成的话那么我们来自动生成一下
如上图打开maven projects如上图进行操作就可自动生成需要的mapper 实体 dao等信息。上图是生成了一个数据源的那么我们来生成第二个数据源中的表操作如上图,需要改变第二个数据源的位置信息等。(重复的事情就不做了和上面生成一样的道理,只是改些路径和对应的表名)
在下图两个数据源完全生成好后的目录结构
项目到这里就已经整合完成了,之后就可以正常的创建service,controller进行操作了。
来源:https://blog.csdn.net/m0_37034294/article/details/80936827
猜你喜欢
- 目录1、IP地址2、端口3、通信协议3.1 TCP/IP协议簇:实际上是一组协议3.2 TCP UDP对比3.3 TCP实现聊天3.4 TC
- 一、示例代码访问 localhost:8080/jsonTest —— 返回 json 格式的数据@
- 系列文章已完成,目录如下:jdk-logging log4j logback日志系统实现机制原理介绍commons-lo
- 一、前言文稿扫描大家用的都比较频繁、想是各种证件、文件都可以通过扫描文稿功能保存到手机。相比直接拍照,在扫描文稿时,程序会对图像进行一些矫正
- Java中字符串对象创建有两种形式,一种为字面量形式,如String str = "hello";,另一种就是使用new
- 本文实例讲述了Android编程实现WebView添加进度条的方法。分享给大家供大家参考,具体如下:标准的XML界面<?xml ver
- 多数据源创建数据库CREATE DATABASE mybatis_plus_1;USE mybatis_plus_1;CREATE TABL
- 最近有时间,写一些很简单、很基础的东西,主要在操作层面。主要考虑如下: 1、经常搭建开发环境,所以有必要记录一下,自己也可以备查; 2、给新
- springboot项目启动慢的问题排查springboot项目,随着时间的推移,启动耗时逐步增加,从几分钟慢慢的达到30多分钟,有点恐怖!
- 前言:List 去重指的是将 List 中的重复元素删除掉的过程。此题目考察的是对 List 迭代器、Set 集合和 JDK 8 中新特性的
- IntelliJ IDEA是广受Java开发者喜爱的工具,其商业版的价格十分昂贵,如下图:现在有机会免费获取IntelliJ IDEA的正版
- 这篇文章主要介绍了SpringBoot FreeWorker模板技术解析,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考
- 一、简介(1)、MySQL是一个关系型数据库系统,是如今互联网公司最常用的数据库和最广泛的数据库。为服务端数据库,能承受高并发的访问量。(2
- 定义在一幅无向图G=(V,E) 中,(u,v) 为连接顶点u和顶点v的边,w(u,v)为边的权重,若存在边的子集T&am
- 这篇文章主要介绍了spring cloud gateway请求跨域问题解决方案,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定
- 1. 线程转储简介线程转储(Thread Dump)就是JVM中所有线程状态信息的一次快照。线程转储一般使用文本格式, 可以将其保存到文本文
- 前言今天看代码看到有牵扯到弱引用的东西,就先稍微补一补Java的四种引用类型吧。Java为引用类型专门定义了一个类Reference,它是引
- 前言通过此篇文章,你将了解到:Flutter windows和Android桌面应用屏幕适配的解决方案;屏幕适配的相关知识和原理;flutt
- 好久就想着好好搭建一个ssm框架,自己以后用也方便吧,但是最近的事真的是很多,很多事情都没有去干,有时候自己会怀疑一下人生自己该不该去做程序
- 当数据库中数据条数过多时,一个页面就不能显示,这是要设置分页查询,首先要使用的是数据库sql语句的limit条件实现分组查询sql语句大概形