馬老師Flink實(shí)時(shí)計(jì)算引擎
2022-11-17 23:40 作者:bili_1559000721 | 我要投稿
既然它錯(cuò)了，那我就強(qiáng)行修正唄。這屬性還不對(duì)外暴露，我只能選擇反射。像這樣:
? ? ? ?Environment environment = sessionFactory.getConfiguration().getEnvironment();
? ? ? ?Field dataSourceField = environment.getClass().getDeclaredField("dataSource");
? ? ? ?dataSourceField.setAccessible(true);
? ? ? ?dataSourceField.set(environment, dynamicDataSource.determineTargetDataSource());
標(biāo)簽：
