nodejs对连接mysql数据库进行封装，使用库实现对数据库的增删查改操作

一、先安装mysql中间件

npm i mysql --save

二、config.json配置库文件

{"host": "localhost","port": "3306","user": "root","password": "root","database": "xiaou"
}

三、封装mysql连接库

const mysql = require('mysql'); //导入mysql中间件
const to = require('../utils/async_to');
const fs = require('fs');
const path = require('path');class DB {constructor({host = 'localhost', //主机名或id地址port = '3306', //端口号user = 'root', //用户名password = 'root', //密码database = 'xiaou' //数据库名} = {}) {this.conn = null;this.config = {host,port,user,password,database};};//1.建立连接connect() {//创建服务器连接，将连接对象，赋值给connthis.conn = mysql.createConnection(this.config);return new Promise((resolve, reject) => {//建立连接this.conn.connect(err => {err ? reject(err) : resolve();});});};//2.对数据库的操作async query(sql, params = []) {//每次执行query都会创建一个新的连接let [err, data] = await to(this.connect());if (err) throw err; //如果发生错误将会抛出return new Promise((resolve, reject) => {this.conn.query(sql, params, (err, data) => {err ? reject(err) : resolve(data);});});};//3.关闭连接close() {this.conn.end();};
}// 读取配置文件信息
let buf = fs.readFileSync(path.join(__dirname, 'config.json'));//导出DB对象的实例
module.exports = new DB(JSON.parse(buf.toString()));

上面库需要搭配async_to使用

let to = (promise) => {return promise.then(data => [null, data]).catch(err => [err, null]);
};module.exports = to;

四、使用方法

因为封装的时候使用了async，所以使用的使用注意搭配async和await使用

const db = require('../db');
const to = require('../../utils/async_to');register();
//注册业务
let register = async(req, res) => {let result = await existUser(username);if (result.length > 0) {res.send(myError('该用户已经存在'));return;}}//判断用户是否存在
async function existUser(username) {//具体使用db.querylet [err, data] = await to(db.query("SELECT member.username FROM member WHERE username=?", username));return err ? err : data;
};

往期精彩文章

leetcode-js刷题记录&数据结构
docker下YApi部署教程-支持swagger数据导入
带你深入理解什么叫js闭包
使用Object.defineProperty进行数据劫持,实现响应式原理-剖析vue2.0
前端性能优化之rel=“prefetch“预/懒加载功能
前端唤起相机的方法H5+JS

nodejs对连接mysql数据库进行封装，使用库实现对数据库的增删查改操作相关推荐

【MySQL】数据库中表的增删查改操作详解
文章目录前言 SQL的通用语法一.表的创建与表的新增语法数据类型的介绍演示二.表的删除语法删整张表的语法删记录的语法演示三.表的查询查询整张表 (一)全列查询 (二)指定列查询 ...
数据库mysql增删查改操作指令
1.基础操作 MySQL服务器->许多数据库->许多数据表-> 指定表头,表头描述了列名和列类型-> 每行为一个记录,每列为一个字段数据类型:tinyint(1字节),sma ...
浅谈IDEA中JBDC的简单增删查改操作及简单封装
连接数据库 1.加载驱动 Class.forName("com.mysql.jdbc.Driver"); 本行代码主要作用是加载(注册)数据库驱动(到JVM) 2.创建链接 Con ...
Mysql库及表的基本概念、增删查改操作以及表的约束、多表联查
什么是数据库? 存储数据的仓库数据库的存储介质:磁盘和内存. 为什么要用数据库不用文件?(数据库与文件进行数据存储的区别) 1.文件存储安全性低 2.数据库对数据进行良好的存储,查询以及管理 3.便 ...
Java操作MongoDB数据库CRUD（增删查改）
Java操作MongoDB数据库CRUD(增删查改) 借助mongo-java-driver包,对MongoDB数据库的集合(DataTable)及文档(BSON对象数据)进行增删查改操作.本文的核心 ...
【MySQL】增删查改CURD（基础版）
目录前言一.新增二.查询 1. 全列查找: 2. 指定列查询 3. 查询字段为表达式(一边查一边计算) 4. 查询:各列之间的计算 5. 起别名 6. 查询时进行去重: 7. 查询结果进行排序: ...
MySQL - 对数据表进行“增删查改”的基础操作 - 细节狂魔
文章目录前文知识点回顾正文 :对数据表进行"增删查改"操作新增操作 - insert 关键字查找语句(基础操作) - select关键字 - 重点!!!!!!!! 1.最基 ...
MySQL表sql语句增删查改_学会这些操作你就不会栓Q(狗头)
目录本章目标 CRUD 新增(Create) 单行数据,全列插入多行插入,指定列插入查询(Retrieve) 修改(Update) 删除(Delete) 本章目标学会MySQL表中的sql语句 ...
利用 MySQLi 将PHP连接到mysql数据库，并采用MySQLi以面向对象的方式对mysql进行增删查改（CRUD）
包括 1.mysqli以面向对象的方式连接数据库 2.以面向对象的方式新增数据库 3.以面向对象的方式新增数据表 4.以面向对象的方式在数据表中增加记录 5.以面向对象的方式在数据表中查找记录 6.以 ...

nodejs对连接mysql数据库进行封装，使用库实现对数据库的增删查改操作

一、先安装mysql中间件

二、config.json配置库文件

三、封装mysql连接库

四、使用方法

往期精彩文章

nodejs对连接mysql数据库进行封装，使用库实现对数据库的增删查改操作相关推荐

最新文章

热门文章