mysql - Sequelize 事务执行回滚但数据库不执行

Question

这是 PostgreSQL 中数据库表和约束的快照:

CREATE TABLE garage (
    garage_id integer NOT NULL,
    garage_name text,
    garage_description text
);

CREATE TABLE auto (
    auto_id serial PRIMARY KEY,
    auto_name text,
    auto_description text,
    auto_price numeric(20,2),
    auto_category text,
    garage_id integer
);

ALTER TABLE ONLY auto
    ADD CONSTRAINT auto_garage_id_fkey FOREIGN KEY (gerage_id)
    REFERENCES gerage(gerage_id);

这里我使用 Sequelize 在 nodejs 中定义数据库对象:

var Auto = sequelize.define('auto', {
    auto_id: {
        type: Sequelize.INTEGER,
        primaryKey: true,
        autoIncrement: true
    },
    auto_name: Sequelize.STRING,
    auto_description: Sequelize.STRING,
    auto_price: Sequelize.NUMERIC,
    auto_category: Sequelize.STRING,
    garage_id: Sequelize.INTEGER
}, {freezeTableName: true,
        tableName: "auto",
        timestamps: false,
        paranoid: false,
        underscored: true});

function createAutos(auto_1,auto_2){
    return sequelize.transaction().then(function(t){
        return Auto.create(auto_1, 
            {fields: ['auto_name', 'auto_description', 'auto_price', 'auto_category', 'garage_id']},
            {transaction: t}
        ).then(function(){ 
            return Auto.create(auto_2, 
                {fields: ['auto_name', 'auto_description', 'auto_price', 'auto_category', 'garage_id']},
                {transaction: t});
        }).then(function(){
            t.commit();
        }).catch(function(err){
            t.rollback();
        });
    });
}

我在这里执行以下方法来测试事务性 createAutos():

createAutos({
    "auto_name": 'bmw',
    "auto_description": 'sport',
    "auto_price":4.95,
    "auto_category": 'luxes',
    "garage_id": 1 // Exists in the database
},{
    "auto_name": 'SSSS',
    "auto_description": 'sport',
    "auto_price":4.95,
    "auto_category": 'luxes',
    "garage_id": 200 // Doesn't exist in the database.
});

执行时，在控制台可以看到如下输出日志:

Executing (bf8cb998-657b-49b7-b29e-957bcf770b40): START TRANSACTION;
Executing (bf8cb998-657b-49b7-b29e-957bcf770b40): SET SESSION TRANSACTION ISOLATION LEVEL REPEATABLE READ;
Executing (bf8cb998-657b-49b7-b29e-957bcf770b40): SET autocommit = 1;
Executing (default): INSERT INTO "auto" ("auto_name","auto_description","auto_price","auto_category","garage_id") VALUES ('bmw','sport',4.95,'luxes',1) RETURNING *;
Executing (default): INSERT INTO "auto" ("auto_name","auto_description","auto_price","auto_category","garage_id") VALUES ('SSSS','sport',4.95,'luxes',200) RETURNING *;
Executing (bf8cb998-657b-49b7-b29e-957bcf770b40): ROLLBACK;

但是在数据库中，第一个自动“bmw”被写入，尽管整个事务已回滚。

我用 PostgreSQL 9.3.10、Ubuntu、MySQL 5.5.46、sequelize 3.13.0 和 3.0.0 测试了程序

有没有人注意到这里的代码有错误，或者这是一个错误......？

Answer 1

在您的输出日志中，我们可以看到两笔交易，一笔是 bf8cb998-657b-49b7-b29e-957bcf770b40，另一笔是 Default。第一个是回滚的，第二个不是，那是你插入的地方。

您尝试将事务传递给 Create 函数，但看起来 Sequelize 没有得到它。某些版本之前，交易的语法发生了变化，您可以尝试将“交易:t”属性放在第二个对象而不是第三个对象中吗？像这样:

Auto.create(auto_1, 
        {fields: ['auto_name', 'auto_description', 'auto_price', 'auto_category', 'garage_id'],
        transaction: t}