diff --git a/plugins/dbgate-plugin-mssql/src/backend/tediousDriver.js b/plugins/dbgate-plugin-mssql/src/backend/tediousDriver.js index 028aa0304..c10204f62 100644 --- a/plugins/dbgate-plugin-mssql/src/backend/tediousDriver.js +++ b/plugins/dbgate-plugin-mssql/src/backend/tediousDriver.js @@ -161,14 +161,14 @@ async function tediousStream(dbhan, sql, options) { }); }; - pool.on('infoMessage', handleInfo); - pool.on('errorMessage', handleError); + dbhan.client.on('infoMessage', handleInfo); + dbhan.client.on('errorMessage', handleError); const request = new tedious.Request(sql, (err, rowCount) => { // if (err) reject(err); // else resolve(result); options.done(); - pool.off('infoMessage', handleInfo); - pool.off('errorMessage', handleError); + dbhan.client.off('infoMessage', handleInfo); + dbhan.client.off('errorMessage', handleError); options.info({ message: `${rowCount} rows affected`,