util.java

java 小型系统连接池参照适用于中小型网站

        }
      }
    }
    catch(Exception e) {
      Util.create().writeExceptionMessage(
        "Util : closeConnection()", e,
        "Connection偺夝曻拞偵椺奜偑敪惗偟傑偟偨丅"
      );
      throw e;
    }
    finally {
      notifyAll();
      Util.create().writeMessage1("Util : closeConnection()", "notify.");
    }

    Util.create().writeMessage1("Util : closeConnection()", "愙懕悢 = " + String.valueOf(connectionCount));
    Util.create().writeMessage0("Util : closeConnection()", "end.");
  }

  //----------------------------------------------------------------------------

  /**<p>
  *巜掕偝傟偨弶婜壔僨乕僞僼傽僀儖偺搊榐傪峴偆丅<BR>
  *弶婜壔僨乕僞僼傽僀儖偲偼屻弎偡傞宍幃偱擟堄偺暥帤楍傪搊榐偟偨僼傽僀儖偱偁傝丄
  *傾僾儕働乕僔儑儞偼偙偺儊僜僢僪傪巊梡偟偰弶婜壔僨乕僞僼傽僀儖偺搊榐傪偡傞偙偲偑偱偒傞丅
  *</p><p>
  *<b>僨乕僞搊榐宍幃</b>:
  *<pre>
  *  僉乕 = 抣
  *</pre></p>
  *@param  fileName 弶婜壔僨乕僞僼傽僀儖偺僼儖僷僗柤丅
  *@param  key      撉傒庢傞抣偵懳墳偟偨僉乕丅
  */
  public synchronized static void addInitDataFiles(String key, String fileName) {
    initDataFiles.put(key, fileName);
  }

  /**<p>
  *巜掕偝傟偨弶婜壔僨乕僞僼傽僀儖偐傜巜掕偝傟偨僉乕偵懳墳偡傞抣傪撉傒庢傞丅<BR>
  *弶婜壔僨乕僞僼傽僀儖偲偼屻弎偡傞宍幃偱擟堄偺暥帤楍傪搊榐偟偨僼傽僀儖偱偁傝丄
  *傾僾儕働乕僔儑儞偼偙偺儊僜僢僪傪巊梡偟偰搊榐撪梕傪撉傒庢傞偙偲偑偱偒傞丅
  *</p><p>
  *<b>僨乕僞搊榐宍幃</b>:
  *<pre>
  *  僉乕 = 抣
  *</pre></p>
  *@param  fileName 弶婜壔僨乕僞僼傽僀儖偺僼儖僷僗柤丅
  *@param  key      撉傒庢傞抣偵懳墳偟偨僉乕丅
  *@return 撉傒庢偭偨抣丅
  *@throws FileNotFoundException 巜掕偝傟偨弶婜壔僨乕僞僼傽僀儖偑懚嵼偟側偄応崌丅
  *@throws IOException           巜掕偝傟偨弶婜壔僨乕僞僼傽僀儖偺撉傒崬傒偵幐攕偟偨応崌丅
  */
  public static String getInitParam(String fileName, String key) throws Exception {
    Util.create().writeMessage0("Util : getInitParam()", "start.");

    String _fileName = (String)initDataFiles.get(fileName);
    if(_fileName == null) {_fileName = fileName;}

    try {
      String  _inLine    = "";
      BufferedReader _in = new BufferedReader(new FileReader(_fileName));

      while ((_inLine = _in.readLine()) != null) {
        StringTokenizer _st = new StringTokenizer(_inLine, "=");
        if(_st.nextToken().equals(key)) {
          Util.create().writeMessage0("Util : getInitParam()", "ReadLine = " + _inLine);
          Util.create().writeMessage0("Util : getInitParam()", "end.");
          return _st.nextToken();
        }
      } // while ((_inLine = _in.readLine()) != null)
    }
    catch(FileNotFoundException e) {
      Util.create().writeExceptionMessage(
        "Util : getInitParam()", e,
        _fileName + "偑尒偮偐傝傑偣傫丅"
      );
      throw e;
    }
    catch(IOException e) {
      Util.create().writeExceptionMessage(
        "Util : getInitParam()", e,
        fileName + "偺撉傒崬傒偵幐攕偟傑偟偨丅"
      );
      throw e;
    }

    Util.create().writeMessage0("Util : getInitParam()", "end.");
    return new String("");
  }

  //----------------------------------------------------------------------------

  /**<p>
  *儘僌婰榐僣乕儖偵儊僢僙乕僕傪憲怣偡傞丅<BR>
  *儊僢僙乕僕婰榐儗儀儖偑0埲壓偺応崌丄搉偝傟偨儊僢僙乕僕傪儘僌婰榐僣乕儖傊憲怣偡傞丅
  *</p><p>
  *儊僢僙乕僕婰榐儗儀儖偼弶婜壔僨乕僞僼傽僀儖乮InitData.txt乯偺MessageLevel僉乕偵巜掕偝傟偨抣偵傛傝寛掕偝傟傞丅
  *Util偵偼婰榐儗儀儖偵懳墳偟偨儊僜僢僪偑梡堄偝傟偰偍傝丄偦傟偧傟埲壓偺傛偆偵摦嶌偡傞丅
  *</p>
  *<pre>
  *  writeMessage0()...儊僢僙乕僕婰榐儗儀儖 <= 0 偺帪丄搉偝傟偨儊僢僙乕僕傪婰榐丅
  *  writeMessage1()...儊僢僙乕僕婰榐儗儀儖 <= 1 偺帪丄搉偝傟偨儊僢僙乕僕傪婰榐丅
  *  writeMessage2()...儊僢僙乕僕婰榐儗儀儖 <= 2 偺帪丄搉偝傟偨儊僢僙乕僕傪婰榐丅
  *</pre>
  *<p>
  *幚嵺偵儘僌婰榐僣乕儖偵憲怣偝傟傞僼僅乕儅僢僩偼埲壓偺捠傝丅
  *</p>
  *<pre>
  *  I header偲偟偰搉偝傟偨撪梕 message偲偟偰搉偝傟偨撪梕
  *</pre>
  *@param header  儊僢僙乕僕偺僿僢僟乕丅儊僢僙乕僕偺弌椡尦傪帵偡忣曬偑搉偝傟傞偙偲傪憐掕偟偰偄傞丅
  *@param message 儊僢僙乕僕杮懱丅
  */
  public synchronized void writeMessage0(String header, String message) {
    if(messageLevel <= 0) {writeMessage(header, message);}
  }

  /**<p>
  *儘僌婰榐僣乕儖偵儊僢僙乕僕傪憲怣偡傞丅<BR>
  *儊僢僙乕僕婰榐儗儀儖偑1埲壓偺応崌丄搉偝傟偨儊僢僙乕僕傪儘僌婰榐僣乕儖傊憲怣偡傞丅
  *</p><p>
  *writeMessage0()傪嶲徠丅
  *</p>
  *@param header  儊僢僙乕僕偺僿僢僟乕丅儊僢僙乕僕偺弌椡尦傪帵偡忣曬偑搉偝傟傞偙偲傪憐掕偟偰偄傞丅
  *@param message 儊僢僙乕僕杮懱丅
  */
  public synchronized void writeMessage1(String header, String message) {
    if(messageLevel <= 1) {writeMessage(header, message);}
  }

  /**<p>
  *儘僌婰榐僣乕儖偵儊僢僙乕僕傪憲怣偡傞丅<BR>
  *儊僢僙乕僕婰榐儗儀儖偑2埲壓偺応崌丄搉偝傟偨儊僢僙乕僕傪儘僌婰榐僣乕儖傊憲怣偡傞丅
  *</p><p>
  *writeMessage0()傪嶲徠丅
  *</p>
  *@param header  儊僢僙乕僕偺僿僢僟乕丅儊僢僙乕僕偺弌椡尦傪帵偡忣曬偑搉偝傟傞偙偲傪憐掕偟偰偄傞丅
  *@param message 儊僢僙乕僕杮懱丅
  */
  public synchronized void writeMessage2(String header, String message) {
    if(messageLevel <= 2) {writeMessage(header, message);}
  }

  private void writeMessage(String header, String message) {
    try {
      if(logRecorder != null) {
        Object[] obj = new Object[1];
        obj[0] = new String("I " + header + " " + message);
        logRecorder.request(LogRecorder.WRITE_LOG, obj);
      }
//    if(logRecorder != null) {logRecorder.writeLog("I " + header + " " + message);}
      System.out.println("I " + header + " " + message);
    }
    catch(RemoteException _e) {}
  }

  /**<p>
  *儘僌婰榐僣乕儖偵椺奜儊僢僙乕僕傪憲怣偡傞丅<BR>
  *搉偝傟偨儊僢僙乕僕偲偲傕偵丄椺奜僀儞僗僞儞僗偐傜庢摼偱偒傞忣曬傪儘僌婰榐僣乕儖偵憲怣偡傞丅
  *幚嵺偵儘僌婰榐僣乕儖偵憲怣偝傟傞僼僅乕儅僢僩偼埲壓偺捠傝丅
  *</p>
  *<pre>
  *  E header偲偟偰搉偝傟偨撪梕 椺奜偑敪惗
  *  E  椺奜僋儔僗柤 = 搉偝傟偨椺奜偺僋儔僗柤
  *  E  message偲偟偰搉偝傟偨撪梕
  *</pre>
  *@param header  椺奜儊僢僙乕僕偺僿僢僟乕丅椺奜儊僢僙乕僕偺弌椡尦傪帵偡忣曬偑搉偝傟傞偙偲傪
  *               憐掕偟偰偄傞丅
  *@param e       敪惗偟偨椺奜偺僀儞僗僞儞僗丅
  *@param message 椺奜儊僢僙乕僕杮懱丅
  */
  public synchronized void writeExceptionMessage(String header, Exception e, String message) {
    try {
      if(logRecorder != null) {
        Object[] obj = new Object[1];
        obj[0] = new String("E " + header + " 椺奜偑敪惗");
        logRecorder.request(LogRecorder.WRITE_LOG, obj);
        obj[0] = new String("E  椺奜僋儔僗柤 = " + e.getClass().getName());
        logRecorder.request(LogRecorder.WRITE_LOG, obj);
        obj[0] = new String("E  " + message);
        logRecorder.request(LogRecorder.WRITE_LOG, obj);
      }
/*
      if(logRecorder != null) {
        logRecorder.writeLog("E " + header + " 椺奜偑敪惗");
        logRecorder.writeLog("E  椺奜僋儔僗柤 = " + e.getClass().getName());
        logRecorder.writeLog("E  " + message);
      }
*/
      System.out.println("E " + header + " 椺奜偑敪惗");
      System.out.println("E  椺奜僋儔僗柤 = " + e.getClass().getName());
      System.out.println("E  " + message);
    }
    catch(RemoteException _e) {}
  }

  /**<p>
  *儘僌婰榐僣乕儖偵SQL椺奜儊僢僙乕僕傪憲怣偡傞丅<BR>
  *搉偝傟偨SQL椺奜僀儞僗僞儞僗偐傜庢摼偱偒傞忣曬傪儘僌婰榐僣乕儖偵憲怣偡傞丅
  *幚嵺偵儘僌婰榐僣乕儖偵憲怣偝傟傞僼僅乕儅僢僩偼埲壓偺捠傝丅
  *</p>
  *<pre>
  *  E  SQL僄儔乕僐乕僪     = 搉偝傟偨SQL椺奜偺SQL僄儔乕僐乕僪
  *  E  SQL僄儔乕儊僢僙乕僕 = 搉偝傟偨SQL椺奜偺SQL僄儔乕儊僢僙乕僕
  *</pre>
  *@param e 敪惗偟偨SQL椺奜偺僀儞僗僞儞僗丅
  */
  public synchronized void writeSQLExceptionMessage(SQLException e) {
    try {
      if(logRecorder != null) {
        Object[] obj = new Object[1];
        obj[0] = new String("E  SQL僄儔乕僐乕僪     = " + e.getErrorCode());
        logRecorder.request(LogRecorder.WRITE_LOG, obj);
        obj[0] = new String("E  SQL僄儔乕儊僢僙乕僕 = " + e.getMessage());
        logRecorder.request(LogRecorder.WRITE_LOG, obj);
      }
/*
      if(logRecorder != null) {
        logRecorder.writeLog("E  SQL僄儔乕僐乕僪     = " + e.getErrorCode());
        logRecorder.writeLog("E  SQL僄儔乕儊僢僙乕僕 = " + e.getMessage());
      }
*/
      System.out.println("E  SQL僄儔乕僐乕僪     = " + e.getErrorCode());
      System.out.println("E  SQL僄儔乕儊僢僙乕僕 = " + e.getMessage());
   }
    catch(RemoteException _e) {}
  }

  public String nullToBlank(String str) throws Exception {
    if(str != null) {
      return str;
    }
    else {
      return "";
    }
  }
/*
  public synchronized void writeECFunctionExceptionMessage(ECFunctionException e) {
    try {
      if(logRecorder != null) {
        logRecorder.writeLog("E  EC僄儔乕儊僢僙乕僕  = " + e.getMessage());
        logRecorder.writeLog("E  EC僄儔乕僐乕僪      = " + Long.toHexString(e.getECFunctionErr()));
        logRecorder.writeLog("E  OpenSSL僄儔乕僐乕僪 = " + String.valueOf(e.getSysErr()));
      }
      System.out.println("E  EC僄儔乕儊僢僙乕僕  = " + e.getMessage());
      System.out.println("E  EC僄儔乕僐乕僪      = " + Long.toHexString(e.getECFunctionErr()));
      System.out.println("E  OpenSSL僄儔乕僐乕僪 = " + String.valueOf(e.getSysErr()));
    }
    catch(RemoteException _e) {}
  }
*/
}