本章节我们将为大家介绍如何使用 Node.js 来连接 MySQL，并对数据库进行操作。 如果你还没有 MySQL 的基本知识，可以参考我们的教程：MySQL 教程。 本教程使用到的 Websites 表 SQL 文件：websites.sql。

安装驱动

本教程使用了淘宝定制的 cnpm 命令进行安装：

  1. cnpm install mysql

连接数据库

在以下实例中根据你的实际配置修改数据库用户名、及密码及数据库名：

  1. var mysql = require('mysql')
  3. var connection = mysql.createConnection({
  4.   host: 'localhost',
  5.   user: 'root',
  6.   password: 'Qwer@1234',
  7.   database: 'test'
  8. })
  10. connection.connect()
  12. connection.query('SELECT 9 + 6 AS solution', function (error, results, fields) {
  13.   if (error) throw error;
  14.   console.log('The solution is: ', results[0].solution)
  15.   connection.end()
  16. })
  18. /* 
  19. The solution is: 15 
  20. */

数据库连接参数说明：

参数 描述
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 )

在进行数据库操作前，你需要将本站提供的 Websites 表 SQL 文件websites.sql导入到你的 MySQL 数据库中。
本教程测试的 MySQL 用户名为 root，密码为 123456，数据库为 test，你需要根据自己配置情况修改。

创建数据库和创建表

  1. #创建数据库
  2. create database 数据库名 charset=utf8;
  3. #使用数据库
  4. use 数据库名;
  5. #创建表
  6. create table goods(字段 类型 约束);
  10. create database test charset=utf8;
  11. use test;
  12. create table goods(
  13.     id int unsigned primary key auto_increment not null,
  14.     name varchar(150) not null,
  15.     cate_name varchar(40) not null,
  16.     brand_name varchar(40) not null,
  17.     price decimal(10,3) not null default 0,
  18.     is_show bit not null default 1,
  19.     is_saleoff bit not null default 0
  20. );
  22. insert into goods values(0,'r510vc 15.6英寸笔记本','笔记本','华硕','3399',default,default); 
  23. insert into goods values(0,'y400n 14.0英寸笔记本电脑','笔记本','联想','4999',default,default);
  24. insert into goods values(0,'g150th 15.6英寸游戏本','游戏本','雷神','8499',default,default);

查询数据

将上面我们提供的 SQL 文件导入数据库后，执行以下代码即可查询出数据：

  1. var mysql = require('mysql')
  3. var connection = mysql.createConnection({
  4.   host: 'localhost',
  5.   user: 'root',
  6.   password: 'Qwer@1234',
  7.   port: '3306',
  8.   database: 'test'
  9. })
  11. connection.connect()
  13. var sql = 'SELECT * FROM goods'
  14. //查
  15. connection.query(sql, function (err, result) {
  16.   if (err) { return console.log('[SELECT ERROR] - ', err.message) }
  18.   console.log('--------------------------SELECT----------------------------')
  19.   console.log(result)
  20.   console.log('------------------------------------------------------------\n\n')
  21. })
  23. connection.end()

插入数据

我们可以向数据表 websties 插入数据：

  1. var mysql = require('mysql')
  3. var connection = mysql.createConnection({
  4.   host: 'localhost',
  5.   user: 'root',
  6.   password: 'Qwer@1234',
  7.   port: '3306',
  8.   database: 'test'
  9. })
  11. connection.connect()
  13. var addSql = 'INSERT INTO goods(id,name,cate_name,brand_name,price,is_show,is_saleoff) VALUES(0,?,?,?,?,?,?)'
  14. var addSqlParams = ['mig1th 15.6英寸游戏本', '轻薄本', '华为', 8499, false, false]
  16. //增
  17. connection.query(addSql, addSqlParams, function (err, result) {
  18.   if (err) { return console.log('[INSERT ERROR] - ', err.message) }
  19.   console.log('--------------------------INSERT----------------------------')
  20.   //console.log('INSERT ID:',result.insertId)        
  21.   console.log('INSERT ID:', result)
  22.   console.log('-----------------------------------------------------------------\n\n')
  23. })
  25. connection.end()

执行成功后，查看数据表，即可以看到添加的数据

更新数据

我们也可以对数据库的数据进行修改：

  1. var mysql = require('mysql')
  3. var connection = mysql.createConnection({
  4.   host: 'localhost',
  5.   user: 'root',
  6.   password: 'Qwer@1234',
  7.   port: '3306',
  8.   database: 'test'
  9. })
  11. connection.connect()
  13. var modSql = 'UPDATE goods SET brand_name = ? WHERE Id = ?'
  14. var modSqlParams = ['微软surface',  5]
  15. //改
  16. connection.query(modSql, modSqlParams, function (err, result) {
  17.   if (err) { return console.log('[UPDATE ERROR] - ', err.message) }
  18.   console.log('--------------------------UPDATE----------------------------')
  19.   console.log('UPDATE affectedRows', result.affectedRows)
  20.   console.log('-----------------------------------------------------------------\n\n')
  21. })
  23. connection.end()

删除数据

我们可以使用以下代码来删除 id 为 6 的数据:

  1. var mysql = require('mysql')
  3. var connection = mysql.createConnection({
  4.   host: 'localhost',
  5.   user: 'root',
  6.   password: 'Qwer@1234',
  7.   port: '3306',
  8.   database: 'test'
  9. })
  10. connection.connect()
  12. var delSql = 'DELETE FROM goods where id=5'
  13. //删
  14. connection.query(delSql, function (err, result) {
  15.   if (err) { return console.log('[DELETE ERROR] - ', err.message) }
  16.   console.log('--------------------------DELETE----------------------------')
  17.   console.log('DELETE affectedRows', result.affectedRows)
  18.   console.log('-----------------------------------------------------------------\n\n')
  19. })
  21. connection.end()