欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

springboot mybatis druid配置多數(shù)據(jù)源教程

 更新時間:2021年11月17日 10:50:32   作者:liuhmmjj  
這篇文章主要介紹了springboot mybatis druid配置多數(shù)據(jù)源教程,具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教

1、項目代碼結(jié)構(gòu)

2、導(dǎo)入基本依賴

記得需要導(dǎo)入mysql驅(qū)動mysql-connector-java

<dependencies>
		<dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-starter-web</artifactId>
		</dependency>
		<dependency>
			<groupId>org.mybatis.spring.boot</groupId>
			<artifactId>mybatis-spring-boot-starter</artifactId>
			<version>2.1.2</version>
		</dependency>
		<dependency> <!-- MySql驅(qū)動 -->
			<groupId>mysql</groupId>
			<artifactId>mysql-connector-java</artifactId>
		</dependency>
		<!--druid 依賴-->
		<dependency>
			<groupId>com.alibaba</groupId>
			<artifactId>druid-spring-boot-starter</artifactId>
			<version>1.1.10</version>
		</dependency>
 
		<dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-devtools</artifactId>
			<scope>runtime</scope>
			<optional>true</optional>
		</dependency>
		<dependency>
			<groupId>org.projectlombok</groupId>
			<artifactId>lombok</artifactId>
			<optional>true</optional>
		</dependency>
		<dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-starter-test</artifactId>
			<scope>test</scope>
			<exclusions>
				<exclusion>
					<groupId>org.junit.vintage</groupId>
					<artifactId>junit-vintage-engine</artifactId>
				</exclusion>
			</exclusions>
		</dependency>
	</dependencies>

3、配置多數(shù)據(jù)源

注意:Spring Boot 2.X 版本不再支持配置繼承,多數(shù)據(jù)源的話每個數(shù)據(jù)源的所有配置都需要單獨配置,否則配置不會生效。

