{ pool.getConnection(function (err,connection) { if(err){ reject(err); }else{ connection.query(sql,values,(err,rows)=>{ if(err){ reject(err); }else{ resolve(rows); } connection.release(); //为每一个请求都建立一个connection使用完后调用connection.release(); 直接释放资源。 //query用来操作数据库表 }) } }) })}

//session存储配置，将session存储至数据库
const sessionMysqlConfig = {
user: config.database.USERNAME,database: config.database.DATABASE,host: config.database.HOST,}

//配置session中间件
app.use(session({
key: 'USER_SID',store: new MysqlStore(sessionMysqlConfig)
}))

//配置静态资源加载中间件
app.use(koaStatic(
path.join(__dirname,'./public')
))

//配置服务端模板渲染引擎中间件
app.use(views(path.join(__dirname,'./views'),{
extension: 'ejs'
}))

//使用表单解析中间件
app.use(bodyParser({
"formLimit":"5mb","jsonLimit":"5mb","textLimit":"5mb"
}));

//使用新建的路由文件
//登录
app.use(require('./routers/signin.js').routes())
//注册
app.use(require('./routers/signup.js').routes())
//退出登录
app.use(require('./routers/signout.js').routes())
//首页
app.use(require('./routers/home.js').routes())
//个人主页
app.use(require('./routers/personal').routes())
//文章页
app.use(require('./routers/articles').routes())
//资源分享
app.use(require('./routers/share').routes())
//个人日记
app.use(require('./routers/selfNote').routes())
//监听在8080端口
app.listen(8080)

console.log(listening on port ${config.port})

var posts = `create table if not exists posts(
id INT(200) NOT NULL AUTO_INCREMENT,title VARCHAR(100) NOT NULL,content TEXT NOT NULL,uid INT(200) NOT NULL,moment VARCHAR(40) NOT NULL,comments VARCHAR(255) NOT NULL DEFAULT '0',pv VARCHAR(40) NOT NULL DEFAULT '0',likes INT(200) NOT NULL DEFAULT '0',type VARCHAR(20) NOT NULL,avator VARCHAR(100),collection INT(200) NOT NULL DEFAULT '0',PRIMARY KEY (id),FOREIGN KEY (uid) REFERENCES users(id)
ON DELETE CASCADE

);`

var comment= create table if not exists comment( id INT(200) NOT NULL AUTO_INCREMENT,postid INT(200) NOT NULL,PRIMARY KEY ( id ),FOREIGN KEY (postid) REFERENCES posts(id) ON DELETE CASCADE );

var likes = create table if not exists likes( id INT(200) NOT NULL AUTO_INCREMENT,FOREIGN KEY (postid) REFERENCES posts(id) ON DELETE CASCADE );
var collection = create table if not exists collection( id INT(200) NOT NULL AUTO_INCREMENT,uid VARCHAR(100) NOT NULL,FOREIGN KEY (postid) REFERENCES posts(id) ON DELETE CASCADE );
var follow = create table if not exists follow( id INT(200) NOT NULL AUTO_INCREMENT,fwid INT(200) NOT NULL DEFAULT '0',FOREIGN KEY (uid) REFERENCES users(id) ON DELETE CASCADE )

let createTable = function(sql){
return query(sql,[]);
}

//建表
createTable(users);
createTable(posts);
createTable(comment);
createTable(likes);
createTable(collection);
createTable(follow);
//createTable(follower);
//注册用户
let insertData = function(value){
let _sql = "insert into users(name,pass) values(?,?);"
return query(_sql,value);
}
//更新头像
let updateUserImg = function(value){
let _sql = "update users set avator=? where id=?"
return query(_sql,value);
}
//更新用户信息
let updateUser = function(value){
let _sql = "update users set name=?,job=?,company=?,introdu=?,userhome=?,github=? where id=?"
return query(_sql,value);
}
//发表文章
let insertPost = function(value){
let _sql = "insert into posts(name,title,content,uid,moment,type,avator) values(?,?,value);
}

//更新文章评论数
let updatePostComment = function(value){
let _sql = "update posts set comments=? where id=?"
return query(_sql,value);
}
.......

Myblog