安装

yarn add mysql -S

使用

创建 mysql.js 文件夹

/*导入模块*/
const mysql = require('mysql');
​
/*创建一个数据库连接*/
const db = mysql.createPool({
  host: '', /* 地址*/
  port: "3306", /* 端口号*/
  user: 'root', /* 用户名*/
  password: "Gongjian_93692", /* 密码*/
  database: 'tencemtim' /*数据库名称*/
});
​
/*连接状态监听器*/
db.getConnection((err, connection) => {
  if(err) {
    console.log("连接失败")
    console.log(err);
  }else{
    console.log("连接成功")
  }
})
​
/*查询数据*/
/*SHOW * FROM users;*/
const queryDB = (sql)=>{
  return new Promise((resolve,reject)=>{
    db.query(
      sql,
      function(err, data) {
        if(err){
          reject({
            code:102,
            error:err
          })
        }else{
          resolve({
            code:101,
            data:data
          })
        }
      }
    );
  })
}
​
/*增加数据*/
/*INSERT INTO users SET ?*/
const addDB = (sql,data)=>{
  return new Promise((resolve,reject)=>{
    db.query(sql, data, (err, data) => {
      if (err) {
        reject({
          code:102,
          error:err
        })
      } else {
        resolve({
          code:101,
          data:data
        })
      }
    });
  })
}
​
/* 修改数据 */
/* 'UPDATE users SET ? WHERE id = ?' */
const reviseDB = (sql)=>{
  return new Promise((resolve,reject)=>{
    db.query(sql, [data], (error, data) => {
      if(error){
        reject(
          {
            code:102,
            error:error
          }
        )
      }else{
        resolve(
          {
            code:101,
            data:data
          }
        )
      }
    });
  })
}
​
module.exports = {
  queryDB,
  addDB,
  reviseDB
};
​
​

使用方式直接引入即可.

const { addDB, queryDB } = require('../util/mysql');

疑问: 上面这种直接引入的方式，不会让 node 重复去连接数据库。

方法调用示例

/*查询：*/
db.query('select * from users');
​
/* 插入：*/
db.query('INSERT INTO `users`(`id`,`name`,`age`, `password`) VALUES (?,?,?,?)',[null,"kerwin",100,"123456"]);
​
/* 更新：*/
db.query(`UPDATE users SET name = ? ,age=? WHERE id = ?`,["xiaoming2",20,1])
​
/* 删除：*/
db.query(`DELETE FROM users WHERE id=?`,[1])