spring:
  datasource:
    db1:
      url: jdbc:mysql://127.0.0.1:3306/db01?characterEncoding=UTF-8&serverTimezone=Asia/Shanghai&useSSL=false
      username: root
      password:
      driver-class-name: com.mysql.cj.jdbc.Driver
 
      # 初始化時建立物理連接的個數(shù)。初始化發(fā)生在顯示調(diào)用 init 方法,或者第一次 getConnection 時
      initialSize: 5
      # 最小連接池數(shù)量
      minIdle: 5
      # 最大連接池數(shù)量
      maxActive: 10
      # 獲取連接時最大等待時間,單位毫秒。配置了 maxWait 之后,缺省啟用公平鎖,并發(fā)效率會有所下降,如果需要可以通過配置 useUnfairLock 屬性為 true 使用非公平鎖。
      maxWait: 60000
      # Destroy 線程會檢測連接的間隔時間,如果連接空閑時間大于等于 minEvictableIdleTimeMillis 則關(guān)閉物理連接。
      timeBetweenEvictionRunsMillis: 60000
      # 連接保持空閑而不被驅(qū)逐的最小時間
      minEvictableIdleTimeMillis: 300000
      # 用來檢測連接是否有效的 sql 因數(shù)據(jù)庫方言而異, 例如 oracle 應(yīng)該寫成 SELECT 1 FROM DUAL
      validationQuery: SELECT 1
      # 建議配置為 true,不影響性能,并且保證安全性。申請連接的時候檢測,如果空閑時間大于 timeBetweenEvictionRunsMillis,執(zhí)行 validationQuery 檢測連接是否有效。
      testWhileIdle: true
      # 申請連接時執(zhí)行 validationQuery 檢測連接是否有效,做了這個配置會降低性能。
      testOnBorrow: false
      # 歸還連接時執(zhí)行 validationQuery 檢測連接是否有效,做了這個配置會降低性能。
      testOnReturn: false
      # 是否自動回收超時連接
      removeAbandoned: true
      # 超時時間 (以秒數(shù)為單位)
      remove-abandoned-timeout: 1800
 
    db2:
      url: jdbc:mysql://127.0.0.1:3306/db02?characterEncoding=UTF-8&serverTimezone=Asia/Shanghai&useSSL=false
      username: root
      password:
      driver-class-name: com.mysql.cj.jdbc.Driver
 
      # 初始化時建立物理連接的個數(shù)。初始化發(fā)生在顯示調(diào)用 init 方法,或者第一次 getConnection 時
      initialSize: 6
      # 最小連接池數(shù)量
      minIdle: 6
      # 最大連接池數(shù)量
      maxActive: 10
      # 獲取連接時最大等待時間,單位毫秒。配置了 maxWait 之后,缺省啟用公平鎖,并發(fā)效率會有所下降,如果需要可以通過配置 useUnfairLock 屬性為 true 使用非公平鎖。
      maxWait: 60000
      # Destroy 線程會檢測連接的間隔時間,如果連接空閑時間大于等于 minEvictableIdleTimeMillis 則關(guān)閉物理連接。
      timeBetweenEvictionRunsMillis: 60000
      # 連接保持空閑而不被驅(qū)逐的最小時間
      minEvictableIdleTimeMillis: 300000
      # 用來檢測連接是否有效的 sql 因數(shù)據(jù)庫方言而異, 例如 oracle 應(yīng)該寫成 SELECT 1 FROM DUAL
      validationQuery: SELECT 1
      # 建議配置為 true,不影響性能,并且保證安全性。申請連接的時候檢測,如果空閑時間大于 timeBetweenEvictionRunsMillis,執(zhí)行 validationQuery 檢測連接是否有效。
      testWhileIdle: true
      # 申請連接時執(zhí)行 validationQuery 檢測連接是否有效,做了這個配置會降低性能。
      testOnBorrow: false
      # 歸還連接時執(zhí)行 validationQuery 檢測連接是否有效,做了這個配置會降低性能。
      testOnReturn: false
      # 是否自動回收超時連接
      removeAbandoned: true
      # 超時時間 (以秒數(shù)為單位)
      remove-abandoned-timeout: 1800
 
    # WebStatFilter 用于采集 web-jdbc 關(guān)聯(lián)監(jiān)控的數(shù)據(jù)。
    web-stat-filter:
      # 是否開啟 WebStatFilter 默認(rèn)是 true
      enabled: true
      # 需要攔截的 url
      url-pattern: /*
      # 排除靜態(tài)資源的請求
      exclusions: "*.js,*.gif,*.jpg,*.png,*.css,*.ico,/druid/*"
 
    # Druid 內(nèi)置提供了一個 StatViewServlet 用于展示 Druid 的統(tǒng)計信息。
    stat-view-servlet:
      #是否啟用 StatViewServlet 默認(rèn)值 true
      enabled: true
      # 需要攔截的 url
      url-pattern: /druid/*
      # 允許清空統(tǒng)計數(shù)據(jù)
      reset-enable: true
      login-username: druid
      login-password: druid

4、配置類

主數(shù)據(jù)源配置類:

package com.study.multisource.config; 
import com.alibaba.druid.pool.DruidDataSource;
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.factory.annotation.Qualifier;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.boot.jdbc.DataSourceBuilder;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;
import org.springframework.core.io.support.PathMatchingResourcePatternResolver; 
import javax.sql.DataSource;
 
/**
 * @author liuhui
 * @date 2020/5/14 16:56
 */
@Configuration
@MapperScan(basePackages = "com.study.multisource.mybatis.oneDao",sqlSessionFactoryRef = "oneSqlSessionFactory")
public class DataSourceConfig1 {
    // 將這個對象放入Spring容器中
    @Bean(name = "oneDataSource")
    // 表示這個數(shù)據(jù)源是默認(rèn)數(shù)據(jù)源
    @Primary
    // 讀取application.properties中的配置參數(shù)映射成為一個對象
    // prefix表示參數(shù)的前綴
    @ConfigurationProperties(prefix = "spring.datasource.db1")
    public DataSource getDateSource1()
    {
        return DataSourceBuilder.create().type(DruidDataSource.class).build();
    }
 
