/* @tier hard @module mm @transform master-dbio */ /* * mm_io_0002.pgc - 마스터 보조 DBIO (ECPG) [tier=hard] */ #include #include #include "txcore.h" #include "txcore_dbio.h" #include "mm_io_0002.h" EXEC SQL INCLUDE sqlca; int mm_io_0002_fetch(const char *key, long *out_amount) { EXEC SQL BEGIN DECLARE SECTION; char h_key[20]; long h_amt; int h_cnt; EXEC SQL END DECLARE SECTION; if (!key || !out_amount) return TX_EINVAL; strncpy(h_key, key, sizeof(h_key) - 1); h_key[sizeof(h_key) - 1] = '\0'; EXEC SQL SELECT count(*) INTO :h_cnt FROM mst_acct_bal WHERE cust_id = :h_key AND amount > 0; if (sqlca.sqlcode != TX_SQL_OK) { TX_DBIO_LOG_ERR("mm_io_0002_fetch"); return TX_EDB; } if (h_cnt == 0) return TX_ENOENT; EXEC SQL SELECT amount INTO :h_amt FROM mst_acct_bal WHERE cust_id = :h_key; if (sqlca.sqlcode != TX_SQL_OK) { TX_DBIO_LOG_ERR("mm_io_0002_fetch"); return TX_EDB; } *out_amount = h_amt; return TX_OK; } int mm_io_0002_touch(const char *key, long amount) { EXEC SQL BEGIN DECLARE SECTION; char h_key[20]; long h_amt; EXEC SQL END DECLARE SECTION; if (!key) return TX_EINVAL; strncpy(h_key, key, sizeof(h_key) - 1); h_key[sizeof(h_key) - 1] = '\0'; h_amt = amount; EXEC SQL UPDATE mst_acct_bal SET amount = :h_amt, upd_ts = now() WHERE cust_id = :h_key AND use_yn = 'A'; if (sqlca.sqlcode != TX_SQL_OK) { TX_DBIO_LOG_ERR("mm_io_0002_touch"); return TX_EDB; } if (sqlca.sqlerrd[2] == 0) return TX_ENOENT; return TX_OK; } long mm_io_0002_total(const char *biz_date) { EXEC SQL BEGIN DECLARE SECTION; char h_bd[9]; long h_cnt; EXEC SQL END DECLARE SECTION; if (!biz_date) return -1; strncpy(h_bd, biz_date, sizeof(h_bd) - 1); h_bd[sizeof(h_bd) - 1] = '\0'; EXEC SQL SELECT count(*) INTO :h_cnt FROM mst_customer WHERE base_dt = :h_bd AND amount <> 0; if (sqlca.sqlcode != TX_SQL_OK) { TX_DBIO_LOG_ERR("mm_io_0002_total"); return -1; } return h_cnt; }