diff --git a/server/common/dbpool.js b/server/common/dbpool.js index 08d4474..39b98c8 100644 --- a/server/common/dbpool.js +++ b/server/common/dbpool.js @@ -70,18 +70,18 @@ async function internalDbConn(app, name, method, ...args) { }; } -async function getBcEventConn(app, method, ...args) { +async function execBcEventConn(app, method, ...args) { return await internalDbConn(app, constant.BCEVENTDB_NAME, method, ...args); } -async function getBcNftConn(app, method, ...args) { +async function execBcNftConn(app, method, ...args) { return await internalDbConn(app, constant.BCNFTDB_NAME, method, ...args); } -async function getGameConn(app, method, ...args) { +async function execGameConn(app, method, ...args) { return await internalDbConn(app, constant.GAMEDB_NAME, method, ...args); } -exports.getBcEventConn = getBcEventConn; -exports.getBcNftConn = getBcNftConn; -exports.getGameConn = getGameConn; +exports.execBcEventConn = execBcEventConn; +exports.execBcNftConn = execBcNftConn; +exports.execGameConn = execGameConn; diff --git a/server/web3bcspider/services/erc721_refresher.js b/server/web3bcspider/services/erc721_refresher.js index 4e2999e..e8410e0 100644 --- a/server/web3bcspider/services/erc721_refresher.js +++ b/server/web3bcspider/services/erc721_refresher.js @@ -30,7 +30,7 @@ class Erc721Refresher extends BaseService { async pullEvent() { const logHead = this.genLogHead('pullEvent '); try { - const {err, rows} = await dbpool.getBcEventConn( + const {err, rows} = await dbpool.execBcEventConn( app, 'execQuery', ',SELECT * FROM t_erc721_refresh WHERE idx > ' + this.lastIdx.toString() + ' ' + @@ -208,7 +208,7 @@ class Erc721Refresher extends BaseService { } async update(row, fields) { - const {err} = await this.dbpool.getBcEventConn( + const {err} = await this.dbpool.execBcEventConn( app, 'update', 't_erc721_refresh', diff --git a/server/web3bcspider/services/pull_bcevent.js b/server/web3bcspider/services/pull_bcevent.js index fa7d878..6e97042 100644 --- a/server/web3bcspider/services/pull_bcevent.js +++ b/server/web3bcspider/services/pull_bcevent.js @@ -86,7 +86,7 @@ class PullBcEvent extends BaseService { const firstBlockNumber = this.getInitBlock(); while (this.lastBlockNumber < 1) { try { - const {err, row} = await dbpool.getBcEventConn( + const {err, row} = await dbpool.execBcEventConn( app, 'ormSelectOne', 't_last_block', @@ -134,7 +134,7 @@ class PullBcEvent extends BaseService { async saveLastBlockNumber(blockNumber) { const logHead = this.genLogHead(' event_process.saveLastBlockNumber: '); while (true) { - const {err} = await dbpool.getBcEventConn( + const {err} = await dbpool.execBcEventConn( app, 'upsert', 't_last_block', @@ -172,7 +172,7 @@ class PullBcEvent extends BaseService { const nowTime = utils.getUtcTime(); const returnValues = event['returnValues']; const hashCode = ''; - const {err} = await dbpool.getBcEventConn( + const {err} = await dbpool.execBcEventConn( app, 'upsert', 't_blockchain_event',