@@ -5,6 +5,7 @@ const exec = util.promisify(require('child_process').exec);
55const { spawn } = require ( 'child_process' ) ;
66const { buildQuery, queryType } = require ( './queryHelper' ) ;
77const localization = require ( '../../localization/en.json' ) ;
8+ const { ERROR_MESSAGE } = require ( '../../constants/constants' ) ;
89
910const SYSTEM_DATABASES = [
1011 'val' ,
@@ -175,11 +176,13 @@ const createConnection = async (connectionInfo, sshService, logger) => {
175176 const teradataClientPath = path . resolve ( __dirname , '..' , 'addons' , 'TeradataClient.jar' ) ;
176177 const teradataClientCommandArguments = buildCommand ( teradataClientPath , connectionSettings ) ;
177178
179+ const getAbortedError = ( ) => new Error ( ERROR_MESSAGE . aborted ) ;
180+
178181 return {
179182 execute : ( query , signal ) => {
180183 return new Promise ( ( resolve , reject ) => {
181184 if ( signal ?. aborted ) {
182- return reject ( new Error ( 'Query execution was aborted' ) ) ;
185+ return reject ( getAbortedError ( ) ) ;
183186 }
184187
185188 const queryArgument = createArgument ( 'query' , query ) ;
@@ -196,7 +199,7 @@ const createConnection = async (connectionInfo, sshService, logger) => {
196199 queryResult . kill ( 'SIGTERM' ) ;
197200 activeQueries . delete ( queryResult ) ;
198201 }
199- reject ( new Error ( 'Query execution was aborted' ) ) ;
202+ reject ( getAbortedError ( ) ) ;
200203 } ;
201204
202205 if ( signal ) {
0 commit comments