diff --git a/plugins/dbgate-plugin-dbf/src/backend/reader.js b/plugins/dbgate-plugin-dbf/src/backend/reader.js index be26f53ab..90afd4d17 100644 --- a/plugins/dbgate-plugin-dbf/src/backend/reader.js +++ b/plugins/dbgate-plugin-dbf/src/backend/reader.js @@ -4,6 +4,10 @@ const fs = require('fs'); const stream = require('stream'); const { DBFFile } = require('dbffile'); +const { getLogger, extractErrorLogData } = global.DBGATE_PACKAGES['dbgate-tools']; + +const logger = getLogger('dbfReader'); + let dbgateApi; function getFieldType(field) { @@ -55,7 +59,7 @@ async function reader({ fileName, encoding = 'ISO-8859-1', includeDeletedRecords pass.write({ __isStreamHeader: true, columns, - }) + }); let readedRows = 0; // Read each record and push it into the stream @@ -71,6 +75,7 @@ async function reader({ fileName, encoding = 'ISO-8859-1', includeDeletedRecords pass.end(); } catch (error) { // If any error occurs, destroy the stream with the error + logger.error(extractErrorLogData(error), 'Error reading DBF file'); pass.end(); } })();