关于nodejs访问mysql的思考

Posted 段江涛IT

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了关于nodejs访问mysql的思考相关的知识,希望对你有一定的参考价值。

nodejs要访问mysql数据库,首先必须要安装包mysql,命令:npm install mysql。安装成功后的访问数据库代码如下:

var mysql = require(‘mysql‘);
var options = {
    host: ‘172.23.88.107‘,
    port: 3306,
    database: ‘test‘,
    user: ‘root‘,
    password: ‘zdsoft‘
};

var pool = mysql.createPool(options);

pool.getConnection(function (err, conn) {
    if (err) {
        console.log(err);//打印错误消息
    } else {
        conn.query("select * from student", null, function (err, results, fields) {
            //释放连接
            conn.release();

            if (err) {
                console.log(err);
            } else {
                console.log(results);//成功,打印结果集
            }
        })
    }
});

 

ok,上面的代码经过测试是没有任何问题的,但是现在就有个问题了,我们每次访问数据库都写这么大一篇感觉太累了,于是我们想把公共的部分提取出来创建一个类,文件名为:sqlHelper.js。由于数据库访问是异步访问的,因此我们不能直接通过返回return的方式,因此就必须要使用回调函数,sqlHelper.js的代码如下:

var mysql = require(‘mysql‘);
var options = {
    host: ‘172.23.88.107‘,
    port: 3306,
    database: ‘test‘,
    user: ‘root‘,
    password: ‘zdsoft‘
};

var pool = mysql.createPool(options);

exports.query = function (sql, vals, fn) {
    pool.getConnection(function (err, conn) {
        if (err) {
            fn(new Error(err));
        } else {
            conn.query(sql, null, function (err, results, fields) {
                //释放连接
                conn.release();

                if (err) {
                    fn(new Error(err));
                } else {
                    fn(null, results, fields);
                }
            })
        }
    });
}

 

这样,我们在调用的时候直接传入fn这个回调函数即可,调用方法如下:

var mysql = require(‘./lib/sqlHelper.js‘);//sqlHelper.js文件在lib文件夹下面

var result = mysql.query("select * from student", null, function (err, results, fields) {
    if (results) {
        for (let index = 0; index < results.length; index++) {
            console.log(results[index].name);
        }
    } else {
        console.log("err,msg:" + err);
    }
});

 

自此,我们也算是大功告成了。

================================================分割线===========================================================

然而,我们还有另外一种实现方式,就是通过Promise这个对象,通过Promise对象我们可以像编写同步程序一样去编写异步代码,从而不用去无限次的嵌套回调函数,sqlHelper.js修改如下:

var mysql = require(‘mysql‘);
var options = {
    host: ‘172.23.88.107‘,
    port: 3306,
    database: ‘test‘,
    user: ‘root‘,
    password: ‘zdsoft‘
};

var pool = mysql.createPool(options);

exports.query = function (sql) {
    return new Promise(function (resolve, reject) {
        pool.getConnection(function (err, conn) {
            if (err) {
                reject(err);//让状态变为已失效,并把错误消息传递回去
            } else {
                conn.query(sql, null, function (err, results, fields) {
                    //释放连接
                    conn.release();

                    if (err) {
                        reject(err);
                    } else {
                        resolve(results, fields);//让状态变为已成功,并把成功数据传递回去
                    }
                })
            }
        });
    });
}

 

调用方法修改如下:

var mysql = require(‘./lib/sqlHelper.js‘);//sqlHelper.js文件在lib文件夹下面

var promise = mysql.query("select * from student");
promise.then(function (results, fields) {
    for (let index = 0; index < results.length; index++) {
        console.log(results[index].name);
    }
}, function (err) {
    console.log(err);
});

 

可以看到,我们已经没有使用回调函数了。

以上是关于关于nodejs访问mysql的思考的主要内容,如果未能解决你的问题,请参考以下文章

关于线程任务的一些思考

拒绝用户访问(NodeJS 和 MySQL)

nodejs常用代码片段

关于mysql驱动版本报错解决,Cause: com.mysql.jdbc.exceptions.jdbc4Unknown system variable ‘query_cache_size(代码片段

从运行在 Linux 上的 nodejs 通过 *** 访问 Windows 服务器上的数据库

使用 NodeJS 和 JSDOM/jQuery 从代码片段构建 PHP 页面