Java中如何使用JFinal框架動(dòng)態(tài)切換數(shù)據(jù)庫(kù)

這篇文章主要介紹了Java中如何使用JFinal框架動(dòng)態(tài)切換數(shù)據(jù)庫(kù)，具有一定借鑒價(jià)值，感興趣的朋友可以參考下，希望大家閱讀完這篇文章之后大有收獲，下面讓小編帶著大家一起了解一下。

需求：需要根據(jù)企業(yè)ID切換對(duì)應(yīng)的數(shù)據(jù)庫(kù)，同時(shí)，后期可動(dòng)態(tài)增加數(shù)據(jù)庫(kù)配置

JFinal框架中對(duì)于對(duì)于多數(shù)據(jù)源配置有兩種方式：
1.通過(guò)配置文件配置，有多少數(shù)據(jù)庫(kù)就要配置多少，服務(wù)啟動(dòng)時(shí)加載所有數(shù)據(jù)庫(kù)，缺點(diǎn)：不能動(dòng)態(tài)增加數(shù)據(jù)庫(kù)
2.只配置一個(gè)主數(shù)據(jù)庫(kù)信息就可以了，其他數(shù)據(jù)庫(kù)信息保存在表中，通過(guò)讀取表數(shù)據(jù)加載數(shù)據(jù)庫(kù)連接，優(yōu)點(diǎn)：在數(shù)據(jù)表中增加數(shù)據(jù)庫(kù)配置即可動(dòng)態(tài)增加數(shù)據(jù)庫(kù)連接。

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

一、新建數(shù)據(jù)表：保存數(shù)據(jù)庫(kù)連接信息

配置表對(duì)應(yīng)的實(shí)體類

public class DbDto {
  /**
   * 企業(yè)ID
   */
  private String comp_id;
  /**
   * 企業(yè)名稱
   */
  private String comp_name;
  /**
   * 企業(yè)數(shù)據(jù)庫(kù)名
   */
  private String dbname;
  /**
   * 連接地址（ip + 端口號(hào)）
   */
  private String dbhost;
  /**
   * 用戶名
   */
  private String dbuser;
  /**
   * 用戶密碼
   */
  private String dbpwd;
  /**
   * 表名前綴
   */
  private String prefix;
  /**
   * 編碼類型
   */
  private String charset;
  /**
   * 默認(rèn)庫(kù)(1:是 0:不是)
   */
  private String is_default;

}

二、切換數(shù)據(jù)庫(kù)公共方法，根據(jù)企業(yè)ID切換對(duì)應(yīng)的數(shù)據(jù)庫(kù)（需要依賴druid）

/**
   * 根據(jù)企業(yè)ID查詢對(duì)應(yīng)數(shù)據(jù)庫(kù)
   *
   * @param compId      企業(yè)ID
   * @return         數(shù)據(jù)庫(kù)配置名
   * @throws Exception    返回處理異常
   */
  public static String chooseDbByCompId(String compId) throws Exception{
    //企業(yè)ID為空時(shí)，默認(rèn)使用主數(shù)據(jù)庫(kù)
    if (StringUtils.isBlank(compId)){
      return SYS_TABLE.MASTER_DB;
    }
    DbDto dbDto;
    try {
      //查詢Redis緩存的compId對(duì)應(yīng)的數(shù)據(jù)庫(kù)配置信息
      String jsonStr = RedisClient.getString(SYS.REDIS_COMP_DB + compId);
      if (StringUtils.isNotBlank(jsonStr)){
        dbDto = JSONObject.parseObject(jsonStr, DbDto.class);
      }else {
        //緩存不存在，查詢數(shù)據(jù)庫(kù)
        Record dbRecord = Db.use(SYS_TABLE.MASTER_DB).findFirst("select * from 配置表 where comp_id = ? ", compId);
        //parseObject方法是自己封裝的Record轉(zhuǎn)實(shí)體類方法，在前面的文章有寫過(guò)，也是在這個(gè)工具類中
        dbDto = parseObject(dbRecord, DbDto.class);
        //加入緩存
        if (dbDto != null){
          RedisClient.setString(SYS.REDIS_COMP_DB + compId, JSONObject.toJSONString(dbDto));
        }
      }
      if (dbDto == null){
        logger.info("切換數(shù)據(jù)庫(kù)失敗,企業(yè)不存在或無(wú)對(duì)應(yīng)數(shù)據(jù)庫(kù)配置!");
        return null;
      }
      //是否已存在該數(shù)據(jù)庫(kù)連接
      if (DbKit.getConfig(dbDto.getDbname()) == null){
        //創(chuàng)建數(shù)據(jù)庫(kù)連接
        DruidPlugin plugin = new DruidPlugin("jdbc:mysql://" + dbDto.getDbhost()+ "/"+dbDto.getDbname(), dbDto.getDbuser(), dbDto.getDbpwd());
        plugin.start();
        ActiveRecordPlugin arp= new ActiveRecordPlugin(dbDto.getDbname(), plugin);
        arp.start();
      }
    }catch (Exception e){
      logger.error("捕獲異常: 切換數(shù)據(jù)庫(kù)失敗!", e);
      return null;
    }
    return dbDto.getDbname();
  }

這樣根據(jù)參數(shù)compId即可動(dòng)態(tài)選擇參數(shù)對(duì)應(yīng)的數(shù)據(jù)庫(kù)（CommonUtil是我封裝這個(gè)方法的工具類）

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

感謝你能夠認(rèn)真閱讀完這篇文章，希望小編分享的“Java中如何使用JFinal框架動(dòng)態(tài)切換數(shù)據(jù)庫(kù)”這篇文章對(duì)大家有幫助，同時(shí)也希望大家多多支持億速云，關(guān)注億速云行業(yè)資訊頻道，更多相關(guān)知識(shí)等著你來(lái)學(xué)習(xí)!