diff --git a/server/web3dbspider/services/dbevent_process.js b/server/web3dbspider/services/dbevent_process.js index 07fa836..51e642b 100644 --- a/server/web3dbspider/services/dbevent_process.js +++ b/server/web3dbspider/services/dbevent_process.js @@ -7,6 +7,8 @@ const BaseService = require('./baseservice'); const metaFactory = require('../metadata/factory'); const eventsFactory = require('./events/factory'); +const LIMIT_COUNT = 100; + class DbEventProcess extends BaseService { static #tableMaxIdxHash = {}; @@ -79,7 +81,7 @@ class DbEventProcess extends BaseService { const {err, rows} = await this.conn.execQuery( 'SELECT * FROM ${tableName} WHERE `idx` > ? AND `idx` <= ? ' + 'AND net_id = ? AND event_name = ? AND contract_address = ? AND ' + - 'state = ' + constant.EVENTDB_STATE_PENDING + ' ' + + 'status = ' + constant.EVENTDB_STATE_PENDING + ' ' + 'LIMIT ' + LIMIT_COUNT, [ startIdx.toString(),