当前位置: 开发笔记 > 后端 > 正文

用MySQL构建一个工作跟踪流程_MySQL

作者：bakurei_492 | 来源：互联网 | 2017-05-12 16:11

为了了解在Node中如何使用MySQL，我们来看一个需要RDBMS的程序。假设你要创建一个Web程序，用来记录你是如何度过工作日的。这需要记录工作的日期，花在工作上的时间，以及工作完成情况的描述。

为了了解在Node中如何使用MySQL，我们来看一个需要RDBMS的程序。
假设你要创建一个Web程序，用来记录你是如何度过工作日的。这需要记录工作的日期，花在工作上的时间，以及工作完成情况的描述。

1. 系统分析

1.1 系统流程

这个程序会有个表单，用来输入工作的详细信息，如图：
这里写图片描述

? 工作信息输入后，可以被归档或删除，让它不再显示在用来输入更多工作的输入域上方，如图。点击“Archived Work”链接可以把之前归档的工作项全部显示出来。
这里写图片描述

1.2 系统任务

创建程序逻辑创建程序工作所需的辅助函数编写让你可以用MySQL添加、删除、更新和获取数据的函数编写渲染HTML记录和表单的代码

1.3 使用模块

这个程序会用Node内置的http模块实现Web服务器的功能，用一个第三方模块跟MySQL服务器交互。一个名为timetrack的定制模块，它是程序特有的函数，用来在MySQL中存储、修改和获取数据。图5-4是这个程序的概览。
先用下面这条命令安装这个很受欢迎的MySQL Node模块：

npm install mysql

这里写图片描述
?

1.4 最终效果

最终结果如图5-5所示，一个可以用来记录所做工作的简单Web程序，还可以回顾、归档及删除工作记录。
这里写图片描述
?

2. 创建程序的逻辑

接下来需要创建两个文件存放程序逻辑。这个两个文件分别是： timetrack_server.js，用来启动程序； timetrack.js，包含程序相关功能的模块。
先创建timetrack_server.js，把代码清单5-7中的代码放到里面。这段代码包含Node的HTTPAPI，程序特定的逻辑以及MySQL API。根据你的MySQL配置填入host、 user和password这些设定值。

var http = require( &＃39;http&＃39; ) ;
var work = require( &＃39;./lib/timetrack&＃39; ) ;
var mysql = require( &＃39;mysql&＃39; ) ;

var db = mysql.createConnection( {
    host: &＃39;127.0.0.1&＃39;,
    user: &＃39;root&＃39;,
    password: &＃39;root&＃39;,
    database: &＃39;timetrack&＃39;
} ) ;

接下来添加代码清单5-8中的逻辑，定义Web程序的行为。用这个程序可以浏览、添加和删除工作执行记录。此外还可以归档工作记录。被归档的工作记录不再出现在主页面上，但还可以在一个单独的Web页面上浏览。

var server = http.createServer( function (req, res) {
    switch ( req.method ) {
        case &＃39;POST&＃39;: {
            switch ( req.url ) {
                case &＃39;/&＃39;: {
                    work.add( db, req, res ) ;
                    break ;
                }
                case &＃39;/archive&＃39;: {
                    work.archive( db, req, res ) ;
                    break ;
                }
                case &＃39;/delete&＃39;: {
                    work.delete(db, req, res) ;
                    break ;
                }
            }
            break ;
        }

        case &＃39;GET&＃39;: {
            switch ( req.url ) {
                case &＃39;/&＃39;: {
                    work.show( db, res ) ;
                    break ;
                }
                case &＃39;http://blog.csdn.net/archived&＃39;: {
                    work.showArchived( db, res ) ;
                    break ;
                }
            }
            break ;
        }
    }
} ) ;

代码清单5-9是timetrack_server.js中的最后一块代码。这段代码创建了一个数据库表（如果不存在的话），启动HTTP服务器，监听本机的3000端口。所有的node-mysql查询都用query函数执行。

db.query(
    &＃39;create table if not exists work ( &＃39; +
    &＃39;id int(10) not null auto_increment, &＃39; +
    &＃39;hours decimal(5, 2) default 0, &＃39; +
    &＃39;date date, &＃39; +
    &＃39;archived int(1) default 0, &＃39; +
    &＃39;description longtext, &＃39; +
    &＃39;primary key(id) )&＃39;,
    function (err) {
        if (err) throw err ;
        console.log( &＃39;Server started...&＃39; ) ;
        server.listen( 3000, &＃39;127.0.0.1&＃39; ) ;
    }
) ;

3. 创建辅助函数发送HTML，创建表单，接收表单数据

启动程序的文件已经完成，该创建定义程序其他功能的文件了。创建一个名为lib的目录，然后在这个目录下创建文件timetrack.js。把代码清单5-10中的代码放到这个文件中，其中包含Node querystring API，并定义了辅助函数，用来发送Web页面HTML，接收通过表单提交的数据。

npm install querystring

var qs = require( &＃39;querystring&＃39; ) ;

