nodejs使用sequelize操作mysql實例


sequelize是node操作mysql的一款npm包,包含很多特性:數據庫模型映射、事務處理、模型屬性校驗、關聯映射等,花了兩天時間學習了下基本的一些操作,特別是關聯映射部分的操作,包含1:1、1:N、N:N部分,利用express框架實現簡單的rest服務。

關於項目結構:

其中,routes存放各種路由,models配置各種數據庫模型類,ref.js用來配置相關的數據模型關聯關系,主要關系為:user和loginInfo是1:1、user和address是1:N、user和role是N:N關系,index.js主要是加載路由:

module.exports = function(app) {
    app.use("/api/users", require("./user.js"));
    app.use("/api/addresses", require("./address.js"));
    app.use("/api/loginInfos", require("./loginInfo.js"));
    app.use("/api/roles", require("./role.js"));
};

ref.js映射關系配置類:

/**
 * 模型關聯類
 */
var { sequelize } = require("../config/db");
var User = sequelize.import("./user");
var LoginInfo = sequelize.import("./loginInfo");
var Address = sequelize.import("./address");
var Role = sequelize.import("./role");

//建立模型之間關聯關系
User.hasOne(LoginInfo);
LoginInfo.belongsTo(User);

User.hasMany(Address, {
    foreignKey: 'user_id',
    targetKey: 'id',
    as: "Addresses" //別名,目標模型會混入到源模型后會使用該名稱,存在getAddresses、setAddresses等方法
});
Address.belongsTo(User); //address想反查user必須加這個,否則只能實現user查詢address

User.belongsToMany(Role, {
    through: "userRoles"
});
Role.belongsToMany(User, {
    through: 'userRoles'
});

//創建表
sequelize.sync({ force: false });

數據庫配置類:

const Sequelize = require('sequelize');
const sequelize = new Sequelize('node-sequelize', 'admin', 'admin', {
    host: 'localhost',
    dialect: 'mysql',
    pool: {
        max: 5,
        min: 0,
        idle: 10000
    }
});

//測試數據庫鏈接
sequelize.authenticate().then(function() {
    console.log("數據庫連接成功");
}).catch(function(err) {
    //數據庫連接失敗時打印輸出
    console.error(err);
    throw err;
});

exports.sequelize = sequelize;
exports.Sequelize = Sequelize;

當然,app.js要做的就是加載路由、加載映射關系配置文件,使數據模型和數據庫同步:

//加載主外鍵關系及創建數據庫
require('./models/ref');

Router(app);

詳細代碼已上傳至github:https://github.com/caiya/node-sequelize

 


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM