クラス 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) 新規作成
- 機能分類
- メッセージ連携
- バージョン
- 5
- 作成者
- oota
- 導入されたバージョン:
- JDK7
-
-
フィールドの概要
フィールド 修飾子とタイプ フィールド 説明 static String
FGKAN_END
完了 "3"static String
FGKAN_ERROR
エラー"4"static String
FGKAN_PROCESS
処理中 "2"
-
コンストラクタの概要
コンストラクタ コンストラクタ 説明 DBAccessQueue(String systemid, String usrset, String prpupd, String dmnName)
コンストラクター 初期処理を行います。
-
メソッドの概要
すべてのメソッド インスタンス・メソッド concreteメソッド 修飾子とタイプ メソッド 説明 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(キュー受信結果テーブル)エラー更新 キュー受信結果テーブルをエラー状態に更新します。
-
-
-
フィールドの詳細
-
FGKAN_PROCESS
public static final String FGKAN_PROCESS
処理中 "2"- 関連項目:
- 定数フィールド値
-
FGKAN_ERROR
public static final String FGKAN_ERROR
エラー"4"- 関連項目:
- 定数フィールド値
-
-
コンストラクタの詳細
-
DBAccessQueue
public DBAccessQueue(String systemid, String usrset, String prpupd, String dmnName)
コンストラクター 初期処理を行います。- パラメータ:
systemid
- システムIDusrset
- ユーザIDprpupd
- プログラムIDdmnName
- デーモン名
-
-
メソッドの詳細
-
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
- 処理NObizlogicId
- ビズロジックIDmessageText
- メッセージ
-
updateGE68Error
public void updateGE68Error(String syoriNo, String errMsg)
GE68(キュー受信結果テーブル)エラー更新 キュー受信結果テーブルをエラー状態に更新します。- パラメータ:
syoriNo
- 処理NOerrMsg
- エラーメッセージ
-
-