exports.sendHtml = function (res, html) {
    res.setHeader( &＃39;Content-Type&＃39;, &＃39;text/html&＃39; ) ;
    res.setHeader( &＃39;Content-Length&＃39;, Buffer.byteLength( html ) ) ;
    res.end( html ) ;
} ;

exports.parseReceivedData = function (req, cb) {
    var body = &＃39;&＃39; ;
    req.setEncoding( &＃39;utf8&＃39; ) ;
    req.on( &＃39;data&＃39;, function (chunk) {
        body = chunk ;
    } ) ;
    req.on( &＃39;end&＃39;, function () {
        var data = qs.parse( body ) ;
        cb( data ) ;
    } ) ;
} ;

exports.actiOnForm= function (id, path, label) {
    var html = &＃39;

&＃39; + &＃39;&＃39; + &＃39;&＃39; + &＃39; &＃39; ; return html ; } ;

4. 用MySQL添加数据

辅助函数到位了，该编写往MySQL数据库里添加工作记录的代码了。把下面代码清单里的代码添加到timetrack.js中。

exports.add = function (db, req, res) {
    exports.parseReceivedData( req, function (work) {
        db.query(
            &＃39;insert into work( hours, date, description ) &＃39; +
            &＃39;values ( ?, ?, ? )&＃39;,
            [ work.hours, work.date, work.description ],
            function (err) {
                if (err) throw err ;
                exports.show( db, res ) ;
            }
        ) ;
    } ) ;
} ;

注意上面代码中的问号（?），这是用来指明应该把参数放在哪里的占位符。在添加到查询语句中之前， query方法会自动把参数转义，以防遭受到SQL注入攻击。此外还要留意一下query方法的第二个参数，是一串用来替代占位符的值。

5. 删除MySQL数据

exports.delete = function (db, req, res) {
    exports.parseReceivedData(req, function (work) {
        db.query(
            &＃39;delete from work where id = ?&＃39;,
            [work.id],
            function (err) {
                if (err) throw err ;
                exports.show( db, res ) ;
            }
        ) ;
    } ) ;
} ;

6. 更新MySQL数据

为了实现更新工作记录的逻辑，将它标记为已归档，把下面的代码添加到timetrack.js中。

exports.archive = function (db, req, res) {
    exports.parseReceivedData( req, function (work) {
        db.query(
            &＃39;update work set archived = 1 where id = ?&＃39;,
            [work.id],
            function (err) {
                if (err) throw err ;
                exports.show( db, res ) ;
            }
        ) ;
    } ) ;
} ;

7. 获取MySQL数据

添加、删除、更新工作记录的逻辑已经定义好了，现在可以把代码清单5-14中的逻辑添加到到timetrack中，用来获取工作记录数据（归档的或未归档的），从而把它渲染为HTML。在发起查询时传入了一个回调函数，它的参数rows是用来保存返回的查询结果的。

exports.show = function (db, res, showArchived) {
    console.log( &＃39;in show function&＃39; ) ;
    var query = &＃39;select * from work &＃39; +
       &＃39;where archived = ? &＃39; +
       &＃39;order by date desc &＃39; ;
    var archiveValue = (showArchived) ? 1 : 0 ;
    console.log( &＃39;archiveValue:&＃39; + archiveValue ) ;
    db.query(
        query,
        [archiveValue],
        function (err, rows) {
            console.log( rows ) ;
            if (err) throw err ;
            html = (showArchived)
                ? &＃39;&＃39;
                : &＃39;Archived Work
&＃39; ;
            html += exports.workHitlistHtml( rows ) ;
            html += exports.workFormHtml() ;
            exports.sendHtml(res, html) ;
        }
    ) ;
} ;

exports.showArchived = function (db, res) {
    exports.show(db, res, true) ;
}

8. 渲染MySQL记录

将下面代码清单中的代码添加到timetrack.js中。它会将工作记录渲染为HTML。

exports.workHitlistHtml = function (rows) {
    var html = &＃39;&＃39; ;
    for( var i in rows ) {
        html += &＃39;&＃39; ;
        html += &＃39;&＃39;
        html += &＃39;&＃39;
        html += &＃39;&＃39;
        if ( !rows[i].archived ) {
            html += &＃39;&＃39;
        }
        html += &＃39;&＃39; ;
    }
    html += &＃39;

&＃39; + rows[i].date + &＃39; &＃39; + rows[i].hours + &＃39; &＃39; + rows[i].description + &＃39; &＃39; + exports.workArchiveForm( rows[ i ].id ) + &＃39; &＃39; +exports.workDeleteForm( rows[i].id )+ &＃39;

&＃39; ; return html ; } ;

9. 渲染HTML表单

exports.workFormHtml = function () {
   var html = &＃39;

&＃39; + &＃39;

Date (YYYY-MM-DD):

&＃39; + &＃39;

Hours worked:

&＃39; + &＃39;

Description: &＃39; + &＃39;

&＃39; + &＃39;&＃39; + &＃39;

&＃39; ; return html ; } ; exports.workArchiveForm = function (id) { return exports.actionForm(id, &＃39;/archive&＃39;, &＃39;Archive&＃39;) ; } ; exports.workDeleteForm = function (id) { return exports.actionForm( id, &＃39;/delete&＃39;, &＃39;Delete&＃39; ) ; } ;

