如何解决tedious包‘单连接一次仅能执行一个查询’的报错问题？

核心原因 #

Tedious的单个Connection实例同一时间仅能处理一个查询请求。当前端发起并行请求时，复用同一连接执行新查询会触发状态冲突，导致报错：Requests can only be made in the LoggedIn state, not the SentClientRequest state。

解决方案 #

1. 使用连接池（最推荐，API改动极小）

Tedious内置ConnectionPool，能自动管理连接的分配、复用与回收，每个请求会拿到独立的空闲连接执行查询，从根源避免单连接并行冲突。

如果你的项目已经封装了通用的数据库查询API，只需将内部的单连接逻辑替换为连接池获取/释放，对外的API完全无需修改：

const { ConnectionPool, Request } = require('tedious');

// 初始化连接池（全局只需要一次）
const pool = new ConnectionPool({
  server: '你的SQL Server地址',
  authentication: {
    type: 'default',
    options: {
      userName: '用户名',
      password: '密码'
    }
  },
  options: {
    database: '目标数据库',
    encrypt: true // 根据你的SQL Server配置调整
  }
});

// 封装查询方法（替换你现有的查询函数）
async function executeQuery(sql) {
  return new Promise((resolve, reject) => {
    // 从连接池获取空闲连接
    pool.acquire((err, connection) => {
      if (err) return reject(err);

      const request = new Request(sql, (err, rowCount) => {
        // 查询完成后将连接释放回池
        connection.release();
        if (err) return reject(err);
      });

      // 收集查询结果（根据你的业务需求调整）
      const result = [];
      request.on('row', (columns) => {
        const row = {};
        columns.forEach(col => row[col.metadata.colName] = col.value);
        result.push(row);
      });

      // 查询完成后返回结果
      request.on('requestCompleted', () => {
        resolve(result);
      });

      connection.execSql(request);
    });
  });
}

2. 为每个HTTP请求创建独立连接

如果不想用连接池，可在每个Express路由处理函数中创建新的Connection实例，确保请求之间的连接完全隔离。但这种方式会频繁建立/断开数据库连接，性能较差，仅适合低并发场景：

const { Connection, Request } = require('tedious');
const express = require('express');
const app = express();

const dbConfig = { /* 你的数据库配置 */ };

app.get('/api/page-data', (req, res) => {
  const connection = new Connection(dbConfig);
  
  connection.on('connect', (err) => {
    if (err) {
      console.error(err);
      return res.status(500).send('数据库连接失败');
    }

    const request = new Request('SELECT * FROM YourTable', (err) => {
      connection.close(); // 查询完成关闭连接
      if (err) return res.status(500).send(err.message);
    });

    const result = [];
    request.on('row', (columns) => {
      const row = {};
      columns.forEach(col => row[col.metadata.colName] = col.value);
      result.push(row);
    });

    request.on('requestCompleted', () => {
      res.json(result);
    });

    connection.execSql(request);
  });

  connection.connect();
});

3. 正确终止未完成的请求（针对你之前尝试无效的情况）

你之前终止旧请求未生效，大概率是没有正确处理Tedious的取消逻辑。需要调用request.cancel()，并配合连接的reset方法确保连接回到可用状态：

// 跟踪当前活跃的请求和连接（仅适合单用户/低并发场景）
let activeRequest = null;
let activeConnection = null;

app.get('/api/pageA', (req, res) => {
  // 取消未完成的旧请求
  if (activeRequest) {
    activeRequest.cancel();
  }

  activeConnection = new Connection(dbConfig);
  activeConnection.on('connect', (err) => {
    if (err) return res.status(500).send(err);

    activeRequest = new Request('SELECT * FROM PageAData', (err, rowCount) => {
      activeRequest = null;
      activeConnection.close();
      if (err) return res.status(500).send(err);
      // 返回结果...
    });

    // 监听请求取消事件，重置连接状态
    activeRequest.on('cancel', () => {
      activeRequest = null;
      activeConnection.reset(() => {
        activeConnection.close();
        activeConnection = null;
        res.status(200).send('旧请求已取消');
      });
    });

    activeConnection.execSql(activeRequest);
  });
  activeConnection.connect();
});

关于无需修改数据库通信API的疑问 #

使用连接池方案可以做到几乎不修改对外的数据库通信API：只需替换你封装的查询函数内部的连接逻辑，上层的Express路由、前端请求的接口调用完全不需要改动，仅需调整底层实现即可解决问题。

内容的提问来源于stack exchange，提问作者Nekena Rayane RATIARIVELO