1.使用場(chǎng)景

一個(gè)mybatis entity 對(duì)應(yīng)多張表（表明不同的表–> 多張表結(jié)構(gòu)一致只有表名稱不同），在使用時(shí)，可以動(dòng)態(tài)映射表名稱。
比如：按照時(shí)間分表，某些業(yè)務(wù)冷熱數(shù)據(jù)分離后數(shù)據(jù)存在不同的表中等

2.一定要時(shí)常注意工具的更新，不吃虧

因?yàn)楣ぷ餍枰?，最近需要?shí)現(xiàn)一個(gè)類似如下業(yè)務(wù)等功能交互：

簡(jiǎn)單的描述就是：有一部分的表數(shù)據(jù)，采用了外部同步的模式，同步到了doris中，在業(yè)務(wù)中采用雙數(shù)據(jù)源的方式，數(shù)據(jù)寫在mysql，讀走doris （此處不考慮數(shù)據(jù)同步的延遲問題 ，這是個(gè)大問題，但我們這篇文章先不考慮這個(gè)問題）。

要實(shí)現(xiàn)上面的方案，需要解決以下幾個(gè)問題：

雙數(shù)據(jù)源的問題doris/mysql中庫(kù)和表的名稱不一致（例如：上圖綠色打底的表，在mysql和doris中表的結(jié)構(gòu)一致，但在mysql中庫(kù).表名為 ： databaseA.tableA ，在doris中則為 databaseB.ods_tableB_s）

在之前項(xiàng)目研究中，因?yàn)橛凶约喝プ远xdao層mapper的方法，mybatis表中的方法對(duì)應(yīng)的sql在項(xiàng)目啟動(dòng)時(shí)就已經(jīng)生成好了對(duì)應(yīng)的sql模板，在程序運(yùn)行中，只是用參數(shù)代替即可。

例如上圖，因?yàn)槲抑坝玫膍ybatis-plus 的版本比較低，在生成模板時(shí)實(shí)際上就已經(jīng)確定了表的名稱。這就導(dǎo)致了無(wú)法在使用的時(shí)候重新替換。為了實(shí)現(xiàn)這個(gè)功能，自己實(shí)現(xiàn)的時(shí)候也是一直往我如何在生成模板語(yǔ)句的時(shí)候就直接把我想要的表名替換替換進(jìn)去。 在實(shí)現(xiàn)的差不多的時(shí)候，同事來(lái)了一句，mybatis-plus不是支持的嗎？ hhhh，所以說(shuō)，還是要去關(guān)注一下你在項(xiàng)目中所用到的jar包的迭代更新哦，會(huì)發(fā)現(xiàn)很多，然后開始偷懶。

3.對(duì)mybatis-plus進(jìn)行升級(jí)

我把版本從：3.3.0 升級(jí)到了 3.4.3.2
啟動(dòng)項(xiàng)目的時(shí)候發(fā)現(xiàn)服務(wù)啟動(dòng)失敗了，著急嘿～

然后在解決問題的過(guò)程中發(fā)現(xiàn)時(shí)因?yàn)閖ar包沖突了 。
然后發(fā)現(xiàn)了idea中一個(gè)很好使用的工具【在pom.xml文件中要，右擊鼠標(biāo)進(jìn)入到Maven -> show dependence 】可以很直觀的看見沖突法jar包，然后去解決對(duì)應(yīng)的沖突就可以了 （這里不多說(shuō)了，給大家一個(gè)學(xué)習(xí)鏈接傳送門：https://blog.csdn.net/daerzei/article/details/82344569）

4.將原來(lái)的mybatis的插件配置調(diào)整成新版本的，并添加上動(dòng)態(tài)表名的模塊

4.1 調(diào)整mybatis plus 配置

    @Bean
    public MybatisPlusInterceptor mybatisPlusInterceptor() {
        MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor();
        interceptor.addInnerInterceptor(new PaginationInnerInterceptor(DbType.MYSQL));

        DynamicTableNameInnerInterceptor dynamicTableNameInnerInterceptor = new DynamicTableNameInnerInterceptor();
        //添加上自己實(shí)現(xiàn)的表名處理器DayRecordTableNameHandler
        dynamicTableNameInnerInterceptor.setTableNameHandler(new DayRecordTableNameHandler());
        interceptor.addInnerInterceptor(dynamicTableNameInnerInterceptor);

        return interceptor;
    }

4.2 自定義表名稱處理器

結(jié)合threadlocal 來(lái)確定對(duì)對(duì)應(yīng)的業(yè)務(wù)邏輯使用什么表名稱（我這里是利用將數(shù)據(jù)源信息放入到threadlocal中，然后來(lái)映射不同的表名稱），下面的代碼示例是一個(gè)簡(jiǎn)化版：

public class DayRecordTableNameHandler implements TableNameHandler {
    private static final Logger log = LoggerFactory.getLogger(DayRecordTableNameHandler.class);

    public DayRecordTableNameHandler(){
    }

    @Override
    public String dynamicTableName(String sql, String tableName) {
        Object dataSource = HnThreadLocal.get(SystemConstants.DATASOURCE);
        if(Objects.isNull(dataSource)){
            return tableName;
        }
        if(Objects.equals(tableName,"zsh_day_record")){
            int dataSourceIntValue = (int)dataSource;
            if(Objects.equals(dataSourceIntValue,1)){
                log.info("表名替換:"+tableName+"--->sql:ods_zsh_day_record_s");
                return "ods_zsh_day_record_s";
            }
        }
        return tableName;
    }

}

4.3 利用AOP切換數(shù)據(jù)源

這里想省略了，多數(shù)據(jù)源用的是dynamic-datasource-spring-boot-starter
AOP監(jiān)聽多是 @DS ，依據(jù)注解value來(lái)判斷數(shù)據(jù)源是不是走doris

5.運(yùn)行一下

成功運(yùn)行

6. 需要注意的地方

threadlocal 中的數(shù)據(jù)在aop中最好自己釋放掉 ，spring是用的線程池，如果不清理掉會(huì)影響線程下次使用的程序這是個(gè)草稿實(shí)現(xiàn)，因?yàn)榍懊鎻?qiáng)調(diào)的數(shù)據(jù)同步模塊，是需要考慮進(jìn)去的，繼續(xù)摸索啦～～～

到此這篇關(guān)于mybatis-plus動(dòng)態(tài)表名實(shí)現(xiàn)方法的文章就介紹到這了,更多相關(guān)mybatis-plus動(dòng)態(tài)表名內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！