25、Node.js 访问 MySQL 数据库

本章节我们将学习如何使用 Node.js 访问和操作 MySQL 数据库

如果你未了解过 MySQL,可以学习我们的 MySQL 基础教程

本章节我们使用到的 SQL 表文件 node_site.sql

安装驱动

我们使用 mysql 访问 MySQL 数据库

$ npm install mysql

引入 mysql 模块

var driver  = require('mysql');

导入数据

在进行数据库操作前,需要将本站提供的 node_site.sql 表 SQL 文件 node_site.sql 导入到 MySQL 数据库 node_site 中

你可以使用以下命令把 node_site.sql 导入到 node_site 数据库中

$ wget https://ddkk.com/static/media/node_site.sql
$ mysql -uroot -p -e "CREATE DATABASE node_site;"
$ mysql -uroot -p --default-character-set=utf8mb4 node_site < node_site.sql

连接 MySQL 数据库

使用 createConnection 方法可以创建连接
使用 connect() 方法可以连接到 MySQL 数据库

你可以根据你的实际配置修改数据库用户名、及密码及数据库名

main.js

/*
 * filename: main.js
 * author: DDKK.COM 弟弟快看,程序员编程资料站(ddkk.com)
 * Copyright © 2015-2065 ddkk.com. All rights reserved.
*/

var driver      = require('mysql');
var conn        = driver.createConnection({
  host     : 'localhost',
  user     : 'root',
  password : '',
  database : 'node_site'
});

conn.connect();

conn.query('SELECT 3 + 7 AS sumof', function (error, results, fields) {
  if (error) throw error;
  console.log('The sum of 3 + 7 is: ', results[0].sumof);
});

运行以上 Node.js 脚本,输出结果如下

$ node main.js
The sum of 3 + 7 is:  10

createConnection 参数说明

参数 描述
host 主机地址 (默认:localhost)
user 用户名
password 密码
port 端口号 (默认:3306)
database 数据库名
charset 连接字符集(默认:’UTF8_GENERAL_CI’,注意字符集的字母都要大写)
localAddress 此IP用于TCP连接(可选)
socketPath 连接到unix域路径,当使用 host 和 port 时会被忽略
timezone 时区(默认:’local’)
connectTimeout 连接超时(默认:不限制;单位:毫秒)
stringifyObjects 是否序列化对象
typeCast 是否将列值转化为本地JavaScript类型值 (默认:true)
queryFormat 自定义query语句格式化方法
supportBigNumbers 数据库支持bigint或decimal类型列时,需要设此option为true (默认:false)
bigNumberStrings supportBigNumbers和bigNumberStrings启用 强制bigint或decimal列以JavaScript字符串类型返回(默认:false)
dateStrings 强制timestamp,datetime,data类型以字符串类型返回,而不是JavaScript Date类型(默认:false)
debug 开启调试(默认:false)
multipleStatements 是否许一个query中有多个MySQL语句 (默认:false)
flags 用于修改连接标志
ssl 使用ssl参数(与crypto.createCredenitals参数格式一至)或一个包含ssl配置文件名称的字符串,目前只捆绑Amazon RDS的配置文件

更多参数可以参考 : https://github.com/mysqljs/mysql

数据库操作( CURD )

查询数据

connnection.query() 方法可以查询数据

main.js

/*
 * filename: main.js
 * author: DDKK.COM 弟弟快看,程序员编程资料站(ddkk.com)
 * Copyright © 2015-2065 ddkk.com. All rights reserved.
*/

var driver      = require('mysql');
var conn        = driver.createConnection({
  host     : 'localhost',
  user     : 'root',
  password : '',
  database : 'node_site'
});

conn.connect();

var  sql = 'SELECT * FROM node_site';

conn.query(sql,function (err, result) {
        if(err){
          console.log('[SELECT ERROR] - ',err.message);
          return;
        }

       console.log('---------------------SELECT------------------');
       console.log(result);
       console.log('---------------------------------------------\n\n');  
});

conn.end();

运行以上 Node.js 脚本,输出结果如下

