Lines 404-444javascript
404 requestTimeoutMs: source.connection.requestTimeoutMs ?? null,
406 mappingId: mapping.id,
407 mappingVersion: mapping.version,
408 mappingDefinitionFingerprint: hashStable(mapping),
409 parameters: source.parameters ?? {},
412async function createMssqlClient(connection, source) {
413 const server = readRequiredEnv(source.id, 'server', connection.serverEnv ?? connection.hostEnv);
414 const database = readRequiredEnv(source.id, 'database', connection.databaseEnv);
415 const user = readRequiredEnv(source.id, 'user', connection.userEnv);
416 const password = readRequiredEnv(source.id, 'password', connection.passwordEnv);
417 const portValue = readOptionalEnv(connection.portEnv);
418 const port = portValue ? Number(portValue) : undefined;
419 if (portValue && (!Number.isInteger(port) || port <= 0)) {
420 throw new Error(`Generic SQL source ${source.id} has invalid SQL Server port in ${connection.portEnv}`);
424 const moduleName = 'mssql';
425 module = await import(moduleName);
426 }
MediumDynamic Require
Package source references dynamic require/import behavior.
dist/generic-sql-source.jsView on unpkg · L424 428 throw new Error(`Generic SQL source ${source.id} requires optional package mssql for dialect mssql: ${error instanceof Error ? error.message : String(error)}`);
430 const pool = await new module.ConnectionPool({
437 encrypt: connection.encrypt ?? true,
438 trustServerCertificate: connection.trustServerCertificate ?? false,
440 requestTimeout: connection.requestTimeoutMs ?? 30000,
443 async query(sql, parameters) {
444 const request = pool.request();