クラス DBAccessQueue
java.lang.Object
org.opengion.hayabusa.queue.DBAccessQueue
キュー処理用のDBアクセスクラス
キューの受信と送信処理で、
データベースにアクセスして処理を行います。
実際のMQ,SQSとの通信そのものはfukurouで行います。
- 変更履歴:
- 5.10.15.2 (2019/09/20) 新規作成
- 機能分類
- メッセージ連携
- 導入されたバージョン:
- JDK7
-
フィールドの概要
フィールド -
コンストラクタの概要
コンストラクタコンストラクタ説明DBAccessQueue(String systemid, String usrset, String prpupd, String dmnName) コンストラクター 初期処理を行います。 -
メソッドの概要
修飾子とタイプメソッド説明処理番号生成 GE68_SEQUENCEからシーケンス番号を生成します。voidinsertGE68(String queueNm, String syno, String bizlogicId, String messageText) GE68(キュー受信結果テーブル)登録 キュー受信結果テーブルに受信データを登録します。String[][]GE65検索 GE65の処理対象リストを取得します。String[][]受信管理データ取得 受信管理テーブルから、キューIDとbizlogic名を取得します。voidupdateGE66(String ykno, String fgkan) 完了フラグの更新 完了フラグを指定された値に更新します。voidupdateGE66Error(String ykno, String errMsg) エラー状態に更新 完了フラグをエラー状態に更新して、 エラー情報を格納します。voidupdateGE68(String syno, String fgkan) GE68(キュー受信結果テーブル)更新 キュー受信結果テーブルを指定された完了状態に更新します。voidupdateGE68Error(String syoriNo, String errMsg) GE68(キュー受信結果テーブル)エラー更新 キュー受信結果テーブルをエラー状態に更新します。
-
フィールド詳細
-
コンストラクタの詳細
-
DBAccessQueue
コンストラクター 初期処理を行います。- パラメータ:
systemid- システムIDusrset- ユーザIDprpupd- プログラムIDdmnName- デーモン名
-
-
メソッドの詳細
-
selectGE65
GE65検索 GE65の処理対象リストを取得します。- 戻り値:
- 処理対象リスト
-
updateGE66Error
エラー状態に更新 完了フラグをエラー状態に更新して、 エラー情報を格納します。- パラメータ:
ykno- 要求番号errMsg- エラーメッセージ
-
updateGE66
完了フラグの更新 完了フラグを指定された値に更新します。- パラメータ:
ykno- 要求番号fgkan- 完了フラグ
-
setlectGE67
受信管理データ取得 受信管理テーブルから、キューIDとbizlogic名を取得します。- 戻り値:
- 受信管理リスト
-
generateSyoriNo
処理番号生成 GE68_SEQUENCEからシーケンス番号を生成します。- 戻り値:
- 処理番号
- 変更履歴:
- 7.0.6.4 (2019/11/29) TransactionRealのclose漏れ対応
-
updateGE68
GE68(キュー受信結果テーブル)更新 キュー受信結果テーブルを指定された完了状態に更新します。- パラメータ:
syno- 処理番号fgkan- 完了フラグ
-
insertGE68
GE68(キュー受信結果テーブル)登録 キュー受信結果テーブルに受信データを登録します。- パラメータ:
queueNm- キュー名syno- 処理NObizlogicId- ビズロジックIDmessageText- メッセージ
-
updateGE68Error
GE68(キュー受信結果テーブル)エラー更新 キュー受信結果テーブルをエラー状態に更新します。- パラメータ:
syoriNo- 処理NOerrMsg- エラーメッセージ
-