一、node操作mysql数据库
1) 安装mysql 模块
npm i mysql
node操作数据库需要四个步骤：
// 1 配置连接参数，创建连接
let connection = mysql.createConnection({
host:"localhost",
user:"root",
password:"",
database:"ujiuye"
})
// 2 调用 connect() 尝试连接数据库
connection.connect((err)=>{
if(err){
console.log( "连接失败："+ err.stack );
return;
}
console.log("连接成功"+ connection.threadId );
})
// 3 执行CRUD 操作
// 查询操作
connection.query("select * from 班级",[],(err,results,fields)=>{
// console.log( results);
for(let item of results){
console.log(`班号：${item.班号}，班主任：${item.班主任}，班长：${item.班长}`);
}
})
// 4 关闭数据库连接，释放资源
connection.end();
2)注意， select 操作，成功后返回一个查询结果组成的json。
connection.query("select * from 班级",[],(err,results,fields)=>{
// console.log( results);
for(let item of results){
console.log(`班号：${item.班号}，班主任：${item.班主任}，班长：${item.班长}`);
}
})
3) 插入，修改、删除等操作结果 会返回一个对象：
OkPacket {
fieldCount: 0,
affectedRows: 1,
insertId: 18,
serverStatus: 2,
warningCount: 0,
message: '',
protocol41: true,
changedRows: 0
}
注意，如果参数错误，sql语句可能会成功执行，不会报错，但实际没有实现用户想要的删除效果。因此最好判断 对象中的affectedRows 如果大于0，才能确定确实执行了删除操作。
二、mysql执行数据操作的封装类db.js
1) 封装类的骨架
let mysql = require("mysql");
class Db{
constructor(){
}
// 返回一个链接对象，以备query()使用
initConn(){
}
// 执行数据库的CRUD操作
query(){
}
// 关闭连接，释放资源
close(){
}
}
let db = new Db();
module.exports = db;
2) 将外部配置属性作为模块导入
let mysql = require("mysql");
let dbconfig = require("./dbconfig");
class Db{
constructor({host="localhost",user="root",password="",prot=3306,database=""}){
this.options={
host,
user,
password,
database
}
}
// 返回一个链接对象，以备query()使用
initConn(){
}
// 执行数据库的CRUD操作
query(){
}
// 关闭连接，释放资源
close(){
}
}
let db = new Db(dbconfig);
module.exports = db;
3) 实现query( )方法，因为外部使用时想使用async...await ,因此 query()需要返回一个promise对象
let mysql = require("mysql");
let dbconfig = require("./dbconfig");
class Db{
constructor({host="localhost",user="root",password="",prot=3306,database=""}){
this.options={
host,
user,
password,
database
}
}
// 返回一个链接对象，以备query()使用
initConn(){
}
// 执行数据库的CRUD操作
query(){
this.connection = await this.initConn();
return new Promise((resolve,reject)=>{
this.connection.query(sql,arr,(err,result)=>{
if(!err){
resolve( result)
}else{
reject(err);
}
})
})
}
// 关闭连接，释放资源
close(){
}
}
let db = new Db(dbconfig);
module.exports = db;
4) query方法需要 connection对象， 而 connect() 又是一个异步，因此再次封装到promise中
let mysql = require("mysql");
let dbconfig = require("./dbconfig");
class Db{
constructor({host="localhost",user="root",password="",prot=3306,database=""}){
this.options={
host,
user,
password,
database
}
}
// 返回一个链接对象，以备query()使用
initConn(){
let conn = mysql.createConnection( this.options );
return new Promise((resolve,reject)=>{
conn.connect((err)=>{
if(!err){
resolve( conn )
}else{
reject(err)
}
})
})
}
// 执行数据库的CRUD操作
query(){
this.connection = await this.initConn();
return new Promise((resolve,reject)=>{
this.connection.query(sql,arr,(err,result)=>{
if(!err){
resolve( result)
}else{
reject(err);
}
})
})
}
// 关闭连接，释放资源
close(){
}
}
let db = new Db(dbconfig);
module.exports = db;
5) 实现close()方法。最终的代码：
let mysql = require("mysql");
let dbconfig = require("./dbconfig");
class Db{
constructor({host="localhost",user="root",password="",prot=3306,database=""}){
this.options={
host,
user,
password,
database
};
this.connection = null;
}
// 返回一个链接对象，以备query()使用
initConn(){
let conn = mysql.createConnection( this.options );
return new Promise((resolve,reject)=>{
conn.connect((err)=>{
if(!err){
resolve( conn )
}else{
reject(err)
}
})
})
}
// 执行数据库的CRUD操作
async query(sql,arr=[]){
this.connection = await this.initConn();
return new Promise((resolve,reject)=>{
this.connection.query(sql,arr,(err,result)=>{
if(!err){
resolve( result)
}else{
reject(err);
}
})
})
}
// 关闭连接，释放资源
close(){
this.connection.end();
}
}
let db = new Db(dbconfig);
module.exports = db;
