【实战】nodejs 必会技能 —— 封装 mysql 数据库连接

本文介绍: 运行中若遇到如下报错，请检查输入信息是否正确（host、port、user、password 等），jdbc 配置中拿到的相关信息尤其是密码很可能是加密后的。若是担心网络问题造成连接失败，可以在连接 reje ct 部分添加定时并回调连接。数据库连接池 pool 可以有效避免频繁连接、断开导致的资源消耗。欢迎留言一起学习探讨。

[mysql – mysql 中文文档翻译 – Bre word 文档集合]：(https://www.b re word.com/mysql js–mysql)

一、准备 工作

安装依赖包：

npm i mysql -s

[mysql – npm]：(https://www.npmjs.com/package/mysql)

二、连接 数据库

const mysql = require("mysql");
const db_config={
    host:"localhost",
    user:"root",
    password:"root",
    port:"3306",
    database:"mydb" 
}
let conn = mysql.createConnection(db_config);

// 连接数据库
conn.connect(err =&gt; {
    if(err) {
        throw err
    } else{
        console.log("连接成功!");
    }
})

// 查询数据库
conn.query("select * from user", (err, res) =&gt; {
    if(err){
        throw err
    }else{
        console.log(res);
        closeMysql(conn);
    }
});

// 关闭数据库
let closeMysql = conn =&gt; {
    conn.end(err =&gt; {
        if(err){
        	throw err
        }else{
            console.log('关闭成功!');
        }
	});
}

运行中若遇到如下报错，请检查输入信息是否正确（h os t、port、user、password 等），jdbc 配置中拿到的相关信息尤其是密码很可能是加密后的

Error: ER_ACCESS_DENIED_ERROR: Access denied for user ‘root‘@‘localhost‘ (using password: YES)

node – MySQL 数据库连接配置项：

h os t：主机地址（默认：localhost）

user：用户名

password：密码

port：端口号（默认：3306）

database：数据库名

charset：连接字符集（默认：‘UTF8_GENERAL_CI’，注意字符集的字母都要大写）

localAddr ess：此IP用于TCP连接（可选）

socketPa th：连接到unix域路径，当使用 h os t 和port 时会被忽略

timezone：时区（默认：‘local’）

connectTimeout：连接超时（默认：不限制；单位：毫秒）

stringifyObjects：是否序列化对象（默认：‘false’ ；与安全相关）

typeCast：是否将列值转化为本地Ja vaScri p t 类型值（默认：true）

queryFormat：自定义 query 语句格式化方法

supportBigNumbers：数据库支持 bi gint或decimal 类型列时，需要设此option为true （默认：false）

bi gNumberStr in gs：supportBigNumbers和bigNumberStr in gs 启用强制 bigint或decimal列以Ja vaScript字符串类型返回（默认：false）

dateStrin gs：强制 timestamp,datetime,data 类型以字符串类型返回，而不是Ja vaScriptDate类型（默认：false）

debug：开启调试（默认：false）

multi pleStatemen ts：是否许一个 query中有多个MySQL语句（默认：false）

flags：用于修改连接标志

ssl：使用 ssl 参数（与 crypto.createCredenitals 参数格式一至）或一个包含ssl 配置文件名称的字符串，目前只捆绑 Amazo n RDS 的配置文件

欢迎关注【程序边界】

三、数据池保持连接 & 公共 方法 封装

数据库连接池 pool 可以有效避免频繁连接、断开导致的资源消耗

1.封装

const mysql = require('mysql')

const db_config = {
	host:"localhost",
	user:"root",
	password:"root",
	port:"3306",
	database:"mydb" 
}

let sqlConnTemp = (sql, params) => {
  return new Promise((resolve, reject) => {
    let conn = mysql.createConnection(db_config)
    let closeMysql = conn => conn.end(err => if(err) throw err )
    conn.connect((err, conn) => {
      err ? reject(err) : conn.query(sql, params, (err, data, fields) => {
        err ? reject(err) : resolve(data)
      })
      closeMysql(conn);
    })
  })
}

let sqlConn = (sql, params) => {
  return new Promise((resolve, reject) => {
  	// 连接池（保持连接）
    const pool = mysql.createPool(db_config)
    pool.getConnection((err, conn)=>{
        err ? reject(err) : conn.query(sql, params, (err, data, fields) => {
	        err ? reject(err) : resolve(data)
      	})
      	conn.release() // 仅释放未关闭
      	// pool.end() // 关闭连接
    })
  })
}

module.exports = { sqlConn，sqlConnTemp }

2.调用

const { sqlConn }= require('./mysql')

sqlConn('select * from user_table where age = ? and sex = ?',[21, 1]).then((data) => {
    console.log(data)
    res.send(data)
}).catch((err) => {
    console.error(err)
    res.send(err)
})

若是担心网络问题造成连接失败，可以在连接reject部分添加定时并回调连接

未完待续。。。欢迎留言一起学习探讨

拓展阅读：

[数据库连接池、sequelize 实现增删改查等操作]：(https://blog.csdn.net/TangJing_/art icle/de tails/121602581)

四、拓展学习

1.mysql 命令行

(1)查看 当前所有数据库：

show database;

(2)使用 指定 数据库：

use DBName;

(3)查看 当前库的所有表：

show tables；

(4)查看其它库的所有表：

show tables from DBName;

(5)创建表：

create table tableName (
	colName dataType;
	colName dataType;
	...
);

(6)查看表结构

desc tableName;

(7)查看 当前 版本

如果没有连接到了 mysql 服务，可以输入以下命令：

# mysql  Ver 8.0.32 for Win64 on x86_64 (MySQL Community Server - GPL)
mysql -V
# 用账号 ODBC，连接上MySQL服务器，默认连接到localhost上的3306端口。
mysql -v
# 仅限 windows 系统（`|`管道符;find命令查找字符串;注意引号）
mysql --help | find "Ver"
# 仅限 linux系统（`|`管道符;grep命令查找字符串）
mysql --help | grep Ver

权限有问题会报错：

ERROR 1045 (28000): Access denied for user 'ODBC'@'localhost' (using password: NO)

如果已经连接到了 mysql 服务，可以输入以下命令：

select version();

在这里插入图片描述
或：

status;

在这里插入图片描述
或：

在这里插入图片描述

2.语法 规范

不区分大小写，但是建议关键字大写，表名、列名小写
每条命令分号结尾
每条命令根据需要，可以进行缩进，或换行
注释
- (1)单行注释：#注释文字
- (2)单行注释：–[空格]注释文字
- (3)多行注释：/* 注释文字

3.mysql 其他

(1)查看自己 数据库文件所在的位置

在mysql文件夹找到 my.ini 文件
使用记事本打开：
Ctrl+F，搜索 datadir ：
如果上面的方式你掌握了，下面来一个终极大招：

show global variables like "%datadir%";

登入后，一行命令直接查出：

在这里插入图片描述
数据库整体搬迁直接迁移目录即可

my.ini

[mysqld]
# 设置3306端口
port=3306
# 设置mysql的安装目录
basedir=D:Program Filesmysql-8.0.19-winx64
# 设置mysql数据库的数据的存放目录
datadir=D:Program Filesmysql-8.0.19-winx64Data
# 允许最大连接数
max_connections=200
# 允许连接失败的次数（防止有人攻击数据库系统）
max_connect_errors=10
# 服务端使用的字符集默认为UTF8
character-set-server=utf8
# 创建新表时将使用的默认存储引擎
default-storage-engine=INNODB
# 默认使用“mysql_native_password”插件认证
default_authentication_plugin=mysql_native_password
sql_mode=STRICT_TRANS_TABLES,NO_ZERO_IN_DATE,NO_ZERO_DATE,ERROR_FOR_DIVISION_BY_ZERO,NO_ENGINE_SUBSTITUTION
[mysql]
# 设置mysql客户端默认字符集
default-character-set=utf8
[client]
# 设置mysql客户端连接服务端时默认使用的端口
port=3306
default-character-set=utf8