Node.js - Sequelize ORM - 简单 CRUD(创建、读取、更新和删除)示例

Question

在搜索使用最新 Sequelize ORM 版本 4.15 实现 CRUD 代码的简单示例后，无法在单个问题中找到答案。必须单独搜索每个 CRUD 操作。

Answer 1

使用 Node.js 和 Sequelize ORM 进行简单的 CRUD:

使用带有“id”和“name”字段的简单组织实体的示例。

1. app.js

   ...
var 组织 = require('./routes/organizations');
...

路线/组织

module.exports = function (sequelize, DataTypes) {
    return sequelize.define('organization', {
        id: {
            type: DataTypes.INTEGER(11),
            allowNull: false,
            primaryKey: true,
            autoIncrement: true
        },
        name: {
            type: DataTypes.STRING(200),
            allowNull: false
        }
    }, {
            tableName: 'organization'
        });
};

路线/组织

var express = require('express');
var router = express.Router();

const sequelize = require('path/to/sequelize');
const Model = sequelize.import('../models/organization');

/* GET Models. */
router.get('/', function (req, res, next) {
    var code = 500;
    var message = 'Internal Server Error';
    var result = '';

    var page = req.query.page || 1;
    var limit = req.query.limit || 5;
    var offset = (page - 1) * limit;

    Model
        .findAndCountAll({
            offset: +offset,
            limit: +limit
        })
        .then(result => {
            code = 200;
            message = 'OK';

            res.json({
                code: code,
                message: message,
                response: {
                    data: { models: result }
                }
            });
        });
});

/* GET Model. */
router.get('/:id', function (req, res, next) {
    var code = 500;
    var message = 'Internal Server Error';
    var result = '';

    var id = req.params.id | 0;

    Model
        .find({
            where: {
                id: id
            }
        })
        .then(result => {
            code = 200;
            message = 'OK';

            res.json({
                code: code,
                message: message,
                response: {
                    data: { model: result }
                }
            });
        });
});

/* POST new Model. */
router.post('/', function (req, res, next) {
    var code = 500;
    var message = 'Internal Server Error';
    var response = '';

    var postData = {
        name: req.body.name
    };

    Model.create(postData)
        .then(function (model) {
            code = 200;
            message = 'OK';
            response = 'Record is successfully added.';

            res.json({
                code: code,
                message: message,
                response: {
                    msg: response
                }
            });
        })
        .catch(function (err) {
            code = 500;
            response = message;

            res.json({
                code: code,
                message: message,
                response: {
                    msg: response
                }
            });
        });
});

/* PUT old Model. */
router.put('/:id', function (req, res, next) {
    var code = 500;
    var message = 'Internal Server Error';
    var response = '';

    var id = req.params.id;
    var putData = {
        name: req.body.name
    };

    Model.update(putData,
        {
            where: {
                id: id
            }
        }
    )
        .then(function (model) {
            code = 200;
            message = 'OK';
            response = 'Record is successfully updated.';

            res.json({
                code: code,
                message: message,
                response: {
                    msg: response
                }
            });
        })
        .catch(function (err) {
            code = 500;
            response = message;

            res.json({
                code: code,
                message: message,
                response: {
                    msg: response
                }
            });
        });
});

/* DELETE Model. */
router.delete('/:id', function (req, res, next) {
    var code = 500;
    var message = 'Internal Server Error';
    var response = '';

    var id = req.params.id;

    Model.destroy(
        {
            where: {
                id: id
            }
        }
    )
        .then(function (deletedRecord) {
            if (deletedRecord === 1) {
                code = 200;
                message = 'OK';
                response = 'Record is successfully deleted.';
            } else {
                code = 404;
                message = 'OK';
                response = 'Record not found.';
            }
            res.json({
                code: code,
                message: message,
                response: {
                    msg: response
                }
            });
        })
        .catch(function (err) {
            code = 500;
            response = message;

            res.json({
                code: code,
                message: message,
                response: {
                    msg: response
                }
            });
        });
});

module.exports = router;

如果能知道比上面更好的代码，我们将不胜感激。它可以帮助某人。