前两天，我們已經介紹了關於JdbcTemplate的多數據源配置以及Spring Data JPA的多數據源配置，接下來具體說說使用MyBatis時候的多數據源場景該如何配置。
添加多數據源的配置
先在Spring Boot的配置文件application.properties中設置兩個你要鏈接的數據庫配置，比如這樣：
spring.datasource.primary.jdbc-url=jdbc:mysql://localhost:3306/test1
spring.datasource.primary.username=root
spring.datasource.primary.password=123456
spring.datasource.primary.driver-class-name=com.mysql.cj.jdbc.Driver
spring.datasource.secondary.jdbc-url=jdbc:mysql://localhost:3306/test2
spring.datasource.secondary.username=root
spring.datasource.secondary.password=123456
spring.datasource.secondary.driver-class-name=com.mysql.cj.jdbc.Driver
說明與注意：
- 多數據源配置的時候，與單數據源不同點在於spring.datasource之後多設置一個數據源名稱primary和secondary來區分不同的數據源配置，這個前綴將在後續初始化數據源的時候用到。
- 數據源連接配置2.x和1.x的配置項是有區別的：2.x使用spring.datasource.secondary.jdbc-url，而1.x版本使用spring.datasource.secondary.url。如果你在配置的時候發生了這個報錯java.lang.IllegalArgumentException: jdbcUrl is required with driverClassName.，那麼就是這個配置項的問題。
- 可以看到，不論使用哪一種數據訪問框架，對於數據源的配置都是一樣的。
初始化數據源與MyBatis配置
完成多數據源的配置信息之後，就來創建個配置類來加載這些配置信息，初始化數據源，以及初始化每個數據源要用的MyBatis配置。
這裏我們繼續將數據源與框架配置做拆分處理：
- 單獨建一個多數據源的配置類，比如下面這樣：
@Configuration
public class DataSourceConfiguration {
@Primary
@Bean
@ConfigurationProperties(prefix = "spring.datasource.primary")
public DataSource primaryDataSource() {
return DataSourceBuilder.create().build();
}
@Bean
@ConfigurationProperties(prefix = "spring.datasource.secondary")
public DataSource secondaryDataSource() {
return DataSourceBuilder.create().build();
}
}
可以看到內容跟JdbcTemplate、Spring Data JPA的時候是一模一樣的。通過@ConfigurationProperties可以知道這兩個數據源分別加載了spring.datasource.primary.*和spring.datasource.secondary.*的配置。@Primary註解指定了主數據源，就是當我們不特別指定哪個數據源的時候，就會使用這個Bean真正差異部分在下面的JPA配置上。
- 分別創建兩個數據源的MyBatis配置。
Primary數據源的JPA配置：
@Configuration
@MapperScan(
basePackages = "com.didispace.chapter39.p",
sqlSessionFactoryRef = "sqlSessionFactoryPrimary",
sqlSessionTemplateRef = "sqlSessionTemplatePrimary")
public class PrimaryConfig {
private DataSource primaryDataSource;
public PrimaryConfig(@Qualifier("primaryDataSource") DataSource primaryDataSource) {
this.primaryDataSource = primaryDataSource;
}
@Bean
public SqlSessionFactory sqlSessionFactoryPrimary() throws Exception {
SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
bean.setDataSource(primaryDataSource);
return bean.getObject();
}
@Bean
public SqlSessionTemplate sqlSessionTemplatePrimary() throws Exception {
return new SqlSessionTemplate(sqlSessionFactoryPrimary());
}
}
Secondary數據源的JPA配置：
@Configuration
@MapperScan(
basePackages = "com.didispace.chapter39.s",
sqlSessionFactoryRef = "sqlSessionFactorySecondary",
sqlSessionTemplateRef = "sqlSessionTemplateSecondary")
public class SecondaryConfig {
private DataSource secondaryDataSource;
public SecondaryConfig(@Qualifier("secondaryDataSource") DataSource secondaryDataSource) {
this.secondaryDataSource = secondaryDataSource;
}
@Bean
public SqlSessionFactory sqlSessionFactorySecondary() throws Exception {
SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
bean.setDataSource(secondaryDataSource);
return bean.getObject();
}
@Bean
public SqlSessionTemplate sqlSessionTemplateSecondary() throws Exception {
return new SqlSessionTemplate(sqlSessionFactorySecondary());
}
}
說明與注意：
- 配置類上使用
@MapperScan註解來指定當前數據源下定義的Entity和Mapper的包路徑；另外需要指定sqlSessionFactory和sqlSessionTemplate，這兩個具體實現在該配置類中類中初始化。 - 配置類的構造函數中，通過
@Qualifier註解來指定具體要用哪個數據源，其名字對應在DataSourceConfiguration配置類中的數據源定義的函數名。 - 配置類中定義SqlSessionFactory和SqlSessionTemplate的實現，注意具體使用的數據源正確（如果使用這裏的演示代碼，只要第二步沒問題就不需要修改）。
上一篇介紹JPA的時候，因為之前介紹JPA的使用時候，說過實體和Repository定義的方法，所以省略了 User 和 Repository的定義代碼，但是還是有讀者問怎麼沒有這個，其實都有說明，倉庫代碼里也都是有的。未避免再問這樣的問題，所以這裏就貼一下吧。
根據上面Primary數據源的定義，在com.didispace.chapter39.p包下，定義Primary數據源要用的實體和數據訪問對象，比如下面這樣：
@Data
@NoArgsConstructor
public class UserPrimary {
private Long id;
private String name;
private Integer age;
public UserPrimary(String name, Integer age) {
this.name = name;
this.age = age;
}
}
public interface UserMapperPrimary {
@Select("SELECT * FROM USER WHERE NAME = #{name}")
UserPrimary findByName(@Param("name") String name);
@Insert("INSERT INTO USER(NAME, AGE) VALUES(#{name}, #{age})")
int insert(@Param("name") String name, @Param("age") Integer age);
@Delete("DELETE FROM USER")
int deleteAll();
}
根據上面Secondary數據源的定義，在com.didispace.chapter39.s包下，定義Secondary數據源要用的實體和數據訪問對象，比如下面這樣：
@Data
@NoArgsConstructor
public class UserSecondary {
private Long id;
private String name;
private Integer age;
public UserSecondary(String name, Integer age) {
this.name = name;
this.age = age;
}
}
public interface UserMapperSecondary {
@Select("SELECT * FROM USER WHERE NAME = #{name}")
UserSecondary findByName(@Param("name") String name);
@Insert("INSERT INTO USER(NAME, AGE) VALUES(#{name}, #{age})")
int insert(@Param("name") String name, @Param("age") Integer age);
@Delete("DELETE FROM USER")
int deleteAll();
}
測試驗證
完成了上面之後，我們就可以寫個測試類來嘗試一下上面的多數據源配置是否正確了，先來設計一下驗證思路：
- 往Primary數據源插入一條數據
- 從Primary數據源查詢剛才插入的數據，配置正確就可以查詢到
- 從Secondary數據源查詢剛才插入的數據，配置正確應該是查詢不到的
- 往Secondary數據源插入一條數據
- 從Primary數據源查詢剛才插入的數據，配置正確應該是查詢不到的
- 從Secondary數據源查詢剛才插入的數據，配置正確就可以查詢到
具體實現如下：
@Slf4j
@RunWith(SpringRunner.class)
@SpringBootTest
@Transactional
public class Chapter39ApplicationTests {
@Autowired
private UserMapperPrimary userMapperPrimary;
@Autowired
private UserMapperSecondary userMapperSecondary;
@Before
public void setUp() {
// 清空測試表，保證每次結果一樣
userMapperPrimary.deleteAll();
userMapperSecondary.deleteAll();
}
@Test
public void test() throws Exception {
// 往Primary數據源插入一條數據
userMapperPrimary.insert("AAA", 20);
// 從Primary數據源查詢剛才插入的數據，配置正確就可以查詢到
UserPrimary userPrimary = userMapperPrimary.findByName("AAA");
Assert.assertEquals(20, userPrimary.getAge().intValue());
// 從Secondary數據源查詢剛才插入的數據，配置正確應該是查詢不到的
UserSecondary userSecondary = userMapperSecondary.findByName("AAA");
Assert.assertNull(userSecondary);
// 往Secondary數據源插入一條數據
userMapperSecondary.insert("BBB", 20);
// 從Primary數據源查詢剛才插入的數據，配置正確應該是查詢不到的
userPrimary = userMapperPrimary.findByName("BBB");
Assert.assertNull(userPrimary);
// 從Secondary數據源查詢剛才插入的數據，配置正確就可以查詢到
userSecondary = userMapperSecondary.findByName("BBB");
Assert.assertEquals(20, userSecondary.getAge().intValue());
}
}
代碼示例
本文的相關例子可以查看下面倉庫中的chapter3-9目錄：
- Github：https://github.com/dyc87112/SpringBoot-Learning/
- Gitee：https://gitee.com/didispace/SpringBoot-Learning/
如果您覺得本文不錯，歡迎Star支持，您的關注是我堅持的動力！
本站聲明:網站內容來源於博客園,如有侵權,請聯繫我們,我們將及時處理
【其他文章推薦】
※為什麼 USB CONNECTOR 是電子產業重要的元件?
※網頁設計一頭霧水該從何著手呢? 台北網頁設計公司幫您輕鬆架站!
※台北網頁設計公司全省服務真心推薦
※想知道最厲害的網頁設計公司"嚨底家"!
※新北清潔公司,居家、辦公、裝潢細清專業服務
※推薦評價好的iphone維修中心
《富比世》報導，當特斯拉 Model S 電動車上市時，Gogoro 創辦人陸學森原本想要擁有一輛，但是第一個問題是在台灣沒有上市，就算進口一輛，台灣的住處大樓沒有獨立車庫，無法安裝幫 Model S 電動車充電的充電座，若非要開 Model S 電動車，只能在公司裝設充電座在公司充電，但這樣一來，週末就無法開出去兜風，豈不是大煞風景，最後陸學森在女友說服下，還是打退堂鼓。 這個困擾，其實也是各國所有大樓住戶的困擾，雖然以美國來說，如加州等地區路上設有充電站，不過電動車車主總是想要在家把電充飽飽才開出門，以免半路沒電，據美國能源部統計，80% 電動車都是在家充電，要是在家不能充電，購買電動車的意願就會降低，ChargePoint 執行長帕斯奎‧羅曼諾（Pasquale Romano）表示，除了少數例外，住大樓的人通常不買電動車，正是因為如此。 那要如何改善這個情況？羅曼諾認為，過去為了讓少數電動車主能在大樓停車場充電，大樓業主得全數自掏腰包在停車場設置充電座，投資風險很高，因此意願低落，但大樓業主如果並不用負擔充電座的設置費用，像大樓附設的投幣式自助洗衣機一樣，由業者來設置機器，這樣就成了。 
特斯拉（Tesla）高調宣布鋰電池儲能系統，其中針對企業用戶的「Powerpack」，100 度電售價 25,000 美元，已將平均儲能成本拉低到相當驚人的每度電 250 美元，一般認為若平均儲能成本降到每度電 100 美元，將引爆能源儲存革命，特斯拉挾 GigaFactory 的威力，正全速逼近這個目標，不過，卻有一個小型新創事業，認為現在就可以做到。 這家新創事業 FreeWire 初期募資金額不過 42.5 萬美元，加上美國海軍資助 50 萬美元，如何能超越家大業大的特斯拉？其實原理也不難，就是採用二手電池。 FreeWire 、日產（Nissan）與 NEC 合資的汽車能源供應公司（Automotive Energy Supply Corporation，AESC）合作，AESC 是僅次於 Panasonic，全球第二大車用鋰電池供應商，市佔率達 21%，2014 年銷售最佳的電動車是 Nissan Leaf，其電池正是由 AESC 供應，Nissan 每個月都會測試電池，每六個月就汰換效能已經衰退的鋰電池，數量以千計，對 Nissan 來說庫存這些二線電池是個麻煩，但這些電池的效能或許已經不不敷電動車所需，拿來做為能源儲存用途卻還很有用。 於是，FreeWire 以新電池六分之一的價格取得這些二手電池，第一步，是取之於電動車用之於電動車，將這些二手電池組裝成總容量 48 度電的行動充電車，專供電動車在本來沒有設置充電座的停車場、機場、企業廠區等處充電，行動充電車可以推到停車場任何一個停車格，幫電動車充電，如此一來，停車場可以省下設置大量充電座的成本，卻能提供身為少數的電動車主充電服務，而這些二手電池在每天充放電循環 2 次的情況下，還可以有 5 年的壽命。 