【Node.js 连接 MySQL】

安装 mysql

$ npm install mysql

连接数据库

var mysql = require('mysql')
var db = mysql.createConnection({
  host: 'localhost',
  user: 'root',
  password: '123456',
  database: 'test',
})

db.connect()

数据库连接参数说明：

参数	描述
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 的配置文件

数据库操作( CURD )

查询数据

var sql = 'SELECT * FROM websites'
//查
db.query(sql, function (err, result) {
  if (err) {
    console.log('[SELECT ERROR] - ', err.message)
    return
  }
})

db.end()

插入数据

// 单条插入
var addSql = 'INSERT INTO websites(Id,name,url,alexa,country) VALUES(0,?,?,?,?)'
var addSqlParams = ['菜鸟工具', 'https://c.runoob.com', '23453', 'CN']
//增
db.query(addSql, addSqlParams, function (err, result) {
  if (err) {
    console.log('[INSERT ERROR] - ', err.message)
    return
  }
})

db.end()

// 多条插入
var addSql = 'INSERT INTO websites(Id,name,url,alexa,country) VALUES ?'
var addSqlParams = [
  ['菜鸟工具', 'https://c.runoob.com', '23453', 'CN'],
  ['菜鸟工具', 'https://c.runoob.com', '23453', 'CN'],
]
//增
db.query(addSql, [addSqlParams], function (err, result) {
  if (err) {
    console.log('[INSERT ERROR] - ', err.message)
    return
  }
})

db.end()

更新数据

var modSql = 'UPDATE websites SET name = ?,url = ? WHERE Id = ?'
var modSqlParams = ['菜鸟移动站', 'https://m.runoob.com', 6]
//改
db.query(modSql, modSqlParams, function (err, result) {
  if (err) {
    console.log('[UPDATE ERROR] - ', err.message)
    return
  }
})

db.end()

删除数据

var delSql = 'DELETE FROM websites where id=6'
//删
db.query(delSql, function (err, result) {
  if (err) {
    console.log('[DELETE ERROR] - ', err.message)
    return
  }
})

db.end()