标签：body function koa ctx connection json error var query

var Koa = require(‘koa’);
var Router = require(‘koa-router’ );
var bodyParser = require(‘koa-bodyparser’);
var mysql = require(‘mysql’);
var app = new Koa();
var router = new Router();
app.use(bodyParser());

var connection = mysql.createConnection({
host : ‘localhost’,
port:3306,
user : ‘root’,
password : ‘xxx’,
database : ‘url’
});
connection.connect();

//第一类封装 ，一般用于不传递多个参数
const query = function (sql) {
return new Promise((resolve, reject) => {
connection.query(sql, function (error, results) {
if(error){
reject(error);
}else{
resolve(results)
}
});
})
}
//第二类封装 ，一般用于传递多个参数
const query1 = function (userStr,name,passwd,token1) {
return new Promise((resolve, reject) => {
connection.query(userStr, function (error, result) {
if(error){
reject(error);
}else{
if (result.length > 0) {
json[‘message’] = ‘用户已经存在’;
json[‘resultCode’]= 1;
} else {
json[‘message’] = ‘注册成功’;
json[‘token’] = token1;
json[‘resultCode’] = 200;
var insertStr = insert into login (username, password,token) values ("${name}", "${passwd}","${token1}");
console.log(insertStr)
connection.query(insertStr, function (err, res) {
if (err) throw err;
})
}
resolve(json)
}
});
})
}
// 使用第一类封装
router.get( ‘/csdnurl’, async(ctx, next) => {
var sql = “select * from csdnurl”;
let results = await query(sql);
ctx.body=results
});

更多内容请见原文，原文转载自：https://blog.csdn.net/weixin_44519496/article/details/119816321

标签：body,function,koa,ctx,connection,json,error,var,query
来源： https://www.cnblogs.com/wangchuanxinshi/p/16352667.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。