node连接mysql创建简单服务

// 引入express
const express = require('express')
// 引入mysql
var mysql = require('mysql')
const app = express()
let port = 3030 // 设置服务端允许的端口号

// 设置一个时间转化函数
function DateToString(date) {
  if (!date) return null
  let year = date.getFullYear()
  let month = date.getMonth() + 1
  let day = date.getDate()
  return year + '-' + month + '-' + day
}

// 设置允许跨域请求
app.all('*', function (req, res, next) {
  res.header('Access-Control-Allow-Origin', '*')
  res.header('Access-Control-Allow-Headers', 'Origin, X-Requested-With, Content-Type, Accept')
  res.header('Access-Control-Allow-Methods', 'PUT,POST,GET,DELETE,OPTIONS')
  res.header('X-Powered-By', ' 3.2.1')
  res.header('Content-Type', 'application/json;charset=utf-8')
  next()
})

// 配置mysql相关参数
var connection = mysql.createConnection({
  host: 'localhost',
  user: 'root',
  password: '123456',
  port: '3306',
  database: 'todos',
})

// 建立数据库连接
connection.connect()

// 新增数据（这里为了方便使用get请求，通过路径传参获取参数）
app.get('/addTodo', function (req, res, next) {
  let post = req.query
  if (!post.title || !post.done) {
    res.json({
      message: '请传入参数',
    })
    return
  }
  // 新增数据
  const addSql = 'insert into todoList(title,done,date) values(?,?,?)'
  const addSqlParams = [post.title, post.done, DateToString(new Date())]
  connection.query(addSql, addSqlParams, function (err, result) {
    if (err) {
      res.json({
        code: 400,
        message: err.message,
        result: err.message,
      })
      console.log('[INSERT ERROR] - ', err.message)
      return
    }
    res.json({
      code: 200,
      message: '新增成功',
      result,
    })
  })
})

// 通过id获取数据
app.get('/getTodo', function (req, res, next) {
  const { id } = req.query
  console.log(req)
  let querySql = ''
  if (!id) {
    querySql = 'select * from todoList'
  } else {
    querySql = 'select * from todoList where id = ?'
  }
  connection.query(querySql, id, function (err, result) {
    console.log(id, '获取数据')
    if (err) {
      res.json({
        code: 400,
        message: err.message,
        result: err.message,
      })
      console.log('[INSERT ERROR] - ', err.message)
      return
    }
    res.json({
      code: 200,
      message: '查询成功',
      result,
    })
  })
})

// 分页获取数据
app.get('/getTodo/:current/:pageSize', function (req, res, next) {
  // 从请求路径中获取第几页和每页的条数
  const { current, pageSize } = req.params
  let total = 0
  /**
   * current = 1, pageSize = 10 就是取当前数据的第一个十条；current = 2表示取第二个十条。
   * sql语句的offset,limit，offset偏移量，就是从数据的第几条开始，limit数量，就是取多少条数据
   *    select * from todos (where id = ?) limit 10 offset 0。
   *    这句话就是从所有数据中取前10条，以此类推，offset包括这条数据，0的话包括第0条就是第一条，注意的是where条件要放在之前，不然会报错
   */
  let offset = Number(current - 1) * Number(pageSize)
  let querySql = `select * from todoList limit ${pageSize} offset ${offset}`
  // 获取total值
  connection.query('select count(*) from todolist', function (err, results) {
    if (err) {
      console.log(err)
      return
    }
    total = results[0]['count(*)']
  })
  connection.query(querySql, function (err, result) {
    if (err) {
      res.json({
        code: 400,
        message: err.message,
        result: err.message,
      })
      console.log('[INSERT ERROR] - ', err.message)
      return
    }
    res.json({
      code: 200,
      message: '查询成功',
      result: { data: result, pageSize: pageSize, pageNum: current, total },
    })
  })
})

// 修改数据
// var modSql = 'UPDATE todoList SET title = ?, done = ? WHERE id = ?'
// var modSqlParams = ['拉粑粑', 1, 4]

// connection.query(modSql, modSqlParams, function (err, result) {
//   if (err) {
//     console.log('[UPDATE ERROR] - ', err.message)
//     return
//   }
//   console.log('UPDATE affectedRows', result.affectedRows)
// })

// 删除数据
app.get('/delTodo', function (req, res, next) {
  const { id } = req.query
  let delSql = ''
  if (!id) {
    res.json({
      message: '请传入参数',
    })
    return
  } else {
    delSql = 'delete from todoList where id = ?'
  }
  connection.query(delSql, id, function (err, result) {
    if (err) {
      res.json({
        code: 400,
        message: err.message,
        data: err.message,
      })
      console.log('[INSERT ERROR] - ', err.message)
      return
    }
    res.send({
      code: 200,
      message: '删除成功',
      result,
    })
  })
})

app.listen(port, function () {
  console.log(`服务运行在${port}端口`)
})