av一区二区在线观看_亚洲男人的天堂网站_日韩亚洲视频_在线成人免费_欧美日韩精品免费观看视频_久草视

您的位置:首頁技術文章
文章詳情頁

Spring AbstractRoutingDatasource 動態數據源的實例講解

瀏覽:6日期:2023-06-30 13:18:08
Spring AbstractRoutingDatasource 動態數據源數據源上下文

AbstractRoutingDatasource 需要信息決定路由到那個數據源,該信息我們稱為上下文??梢允腥魏螌ο螅旅媸纠覀兪褂妹杜e ClientDatabase 作為上下文:

public enum ClientDatabase { CLIENT_A, CLIENT_B}

值得注意的是,實際中上下文可以是任何有意義的領域對象。如 Environment 定義上下文,在這種上下文中枚舉可以包括 PRODUCTION, DEVELOPMENT, and TESTING.

上下文持有者 ( ContextHolder )

上下文持有者實現是存儲當前上下文的容器,如 ThreadLocal 對象。除了包括上下文引用外,還應該包括set , get , clear 靜態方法,AbstractRoutingDatasource 將查詢 ContextHolder 獲得 上下文,然后使用上下文查找實際的數據源。

這里最重要的是使用 ThreadLocal ,讓上下文綁定只當前執行線程。使用這種方法就是為了保障當數據訪問邏輯跨多個數據源使用事務:

public class ClientDatabaseContextHolder { private static ThreadLocal<ClientDatabase> CONTEXT = new ThreadLocal<>(); public static void set(ClientDatabase clientDatabase) {Assert.notNull(clientDatabase, 'clientDatabase cannot be null');CONTEXT.set(clientDatabase); } public static ClientDatabase getClientDatabase() {return CONTEXT.get(); } public static void clear() {CONTEXT.remove(); }}數據源路由器

下面定義 ClientDataSourceRouter 繼承 AbstractRoutingDataSource. 重寫方法 determineCurrentLookupKey ,查詢 ClientDatabaseContextHolder 獲得當前 上下文。AbstractRoutingDataSource 幫我們處理了其他邏輯,僅了解它透明地返回了合適的數據源:

public class ClientDataSourceRouter extends AbstractRoutingDataSource { @Override protected Object determineCurrentLookupKey() {return ClientDatabaseContextHolder.getClientDatabase(); }}配置

下面利用Map上下文存儲DataSource對象,用于配置 AbstractRoutingDataSource 。當然也可以指定缺省數據源,當沒有設定上下文時選擇缺省數據源。

@Configurationpublic class RoutingTestConfiguration { @Bean public ClientService clientService() {return new ClientService(new ClientDao(clientDatasource())); } @Bean public DataSource clientDatasource() {Map<Object, Object> targetDataSources = new HashMap<>();DataSource clientADatasource = clientADatasource();DataSource clientBDatasource = clientBDatasource();targetDataSources.put(ClientDatabase.CLIENT_A, clientADatasource);targetDataSources.put(ClientDatabase.CLIENT_B, clientBDatasource);ClientDataSourceRouter clientRoutingDatasource = new ClientDataSourceRouter();clientRoutingDatasource.setTargetDataSources(targetDataSources);clientRoutingDatasource.setDefaultTargetDataSource(clientADatasource);return clientRoutingDatasource; } // ...}

我們可以使用不同方式的數據源,但典型場景時運行時創建,或使用JNDI方式查找。下面定義示例的Dao類,它依賴動態數據源進行實例化:

public class ClientDao { private static final String SQL_GET_CLIENT_NAME = 'select name from client'; private final JdbcTemplate jdbcTemplate; public ClientDao(DataSource datasource) {this.jdbcTemplate = new JdbcTemplate(datasource); } public String getClientName() {return this.jdbcTemplate.query(SQL_GET_CLIENT_NAME, rowMapper).get(0); } private static RowMapper<String> rowMapper = (rs, rowNum) -> {return rs.getString('name'); };}使用動態數據源

實際使用時,首先設置上下文,然后再執行業務操作。我們定義業務層,其中業務方法包括上下文作為參數。在執行業務之前設置上下文,調用之后清除上下文:

public class ClientService { private final ClientDao clientDao; public ClientService(ClientDao clientDao) {this.clientDao = clientDao; } public String getClientName(ClientDatabase clientDb) {ClientDatabaseContextHolder.set(clientDb);String clientName = this.clientDao.getClientName();ClientDatabaseContextHolder.clear();return clientName; }}總結

本文通過示例解釋如何使用 Spring AbstractRoutingDataSource 實現 動態數據源切換。

以上為個人經驗,希望能給大家一個參考,也希望大家多多支持好吧啦網。

標簽: Spring
相關文章:
主站蜘蛛池模板: 婷婷开心激情综合五月天 | 国产激情自拍视频 | 一区影院 | 亚洲www. | 日韩欧美精品一区 | 天堂综合网 | 亚洲综合日韩精品欧美综合区 | 99精品视频在线 | 精品一区二区三区在线观看 | 久久福利电影 | julia中文字幕久久一区二区 | 国产91亚洲精品一区二区三区 | 国产精品久久久久久久久久久久 | 性色av网站 | 亚洲视频在线看 | 精品福利在线 | 91精品国产一区二区三区 | 免费同性女女aaa免费网站 | 欧美激情亚洲激情 | 亚洲精品字幕 | 免费视频久久 | 午夜精品久久久久久不卡欧美一级 | 久久久夜 | 精品国产一二三区 | 超碰人人人人 | 精品国产91乱码一区二区三区 | 成人国产精品免费观看 | 97狠狠干 | 特黄色一级毛片 | 7777精品伊人久久精品影视 | 三级视频久久 | 精品国产一级 | 羞羞的视频免费在线观看 | 一区二区三区欧美 | jizz中国日本 | av天天澡天天爽天天av | 在线中文字幕国产 | 99热.com| 一本久久a久久精品亚洲 | 精品在线视频播放 | 欧美日韩亚洲在线 |