nodejs连接mysql数据库

首先安装mysql 数据库 [就跟 Mongodb一样需要下载]

//npm install mysqlvar mysql = require(‘mysql‘);//需要事先在mysql中创建一个数据库 同样创建一个表格 //但在 mongodb中 不需要手动创建 直接在语句中操作
var connection = mysql.createConnection({
  host     : ‘localhost‘,
  user     : ‘root‘,
  password : ‘123456‘,
  database : ‘test‘
});connection.connect(function(err,data){　　if(err){　　　　throw err　　}else{//连接成功后输出相应的数据　　　　console.log(data)　　}});//查询mysql所有 数据
connection.query(‘SELECT * FROM users‘, function (error, results, fields) {  　　if (error) throw error;
　　//这是对传过来的数据的处理   　　let data = JSON.stringify(results);	　　let jsondata = JSON.parse(data);	　　console.log(jsondata)});

下面是 node连接 mongodb数据库封装的函数

// 封装一些 链接数据库的方法
var mongodb = require(‘mongodb‘);

module.exports = class ConnectdataBase {
  conDatabase(){
    let mongoClient = mongodb.MongoClient;
    let url="mongodb://localhost:27017/";
    return new Promise ((resolve,reject)=>{
      mongoClient.connect(url,{  useUnifiedTopology: true },function(err,client){
        if(err){
          console.log(‘数据库连接失败‘,err)
          reject(err)
        }else {
            console.log(‘connect successfully!!!‘)
        }
        //引入数据库如果没有该数据库创建一个
        var dbname = client.db(‘blog‘)
        resolve(dbname)
      })
    })
  };
  //插入数据 
  async insert(data){
    let dbo= await this.conDatabase();
    return new Promise ((resolve,reject)=>{
      //创建一个新的集合 一个存储users 一个存储blog
      dbo.collection(‘users‘).insertOne(data,function(err,res){
        resolve(res.result.n)
      })
    })
  };
  //查找数据
  async findGoal(collectionName){
    let dbo= await this.conDatabase();
    return new Promise((resolve,reject)=>{
      dbo.collection(collectionName).find({}).toArray(function(err,res){
        if(err){
          reject(err)
        }else{
          resolve(res)
        }
      })
    })
  }
}