如何使用nodeJs在Lambda函数中使用mysq事务提交回滚

 host: 'your_mysql_host',

 user: 'your_mysql_user',

 password: 'your_mysql_password',

 database: 'your_mysql_database',

 connectionLimit: 10 // 设置连接池的最大连接数

 const connection = await new Promise((resolve, reject) => {

   pool.getConnection((error, connection) => {

     if (error) {

       reject(error);

     } else {

       resolve(connection);

     }

   });

 });

 // 开始事务

 connection.beginTransaction((error) => {

   if (error) {

     connection.release();

     throw error;

   }

   // 在事务中执行数据库操作

   connection.query('INSERT INTO your_table SET ?', { column1: 'value1', column2: 'value2' }, (error, results) => {

     if (error) {

       connection.rollback(() => {

         connection.release();

         throw error;

       });

     } else {

       connection.commit((error) => {

         if (error) {

           connection.rollback(() => {

             connection.release();

             throw error;

           });

         } else {

           connection.release();

           console.log('Transaction committed.');

         }

       });

     }

   });

 });