在模型上使用 beforeCreate 和 findOrCreate 与 Sequelize 发生死锁
Deadlock with Sequelize using beforeCreate and findOrCreate on a model
我遇到错误:
Unhandled rejection SequelizeDatabaseError: ER_LOCK_DEADLOCK: Deadlock found when trying to get lock; try restarting transaction
这是我的模型:
var bcrypt = require('bcryptjs');
module.exports = function (sequelize, DataTypes) {
var User = sequelize.define('User', {
username: {type: DataTypes.STRING, unique: true},
password: DataTypes.STRING,
email: DataTypes.STRING,
isAdmin: DataTypes.BOOLEAN,
isActive: DataTypes.BOOLEAN
}, {
classMethods: {
associate: function (models) {
User.hasMany(models.Comment);
User.hasMany(models.Message, {as: 'receivedMessages', foreignKey: 'Receiver'});
User.hasMany(models.Message, {as: 'sentMessages', foreignKey: 'Sender'});
}
}
});
User.hook('beforeCreate', function (user, options, fn) {
bcrypt.genSalt(SALT_WORK_FACTOR, function (err, salt) {
if (err) {
return next(err);
}
bcrypt.hash(user.password, salt, function (err, hash) {
if (err) {
return next(err);
}
user.password = hash;
return fn(err, user);
});
});
});
User.findOrCreate({
where: {
username: 'admin'
},
defaults: {
username: 'admin',
email: 'admin@admin.com',
password: 'admin',
isAdmin: true,
isActive: true
}
});
return User;
};
如果我删除其中一个挂钩(beforeCreate 或 findOrCreate),它会正常工作。
这似乎是关于事务的问题,但我找不到让它工作的方法。
文档谈到传递交易,但我不知道如何将交易传递给 findOrCreate。
这是文档:http://docs.sequelizejs.com/en/latest/docs/hooks/#model-hooks
有什么想法吗?提前致谢!!
不是解决方案,而是解决方法,我没有使用钩子 "findOrCreate",而是自己完成的:
User.find(
{
where: {
username: 'admin'
}
}
).then(function (user) {
if (!user) {
User.create({
username: 'admin',
email: 'admin@admin.com',
password: 'admin',
isAdmin: true,
isActive: true
}).then(function (newUser) {
console.log('Admin created with id: ' + newUser.id);
});
}
}
);
也许不是最佳答案,但它有效。
我遇到错误:
Unhandled rejection SequelizeDatabaseError: ER_LOCK_DEADLOCK: Deadlock found when trying to get lock; try restarting transaction
这是我的模型:
var bcrypt = require('bcryptjs');
module.exports = function (sequelize, DataTypes) {
var User = sequelize.define('User', {
username: {type: DataTypes.STRING, unique: true},
password: DataTypes.STRING,
email: DataTypes.STRING,
isAdmin: DataTypes.BOOLEAN,
isActive: DataTypes.BOOLEAN
}, {
classMethods: {
associate: function (models) {
User.hasMany(models.Comment);
User.hasMany(models.Message, {as: 'receivedMessages', foreignKey: 'Receiver'});
User.hasMany(models.Message, {as: 'sentMessages', foreignKey: 'Sender'});
}
}
});
User.hook('beforeCreate', function (user, options, fn) {
bcrypt.genSalt(SALT_WORK_FACTOR, function (err, salt) {
if (err) {
return next(err);
}
bcrypt.hash(user.password, salt, function (err, hash) {
if (err) {
return next(err);
}
user.password = hash;
return fn(err, user);
});
});
});
User.findOrCreate({
where: {
username: 'admin'
},
defaults: {
username: 'admin',
email: 'admin@admin.com',
password: 'admin',
isAdmin: true,
isActive: true
}
});
return User;
};
如果我删除其中一个挂钩(beforeCreate 或 findOrCreate),它会正常工作。
这似乎是关于事务的问题,但我找不到让它工作的方法。
文档谈到传递交易,但我不知道如何将交易传递给 findOrCreate。 这是文档:http://docs.sequelizejs.com/en/latest/docs/hooks/#model-hooks
有什么想法吗?提前致谢!!
不是解决方案,而是解决方法,我没有使用钩子 "findOrCreate",而是自己完成的:
User.find(
{
where: {
username: 'admin'
}
}
).then(function (user) {
if (!user) {
User.create({
username: 'admin',
email: 'admin@admin.com',
password: 'admin',
isAdmin: true,
isActive: true
}).then(function (newUser) {
console.log('Admin created with id: ' + newUser.id);
});
}
}
);
也许不是最佳答案,但它有效。