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