クラス DBAccessQueue


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

      • 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

        public String 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 - エラーメッセージ