关于Nodejs处理事务的问题

在 Node.js 中处理数据库事务时，确保所有操作都在同一个连接上是非常重要的。如果每个服务都从连接池中获取自己的连接，那么事务将无法正确地跨这些连接进行管理。为了解决这个问题，可以采用以下几种方法：

方法一：传递当前连接

最直接的方法是在调用服务时传递当前的数据库连接。这样，所有服务都可以使用同一个连接来执行事务中的操作。

示例代码：

const mysql = require('mysql');
const pool = mysql.createPool({
    host: 'localhost',
    user: 'root',
    password: 'password',
    database: 'testdb'
});

function beginTransaction(connection, callback) {
    connection.beginTransaction(function(err) {
        if (err) {
            return callback(err);
        }
        callback(null, connection);
    });
}

function commit(connection, callback) {
    connection.commit(function(err) {
        if (err) {
            connection.rollback(function() {
                throw err;
            });
        }
        callback(err);
    });
}

function rollback(connection, callback) {
    connection.rollback(function() {
        callback(new Error('Transaction failed and rolled back'));
    });
}

function taskService(connection, task, callback) {
    connection.query("INSERT INTO tasks SET ?", task, callback);
}

function segmentService(connection, segment, callback) {
    connection.query("INSERT INTO segments SET ?", segment, callback);
}

pool.getConnection(function(err, connection) {
    if (err) {
        console.error('MySQL 连接失败');
        return callback(err, null);
    }

    beginTransaction(connection, function(err, connection) {
        if (err) {
            rollback(connection, function() {
                throw err;
            });
            return;
        }

        async.parallel([
            function(callback) {
                taskService(connection, { name: 'Task 1' }, callback);
            },
            function(callback) {
                segmentService(connection, { start: '2023-10-01', end: '2023-10-31' }, callback);
            }
        ], function(err, results) {
            if (err) {
                rollback(connection, function() {
                    throw err;
                });
                return;
            }

            commit(connection, function(err) {
                if (err) {
                    rollback(connection, function() {
                        throw err;
                    });
                } else {
                    console.log('事务成功完成');
                }
            });
        });
    });

    // 释放连接
    connection.release();
});

方法二：使用事务中间件

另一种方法是使用事务中间件，例如 knex 或 sequelize，它们提供了更高级的事务管理功能。

示例代码（使用 Knex）：

const knex = require('knex')({
    client: 'mysql',
    connection: {
        host: 'localhost',
        user: 'root',
        password: 'password',
        database: 'testdb'
    }
});

async function main() {
    try {
        await knex.transaction(async (trx) => {
            await knex('tasks').insert({ name: 'Task 1' }).transacting(trx);
            await knex('segments').insert({ start: '2023-10-01', end: '2023-10-31' }).transacting(trx);
        });
        console.log('事务成功完成');
    } catch (err) {
        console.error('事务失败', err);
    }
}

main();

通过以上方法，你可以确保事务中的所有操作都在同一个连接上进行，从而保证事务的一致性和完整性。

我不明白你们怎么会有这样的问题，在service中，首先拿联接，然后再把联接传到module中拿数据。不管拿多少数据，都是一个联接 From Noder