koa连接mysql怎么做_koa-连接mysql数据库
koa-連接mysql數(shù)據(jù)庫
安裝數(shù)據(jù)庫插件
npm install mysql -s
default.js編寫：// 數(shù)據(jù)庫配置
const config = {
port: 3000, // koa運(yùn)行端口
database:{
DATABASE: '****', //數(shù)據(jù)庫
USERNAME: '****', //用戶
PASSWORD: '****', //密碼
PORT: '3306', //端口
HOST: '******' //服務(wù)ip地址
}
}
module.exports = config
mysql .js 編寫：
一個(gè)執(zhí)行mysql處理的函數(shù)const mysql = require('mysql')
const config = require('./default')
var pool = mysql.createPool({
host : config.database.HOST,
user : config.database.USERNAME,
password : config.database.PASSWORD,
database : config.database.DATABASE
});
let query = function( sql, values ) {
return new Promise(( resolve, reject ) => {
pool.getConnection(function(err, connection) {
if (err) {
resolve( err )
} else {
connection.query(sql, values, ( err, rows) => {
if ( err ) {
reject( err )
} else {
resolve( rows )
}
connection.release()
})
}
})
})
}
// 查詢hez數(shù)據(jù)庫
let findHez1 = function () {
let _sql = `SELECT * FROM test `
return query(_sql)
}
//暴露方法
module.exports={findHez1}
編輯一個(gè)路由，驗(yàn)證是否連成功const Koa = require('koa');
const config = require('./config/default');
const mysql = require('./mysql');
const app = new Koa();
app.use(async (ctx, next) => {
await next();
const rt = ctx.response.get('X-Response-Time');
});
app.use(async (ctx) => {
let request = ctx.request;
let data = await mysql.query("members");
console.log(request.origin);
console.log(request.href);
ctx.body = {
"state": true,
"data": data,
}
});
app.listen(config.port);
console.log(`listening on port ${config.port}`);
啟動(dòng)服務(wù)
node index.js
總結(jié)
以上是生活随笔為你收集整理的koa连接mysql怎么做_koa-连接mysql数据库的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： syslog源码_Gunicorn源码分
- 下一篇： linux cmake编译源码,linu