var express = require("express");
var app = express();
var querystring = require("querystring");
//console.log(mysql)

// 与数据库建立连接
connection.connect();
//根据参数，查询数据
app.get('/index', function (req, res) {
 // 处理 get 请求，获取 get 请求参数
 //处理 /:xxx 形式的 get 或 post 请求，获取请求参数 这里没有使用到
 var params = req.query
 //查询语句
 var sql = 'select * from userinfo where name= ? and age=?'
 var where_value = [params.name, params.age];
 // console.log(sql)
 connection.query(sql, where_value, function (err, result) {
 if (err) {
  console.log('[SELECT ERROR]:', err.message);
 }
 res.send(result) //数据库查询结果返回到result中,把查询数据发送到客户端
 });

})
//增加数据
app.post('/add', function (req, res) {
 //获取及处理增加的数据
 var post = '';
 req.on('data', function (chunk) {
 post += chunk;
 console.log(post)
 });
 req.on('end', function () {
 //查询参数解析
 post = querystring.parse(post);
 var sql = 'insert into userinfo set id=? , name=? , age=?, address=?'
 var add_value = [post.id, post.name, post.age, post.address]
 connection.query(sql, add_value, function (err, result) {
  if (err) {
  console.log('新增数据失败');
  }
  res.send('增加数据成功') // 响应内容 增加数据成功
 });
 });
})
//修改数据
app.put('/update', function (req, res) {
 //处理请求修改的数据和条件
 var update = '';
 req.on('data', function (chunk) {
 update += chunk;
 console.log(update)
 });
 req.on('end', function () {
 //查询参数解析
 update = querystring.parse(update);
 var sql = 'update userinfo set name=? , age=?, address=? where id=?'
 var update_value = [update.name, update.age, update.address,update.id]
 connection.query(sql, update_value, function (err, result) {
  if (err) {
  console.log('修改数据失败', err.message);
  }
  res.send('修改数据成功') // 响应内容 修改数据成功
 });
 });
})
//删除数据
app.delete('/delete', function (req, res) {
 var params = req.query
 var sql = 'delete from userinfo where name= ?'
 var where_value = [params.name];
 // console.log(sql)
 connection.query(sql, where_value, function (err, result) {
 if (err) {
  console.log('删除失败', err.message);
 }
 res.send('删除成功')
 });
})
//关闭连接 
//connection.end();
//监听8080端口
var server = app.listen(8080, function () {
 console.log('server running at 3000 port')
})