TVP Schema Name Fix and Request Timeout Improvements

lib/tedious/request.js

@@ -176,6 +176,10 @@ const valueCorrection = function (value, metadata) {
 
 const parameterCorrection = function (value) {
   if (value instanceof Table) {
+    // Use the fully qualified TVP type name as constructed by Table
+    // Use only schema.name or name for TVP type
+    // Avoid duplicating schema if already present in name
+    // Use value.name as the TVP type name, do not prepend schema
     const tvp = {
       name: value.name,
       schema: value.schema,
@@ -493,6 +497,10 @@ class Request extends BaseRequest {
             }
           }
         })
+        // Assign per-request timeout to tedious Request if set
+        if (this.requestTimeout !== undefined) {
+          req.timeout = this.requestTimeout
+        }
 
         this._setCurrentRequest(req)
 

test/common/tests.js

@@ -1852,6 +1852,42 @@ module.exports = (sql, driver) => {
 
         done()
       }).catch(done)
+    },
+    'Fix default requestTimeout is above 15s' (done) {
+      const req = new TestRequest()
+      req.requestTimeout = 25000 // 25 seconds
+      const start = Date.now()
+      req.query("WAITFOR DELAY '00:00:20.000';").then(result => {
+        const elapsed = Date.now() - start
+        assert.ok(!result.error, 'Should not error for long WAITFOR DELAY with high timeout')
+        assert(elapsed >= 20000, 'Query should take at least 20 seconds')
+        done()
+      }).catch(done)
+    },
+    'TVP with schema-qualified name triggers bug' (done) {
+      (async () => {
+        let pool
+        try {
+          pool = await sql.connect(readConfig())
+          const request = pool.request()
+          const tvp = new sql.Table('AI.UDT_StringArray')
+          tvp.columns.add('Name', sql.NVarChar(128), { nullable: false })
+          tvp.rows.add('TestValue1')
+          tvp.rows.add('TestValue2')
+          request.input('InputList', tvp)
+          await request.execute('AI.USP_TestProcedure')
+        } catch (err) {
+          if (err && /Cannot find data type UDT_StringArray/.test(err.message)) {
+            return done()
+          }
+          if (err && /could not find|does not exist|invalid object/i.test(err.message)) {
+            return done()
+          }
+          done(err)
+        } finally {
+          if (pool) await sql.close()
+        }
+      })()
     }
   }
 }

test/tedious/tedious.js

@@ -2,6 +2,9 @@
 
 /* globals describe, it, before, after, afterEach */
 
+// Increase Mocha timeout for long-running tests
+this.timeout && this.timeout(30000)
+
 const sql = require('../../tedious.js')
 const assert = require('node:assert')
 const { join } = require('node:path')
@@ -24,7 +27,8 @@ const config = function () {
 let connection1 = null
 let connection2 = null
 
-describe('tedious', () => {
+describe('tedious', function () {
+  this.timeout(30000) // Increase Mocha timeout for all tests in this suite
   before(done =>
     sql.connect(config(), err => {
       if (err) return done(err)
@@ -105,6 +109,8 @@ describe('tedious', () => {
     it('type validation', done => TESTS['type validation']('query', done))
     it('type validation (batch)', done => TESTS['type validation']('batch', done))
     it('chunked xml support', done => TESTS['chunked xml support'](done))
+    it('Fix default requestTimeout is above 15s', done => TESTS['Fix default requestTimeout is above 15s'](done))
+    it('TVP with schema-qualified name triggers bug', done => TESTS['TVP with schema-qualified name triggers bug'](done))
 
     after(done => sql.close(done))
   })