首页 > 数据库 > MySQL

用mysql + node搭建一个简易工作列表网站

来源：SegmentFault

时间：2023-01-28 16:45:48 365浏览收藏

来到golang学习网的大家，相信都是编程学习爱好者，希望在这里学习数据库相关编程知识。下面本篇文章就来带大家聊聊《用mysql + node搭建一个简易工作列表网站》，介绍一下MySQL、Node.js，希望对大家的知识积累有所帮助，助力实战开发！

初衷

增删改查是web开发最常见的操作，那么接下来这篇文章将演示如何用node + mysql做一个简易的网站。

需要的知识

本教程不涉及express等web框架，但请确保您对node + mysql等有基本了解。

需求分析

本网站共有二个页面，主页和副页。

主页：

如下图，主页最上面是一个查看存档的按钮，点击会进入副页。上半部分是一个表格，有日期，耗时，描述三个字段，每一列有二个操作，可以存档和删除，存档的记录会从主页中消失，而会在副页中显示，点击删除会彻底删除该列。下半部分是一个表单，由用户输入并提交，提交后的记录出现在上半部分的表格中。

副页：

如下图，副页上部是一个表格，有日期，耗时，描述三个字段，每一列只有一个操作，点击删除会彻底删除该列。下部有一个返回按钮，点击会回到主页。

项目目录

在根目录下创建app.js，app.js负责

创建http服务器，页面路由控制，登录数据库

等功能

在根目录下创建lib文件夹，在lib下新建timetrack.js，其负责

解析post请求，与数据库交互（添加，删除，查看，更新），将服务端渲染的html返回到客户端

等功能

安装node的mysql数据库，命令如下：
```
npm install mysql --save
```

最终，目录如下所示：

工具准备

mysql数据库：5.7.22
node版本：10.4.1
workbench：6.3 community

数据库部分

首先，打开workbench，登录进去后，新建一个数据库worklist

新建一个sql tab，输入如下命令，创建一个表，用于存储本项目所涉及的数据。

-- sql脚本
CREATE TABLE IF NOT EXISTS work (
    id INT(10) NOT NULL AUTO_INCREMENT,
    hours DECIMAL(5,2) DEFAULT 0, 
    date DATE, 
    archived INT(1) DEFAULT 0, 
    description LONGTEXT,
    PRIMARY KEY(id));

这样，数据库部分就准备好了。

编码

首先，在app.js中输入如下代码：

let http = require('http')
let work = require('./lib/timetrack')
let mysql = require('mysql')

var db = mysql.createConnection({
  host: '127.0.0.1',
  user: '@your username', // 你的数据库用户名
  password: '@your password',  // 你的数据库密码
  database: 'worklist'
})

var server = http.createServer((req, res) => {
  switch (req.method) {
    case 'POST':
      switch(req.url) {
        case '/':
          work.add(db, req, res)
          break
        case '/archive':
          work.archive(db, req, res)
          break
        case '/delete':
          work.delete(db, req, res)
          break
      }
      break
    case 'GET':
      switch (req.url) {
        case '/':
          work.show(db, res)
          break
        case '/archived':
          work.showArchived(db, res)
          break
      }
      break
  }
})

console.log('Server started...')
server.listen(3000, '127.0.0.1')

接着，在lib目录下的timetrack.js中输入如下代码：

var qs = require('querystring')

// 1 show
exports.show = function (db, res, showArchived) {
  let archiveValue = (showArchived) ? 1 : 0
  db.query(
    'SELECT * FROM work WHERE archived = ? ORDER BY date DESC',
    [archiveValue],
    function (err, rows) {
      if (err) {
        throw err
      }

      if (showArchived) { // 副页
        html = (showArchived) ? '' : '查看存档
'
        html += exports.workHitlistHtml(rows)
        html += '返回'
      } else { // 主页
        html = (showArchived) ? '' : '查看存档
'
        html += exports.workHitlistHtml(rows)
        html += exports.workFormHtml()
      }

      exports.sendHtml(res, html)
    }
  )
}

// 显示上半部分--列表
exports.workHitlistHtml = function (rows) {
  var html = '

' for(var i in rows) { html += '' html += '' html += '' html += '' if (!rows[i].archived) { html += '' } html += '' html += '' } html += '

' + rows[i].date + '

' + rows[i].hours + '

' + rows[i].description + '

' + exports.workArchiveForm(rows[i].id) + '

' + exports.workDeleteForm(rows[i].id) + '

' return html } // 显示下半部分--提交 exports.workFormHtml = function () { var html = '' return html } // 返回到浏览器 exports.sendHtml = function (res, html) { res.setHeader('Content-Type', 'text/html; charset=UTF-8') res.setHeader('Content-Length', Buffer.byteLength(html)) res.end(html) } // 渲染二个操作 -- 存档和删除 exports.workArchiveForm = function (id) { return exports.actionForm(id, '/archive', '存档') } exports.workDeleteForm = function (id) { return exports.actionForm(id, '/delete', '删除') } exports.actionForm = function (id, path, label) { var html = '' return html } // 2 add exports.add = function (db, req, res) { exports.parseReceivedData(req, function(work) { db.query( 'INSERT INTO work (hours, date, description) VALUES (?, ?, ?)', [work.hours, work.date, work.description], function (err) { if (err) throw err exports.show(db, res) } ) }) } // 解析post请求 exports.parseReceivedData = function (req, cb) { var body = '' req.setEncoding('utf8') req.on('data', chunk => { body += chunk }) req.on('end', () => { var data = qs.parse(body) cb(data) }) } // 3 存档 exports.archive = function (db, req, res) { exports.parseReceivedData(req, function(work) { db.query( "UPDATE work SET archived = 1 WHERE id = ?", [work.id], function (err) { if (err) throw err exports.show(db, res) } ) }) } // 4 删除 exports.delete = function (db, req, res) { exports.parseReceivedData(req, function (work) { db.query( "DELETE FROM work WHERE id = ?", [work.id], function (err) { if (err) throw err exports.show(db, res) } ) }) } // 5 查看存档 exports.showArchived = function (db, res) { exports.show(db, res, true) }