    @Bean(name = "oneSqlSessionFactory")
    // 表示這個數(shù)據(jù)源是默認(rèn)數(shù)據(jù)源
    @Primary
    // @Qualifier表示查找Spring容器中名字為oneDataSource的對象
    public SqlSessionFactory oneSqlSessionFactory(@Qualifier("oneDataSource") DataSource datasource)
            throws Exception
    {
        SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
        bean.setDataSource(datasource);
        bean.setMapperLocations(
                // 設(shè)置mybatis的xml所在位置
                new PathMatchingResourcePatternResolver().getResources("classpath*:mapper/one/*.xml"));
        return bean.getObject();
    }
 
    @Bean("oneSqlSessionTemplate")
    // 表示這個數(shù)據(jù)源是默認(rèn)數(shù)據(jù)源
    @Primary
    public SqlSessionTemplate oneSqlSessionTemplate(
            @Qualifier("oneSqlSessionFactory") SqlSessionFactory sessionFactory)
    {
        return new SqlSessionTemplate(sessionFactory);
    }
 
}

次數(shù)據(jù)源配置類:

package com.study.multisource.config; 
import com.alibaba.druid.pool.DruidDataSource;
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.factory.annotation.Qualifier;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.boot.jdbc.DataSourceBuilder;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;
import org.springframework.core.io.support.PathMatchingResourcePatternResolver; 
import javax.sql.DataSource;
 
/**
 * @author liuhui
 * @date 2020/5/14 17:07
 */
@Configuration
@MapperScan(basePackages = "com.study.multisource.mybatis.twoDao",sqlSessionFactoryRef = "twoSqlSessionFactory")
public class DataSourceConfig2 {
    // 將這個對象放入Spring容器中
    @Bean(name = "twoDataSource")
    // 讀取application.properties中的配置參數(shù)映射成為一個對象
    // prefix表示參數(shù)的前綴
    @ConfigurationProperties(prefix = "spring.datasource.db2")
    public DataSource getDateSource1()
    {
        return DataSourceBuilder.create().type(DruidDataSource.class).build();
    }
 
    @Bean(name = "twoSqlSessionFactory")
    // 表示這個數(shù)據(jù)源是默認(rèn)數(shù)據(jù)源
    @Primary
    // @Qualifier表示查找Spring容器中名字為oneDataSource的對象
    public SqlSessionFactory oneSqlSessionFactory(@Qualifier("twoDataSource") DataSource datasource)
            throws Exception
    {
        SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
        bean.setDataSource(datasource);
        bean.setMapperLocations(
                // 設(shè)置mybatis的xml所在位置
                new PathMatchingResourcePatternResolver().getResources("classpath*:mapper/two/*.xml"));
        return bean.getObject();
    }
 
    @Bean("twoSqlSessionTemplate")
    // 表示這個數(shù)據(jù)源是默認(rèn)數(shù)據(jù)源
    @Primary
    public SqlSessionTemplate oneSqlSessionTemplate(
            @Qualifier("twoSqlSessionFactory") SqlSessionFactory sessionFactory)
    {
        return new SqlSessionTemplate(sessionFactory);
    }
 
}

5、啟動類

注意:不需要使用自動配置,那么需要取消加載對應(yīng)的自動配置類。

在啟動類關(guān)閉 Spring Boot 對數(shù)據(jù)源的自動化配置,由我們手動進行多數(shù)據(jù)源的配置:

package com.study.multisource; 
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration;
 
@SpringBootApplication(exclude = {DataSourceAutoConfiguration.class})
public class MultisourceApplication { 
	public static void main(String[] args) {
		SpringApplication.run(MultisourceApplication.class, args);
	} 
}

6、測試使用的表

