springboot 中整合mybatis多數(shù)據(jù)源不使用JPA
更新時(shí)間：2021年08月27日 10:28:07 作者：青蛙與大鵝
這篇文章主要介紹了springboot 中整合mybatis多數(shù)據(jù)源不使用JPA，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教
前言：
小伙伴說(shuō)能不能用springboot整合一下mybatis多數(shù)據(jù)源不使用JPA進(jìn)行數(shù)據(jù)庫(kù)連接操作。那么說(shuō)干就干
創(chuàng)建一個(gè)springboot項(xiàng)目
流程就不介紹了，按圖操作即可
創(chuàng)建項(xiàng)目后可能會(huì)發(fā)現(xiàn)，這個(gè)項(xiàng)目展示的有些不對(duì)勁啊，java類(lèi)前面還有個(gè)小J號(hào)，這是由于maven包還沒(méi)有下載成功，你只需
要去maven projects中重新加載一下就可以了。？maven project在哪。。看下圖
項(xiàng)目創(chuàng)建成功了，那么開(kāi)始說(shuō)下整合mybatis
首先在我們的resources目錄下存在一個(gè)application.properties文件，這是一個(gè)全局配置文件，先將兩個(gè)數(shù)據(jù)源配置添加到這個(gè)文件中（如果你分環(huán)境了可以將數(shù)據(jù)源配置放在不同的目錄下）
//數(shù)據(jù)源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; #數(shù)據(jù)源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;
創(chuàng)建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 {
//數(shù)據(jù)源1 在springboot中做多中配置的時(shí)候需要 @Primary否則會(huì)報(bào)錯(cuò)，springboot需要知道主配置是什么
@Primary
@Bean("crmds")
@ConfigurationProperties("spring.datasource.druid.crmtest")
public DataSource crmDataSource() {
return DruidDataSourceBuilder.create().build();
}
//數(shù)據(jù)源2 @ConfigurationProperties("spring.datasource.druid.paytest")這個(gè)配置會(huì)自動(dòng)引入你在配置文件中的配置
@Bean("payds")
@ConfigurationProperties("spring.datasource.druid.paytest")
public DataSource payDataSource() {
return DruidDataSourceBuilder.create().build();
}
}
上面是一個(gè)總的配置將不同的數(shù)據(jù)源都配置在了這一個(gè)configuration中。下面我們來(lái)建立單獨(dú)的數(shù)據(jù)源配置（這里需要注意一點(diǎn)我們看上面引用的是druid，那么我們需要在pom文件中導(dǎo)入alibaba.druid包，在文章的最后面我會(huì)給大家展示一下pom文件）
數(shù)據(jù)源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);
}
}
上面的配置可以直接使用
路徑需要更換成你的項(xiàng)目路徑這里就不多說(shuō)了，注重提下注解的含義吧。
@Configuration： 用于定義配置類(lèi)，可替換xml配置文件，被注解的類(lèi)內(nèi)部包含有一個(gè)或多個(gè)被@Bean注解的方法，這些方法將會(huì)被AnnotationConfigApplicationContext或AnnotationConfigWebApplicationContext類(lèi)進(jìn)行掃描，并用于構(gòu)建bean定義，初始化Spring容器@MapperScan(）： 指定要掃描的Mapper類(lèi)的包的路徑，sqlSessionTemplateRef ：SqlSessionTemplate實(shí)現(xiàn)了SqlSession，這就是說(shuō)要對(duì)MyBatis的SqlSession進(jìn)行簡(jiǎn)易替換。SqlSessionTemplate通常是被用來(lái)替代默認(rèn)的MyBatis實(shí)現(xiàn)的DefaultSqlSession，因?yàn)樗荒軈⑴c到Spring的事務(wù)中也不能被注入，因?yàn)樗蔷€(xiàn)程不安全的。相同應(yīng)用程序中兩個(gè)類(lèi)之間的轉(zhuǎn)換可能會(huì)引起數(shù)據(jù)一致性的問(wèn)題-
@Qualifier：我的理解就是告訴指定具體引用那個(gè)bean，參考：//www.dbjr.com.cn/article/220973.htm
數(shù)據(jù)源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插件讓我們來(lái)測(cè)試一下（文章最后展示全部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>
<!-- 數(shù)據(jù)庫(kù)驅(qū)動(dòng) -->
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>${mysql.version}</version>
</dependency>
</dependencies>
</plugin>
</plugins>
<finalName>agentapi</finalName>
</build>
創(chuàng)建generatorConfig.properties文件放在resources目錄下
//數(shù)據(jù)庫(kù)連接路徑 mysql.jdbc.connectionURL=jdbc:mysql://xxxxxx:3306/crm?useUnicode=true&characterEncoding=utf-8&zeroDateTimeBehavior=convertToNull mysql.jdbc.userId=xxx mysql.jdbc.password=xxx //自動(dòng)生成實(shí)體類(lèi)路徑包名 module.targetPackage=com.mysql.test.demo.entity.crm //生成實(shí)體類(lèi)路徑位置 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
創(chuàng)建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"/>
<!-- 是否去除自動(dòng)生成的注釋 true：是 ： false:否 -->
<property name="suppressAllComments" value="true"/>
</commentGenerator>
<!--數(shù)據(jù)庫(kù)鏈接URL，用戶(hù)名、密碼 -->
<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>
如果上面的配置都完成的話(huà)那么我們來(lái)自動(dòng)生成一下
如上圖打開(kāi)maven projects如上圖進(jìn)行操作就可自動(dòng)生成需要的mapper 實(shí)體 dao等信息。上圖是生成了一個(gè)數(shù)據(jù)源的那么我們來(lái)生成第二個(gè)數(shù)據(jù)源中的表操作如上圖，需要改變第二個(gè)數(shù)據(jù)源的位置信息等。（重復(fù)的事情就不做了和上面生成一樣的道理，只是改些路徑和對(duì)應(yīng)的表名）
在下圖兩個(gè)數(shù)據(jù)源完全生成好后的目錄結(jié)構(gòu)
項(xiàng)目到這里就已經(jīng)整合完成了，之后就可以正常的創(chuàng)建service，controller進(jìn)行操作了。
以上為個(gè)人經(jīng)驗(yàn)，希望能給大家一個(gè)參考，也希望大家多多支持腳本之家。
相關(guān)文章
解讀List?list=new?ArrayList()是怎么回事
這篇文章主要介紹了解讀List?list=new?ArrayList()是怎么回事，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教2023-06-06
這篇文章主要幫助大家輕松掌握J(rèn)ava代理模式，什么是靜態(tài)代理？感興趣的小伙伴們可以參考一下2016-09-09
這篇文章主要介紹了Java接口中盡量避免使用數(shù)組的建議,根據(jù)實(shí)際示例展示了接口中使用數(shù)組而造成的影響程序速度的現(xiàn)象,需要的朋友可以參考下2015-07-07
二分查找（binary search），也稱(chēng)折半搜索，是一種在有序數(shù)組中查找某一特定元素的搜索算法，接下來(lái)就來(lái)給大家講講都有哪些查找算法，以及經(jīng)典的二分查找法該如何實(shí)現(xiàn),需要的朋友可以參考下2023-07-07
Java實(shí)現(xiàn)NIO聊天室的示例代碼(群聊+私聊)
這篇文章主要介紹了Java實(shí)現(xiàn)NIO聊天室的示例代碼(群聊+私聊)，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2021-05-05
SpringBoot集成JWT的工具類(lèi)與攔截器實(shí)現(xiàn)方式
這篇文章主要介紹了SpringBoot集成JWT的工具類(lèi)與攔截器實(shí)現(xiàn)方式,具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2024-01-01
本文主要介紹了SpringBoot集成Auth0 JWT的示例代碼，文中通過(guò)示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2021-08-08
Java用戶(hù)交互scanner及運(yùn)算結(jié)構(gòu)代碼詳解
這篇文章主要介紹了Java用戶(hù)交互scanner及運(yùn)算結(jié)構(gòu)代碼詳解,文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2020-12-12
微信小程序 navigator 跳轉(zhuǎn)url傳遞參數(shù)
這篇文章主要介紹了 微信小程序 navigator 跳轉(zhuǎn)url傳遞參數(shù)的相關(guān)資料,需要的朋友可以參考下2017-03-03
SpringBoot集成Kaptcha驗(yàn)證碼的詳細(xì)過(guò)程
Kaptcha是一個(gè)強(qiáng)大而靈活的Java驗(yàn)證碼生成庫(kù),通過(guò)合理的配置和使用,它可以有效地提高web應(yīng)用的安全性,防止自動(dòng)化程序的濫用,這篇文章主要介紹了SpringBoot集成Kaptcha驗(yàn)證碼,需要的朋友可以參考下2024-07-07