database package

Submodules

database.database module

class database.database.Database(dlog, dlogname)

ベースクラス: object

Database に接続し、SQLを実行するクラス。

hconf

設定情報読み込み用オブジェクト。クラス変数として保持。

Type:

HaluConf

engine

エンジンの格納場所

Type:

dict

connect

コネクションの格納場所

Type:

dict

trans

トランザクションの格納場所

Type:

dict

begin(dbname)

トランザクション開始

パラメータ:

dbname (str) -- 接続するデータベース名

close()

コネクションをプールに戻す

commit()

コミット実行

connection(dbname)

コネクション取得

パラメータ:

dbname (str) -- 接続するデータベース名

create_engine(dbname)

ＤＢ接続要求 （self.engineはインスタンス変数であるが、sqlalchemy内部でプーリングされているもよう）

パラメータ:

dbname (str) -- 接続するデータベース名

doGenerateSql(dbname, sql_info)

SQL文の実行

パラメータ:

sql_info (dict) -- sqldict['sqls'] の1要素

doSql(dbname, sql_info)

SQL文の実行

パラメータ:

sql_info (dict) -- sqldict['sqls'] の1要素

execute(dbname, str_sql)

ＳＱＬ実行

パラメータ:

• dbname (str) -- 接続するデータベース名

• str_sql (str) -- 実行するSQL文

execute_select(dbname, str_sql, sql_info)

Select SQL実行

hconf = <halumain.haluconf.HaluConf object>

recordCheck(sql_info, sqldict)

sql.json の'check' が設定されている場合、出力レコードの存在チェックを行う check の設定値 : 'not found error'/ 'found error'

パラメータ:

• sql_info (dict) -- sqldict['sqls'] の1要素

• sql_data (dict) -- sqldict

rollback()

ロールバック

database.databasecommon module

class database.databasecommon.DatabaseCommon(dlog, dlogname, sql_info)

ベースクラス: object

SQLデータからSQL文字列を作成する

sql_info

SQLデータの中の'sqls' の1要素 -> sqldict['sqls'][i]

Type:

dict

createDeleteSql()

DELETE文の作成

createFreeSql()

ＳＱＬ文生成（freesql）

createInsertSql()

INSERT文の作成

createSelectSql()

SELECT文の作成

createSql()

SQL文を作成する

戻り値:

str_sql -- SQL文

戻り値の型:

str

createUpdateSql()

UPDATE文の作成

getFieldStr(name, value)

SELECT文の列名文字設定

getFunctStr(value)

INSERT文のVALUES文字設定 UPDATE文の列？文字設定

getMaxLine()

値配列の最大行取得

replaceSql(str_sql, input_record, idx)

バインド変数の値をSQL文に設定する

パラメータ:

• str_sql (str) -- バインド変数置換前のSQL文字列

• input_record (dict) -- sql.json 内のinput レコード -> sql_info['input']['record']

• idx (int) -- value 配列のインデックス

戻り値:

str_sql -- バインド変数置換後のSQL文字列

戻り値の型:

str

Module contents