怎么在node.js中利用Sequelize 對(duì)MySQL進(jìn)行連接？相信很多沒(méi)有經(jīng)驗(yàn)的人對(duì)此束手無(wú)策，為此本文總結(jié)了問(wèn)題出現(xiàn)的原因和解決方法，通過(guò)這篇文章希望你能解決這個(gè)問(wèn)題。
1.1 安裝koa-generator
在終端輸入：
$ npm install -g koa-generator
1.2 使用koa-generator生成koa2項(xiàng)目
$ koa2 HelloKoa2
成功創(chuàng)建項(xiàng)目后，進(jìn)入項(xiàng)目目錄，并執(zhí)行npm install命令
$ cd HelloKoa2 $ npm install
1.3 啟動(dòng)項(xiàng)目
在終端輸入：
$ npm start
項(xiàng)目啟動(dòng)后，默認(rèn)端口號(hào)是3000，在瀏覽器中運(yùn)行可以得到下圖的效果說(shuō)明運(yùn)行成功。
2.1剛剛創(chuàng)建的文件使用webstorm打開(kāi)
新建一個(gè)db目錄
2.2查看Sequelize文檔
使用npm安裝Sequelize
npm install --save sequelize
你還必須手動(dòng)為所選數(shù)據(jù)庫(kù)安裝驅(qū)動(dòng)程序選擇一個(gè)方法之一：
# 選擇以下之一: $ npm install --save pg pg-hstore # Postgres $ npm install --save mysql2 $ npm install --save mariadb $ npm install --save sqlite3 $ npm install --save tedious # Microsoft SQL Server
我這里下載得是MySQL2
2.3連接數(shù)據(jù)庫(kù)
再剛剛創(chuàng)建得db文件加里面添加**config.js**
添加連接代碼：
重慶分公司
重慶分公司
module.exports = {
dbsMysql: 'mysql://root:123456@localhost:3306/new'
//root是數(shù)據(jù)庫(kù)管理員賬號(hào)，‘123546'是密碼 3306是端口號(hào)（MySQL默認(rèn)是3306） school_admin是數(shù)據(jù)庫(kù)名稱(chēng)
}繼續(xù)在db文件夾里面添加mysql.js
添加連接以及添加日記：
const Sequelize = require('sequelize');
const mysqlurl = require('./config').dbsMysql
const sequelize = new Sequelize(mysqlurl, {
// 選擇一種日志記錄參數(shù)
logging: console.log // 默認(rèn)值,顯示日志函數(shù)調(diào)用的第一個(gè)參數(shù)
});
// //每次啟動(dòng)server刷新數(shù)據(jù)庫(kù)
// (async ()=>{
// await sequelize.sync({ force: true });
// })()
module.exports = sequelize3.1模型定義
在db目錄下添加models文件夾再添加一個(gè)new2.js
定義模型：
const { Sequelize, DataTypes, Model } = require('sequelize');
const sequelize = require('../mysql');
const new2 = sequelize.define('t_new2', {
name: {
type: DataTypes.STRING,
allowNull: false
},
},
{
// 這是其他模型參數(shù)
freezeTableName: true
});
// 定義的模型是類(lèi)本身
module.exports= new24.1創(chuàng)建new2路由
在routes文件夾中添加new2.js
//引入kob得routes模塊
const router = require('koa-router')()
//定義模型為剛剛創(chuàng)建得new2.js
let Model = require("../db/models/new2");
//正常來(lái)說(shuō)啟動(dòng)端口為http://localhost:3000 添加/new2就可以進(jìn)入new2路由
router.prefix('/new1')
// 進(jìn)入new2路由以后可以打印this is a users response!
router.get('/', function (ctx, next) {
ctx.body = 'this is a users response!'
})
//設(shè)置增加add接口
router.post('/add', async function (ctx, next) {
console.log(ctx.request.body)
const new2 = await Model.create(ctx.request.body);
ctx.body = {
code:200,
data:new2
}
})
//設(shè)置查詢(xún)find接口
router.post('/find', async function (ctx, next) {
const new2 =await Model.findAll({include: []})
console.log(1111)
ctx.body = {
code: 200,
data: new2
}
})
//設(shè)置通過(guò)id得到所需信息的get接口
router.post('/get', async function (ctx, next) {
// let users = await User.
// find({})
console.log(ctx.request.body)
let new2 = await Model.findOne({
// attributes: ['name', 'where']
where: {
id: ctx.request.body.id
}
});
ctx.body = {
code:200,
data:new2
}
})
//設(shè)置修改update接口
router.post('/update', async function (ctx, next) {
console.log(ctx.request.body)
// let pbj = await Model.update({ _id: ctx.request.body._id }, ctx.request.body);
let new2 = await Model.update(ctx.request.body, {
where: {
id: ctx.request.body.id
}
});
ctx.body = new2
})
//設(shè)置刪除delete接口
router.post('/delete', async function (ctx, next) {
console.log(ctx.request.body)
// 刪除所有名為 "Jane" 的人
await Model.destroy({
where: { id: ctx.request.body.id }
});
ctx.body = 'shibai '
})
// //每次啟動(dòng)server刷新數(shù)據(jù)庫(kù)
// (async ()=>{
// await sequelize.sync({ force: true });
// })()
module.exports = router4.2在app.js里面添加路由
//引入剛剛創(chuàng)建的new2路由
const new2 =require('./routes/new2')//使用我們的路由 app.use(new2.routes(),new2.allowedMethods())
4.3啟動(dòng)項(xiàng)目
在數(shù)據(jù)庫(kù)中查看
5.測(cè)試
5.1使用瀏覽器查看
輸入url：http://localhost:3000/new2
5.2.使用postman測(cè)試接口
測(cè)試find接口（因?yàn)槲覀儗?xiě)的find方法使用的post方法所以記得將get換成post）：
http://localhost:3000/new2/find
測(cè)試get接口
展示一下最后的目錄
看完上述內(nèi)容，你們掌握怎么在node.js中利用Sequelize 對(duì)MySQL進(jìn)行連接的方法了嗎？如果還想學(xué)到更多技能或想了解更多相關(guān)內(nèi)容，歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道，感謝各位的閱讀！
