sequelize 框架之 添删改查

 先来个sqlhelp

var Sequelize = require('sequelize');
var userinfo = require('../models/userinfo');
var config = require('../../config/db.json');

/*TODO:数据源读写分离*/
var read = new Sequelize(config.mysql.read);
var write = new Sequelize(config.mysql.write);

/*TODO:数据源连接数据表*/
write.define('info', userinfo.info, userinfo.info_conf);
write.define('Theme', userinfo.info, userinfo.info_conf);

/*TODO:初始化*/
module.exports = {
    write: write,
    read: read,
    init: function(cb){
        write.sync().then(cb);
    }
};

再来个models

/*TODO:导入模块*/
var Sequelize = require('sequelize');

var prefix = 'n_';

module.exports = {
    info: {
        UserName:{
            type:Sequelize.STRING(20),
            field:'UserName',
            'allowNull': false,         // 是否允许为NULL
            'unique': true
        },
        UserPass:{
            type:Sequelize.STRING(20),
            'allowNull': false,         // 是否允许为NULL
            'unique': true,
            field:'UserPass'
        },
    },
    /*用户*/
    info_conf: {
        tableName: prefix   'info', // 表名
        timestamps: false, // 不显示createAt updateAt
        engine: 'InnoDB',  // MyISAM, InnoDB
        indexes: [
            {
                name: 'id',
                unique: true,
                fields: ['id']
            }


        ]
    },


};

实现下添删 该查

var dbhelper = require('../util/mysqlhelp.js');

var info = dbhelper.write.model('info');

var user = info.build({
    'UserName': '1',
    'UserPass': 'dfdfdf'
});

user.save() ;

//根据条件 需改
info.update({UserPass:'niefengjun'},{where:{UserName:'1'}}).then(function(err,result){
    console.log(err, result);
}, function(err){
    console.log(err);
});

info.destroy({where:{UserName:'1'}}).then(function(err,re)
{
    console.log(err,re) ;
}
).catch(function(e,v)
{
    console.log(e,v) ;
}
)

至此框架的东东基本的就实现了