Node连接mysql数据库方法介绍

前端之家收集整理的这篇文章主要介绍了Node连接mysql数据库方法介绍前端之家小编觉得挺不错的,现在分享给大家,也给大家做个参考。

使用Node做Web开发,基本上都是使用Nosql数据库,最频繁的就是使用MongoDB了,自己做了一些简单的Web开发,为了降低学习门槛,一直使用MysqL来做数据库。这里简单介绍一下连接MysqL数据库的方式,希望能帮助到其他人。

MysqL

使用上述命令安装完MysqL的模块后,就可以直接使用了,官网的DOCS里一个简单的例子如下就可以入门了。

MysqL = require('MysqL'); var connection = MysqL.createConnection({ host: 'localhost',user: 'me',password : 'secret',database : 'my_db' }); connection.connect(); connection.query('SELECT 1 + 1 AS solution',function(err,rows,fields) { if (err) throw err; console.log('The solution is: ',rows[0].solution); }); connection.end();

很简单的一个例子,从上面的例子可以得出:使用createConnection(option)方法创建一个连接对象,然后连接对象的connect()方法创建连接,最后使用query()方法执行sql语句,返回结果作为回调函数的参数rows返回,rows为数组类型。

1. 连接

创建连接对象,需要传入连接数据库的一些连接参数,也就是createConnection(option)里的option,option是一个对象,以键值对的形式传入createConnection()方法里。上例列举出了最基本的参数:

还有其他的参数,可以查询下官方DOCS,这里不一一列举了,初期学习上面这些参数就足以。

2. 关闭

关闭一个连接使用end()方法,end()方法提供一个回调函数,如下:

这是建议使用的方法,end()方法会等待连接回调完成后才关闭连接。官方还提供了另外一种方法destroy()方法,这个方法直接关闭连接,不会等待回调完成。

举个简单的例子:

MysqL = require('MysqL'); var option = require('./connect.js').option; var conn = MysqL.createConnection(option); conn.query('select * from message',fields){ if(!err){ console.log(rows); } }); conn.end(function(err){ console.log('end a connection'); });

最终结果会是:先打印完SELECT数据表结果后,再打印end a connection。而如果你将关闭方法换成conn.destroy();,那么你就别想返回任何结果了,因为还没等回调结束就已经终止连接了。

3. 连接池

连接池的原理是一开始就给你创建多个连接对象放在一个“池子”里,用的时候取一个,用完了放回“池子”里,在一定程度上是有利于节省系统开销的,因为连接对象是在最开始的时候就创建好了,使用的时候不再需要系统开销去创建数据库连接对象。官方DOCS介绍了连接方法

MysqL = require('MysqL'); var pool = MysqL.createPool({ connectionLimit : 10,host : 'example.org',user : 'bob',password : 'secret',database : 'my_db' }); pool.query('SELECT 1 + 1 AS solution',rows[0].solution); });

创建连接池的方法是createPool(option),option里多了一个参数connectionLimit指的是一次性在连接池里创建多少个连接对象,默认10个。如果你想共享一个连接对象,可以使用下面方法进行连接;

MysqL = require('MysqL'); var pool = MysqL.createPool({ host : 'example.org',user : 'bob',database : 'my_db' }); pool.getConnection(function(err,connection) { // Use the connection connection.query( 'SELECT something FROM soMetable',rows) { // And done with the connection. connection.release(); // Don't use the connection here,it has been returned to the pool. });

// Use the connection
connection.query( 'SELECT something2 FROM soMetable2',it has been returned to the pool.
});
});

使用一个连接对象执行两次query()函数

4. 示例1

使用基本的连接方式来连接数据库,分别定义数据连接以及关闭的function,如下示例:

数据库连接与关闭 var MysqL = require('MysqL'); var config = require('./config.json'); // 将数据库连接参数写入MysqL对象,即config.MysqL var connCount = 0; // 统计目前未关闭的连接 exports.getConn = function(){ connCount ++; console.log('............................OPEN a connection,has '+ connCount + ' connection.'); return MysqL.createConnection(config.MysqL); }; exports.endConn = function(conn){ conn.end(function(err){ if(!err){ connCount --; console.log('.........................CLOSE a connection,has '+ connCount + ' connection.'); } }); };

然后给个使用数据库的示例,

查询用户信息 var connect = require('./connect.js'); // 引入数据连接方法 exports.getUser = function(username,callback){ var connection = connect.getConn(); var sql = 'select * from user where username = "' + username + '"'; connection.query(sql,fields){ callback(err,fields); }); connect.endConn(connection); }

5. 示例2

使用数据库连接池,同样先创建数据库连接池的方法,如下两种方式:

MysqL = require('MysqL'); var config = require('./config.json'); var pool = MysqL.createPool(config.MysqL);

exports.querysql = function(sql,callback){
pool.query(sql,fields);
});
}

方法 var MysqL = require('MysqL'); var config = require('./config.json'); var pool = MysqL.createPool(config.MysqL);

exports.querysql = function(sql,callback){
pool.getConnection(function(err,conn){
conn.query(sql,fields){
callback(err,fields);
conn.release(); // 不要忘了释放
});
});
}

使用的时候,直接使用querysql方法即可,如下:

查询用户信息 var connect = require('./connect.js'); exports.getUser = function(username,callback){ var sql = 'select * from user where username = "' + username + '"'; connect.querysql(sql,fields); }); };

官方是推荐使用连接池的方式进行连接的,但是,是直接使用pool.query()连接还是pool.getConnection()的方法来连接,官方并没有介绍其优劣,我简单做了个测试,貌似这两种方式并没有多大的区别,也就没再研究,有知道的烦请告知,谢了~

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持编程之家。

原文链接:https://www.f2er.com/nodejs/41956.html

猜你在找的Node.js相关文章