mysql - 为什么 Sequelize “包含/属性”不适用于 findAll 和 findOne 请求
问题描述
我正在开发一个通过 Sequelize 与 MySQL 通信的 API。我正在与用户及其出版物打交道。这工作得很好,我可以创建与 userId 关联的用户和出版物。但现在我想获取发布用户的名称,而不仅仅是 userId。
所以我处理我的模型“用户”和“出版物”之间的关联。我已经在我的续集模型和迁移文件中定义了关联,但是当我添加到我的控制器时:
model : User,
attributes: ['firstName']
}],
我收到没有详细信息的错误 400。
如果我只写没有属性的“模型:用户”,它也不起作用,所以我猜它找不到模型用户。
我按照 Sequelize 手册中解释的步骤,尝试与其他 github 示例进行比较,理论上似乎还可以。我花了两天时间尝试更改字符大小写,我在这里尝试了 sequelize 给出的许多选项,我删除了所有表并重新创建了它们,但我现在正在绕圈运行 :-)
在我的迁移文件和模型下方。谢谢你的帮助 !
出版物控制器
const models = require('../models'); // importation des modèles sequelize
const Publication = models.publication;
const User = models.user;
exports.getAllPublications = (req, res, next) => {
Publication.findAll({
include: [{
model : User,
attributes: ['firstName']
}],
order: [['createdAt', 'DESC']]
})
.then(
(publications) => {
res.status(200).json(publications);
}
).catch(
(error) => {
res.status(400).json({
error: error
});
}
);
};
用户序列化模型
'use strict';
const {
Model
} = require('sequelize');
module.exports = (sequelize, DataTypes) => {
class User extends Model {
static associate(models) {
models.User.hasMany(models.Publication)
}
};
User.init({
firstName: DataTypes.STRING,
lastName: DataTypes.STRING,
email: DataTypes.STRING,
password: DataTypes.STRING,
isAdmin: DataTypes.BOOLEAN
}, {
sequelize,
modelName: 'User',
});
return User;
};
出版续集模型
'use strict';
const {
Model
} = require('sequelize');
module.exports = (sequelize, DataTypes) => {
class Publication extends Model {
static associate(models) {
models.Publication.belongsTo(models.User, {
foreignKey: {
allowNull: false,
}
});
}
};
Publication.init({
userId: DataTypes.INTEGER,
title: DataTypes.STRING,
content: DataTypes.STRING
}, {
sequelize,
modelName: 'Publication',
});
return Publication;
};
指数
'use strict';
const fs = require('fs');
const path = require('path');
const Sequelize = require('sequelize');
const basename = path.basename(__filename);
require('dotenv').config() // importation dotenv pour sécuriser passwords
const db = {};
let sequelize;
sequelize = new Sequelize(
process.env.DB_NAME,
process.env.DB_USER,
process.env.DB_PASSWORD, {
host: process.env.DB_HOST,
dialect: process.env.DB_DIALECT
});
fs
.readdirSync(__dirname)
.filter(file => {
return (file.indexOf('.') !== 0) && (file !== basename) && (file.slice(-3) === '.js');
})
.forEach(file => {
const model = require(path.join(__dirname, file))(sequelize, Sequelize.DataTypes);
db[model.name] = model;
});
Object.keys(db).forEach(modelName => {
if (db[modelName].associate) {
db[modelName].associate(db);
}
});
db.sequelize = sequelize;
db.Sequelize = Sequelize;
db.user = require("./user.js")(sequelize, Sequelize)
db.publication = require("./publication.js")(sequelize, Sequelize)
db.comment = require("./comment.js")(sequelize, Sequelize)
module.exports = db
发布迁移文件
'use strict';
module.exports = {
up: async (queryInterface, Sequelize) => {
await queryInterface.createTable('Publications', {
id: {
allowNull: false,
autoIncrement: true,
primaryKey: true,
type: Sequelize.INTEGER
},
userId: {
allowNull: false,
type: Sequelize.INTEGER,
references: {
model: 'Users',
key: 'id'
}
},
title: {
allowNull: false,
type: Sequelize.STRING,
len: [2,50]
},
content: {
allowNull: false,
type: Sequelize.STRING(1234),
len: [2,1000]
},
createdAt: {
allowNull: false,
type: Sequelize.DATE
},
updatedAt: {
allowNull: false,
type: Sequelize.DATE
}
});
},
down: async (queryInterface, Sequelize) => {
await queryInterface.dropTable('Publications');
}
};
用户创建控制器
exports.signup = (req, res, next) => {
bcrypt.hash(req.body.password, 10) // On crypte le mot de passe (algorithme exécuté 10 fois) / asynchrone
.then(hash => {
console.log(hash)
const newUser = User.create({ // modèle sequelize
lastName : req.body.lastName,
firstName : req.body.firstName,
email: req.body.email,
password: hash, // On enregistre le mdp crypté plutôt que le mdp simple
})
.then((newUser )=> res.status(201).json({ message: 'created' })) // Requête traitée avec succès et création d’un document
.catch(error =>
res.status(400).json({ error })); // Bad Request*/
})
.catch(error => {
console.log("erreur 500")
res.status(500).json({ error })}); // Erreur interne du serveur
};
按照建议更改模型后的新 App.js
'use strict'
const express = require('express'); // importation application Express
require('dotenv').config() // importation dotenv pour sécuriser passwords
const mysqlTable = process.env.MYSQLTABLE;
const mysqlUsername = process.env.MYSQLUSERNAME;
const mysqlPassword = process.env.MYSQLPASSWORD;
const rateLimit = require("express-rate-limit");
const limiter = rateLimit({
windowMs: 15 * 60 * 1000, // 15 minutes
max: 100 // limit each IP to 100 requests per windowMs
});
const bodyParser = require('body-parser'); // importation fonction body parser pour extraction objet json de la demande
const cors = require('cors'); // module CORS
const { Sequelize } = require('sequelize'); // importation application Sequelize pour communiquer avec MySQL
const userRoutes = require('./routes/user'); // Importation routeur users
const publicationRoutes = require('./routes/publication'); // Importation routeur posts
const commentRoutes = require('./routes/comment'); // Importation routeur posts
const Publication = require('./models/publication');
const User = require('./models/user')
Publication.belongsTo(User, { Constraints: true, onDelete: 'CASCADE'});
User.hasMany(Publication);
const sequelize = new Sequelize(mysqlTable, mysqlUsername, mysqlPassword, { // Connexion à la base de données mySQL
host : 'localhost',
dialect: 'mysql'
})
const app = express(); // application Express
app.use(bodyParser.json()); // Enregistrement body parser
app.use(cors()); // module CORS
app.use(limiter); // rate limit
app.use((req, res, next) => { // Ajout headers pour résoudre les erreurs CORS
res.setHeader('Access-Control-Allow-Origin', '*'); // accéder à notre API depuis n'importe quelle origine
res.setHeader('Access-Control-Allow-Headers', 'Origin, X-Requested-With, Content, Accept, Content-Type, Authorization'); // ajouter les headers mentionnés aux requêtes envoyées vers notre API
res.setHeader('Access-Control-Allow-Methods', 'GET, POST, PUT, DELETE, PATCH, OPTIONS'); // envoyer des requêtes avec les méthodes mentionnées
next();
});
app.use('/api/auth', userRoutes) // Enregistrement routeur users
app.use('/api/publication', publicationRoutes) // Enregistrement routeur publications
app.use('/api/comment', commentRoutes) // Enregistrement routeur publications
module.exports = app;
解决方案
从我们的评论交流中我了解到,问题出在协会的声明上。
就我个人而言,我不喜欢像你所做的那样定义关联(我没有说这是不正确的!),我个人喜欢跟随。
我在特定文件下(例如,在 ./util/database.js 下)创建了 Sequelize 的实例:
数据库.js:
const Sequelize = require('sequelize');
const sequelize = new Sequelize('database_name', 'user_name', 'password', {
dialect: 'mysql',
storage: "./session.mysql",
host: 'localhost'
});
module.exports = sequelize;
我这样定义我的模型:
用户型号:
const Sequelize = require('sequelize');
const sequelize = require('../util/database');
const User = sequelize.define('user', {
id: {
type: Sequelize.INTEGER,
autoIncrement: true,
allowNull: false,
primaryKey: true
},
firstName: Sequelize.STRING,
lastName: Sequelize.STRING,
email: Sequelize.STRING,
password: Sequelize.STRING,
isAdmin: Sequelize.BOOLEAN
});
module.exports = User;
出版模式:
const Sequelize = require('sequelize');
const sequelize = require('../util/database');
const Publication = sequelize.define('publication', {
id: {
type: Sequelize.INTEGER,
autoIncrement: true,
allowNull: false,
primaryKey: true
},
title: Sequelize.STRING,
content: Sequelize.STRING
});
module.exports = Publication;
然后,我在app.js文件中定义关联:
Publication.belongsTo(User, { Constraints: true, onDelete: 'CASCADE'});
User.hasMany(Publication);
为了确保新数据库的架构很好地集成,我使用了sync
带有force
属性的方法(只是第一次,那么你应该删除这个属性并使用同步方法)
// this will run on starting the server
sequelize
.sync({ force: true }) // run it just in the first time after changing the database, this command will re-draw the database
// .sync()
.then(() => app.listen(8080))
.catch(err => console.log(err));
最后,您可以保留您为获取数据所做的工作,也可以执行以下操作:
User.findByPk(userId, {include: ['publications']})
//supposing that you have an instance of a User (user)
user.getPublications({})
user.getPublications({where: { id: publicationId }})
推荐阅读
- python - 如何允许用户直接下载存储在 django 中我的媒体文件夹中的文件?
- c++ - 将 24 小时制转换为 12 小时制
- svelte - 子反应性语句更改时正在执行反应性语句?
- delphi - 位图的快速平滑调整大小
- python - 在 Python 中更改 url 解析过程查询名称和值?
- python - 是否有更快的替代 np.where 来确定 indeces?
- azure-devops-server-2019 - 错误“TF255115:以下服务未启动:TfsJobAgent。” 在启动 Azure DevOPs Server 2019 时
- c++ - C++ Gnu C++ 9.2 对概念和约束的支持
- java - 如何解决 JavaFX 项目中的“需要位置”
- c# - 如何让相同的属性名出现两次?