パッケージ org.opengion.hayabusa.queue

# クラス 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`
  `FGKAN_END`
  完了 "3"
  `static final String`
  `FGKAN_ERROR`
  エラー"4"
  `static final String`
  `FGKAN_PROCESS`
  処理中 "2"

- ## コンストラクタの概要

  コンストラクタ
  コンストラクタ
  説明
  `DBAccessQueue(String systemid, String usrset, String prpupd, String dmnName)`
  コンストラクター 初期処理を行います。

- ## メソッドの概要

  修飾子とタイプ
  メソッド
  説明
  `String`
  `generateSyoriNo()`
  処理番号生成 GE68_SEQUENCEからシーケンス番号を生成します。
  `void`
  `insertGE68(String queueNm, String syno, String bizlogicId, String messageText)`
  GE68(キュー受信結果テーブル)登録 キュー受信結果テーブルに受信データを登録します。
  `String[][]`
  `selectGE65()`
  GE65検索 GE65の処理対象リストを取得します。
  `String[][]`
  `setlectGE67()`
  受信管理データ取得 受信管理テーブルから、キュー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`

- ## フィールド詳細

  - ### FGKAN_PROCESS

    public static final String FGKAN_PROCESS
    処理中 "2"
    関連項目:
      - 定数フィールド値

  - ### FGKAN_END

    public static final String FGKAN_END
    完了 "3"
    関連項目:
      - 定数フィールド値

  - ### FGKAN_ERROR

    public static final String FGKAN_ERROR
    エラー"4"
    関連項目:
      - 定数フィールド値

- ## コンストラクタの詳細

  - ### 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` - エラーメッセージ