クラス DBAccessQueue

java.lang.Object
org.opengion.hayabusa.queue.DBAccessQueue

public class DBAccessQueue extends Object
キュー処理用のDBアクセスクラス キューの受信と送信処理で、 データベースにアクセスして処理を行います。 実際のMQ,SQSとの通信そのものはfukurouで行います。
変更履歴:
5.10.15.2 (2019/09/20) 新規作成
機能分類
メッセージ連携
導入されたバージョン:
JDK7
  • フィールドの概要

    フィールド
    修飾子とタイプ
    フィールド
    説明
    static final String
    完了 "3"
    static final String
    エラー"4"
    static final String
    処理中 "2"
  • コンストラクタの概要

    コンストラクタ
    コンストラクタ
    説明
    DBAccessQueue(String systemid, String usrset, String prpupd, String dmnName)
    コンストラクター 初期処理を行います。
  • メソッドの概要

    修飾子とタイプ
    メソッド
    説明
    処理番号生成 GE68_SEQUENCEからシーケンス番号を生成します。
    void
    insertGE68(String queueNm, String syno, String bizlogicId, String messageText)
    GE68(キュー受信結果テーブル)登録 キュー受信結果テーブルに受信データを登録します。
    String[][]
    GE65検索 GE65の処理対象リストを取得します。
    String[][]
    受信管理データ取得 受信管理テーブルから、キューIDとbizlogic名を取得します。
    void
    updateGE66(String ykno, String fgkan)
    完了フラグの更新 完了フラグを指定された値に更新します。
    void
    updateGE66Error(String ykno, String errMsg)
    エラー状態に更新 完了フラグをエラー状態に更新して、 エラー情報を格納します。
    void
    updateGE68(String syno, String fgkan)
    GE68(キュー受信結果テーブル)更新 キュー受信結果テーブルを指定された完了状態に更新します。
    void
    updateGE68Error(String syoriNo, String errMsg)
    GE68(キュー受信結果テーブル)エラー更新 キュー受信結果テーブルをエラー状態に更新します。

    クラスから継承されたメソッド java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
  • フィールド詳細

  • コンストラクタの詳細

    • DBAccessQueue

      public DBAccessQueue(String systemid, String usrset, String prpupd, String dmnName)
      コンストラクター 初期処理を行います。
      パラメータ:
      systemid - システムID
      usrset - ユーザID
      prpupd - プログラムID
      dmnName - デーモン名
  • メソッドの詳細

    • selectGE65

      public String[][] selectGE65()
      GE65検索 GE65の処理対象リストを取得します。
      戻り値:
      処理対象リスト
    • updateGE66Error

      public void updateGE66Error(String ykno, String errMsg)
      エラー状態に更新 完了フラグをエラー状態に更新して、 エラー情報を格納します。
      パラメータ:
      ykno - 要求番号
      errMsg - エラーメッセージ
    • updateGE66

      public void updateGE66(String ykno, String fgkan)
      完了フラグの更新 完了フラグを指定された値に更新します。
      パラメータ:
      ykno - 要求番号
      fgkan - 完了フラグ
    • setlectGE67

      public String[][] setlectGE67()
      受信管理データ取得 受信管理テーブルから、キューIDとbizlogic名を取得します。
      戻り値:
      受信管理リスト
    • generateSyoriNo

      処理番号生成 GE68_SEQUENCEからシーケンス番号を生成します。
      戻り値:
      処理番号
      変更履歴:
      7.0.6.4 (2019/11/29) TransactionRealのclose漏れ対応
    • updateGE68

      public void updateGE68(String syno, String fgkan)
      GE68(キュー受信結果テーブル)更新 キュー受信結果テーブルを指定された完了状態に更新します。
      パラメータ:
      syno - 処理番号
      fgkan - 完了フラグ
    • insertGE68

      public void insertGE68(String queueNm, String syno, String bizlogicId, String messageText)
      GE68(キュー受信結果テーブル)登録 キュー受信結果テーブルに受信データを登録します。
      パラメータ:
      queueNm - キュー名
      syno - 処理NO
      bizlogicId - ビズロジックID
      messageText - メッセージ
    • updateGE68Error

      public void updateGE68Error(String syoriNo, String errMsg)
      GE68(キュー受信結果テーブル)エラー更新 キュー受信結果テーブルをエラー状態に更新します。
      パラメータ:
      syoriNo - 処理NO
      errMsg - エラーメッセージ