使用mysql-node流式传输数据时无法暂停池

const mysql = require('mysql');

const connection = mysql.createConnection({
  host: 'your_host',
  user: 'your_username',
  password: 'your_password',
  database: 'your_database',
});

// 创建查询流
const query = connection.query('SELECT * FROM your_table');

// 监听查询结果流
query
  .stream()
  .on('data', (row) => {
    // 处理每一行数据
    // 可在此处添加暂停或其他逻辑
  })
  .on('end', () => {
    // 查询结束逻辑
  })
  .on('error', (err) => {
    // 错误处理逻辑
  });

const mysql = require('mysql');

// 自行实现可暂停的连接池
class PausableConnectionPool {
  constructor(config) {
    this.config = config;
    this.connection = null;
    this.paused = false;
  }

  connect() {
    if (!this.connection) {
      this.connection = mysql.createPool(this.config);
    }
    this.paused = false;
  }

  pause() {
    this.paused = true;
  }

  resume() {
    this.paused = false;
  }

  query(sql, values) {
    if (this.paused) {
      // 如果连接池被暂停，则暂停查询操作
      return new Promise((resolve) => resolve());
    } else {
      return this.connection.query(sql, values);
    }
  }
}

const connectionPool = new PausableConnectionPool({
  host: 'your_host',
  user: 'your_username',
  password: 'your_password',
  database: 'your_database',
});

connectionPool.connect();

// 执行查询
connectionPool.query('SELECT * FROM your_table')
  .then((rows) => {
    // 处理查询结果
    // 可在此处添加暂停或其他逻辑
  })
  .catch((err) => {
    // 错误处理逻辑
  });