suchen

Heim >Datenbank >MySQL-Tutorial >用MySQL构建一个工作跟踪流程_MySQL

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

WBOY
WBOYOriginal
2016-05-27 13:45:141157Durchsuche

为了了解在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模块：

<code class="language-npm hljs cmake">npm install mysql</code>

这里写图片描述
?

1.4 最终效果

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

2. 创建程序的逻辑

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

<code class="language-javascript hljs ">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;
} ) ;</code>

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

<code class="language-javascript hljs ">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 ;
        }
    }
} ) ;</code>

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

<code class="language-javascript hljs ">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; ) ;
    }
) ;</code>

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

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

<code class="language-npm hljs cmake">npm install querystring</code>
<code class="language-javascript hljs ">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;</code>
' + '<input name="id" type="hidden" value="' + id + '">' + '<input type="submit" value="' +label+ '">' + '
' ; return html ; } ;

4. 用MySQL添加数据

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

<code class="language-javascript hljs ">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 ) ;
            }
        ) ;
    } ) ;
} ;</code>

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

5. 删除MySQL数据

<code class="language-javascript hljs ">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 ) ;
            }
        ) ;
    } ) ;
} ;</code>

6. 更新MySQL数据

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

<code class="language-javascript hljs ">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 ) ;
            }
        ) ;
    } ) ;
} ;</code>

7. 获取MySQL数据

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

<code class="language-javascript hljs ">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) ;
}</code>

8. 渲染MySQL记录

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

<code class="language-javascript hljs ">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;</code>
' + rows[i].date + ' ' + rows[i].hours + ' ' + rows[i].description + ' ' + exports.workArchiveForm( rows[ i ].id ) + ' ' +exports.workDeleteForm( rows[i].id )+ '
' ; return html ; } ;

9. 渲染HTML表单

<code class="language-javascript hljs ">exports.workFormHtml = function () {
   var html = &#39;</code>
' + '

Date (YYYY-MM-DD):<br> <input name="date" type="text">

' + '

Hours worked:<br> <input name="hours" type="text">

' + '

Description:<br> ' + '<textarea name="description"></textarea>

' + '<input type="submit" value="Add">' + '
' ; return html ; } ; exports.workArchiveForm = function (id) { return exports.actionForm(id, '/archive', 'Archive') ; } ; exports.workDeleteForm = function (id) { return exports.actionForm( id, '/delete', 'Delete' ) ; } ;

10. 试一下

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

<code class="language-node hljs avrasm">node timetrack_server.js</code>

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

Stellungnahme：
Der Inhalt dieses Artikels wird freiwillig von Internetnutzern beigesteuert und das Urheberrecht liegt beim ursprünglichen Autor. Diese Website übernimmt keine entsprechende rechtliche Verantwortung. Wenn Sie Inhalte finden, bei denen der Verdacht eines Plagiats oder einer Rechtsverletzung besteht, wenden Sie sich bitte an admin@php.cn
Vorheriger Artikel：MYSQL企业常用架构与调优经验分享_MySQLNächster Artikel：MYSQL5.7.9开启慢查询日志_MySQL

In Verbindung stehende Artikel

Mehr sehen