#建在db01庫下
CREATE TABLE `user` (
  `id` bigint(20) NOT NULL,
  `name` varchar(255) DEFAULT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;
 
#建在db02庫下
CREATE TABLE `t_item_order` (
  `id` int(9) NOT NULL AUTO_INCREMENT COMMENT '自增id',
  `item_id` int(4) NOT NULL COMMENT '商品id',
  `item_name` varchar(50) NOT NULL DEFAULT '' COMMENT '商品名稱',
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=0 DEFAULT CHARSET=utf8 COMMENT='商品表';

7、測試表對應(yīng)的實體類

package com.study.multisource.entity; 
import lombok.Data;
import lombok.ToString;
 
/**
 * @author liuhui
 * @date 2020/5/14 17:32
 */
@Data
@ToString
public class ItemOrder {
    private Integer id;
    private Integer itemId;
    private String itemName;
}
package com.study.multisource.entity; 
import lombok.Data;
import lombok.ToString;
 
/**
 * @author liuhui
 * @date 2020/5/14 17:29
 */
@Data
@ToString
public class User {
    private Long id;
    private String name;
}

8、持久層:dao層接口

(注意:我將其放在不同目錄下方便區(qū)分管理):

package com.study.multisource.mybatis.oneDao; 
import com.study.multisource.entity.User; 
import java.util.List; 
public interface UserMapper {
    List<User> getAllUser();
}
package com.study.multisource.mybatis.twoDao; 
import com.study.multisource.entity.ItemOrder; 
import java.util.List; 
public interface ItemOrderMapper {
    List<ItemOrder> getAllItemOrder();
}

dao層對應(yīng)的xml配置文件:

UserMapper.xml

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.study.multisource.mybatis.oneDao.UserMapper">
    <select id="getAllUser" resultType="com.study.multisource.entity.User">
        select *
        from `user`
    </select>
</mapper>

ItemOrderMapper.xml

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.study.multisource.mybatis.twoDao.ItemOrderMapper">
    <resultMap id="BaseResultMap" type="com.study.multisource.entity.ItemOrder">
        <id column="id" jdbcType="BIGINT" property="id" />
        <result column="item_id" jdbcType="INTEGER" property="itemId" />
        <result column="item_name" jdbcType="VARCHAR" property="itemName" />
    </resultMap>
    <select id="getAllItemOrder" resultMap="BaseResultMap">
        select *
        from t_item_order
    </select>
</mapper>

service層:

接口:

package com.study.multisource.service; 
import com.study.multisource.entity.ItemOrder;
import com.study.multisource.entity.User; 
import java.util.List;
 
/**
 * @author liuhui
 * @date 2020/5/14 17:24
 */
public interface TestService {
    public List<User> getAllUser();
    public List<ItemOrder> getAllItemOrder();
}

實現(xiàn)類:

package com.study.multisource.service.impl; 
import com.study.multisource.entity.ItemOrder;
import com.study.multisource.entity.User;
import com.study.multisource.mybatis.oneDao.UserMapper;
import com.study.multisource.mybatis.twoDao.ItemOrderMapper;
import com.study.multisource.service.TestService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service; 
import java.util.List;
 
/**
 * @author liuhui
 * @date 2020/5/14 17:25
 */
@Service
public class TestServiceImpl implements TestService {
    @Autowired
    UserMapper userMapper;
    @Autowired
    ItemOrderMapper itemOrderMapper;
    @Override
    public List<User> getAllUser() {
        return userMapper.getAllUser();
    }
 
    @Override
    public List<ItemOrder> getAllItemOrder() {
        return itemOrderMapper.getAllItemOrder();
    } 
}

下面進行測試:

package com.study.multisource.multisource; 
import com.study.multisource.service.TestService;
import lombok.ToString;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
 
@SpringBootTest
class MultisourceApplicationTests { 
	@Autowired
	TestService testService;
	@Test
	void contextLoads() {
	}
	@Test
	void testS(){
		System.out.println(testService.getAllItemOrder());
		System.out.println(testService.getAllUser()); 
	} 
}

結(jié)果:

2020-05-16 08:54:17.566  INFO 12556 --- [           main] com.alibaba.druid.pool.DruidDataSource   : {dataSource-1} inited
[ItemOrder(id=1, itemId=101, itemName=泡泡糖)]
--------------------------
2020-05-16 08:54:17.752  INFO 12556 --- [           main] com.alibaba.druid.pool.DruidDataSource   : {dataSource-2} inited
[User(id=2, name=Lucy), User(id=4, name=Lina)]

當(dāng)然也可以不用向上面分的那么細,也可以把多個數(shù)據(jù)源下面的XxxMapper.xml放在同一個目錄下,同時就可以把多個數(shù)據(jù)源的配置類解析的xml路徑寫成同一個了

new PathMatchingResourcePatternResolver().getResources("classpath*:mapper/*.xml"));

以上為個人經(jīng)驗,希望能給大家一個參考,也希望大家多多支持腳本之家。

相關(guān)文章

  • SpringBoot 實現(xiàn)定時任務(wù)的方法詳解

    SpringBoot 實現(xiàn)定時任務(wù)的方法詳解

    這篇文章主要介紹了SpringBoot 實現(xiàn)定時任務(wù)的方法詳解,文中通過示例代碼介紹的非常詳細,對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友可以參考下
    2019-08-08
  • Java中常見的編碼集問題總結(jié)

    Java中常見的編碼集問題總結(jié)

    這篇文章主要為大家整理了一些Java中常見的編碼集問題,文中的示例代碼講解詳細,對我們深入理解Java有一定的幫助,感興趣的小伙伴可以了解一下
    2023-02-02
  • 簡單了解SpringBoot過濾器及使用方式

    簡單了解SpringBoot過濾器及使用方式

    這篇文章主要介紹了簡單了解SpringBoot過濾器及使用方式,文中通過示例代碼介紹的非常詳細,對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友可以參考下
    2020-04-04
  • java 中enum的使用方法詳解

    java 中enum的使用方法詳解

    這篇文章主要介紹了java 中enum的使用方法詳解的相關(guān)資料,希望通過本文能幫助到大家,理解掌握java 中enum的使用方法,需要的朋友可以參考下
    2017-09-09
  • java8中parallelStream性能測試及結(jié)果分析

    java8中parallelStream性能測試及結(jié)果分析

    本篇文章給大家用代碼實例做了segmentfaultjava8中parallelStream性能測試,并對測試結(jié)果做了說明,需要的朋友學(xué)習(xí)下吧。
    2018-01-01
  • Java中對于雙屬性枚舉的使用案例

    Java中對于雙屬性枚舉的使用案例

    今天小編就為大家分享一篇關(guān)于Java中對于雙屬性枚舉的使用案例,小編覺得內(nèi)容挺不錯的,現(xiàn)在分享給大家,具有很好的參考價值,需要的朋友一起跟隨小編來看看吧
    2018-12-12
  • java模擬hibernate一級緩存示例分享

    java模擬hibernate一級緩存示例分享

    這篇文章主要介紹了java模擬hibernate一級緩存示例,需要的朋友可以參考下
    2014-03-03
  • java基礎(chǔ)知識I/O流使用詳解

    java基礎(chǔ)知識I/O流使用詳解

    編程語言的I/O類庫中常常使用流這個抽象的概念,它代表任何有能力產(chǎn)生數(shù)據(jù)的數(shù)據(jù)源對象或時有能力接收數(shù)據(jù)的接收端對象,本文為大家介紹Java中I/O系統(tǒng)基礎(chǔ)知識
    2014-01-01
  • Java數(shù)據(jù)結(jié)構(gòu)之簡單鏈表的定義與實現(xiàn)方法示例

    Java數(shù)據(jù)結(jié)構(gòu)之簡單鏈表的定義與實現(xiàn)方法示例

    這篇文章主要介紹了Java數(shù)據(jù)結(jié)構(gòu)之簡單鏈表的定義與實現(xiàn)方法,簡單描述了鏈接的概念、原理,并結(jié)合實例形式分析了java定義與使用鏈表的相關(guān)步驟與操作技巧,需要的朋友可以參考下
    2017-10-10
  • IDEA使用Maven創(chuàng)建module出現(xiàn)Ignored?pom.xml問題及解決

    IDEA使用Maven創(chuàng)建module出現(xiàn)Ignored?pom.xml問題及解決

    這篇文章主要介紹了IDEA使用Maven創(chuàng)建module出現(xiàn)Ignored?pom.xml問題及解決方案,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教
    2023-11-11

最新評論