Node.js数据库操作之连接MySQL数据库（一）

介绍

首先说来介绍一下MySQL（非广告）。MySQL是由瑞典的MySQL AB公司开发，后来被甲骨文公司收购。和Oracle一样，MySQL是一个典型的关系型数据库，在百度百科中，把MySQL称为是最好的关系数据库管理系统的之一。

什么是关系型数据库和非关系型数据库

说到关系型数据库，大家肯定就会想到另一个词与之对应，非关系型数据库，那么这两者有什么样的区别呢？

关系型数据库是指采用了关系模型（指的是二维表格模型）来组织数据的数据库，有稳定的表结构；而非关系型数据库中的数据没有关系模型，以对象的形式存放到数据库中，对象之间的关系是通过每个对象的属性来决定的，有点类似于一长串json对象。典型的非关系型数据库有MongoDB和Redis。

MySQL的优缺点

我在项目中使用MySQL作为数据库主要是因为它体积小，速度快，安装完才几百兆，相比于Oracle好几个G它确实“轻”了不少。而且核心程序采用多线程编程，线程也是轻量级的进程，不会占用太多的系统资源，因此一般的中小型网站都选择MySQL数据库，而且最重要的是MySQL几乎是免费的。

但是也正是由于它的轻量级，因此它也“砍掉”了一些功能，比如存储过程等。

使用

这边不再赘述MySQL的安装过程，有需要的读者可以自行百度安装教程。在我们的项目中通过npm install mysql --save来安装依赖。

一个简单的Demo

首先，通过一个小的Demo来测试我们的环境是否已经搭建完毕了：

var mysql = require('mysql');// 连接数据库的配置var connection = mysql.createConnection({ // 主机名称，一般是本机 host: 'localhost', // 数据库的端口号，如果不设置，默认是3306 port: 3306 // 创建数据库时设置用户名 user: 'xyf', // 创建数据库时设置的密码 password: 'xyf', // 创建的数据库 database: 'xyf_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();

运行程序，如果显示“The solution is: 2”，那么整个连接查询是成功的；如果不成功，读者可以根据打印的错误信息提示来修改。

在查询完数据库后，需要通过end()函数将连接关闭。如果连接一直打开，首先会浪费不必要的系统资源；其次，数据库的连接数量有限制，如果达到上限时，会出现后续连接不上报错的情况。

建立数据库连接

要想查询数据库，首先就要跟数据库建立连接，上面的Demo给出了一种建立连接的方式。官方文档还给出了另外两种建立连接的方式。

隐式建立连接

var mysql = require('mysql');var connection = mysql.createConnection(...);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();

我们并没有像Demo中一样使用connect()函数建立连接，而且直接进行了查询，这时候建立连接将会被隐式地调用。

连接回调查询

上面两种连接方式并没有对连接出错的情况进行处理，一旦连接出现错误将带来连锁的多米诺骨牌效应，查询也将会失败，整个程序也会崩溃，为了避免出现这样的情况，我们将查询和关闭连接放到回调函数中。

var mysql = require('mysql');var connection = mysql.createConnection(...);connection.connect(function(err){ if(err){ // 连接失败时的错误处理 console.log(err); return; }  connection.query('SELECT 1 + 1 AS solution', function(err, rows, fields) { if(err){ // 查询失败时的错误处理 console.log(err); return err; } console.log('The solution is: ', rows[0].solution); }); connection.end();});

注：上面的三种建立连接的方式都是可以的，取决于笔者怎么处理连接错误。

关闭连接

打开了数据库的连接我们也需要关闭连接，有两种关闭连接的方式，一种就是我们上面用的end()方法来关闭连接，它可以接收一个回调函数。

connection.end(function(err) { // 这时连接已经被关闭了});

connection.destroy();

var mysql = require('mysql');var pool=mysql.createPool({ host: 'localhost', user: 'xyf', password: 'xyf', port: '3306', database: 'xyf_db', // 最大连接数，默认为10 connectionLimit: 10,})pool.getConnection(function(err,connection){ if(err){ console.log(err); return; } connection.query('SELECT 1 + 1 AS solution',function(err,result){ connection.release(); if(err){ console.log(err); return; } console.log('The solution is: ', result[0].solution); })})

pool.end(function (err) { // 所有连接池中的数据库连接将会被关闭});