国产一级a片免费看高清,亚洲熟女中文字幕在线视频,黄三级高清在线播放,免费黄色视频在线看

打開APP
userphoto
未登錄

開通VIP，暢享免費(fèi)電子書等14項(xiàng)超值服

開通VIP

首頁

好書

留言交流

下載APP

聯(lián)系客服
Spring Boot 整合 Mybatis 實(shí)現(xiàn) Druid 多數(shù)據(jù)源詳解


一、多數(shù)據(jù)源的應(yīng)用場(chǎng)景

目前，業(yè)界流行的數(shù)據(jù)操作框架是 Mybatis，那 Druid 是什么呢？
Druid 是 Java 的數(shù)據(jù)庫連接池組件。Druid 能夠提供強(qiáng)大的監(jiān)控和擴(kuò)展功能。比如可以監(jiān)控 SQL ，在監(jiān)控業(yè)務(wù)可以查詢慢查詢 SQL 列表等。Druid 核心主要包括三部分：
1. DruidDriver 代理 Driver，能夠提供基于 Filter－Chain 模式的插件體系。
2. DruidDataSource 高效可管理的數(shù)據(jù)庫連接池
3. SQLParser

當(dāng)業(yè)務(wù)數(shù)據(jù)量達(dá)到了一定程度，DBA 需要合理配置數(shù)據(jù)庫資源。即配置主庫的機(jī)器高配置，把核心高頻的數(shù)據(jù)放在主庫上；把次要的數(shù)據(jù)放在從庫，低配置。開源節(jié)流嘛，就這個(gè)意思。把數(shù)據(jù)放在不同的數(shù)據(jù)庫里，就需要通過不同的數(shù)據(jù)源進(jìn)行操作數(shù)據(jù)。這里我們舉個(gè) springboot-mybatis-mutil-datasource 工程案例：
user 用戶表在主庫 master 上，地址表 city 在從庫 cluster 上。下面實(shí)現(xiàn)獲取 根據(jù)用戶名獲取用戶信息，包括從庫的地址信息 REST API，那么需要從主庫和從庫中分別獲取數(shù)據(jù)，并在業(yè)務(wù)邏輯層組裝返回。邏輯如圖：

下面就運(yùn)行這個(gè)案例。

 

二、運(yùn)行 springboot-mybatis-mutil-datasource 工程案例

git clone 下載工程 springboot-learning-example ，項(xiàng)目地址見 GitHub – https://github.com/JeffLi1993/springboot-learning-example。下面開始運(yùn)行工程步驟（Quick Start）：
1.數(shù)據(jù)庫準(zhǔn)備
a.創(chuàng)建 cluster 數(shù)據(jù)庫 springbootdb：

1
CREATE DATABASE springbootdb;

b.創(chuàng)建表 city ：(因?yàn)槲蚁矚g徒步)