$ node main.js
--------------------------SELECT----------------------------
[ RowDataPacket {
    id: 1,
    name: 'Google',
    url: 'https://www.google.cm/',
    alexa: 1,
    country: 'USA' },
  RowDataPacket {
    id: 2,
    name: '淘宝',
    url: 'https://www.taobao.com/',
    alexa: 13,
    country: 'CN' },
  RowDataPacket {
    id: 3,
    name: '腾讯网',
    url: 'http://www.qq.com',
    alexa: 9,
    country: 'CN' },
  RowDataPacket {
    id: 4,
    name: '微博',
    url: 'http://weibo.com/',
    alexa: 20,
    country: 'CN' },
  RowDataPacket {
    id: 5,
    name: 'Facebook',
    url: 'https://www.facebook.com/',
    alexa: 3,
    country: 'USA' } ]
------------------------------------------------------------

插入数据

connnection.query() 方法可以运行 SQL 语句

main.js

/*
 * filename: main.js
 * author: DDKK.COM 弟弟快看,程序员编程资料站(ddkk.com)
 * Copyright © 2015-2065 ddkk.com. All rights reserved.
*/

var driver      = require('mysql');
var conn        = driver.createConnection({
  host     : 'localhost',
  user     : 'root',
  password : '',
  database : 'node_site'
});

conn.connect();
var  sql = 'INSERT INTO node_site(id,name,url,alexa,country) VALUES(0,?,?,?,?)';
var  addSqlParams = ['网易', 'https://www.163.com','11', 'CN'];

conn.query(sql,addSqlParams,function (err, result) {
        if(err){
         console.log('[INSERT ERROR] - ',err.message);
         return;
        }        

       console.log('----------------INSERT---------------------');        
       console.log('INSERT ID:',result);        
       console.log('-------------------------------------------\n\n');  
});

conn.end();

运行以上 Node.js 脚本,输出结果如下

$ node main.js
------------------INSERT---------------------
INSERT ID: OkPacket {
  fieldCount: 0,
  affectedRows: 1,
  insertId: 6,
  serverStatus: 2,
  warningCount: 0,
  message: '',
  protocol41: true,
  changedRows: 0 }
----------------------------------------------

然后查看 MySQL node_site 数据库,可以看到我们的数据已经添加了

 

更新数据

/*
 * filename: main.js
 * author: DDKK.COM 弟弟快看,程序员编程资料站(ddkk.com)
 * Copyright © 2015-2065 ddkk.com. All rights reserved.
*/

var driver      = require('mysql');
var conn        = driver.createConnection({
  host     : 'localhost',
  user     : 'root',
  password : '',
  database : 'node_site'
});

conn.connect();
var sql = 'UPDATE node_site SET name = ? WHERE id = ?';
var modSqlParams = ['网易新闻',6];

conn.query(sql,modSqlParams,function (err, result) {
   if(err){
         console.log('[UPDATE ERROR] - ',err.message);
         return;
   }        
  console.log('-------------UPDATE----------------------------');
  console.log('UPDATE affectedRows',result.affectedRows);
  console.log('-----------------------------------------------\n\n');
});

conn.end();

运行以上 Node.js 脚本,输出结果如下

$ node main.js
-------------UPDATE----------------------------
UPDATE affectedRows 1
-----------------------------------------------

然后查看 MySQL node_site 数据库,可以看到我们的数据已经变更了

 

删除数据

现在我们删除 id 为 6 的记录 我们可以使用以下代码来删除 id 为 6 的数据

main.js

/*
 * filename: main.js
 * author: DDKK.COM 弟弟快看,程序员编程资料站(ddkk.com)
 * Copyright © 2015-2065 ddkk.com. All rights reserved.
*/

var driver      = require('mysql');
var conn        = driver.createConnection({
  host     : 'localhost',
  user     : 'root',
  password : '',
  database : 'node_site'
});

conn.connect();
var sql = 'DELETE FROM node_site where id = 6';

conn.query(sql,function (err, result) {
        if(err){
          console.log('[DELETE ERROR] - ',err.message);
          return;
        }        

       console.log('-------------DELETE-----------------------');
       console.log('DELETE affectedRows',result.affectedRows);
       console.log('------------------------------------------\n\n');  
});

conn.end();

运行以上 Node.js 脚本,输出结果如下

$ node main.js
-------------DELETE-----------------------
DELETE affectedRows 1
------------------------------------------

然后查看 MySQL node_site 数据库,可以看到 id=6 的记录已经删除了