需求：需要根據企業ID切換對應的數據庫，同時，后期可動態增加數據庫配置

JFinal框架中對于對于多數據源配置有兩種方式：
1.通過配置文件配置，有多少數據庫就要配置多少，服務啟動時加載所有數據庫，缺點：不能動態增加數據庫
2.只配置一個主數據庫信息就可以了，其他數據庫信息保存在表中，通過讀取表數據加載數據庫連接，優點：在數據表中增加數據庫配置即可動態增加數據庫連接。

本次主要介紹第2種方法：

一、新建數據表：保存數據庫連接信息

配置表對應的實體類

1. public class DbDto {
2. /**
3. * 企業ID
4. */
5. private String comp_id;
6. /**
7. * 企業名稱
8. */
9. private String comp_name;
10. /**
11. * 企業數據庫名
12. */
13. private String dbname;
14. /**
15. * 連接地址（ip + 端口號）
16. */
17. private String dbhost;
18. /**
19. * 用戶名
20. */
21. private String dbuser;
22. /**
23. * 用戶密碼
24. */
25. private String dbpwd;
26. /**
27. * 表名前綴
28. */
29. private String prefix;
30. /**
31. * 編碼類型
32. */
33. private String charset;
34. /**
35. * 默認庫(1:是 0:不是)
36. */
37. private String is_default;
38.  
39. }

二、切換數據庫公共方法，根據企業ID切換對應的數據庫（需要依賴druid）

1. /**
2. * 根據企業ID查詢對應數據庫
3. *
4. * @param compId 企業ID
5. * @return 數據庫配置名
6. * @throws Exception 返回處理異常
7. */
8. public static String chooseDbByCompId(String compId) throws Exception{
9. //企業ID為空時，默認使用主數據庫
10. if (StringUtils.isBlank(compId)){
11. return SYS_TABLE.MASTER_DB;
12. }
13. DbDto dbDto;
14. try {
15. //查詢Redis緩存的compId對應的數據庫配置信息
16. String jsonStr = RedisClient.getString(SYS.REDIS_COMP_DB + compId);
17. if (StringUtils.isNotBlank(jsonStr)){
18. dbDto = JSONObject.parseObject(jsonStr, DbDto.class);
19. }else {
20. //緩存不存在，查詢數據庫
21. Record dbRecord = Db.use(SYS_TABLE.MASTER_DB).findFirst("select * from 配置表 where comp_id = ? ", compId);
22. //parseObject方法是自己封裝的Record轉實體類方法，在前面的文章有寫過，也是在這個工具類中
23. dbDto = parseObject(dbRecord, DbDto.class);
24. //加入緩存
25. if (dbDto != null){
26. RedisClient.setString(SYS.REDIS_COMP_DB + compId, JSONObject.toJSONString(dbDto));
27. }
28. }
29. if (dbDto == null){
30. logger.info("切換數據庫失敗,企業不存在或無對應數據庫配置!");
31. return null;
32. }
33. //是否已存在該數據庫連接
34. if (DbKit.getConfig(dbDto.getDbname()) == null){
35. //創建數據庫連接
36. DruidPlugin plugin = new DruidPlugin("jdbc:mysql://" + dbDto.getDbhost()+ "/"+dbDto.getDbname(), dbDto.getDbuser(), dbDto.getDbpwd());
37. plugin.start();
38. ActiveRecordPlugin arp= new ActiveRecordPlugin(dbDto.getDbname(), plugin);
39. arp.start();
40. }
41. }catch (Exception e){
42. logger.error("捕獲異常: 切換數據庫失敗!", e);
43. return null;
44. }
45. return dbDto.getDbname();
46. }

這樣根據參數compId即可動態選擇參數對應的數據庫（CommonUtil是我封裝這個方法的工具類）

1. Db.use(CommonUtil.chooseDbByCompId(compId)).find（“”）；

到此這篇關于Java中JFinal框架動態切換數據庫的方法的文章就介紹到這了,更多相關JFinal框架動態切換數據庫內容請搜索服務器之家以前的文章或繼續瀏覽下面的相關文章希望大家以后多多支持服務器之家！

原文鏈接：https://blog.csdn.net/weixin_44157394/article/details/115008452