1
2
3
4
5
6
7
8
DROP TABLE IF EXISTS `city`;
CREATE TABLE `city` (
`id` int(10) unsigned NOT NULL AUTO_INCREMENT COMMENT '城市編號(hào)',
`province_id` int(10) unsigned NOT NULL COMMENT '省份編號(hào)',
`city_name` varchar(25) DEFAULT NULL COMMENT '城市名稱',
`description` varchar(25) DEFAULT NULL COMMENT '描述',
PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8;

c.插入數(shù)據(jù)

1
INSERT city VALUES (1 ,1,'溫嶺市','BYSocket 的家在溫嶺。');

然后，再創(chuàng)建一個(gè) master 數(shù)據(jù)庫
a.創(chuàng)建數(shù)據(jù)庫 springbootdb_cluster：

1
CREATE DATABASE springbootdb_cluster;

b.創(chuàng)建表 user ：

1
2
3
4
5
6
7
DROP TABLE IF EXISTS `city`;
CREATE TABLE user
(
id INT(10) unsigned PRIMARY KEY NOT NULL COMMENT '用戶編號(hào)' AUTO_INCREMENT,
user_name VARCHAR(25) COMMENT '用戶名稱',
description VARCHAR(25) COMMENT '描述'
)ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8;

c.插入數(shù)據(jù)

1
INSERT user VALUES (1 ,’泥瓦匠','他有一個(gè)小網(wǎng)站 bysocket.com');

（以上數(shù)據(jù)庫創(chuàng)建無先后順序）

2. 項(xiàng)目結(jié)構(gòu)介紹
項(xiàng)目結(jié)構(gòu)如下圖所示：
org.spring.springboot.config.ds – 配置層，這里是數(shù)據(jù)源的配置，包括 master 和 cluster 的數(shù)據(jù)源配置
org.spring.springboot.controller – Controller 層
org.spring.springboot.dao – 數(shù)據(jù)操作層 DAO，細(xì)分了 master 和 cluster 包下的 DAO 操作類
org.spring.springboot.domain – 實(shí)體類
org.spring.springboot.service – 業(yè)務(wù)邏輯層
Application – 應(yīng)用啟動(dòng)類
application.properties – 應(yīng)用配置文件，應(yīng)用啟動(dòng)會(huì)自動(dòng)讀取配置

3.改數(shù)據(jù)庫配置
打開 application.properties 文件， 修改相應(yīng)的主從數(shù)據(jù)源配置，比如數(shù)據(jù)源地址、賬號(hào)、密碼等。（如果不是用 MySQL，自行添加連接驅(qū)動(dòng) pom，然后修改驅(qū)動(dòng)名配置。）

4.編譯工程
在項(xiàng)目根目錄 springboot-learning-example，運(yùn)行 maven 指令：

1
mvn clean install

 

5.運(yùn)行工程
右鍵運(yùn)行 Application 應(yīng)用啟動(dòng)類（位置：/springboot-learning-example/springboot-mybatis-mutil-datasource/src/main/java/org/spring/springboot/Application.java）的 main 函數(shù)，這樣就成功啟動(dòng)了 springboot-mybatis-mutil-datasource 案例。

在瀏覽器打開：
http://localhost:8080/api/user?userName=泥瓦匠
瀏覽器返回 JSON 結(jié)果：

1
2
3
4
5
6
7
8
9
10
11
{
    "id": 1,
    "userName": "泥瓦匠",
    "description": "他有一個(gè)小網(wǎng)站 bysocket.com",
    "city": {
        "id": 1,
        "provinceId": 1,
        "cityName": "溫嶺市",
        "description": "BYSocket 的家在溫嶺。"
    }
}

這里 city 結(jié)果體來自 cluster 庫，user 結(jié)果體來自 master 庫。

 

三、springboot-mybatis-mutil-datasource 工程代碼配置詳解

代碼共享在我的 GitHub 上：
https://github.com/JeffLi1993/springboot-learning-example/tree/master/springboot-mybatis-mutil-datasource

首先代碼工程結(jié)構(gòu)如下：
org.spring.springboot.config.ds 包包含了多數(shù)據(jù)源的配置，同樣有第三個(gè)數(shù)據(jù)源，按照前幾個(gè)復(fù)制即可
resources/mapper 下面有兩個(gè)模塊，分別是 Mybatis 不同數(shù)據(jù)源需要掃描的 mapper xml 目錄

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
├── pom.xml
└── src
    └── main
        ├── java
        │   └── org
        │       └── spring
        │           └── springboot
        │               ├── Application.java
        │               ├── config
        │               │   └── ds
        │               │       ├── ClusterDataSourceConfig.java
        │               │       └── MasterDataSourceConfig.java
        │               ├── controller
        │               │   └── UserRestController.java
        │               ├── dao
        │               │   ├── cluster
        │               │   │   └── CityDao.java
        │               │   └── master
        │               │       └── UserDao.java
        │               ├── domain
        │               │   ├── City.java
        │               │   └── User.java
        │               └── service
        │                   ├── UserService.java
        │                   └── impl
        │                       └── UserServiceImpl.java
        └── resources
            ├── application.properties
            └── mapper
                ├── cluster
                │   └── CityMapper.xml
                └── master
                    └── UserMapper.xml

 

1. 依賴 pom.xml
Mybatis 通過 Spring Boot Mybatis Starter 依賴
Druid 是數(shù)據(jù)庫連接池依賴

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <groupId>springboot</groupId>
    <artifactId>springboot-mybatis-mutil-datasource</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>springboot-mybatis-mutil-datasource :: Spring Boot 實(shí)現(xiàn) Mybatis 多數(shù)據(jù)源配置</name>
    <!-- Spring Boot 啟動(dòng)父依賴 -->
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>1.5.1.RELEASE</version>
    </parent>
    <properties>
        <mybatis-spring-boot>1.2.0</mybatis-spring-boot>
        <mysql-connector>5.1.39</mysql-connector>
        <druid>1.0.18</druid>
    </properties>
    <dependencies>
        <!-- Spring Boot Web 依賴 -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <!-- Spring Boot Test 依賴 -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
        <!-- Spring Boot Mybatis 依賴 -->
        <dependency>
            <groupId>org.mybatis.spring.boot</groupId>
            <artifactId>mybatis-spring-boot-starter</artifactId>
            <version>${mybatis-spring-boot}</version>
        </dependency>
        <!-- MySQL 連接驅(qū)動(dòng)依賴 -->
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>${mysql-connector}</version>
        </dependency>
        <!-- Druid 數(shù)據(jù)連接池依賴 -->
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>druid</artifactId>
            <version>${druid}</version>
        </dependency>
        <!-- Junit -->
        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
            <version>4.12</version>
        </dependency>
    </dependencies>
</project>

2. application.properties 配置兩個(gè)數(shù)據(jù)源配置
數(shù)據(jù)源配置會(huì)被數(shù)據(jù)源數(shù)據(jù)源配置如下

1
2
3
4
5
6
7
8
9
10
11
## master 數(shù)據(jù)源配置
master.datasource.url=jdbc:mysql://localhost:3306/springbootdb?useUnicode=true&characterEncoding=utf8
master.datasource.username=root
master.datasource.password=123456
master.datasource.driverClassName=com.mysql.jdbc.Driver
## cluster 數(shù)據(jù)源配置
cluster.datasource.url=jdbc:mysql://localhost:3306/springbootdb_cluster?useUnicode=true&characterEncoding=utf8
cluster.datasource.username=root
cluster.datasource.password=123456
cluster.datasource.driverClassName=com.mysql.jdbc.Driver

3. 數(shù)據(jù)源配置
多數(shù)據(jù)源配置的時(shí)候注意，必須要有一個(gè)主數(shù)據(jù)源，即 MasterDataSourceConfig 配置：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
@Configuration
// 掃描 Mapper 接口并容器管理
@MapperScan(basePackages = MasterDataSourceConfig.PACKAGE, sqlSessionFactoryRef = "masterSqlSessionFactory")
public class MasterDataSourceConfig {
    // 精確到 master 目錄，以便跟其他數(shù)據(jù)源隔離
    static final String PACKAGE = "org.spring.springboot.dao.master";
    static final String MAPPER_LOCATION = "classpath:mapper/master/*.xml";
    @Value("${master.datasource.url}")
    private String url;
    @Value("${master.datasource.username}")
    private String user;
    @Value("${master.datasource.password}")
    private String password;
    @Value("${master.datasource.driverClassName}")
    private String driverClass;
    @Bean(name = "masterDataSource")
    @Primary
    public DataSource masterDataSource() {
        DruidDataSource dataSource = new DruidDataSource();
        dataSource.setDriverClassName(driverClass);
        dataSource.setUrl(url);
        dataSource.setUsername(user);
        dataSource.setPassword(password);
        return dataSource;
    }
    @Bean(name = "masterTransactionManager")
    @Primary
    public DataSourceTransactionManager masterTransactionManager() {
        return new DataSourceTransactionManager(masterDataSource());
    }
    @Bean(name = "masterSqlSessionFactory")
    @Primary
    public SqlSessionFactory masterSqlSessionFactory(@Qualifier("masterDataSource") DataSource masterDataSource)
            throws Exception {
        final SqlSessionFactoryBean sessionFactory = new SqlSessionFactoryBean();
        sessionFactory.setDataSource(masterDataSource);
        sessionFactory.setMapperLocations(new PathMatchingResourcePatternResolver()
                .getResources(MasterDataSourceConfig.MAPPER_LOCATION));
        return sessionFactory.getObject();
    }
}

@Primary 標(biāo)志這個(gè) Bean 如果在多個(gè)同類 Bean 候選時(shí)，該 Bean 優(yōu)先被考慮?！付鄶?shù)據(jù)源配置的時(shí)候注意，必須要有一個(gè)主數(shù)據(jù)源，用 @Primary 標(biāo)志該 Bean」
@MapperScan 掃描 Mapper 接口并容器管理，包路徑精確到 master，為了和下面 cluster 數(shù)據(jù)源做到精確區(qū)分
@Value 獲取全局配置文件 application.properties 的 kv 配置,并自動(dòng)裝配
sqlSessionFactoryRef 表示定義了 key ，表示一個(gè)唯一 SqlSessionFactory 實(shí)例

同理可得，從數(shù)據(jù)源 ClusterDataSourceConfig 配置如下：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
@Configuration
// 掃描 Mapper 接口并容器管理
@MapperScan(basePackages = ClusterDataSourceConfig.PACKAGE, sqlSessionFactoryRef = "clusterSqlSessionFactory")
public class ClusterDataSourceConfig {
    // 精確到 cluster 目錄，以便跟其他數(shù)據(jù)源隔離
    static final String PACKAGE = "org.spring.springboot.dao.cluster";
    static final String MAPPER_LOCATION = "classpath:mapper/cluster/*.xml";
    @Value("${cluster.datasource.url}")
    private String url;
    @Value("${cluster.datasource.username}")
    private String user;
    @Value("${cluster.datasource.password}")
    private String password;
    @Value("${cluster.datasource.driverClassName}")
    private String driverClass;
    @Bean(name = "clusterDataSource")
    public DataSource clusterDataSource() {
        DruidDataSource dataSource = new DruidDataSource();
        dataSource.setDriverClassName(driverClass);
        dataSource.setUrl(url);
        dataSource.setUsername(user);
        dataSource.setPassword(password);
        return dataSource;
    }
    @Bean(name = "clusterTransactionManager")
    public DataSourceTransactionManager clusterTransactionManager() {
        return new DataSourceTransactionManager(clusterDataSource());
    }
    @Bean(name = "clusterSqlSessionFactory")
    public SqlSessionFactory clusterSqlSessionFactory(@Qualifier("clusterDataSource") DataSource clusterDataSource)
            throws Exception {
        final SqlSessionFactoryBean sessionFactory = new SqlSessionFactoryBean();
        sessionFactory.setDataSource(clusterDataSource);
        sessionFactory.setMapperLocations(new PathMatchingResourcePatternResolver()
                .getResources(ClusterDataSourceConfig.MAPPER_LOCATION));
        return sessionFactory.getObject();
    }
}

上面數(shù)據(jù)配置分別掃描 Mapper 接口，org.spring.springboot.dao.master（對(duì)應(yīng) xml classpath:mapper/master ） 和 org.spring.springboot.dao.cluster（對(duì)應(yīng) xml classpath:mapper/cluster ） 包中對(duì)應(yīng)的 UserDAO 和 CityDAO 。
都有 @Mapper 標(biāo)志為 Mybatis 的并通過容器管理的 Bean。Mybatis 內(nèi)部會(huì)使用反射機(jī)制運(yùn)行去解析相應(yīng) SQL。

3.業(yè)務(wù)層 biz
biz 照常注入了兩個(gè) DAO，如同以前一樣正常工作。不用關(guān)心和指定到具體說明數(shù)據(jù)源。

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
/**
 * 用戶業(yè)務(wù)實(shí)現(xiàn)層
 *
 * Created by bysocket on 07/02/2017.
 */
@Service
public class UserServiceImpl implements UserService {
    @Autowired
    private UserDao userDao; // 主數(shù)據(jù)源
    @Autowired
    private CityDao cityDao; // 從數(shù)據(jù)源
    @Override
    public User findByName(String userName) {
        User user = userDao.findByName(userName);
        City city = cityDao.findByName("溫嶺市");
        user.setCity(city);
        return user;
    }
}

四、小結(jié)

多數(shù)據(jù)源適合的場(chǎng)景很多。不同的 DataSource ，不同的 SqlSessionFactory 和 不同的 DAO 層，在業(yè)務(wù)邏輯層做 整合?？偨Y(jié)的架構(gòu)圖如下：

同樣，如果實(shí)戰(zhàn)中，大家遇到什么，或者建議《Spring boot 那些事》還需要一起交流的。請(qǐng)點(diǎn)擊留言。


本站僅提供存儲(chǔ)服務(wù)，所有內(nèi)容均由用戶發(fā)布，如發(fā)現(xiàn)有害或侵權(quán)內(nèi)容，請(qǐng)點(diǎn)擊舉報(bào)。
打開APP，閱讀全文并永久保存 查看更多類似文章
猜你喜歡
類似文章
Spring Boot 整合 MyBatis
SpringBoot非官方教程 | 第七篇：springboot開啟聲明式事務(wù)
SpringBoot | 第九章：Mybatis-plus 的集成和使用
教你十分鐘構(gòu)建好 SpringBoot SSM 框架
SpringBoot 集成 MyBatis 框架 【SpringBoot系列2】
Spring Boot + Mybatis 實(shí)現(xiàn)動(dòng)態(tài)數(shù)據(jù)源
更多類似文章 >>
生活服務(wù)
分享 收藏 導(dǎo)長(zhǎng)圖 關(guān)注 下載文章
綁定賬號(hào)成功
后續(xù)可登錄賬號(hào)暢享VIP特權(quán)！
如果VIP功能使用有故障，
可點(diǎn)擊這里聯(lián)系客服！

聯(lián)系客服