jp.ne.mki.wedge.run.db.dc
クラス SqlDataControl
java.lang.Object
|
+--jp.ne.mki.wedge.run.db.control.dc.DataControl
|
+--jp.ne.mki.wedge.run.db.dc.SqlDataControl
- すべての実装インタフェース:
- jp.ne.mki.wedge.run.db.control.dc.DC
- public abstract class SqlDataControl
- extends jp.ne.mki.wedge.run.db.control.dc.DataControl
DC 基本クラスに共通して必要なユーティリティ機能を提供し、SQL 実行における前処理、後処理を実行します。
このクラスを継承し、executeSql(DcRequest req) メソッドを実装してください。
クラス jp.ne.mki.wedge.run.db.control.dc.DataControl から継承したフィールド |
bProfileMode, conf, databaseMain, dataConvertClassTable, dataConvertPackages, ec, listClass, listConstructorParamInitSize, ls, testLogMode, wedgeLog |
メソッドの概要 |
java.util.List |
execute(jp.ne.mki.wedge.run.data.ControlRecord ctlRec,
java.util.List inRec,
java.lang.String sql)
使用中 DB コネクション一覧から DB コネクションを取得し、実行中ステータスをセットしてから、DC 基本クラスを呼び出します。
|
protected abstract DataInterface[] |
executeSql(DcRequest req)
DC 基本クラスの処理を実装します。 |
protected DBDataConvertInterface |
getConvertClass(java.lang.String className)
指定されたクラス名(パッケージ名を含まない)に相当するデータ変換クラスを返します。 |
protected int |
getIdataRowCount(java.util.List inRec)
入力レコードとして渡されたアイテムの行数をカウントして返します。
|
void |
init(jp.ne.mki.wedge.run.db.control.XM_DatabaseMain main,
jp.ne.mki.wedge.run.library.WedgeLog2 log,
jp.ne.mki.wedge.run.db.main.RunDBServerConf dbConf)
初期設定処理を行います。
|
クラス jp.ne.mki.wedge.run.db.control.dc.DataControl から継承したメソッド |
createOutputDataArray, getDatabase, getManager, idataArrayToList, profileLog, setSQLExceptionControlRecord |
クラス java.lang.Object から継承したメソッド |
, clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
SqlDataControl
public SqlDataControl()
init
public final void init(jp.ne.mki.wedge.run.db.control.XM_DatabaseMain main,
jp.ne.mki.wedge.run.library.WedgeLog2 log,
jp.ne.mki.wedge.run.db.main.RunDBServerConf dbConf)
throws java.lang.SecurityException,
java.lang.NoSuchMethodException,
java.lang.ClassNotFoundException,
java.lang.InstantiationException,
java.lang.IllegalAccessException
- クラス
jp.ne.mki.wedge.run.db.control.dc.DataControl
の記述:
- 初期設定処理を行います。
ログクラス、コンフィグレーションクラスへの参照等を取得し、保持します。
- オーバーライド:
- クラス
jp.ne.mki.wedge.run.db.control.dc.DataControl
内の init
execute
public java.util.List execute(jp.ne.mki.wedge.run.data.ControlRecord ctlRec,
java.util.List inRec,
java.lang.String sql)
throws jp.ne.mki.wedge.run.db.control.dc.DcException,
java.sql.SQLException,
java.lang.IllegalArgumentException,
java.lang.InstantiationException,
java.lang.IllegalAccessException,
java.lang.reflect.InvocationTargetException,
java.text.ParseException,
java.io.IOException
- 使用中 DB コネクション一覧から DB コネクションを取得し、実行中ステータスをセットしてから、DC 基本クラスを呼び出します。
DC 基本クラス実行後は、実行中ステータスをクリアします。
実行中ステータスは、一定時間使われていない DB コネクションをコネクションプールに返却する処理のチェックに使われます。
- 関連項目:
DC.execute(jp.ne.mki.wedge.run.data.ControlRecord, java.util.List, java.lang.String)
getIdataRowCount
protected int getIdataRowCount(java.util.List inRec)
- 入力レコードとして渡されたアイテムの行数をカウントして返します。
アイテムの行数が一致していない場合、例外がスローされます。
アイテムの行数が一致していなくても処理を続行させる必要がある場合は、
継承先の DC 基本クラスでこのメソッドをオーバライドしてください。
このメソッドが返した値(行数)は DcRequest.getRows() メソッドで取得することができます。
- パラメータ:
inRec
- 入力レコード- 戻り値:
- 入力アイテムの行数
executeSql
protected abstract DataInterface[] executeSql(DcRequest req)
throws jp.ne.mki.wedge.run.db.control.dc.DcException,
java.sql.SQLException,
java.lang.IllegalArgumentException,
java.lang.InstantiationException,
java.lang.IllegalAccessException,
java.lang.reflect.InvocationTargetException,
java.text.ParseException,
java.io.IOException
- DC 基本クラスの処理を実装します。
- パラメータ:
database
- Connection を管理する DB アクセスオブジェクトsql
- 実行 SQLctlRec
- コントロールレコードinRec
- 入力レコード- 戻り値:
- 実行結果の出力レコード(主に検索結果)
- 例外:
jp.ne.mki.wedge.run.db.control.dc.DcException
- java.sql.SQLException
- java.lang.IllegalArgumentException
- java.lang.InstantiationException
- java.lang.IllegalAccessException
- java.lang.reflect.InvocationTargetException
- java.text.ParseException
- java.io.IOException
-
getConvertClass
protected DBDataConvertInterface getConvertClass(java.lang.String className)
- 指定されたクラス名(パッケージ名を含まない)に相当するデータ変換クラスを返します。
- 戻り値:
- データ変換クラス