test: add integration tests for per-request timeout overrides

Add functional tests to verify per-request requestTimeout works
across all code paths: query, stored procedure, transaction, and
prepared statement. Tests confirm the timeout override fires
independently of the pool-level default.

Co-authored-by: Copilot <223556219+Copilot@users.noreply.github.com>

Author: dhensby

test/cleanup.sql

@@ -22,6 +22,9 @@ if exists (select * from sys.procedures where name = '__testInputOutputValue')
 if exists (select * from sys.procedures where name = '__testRowsAffected')
 	exec('drop procedure [dbo].[__testRowsAffected]')
 
+if exists (select * from sys.procedures where name = '__testDelay')
+	exec('drop procedure [dbo].[__testDelay]')
+
 if exists (select * from sys.types where is_user_defined = 1 and name = 'MSSQLTestType')
 	exec('drop type [dbo].[MSSQLTestType]')
 

test/common/tests.js

@@ -1198,6 +1198,108 @@ module.exports = (sql, driver) => {
       })
     },
 
+    'per-request timeout overrides pool default' (done, driver, message) {
+      const config = readConfig()
+      config.driver = driver
+      config.requestTimeout = 15000
+
+      new sql.ConnectionPool(config).connect().then(conn => {
+        const req = new sql.Request(conn, { requestTimeout: 1000 })
+        req.query('waitfor delay \'00:00:05\';select 1').catch(err => {
+          assert.ok((message ? (message.exec(err.message) != null) : (err instanceof sql.RequestError)))
+
+          conn.close()
+          done()
+        })
+      }).catch(done)
+    },
+
+    'per-request timeout does not affect other requests' (done, driver, message) {
+      const config = readConfig()
+      config.driver = driver
+      config.requestTimeout = 15000
+
+      new sql.ConnectionPool(config).connect().then(conn => {
+        const reqFast = new sql.Request(conn, { requestTimeout: 1000 })
+        const reqNormal = new sql.Request(conn)
+
+        Promise.allSettled([
+          reqFast.query('waitfor delay \'00:00:05\';select 1'),
+          reqNormal.query('waitfor delay \'00:00:02\';select 1')
+        ]).then(([fastResult, normalResult]) => {
+          assert.strictEqual(fastResult.status, 'rejected')
+          assert.ok((message ? (message.exec(fastResult.reason.message) != null) : (fastResult.reason instanceof sql.RequestError)))
+          assert.strictEqual(normalResult.status, 'fulfilled')
+
+          conn.close()
+          done()
+        })
+      }).catch(done)
+    },
+
+    'per-request timeout in transaction' (done, driver, message) {
+      const config = readConfig()
+      config.driver = driver
+      config.requestTimeout = 15000
+
+      new sql.ConnectionPool(config).connect().then(conn => {
+        const tx = new sql.Transaction(conn, { requestTimeout: 1000 })
+        tx.begin().then(() => {
+          const req = tx.request()
+          req.query('waitfor delay \'00:00:05\';select 1').catch(err => {
+            assert.ok((message ? (message.exec(err.message) != null) : (err instanceof sql.RequestError)))
+
+            tx.rollback().then(() => {
+              conn.close()
+              done()
+            }).catch(() => {
+              conn.close()
+              done()
+            })
+          })
+        })
+      }).catch(done)
+    },
+
+    'per-request timeout on stored procedure' (done, driver, message) {
+      const config = readConfig()
+      config.driver = driver
+      config.requestTimeout = 15000
+
+      new sql.ConnectionPool(config).connect().then(conn => {
+        const req = new sql.Request(conn, { requestTimeout: 1000 })
+        req.execute('__testDelay').catch(err => {
+          assert.ok((message ? (message.exec(err.message) != null) : (err instanceof sql.RequestError)))
+
+          conn.close()
+          done()
+        })
+      }).catch(done)
+    },
+
+    'per-request timeout on prepared statement' (done, driver, message) {
+      const config = readConfig()
+      config.driver = driver
+      config.requestTimeout = 15000
+
+      new sql.ConnectionPool(config).connect().then(conn => {
+        const ps = new sql.PreparedStatement(conn, { requestTimeout: 1000 })
+        ps.prepare('waitfor delay \'00:00:05\';select 1').then(() => {
+          ps.execute().catch(err => {
+            assert.ok((message ? (message.exec(err.message) != null) : (err instanceof sql.RequestError)))
+
+            ps.unprepare().then(() => {
+              conn.close()
+              done()
+            }).catch(() => {
+              conn.close()
+              done()
+            })
+          })
+        })
+      }).catch(done)
+    },
+
     'type validation' (mode, done) {
       const req = new TestRequest()
       req.input('image', sql.VarBinary, 'asdf')

test/msnodesqlv8/msnodesqlv8.js

@@ -94,6 +94,11 @@ describe('msnodesqlv8', function () {
     it('request timeout', done => TESTS['request timeout'](done))
     it('BigInt parameters', done => TESTS['BigInt parameters'](done))
     it('BigInt casted types', done => TESTS['BigInt casted types'](done))
+    it('per-request timeout overrides pool default', done => TESTS['per-request timeout overrides pool default'](done))
+    it('per-request timeout does not affect other requests', done => TESTS['per-request timeout does not affect other requests'](done))
+    it('per-request timeout in transaction', done => TESTS['per-request timeout in transaction'](done))
+    it('per-request timeout on stored procedure', done => TESTS['per-request timeout on stored procedure'](done))
+    it('per-request timeout on prepared statement', done => TESTS['per-request timeout on prepared statement'](done))
     it('dataLength type correction', done => TESTS['dataLength type correction'](done))
     it('chunked xml support', done => TESTS['chunked xml support'](done))
 

test/prepare.sql

@@ -171,6 +171,15 @@ begin
 
 end')
 
+exec('create procedure [dbo].[__testDelay]
+as
+begin
+
+	waitfor delay ''00:00:05''
+	select 1 as result
+
+end')
+
 ;with nums as
 (
     select 0 AS n