如何将winston日志写入SQL Server？

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

const config = {
  server: 'your_server',
  authentication: {
    type: 'default',
    options: {
      userName: 'your_username',
      password: 'your_password'
    }
  },
  options: {
    database: 'your_database',
    encrypt: true
  }
};

const connection = new Connection(config);

connection.on('connect', (err) => {
  if (err) {
    console.error(err.message);
  } else {
    // 创建日志表（如果不存在）
    const createTableRequest = new Request(`
      IF NOT EXISTS (SELECT * FROM sysobjects WHERE name='Logs' and xtype='U')
      CREATE TABLE Logs (
        id INT IDENTITY(1,1) PRIMARY KEY,
        level VARCHAR(10),
        message NVARCHAR(MAX),
        timestamp DATETIME
      )
    `, (tableErr) => {
      if (tableErr) {
        console.error(tableErr.message);
      } else {
        console.log('日志表已创建或已存在');
      }
    });

    connection.execSql(createTableRequest);

    // 准备写入日志的请求
    const insertLogRequest = new Request(`
      INSERT INTO Logs (level, message, timestamp)
      VALUES (@level, @message, @timestamp)
    `, (insertErr) => {
      if (insertErr) {
        console.error(insertErr.message);
      } else {
        console.log('日志已成功写入SQL Server');
      }
    });

    // 绑定参数
    insertLogRequest.addParameter('level', TYPES.VarChar);
    insertLogRequest.addParameter('message', TYPES.NVarChar);
    insertLogRequest.addParameter('timestamp', TYPES.DateTime, new Date());

    // 创建winston日志记录器
    const logger = winston.createLogger({
      transports: [
        new winston.transports.Stream({
          write: (log) => {
            // 将日志写入SQL Server
            insertLogRequest.parameters[0].value = log.level;
            insertLogRequest.parameters[1].value = log.message;
            insertLogRequest.parameters[2].value = new Date();
            connection.execSql(insertLogRequest);
          }
        })
      ]
    });

    // 使用winston记录日志
    logger.info('这是一条测试日志');
  }
});

connection.connect();