10. 试一下

程序已经做完了，现在可以运行了。记得先用MySQL管理工具创建名为timetrack的数据库。然后在命令行中用下面的命令启动程序：

node timetrack_server.js

最后在浏览器中访问http://127.0.0.1:3000

推荐阅读

mysql
解决PHP及Web开发中的UTF-8乱码问题

本文详细探讨了在Web开发中常见的UTF-8编码问题及其解决方案，包括HTML页面、PHP脚本、MySQL数据库以及JavaScript和Flash应用中的乱码问题。 ... [详细]

蜡笔小新 2024-11-20 10:58:03
漏洞
软件测试行业深度解析：迈向高薪的必经之路

本文深入探讨了软件测试行业的发展现状及未来趋势，旨在帮助有志于在该领域取得高薪的技术人员明确职业方向和发展路径。 ... [详细]

蜡笔小新 2024-11-21 17:32:44
syslog
CentOS下ProFTPD的安装与配置指南

本文详细介绍在CentOS操作系统上安装和配置ProFTPD服务的方法，包括基本配置、安全设置及高级功能的启用。 ... [详细]

蜡笔小新 2024-11-21 09:45:56
api
H5技术实现经典游戏《贪吃蛇》

本文将分享一个使用HTML5技术实现的经典小游戏——《贪吃蛇》。通过H5技术，我们将探讨如何构建这款游戏的两种主要玩法：积分闯关和无尽模式。 ... [详细]

蜡笔小新 2024-11-21 20:16:59
mysql
Maven + Spring + MyBatis + MySQL 环境搭建与实例解析

本文详细介绍如何使用MySQL数据库进行环境搭建，包括创建数据库表并插入示例数据。随后，逐步指导如何配置Maven项目，整合Spring框架与MyBatis，实现高效的数据访问。 ... [详细]

蜡笔小新 2024-11-21 18:39:23
mysql
我的读书清单（持续更新）

我的读书清单（持续更新）201705311.《一千零一夜》2006（四五年级）2.《中华上下五千年》2008（初一）3.《鲁滨孙漂流记》2008（初二）4.《钢铁是怎样炼成的》20 ... [详细]

蜡笔小新 2024-11-21 13:01:23
mysql
如何将955万数据表的17秒SQL查询优化至300毫秒

本文详细介绍了通过优化SQL查询策略，成功将一张包含955万条记录的财务流水表的查询时间从17秒缩短至300毫秒的方法。文章不仅提供了具体的SQL优化技巧，还深入探讨了背后的数据库原理。 ... [详细]

蜡笔小新 2024-11-21 12:11:54
ci
从CodeIgniter中提取图像处理组件

本指南旨在帮助开发者在未使用CodeIgniter框架的情况下，如何独立使用其强大的图像处理功能，包括图像尺寸调整、创建缩略图、裁剪、旋转及添加水印等。 ... [详细]

蜡笔小新 2024-11-20 19:57:35
ci
Oracle 数据库间通过 DBLink 进行交互的方法

本文介绍了如何在两个Oracle数据库（假设为数据库A和数据库B）之间设置DBLink，以便能够从数据库A中直接访问和操作数据库B中的数据。文章详细描述了创建DBLink前的必要准备步骤以及具体的创建方法。 ... [详细]

蜡笔小新 2024-11-20 11:20:35
node.js
实践指南：使用Express、Create React App与MongoDB搭建React开发环境

本文详细介绍了如何利用Express、Create React App和MongoDB构建一个高效的React应用开发环境，旨在为开发者提供一套完整的解决方案，包括环境搭建、数据模拟及前后端交互。 ... [详细]

蜡笔小新 2024-11-20 10:05:15
node.js
C# 中创建和执行存储过程的方法

本文详细介绍了如何使用 C# 创建和调用 SQL Server 存储过程，包括连接数据库、定义命令类型、设置参数等步骤。 ... [详细]

蜡笔小新 2024-11-19 19:55:59
上传
JavaScript 实现图片文件转Base64编码的方法

本文详细介绍了如何使用JavaScript将用户通过文件输入控件选择的图片文件转换为Base64编码字符串，适用于Web前端开发中图片上传前的预处理。 ... [详细]

蜡笔小新 2024-11-19 12:43:15
mysql
如何在U8系统中连接服务器并获取数据

本文介绍了如何在U8系统中通过不同的方法连接服务器并获取数据，包括使用MySQL客户端连接实例的方法，如非SSL连接和SSL连接，并提供了详细的步骤和注意事项。 ... [详细]

蜡笔小新 2024-11-19 12:08:19
mysql
mysql数据库json类型数据,sql server json数据类型

mysql数据库json类型数据,sql server json数据类型 ... [详细]

蜡笔小新 2024-11-19 11:05:28
mysql
构建用户画像环境：Hive与SparkSQL的高效整合

本文介绍如何通过整合SparkSQL与Hive来构建高效的用户画像环境，提高数据处理速度和查询效率。 ... [详细]

蜡笔小新 2024-11-19 09:44:24