nodejs连接mysql数据库

 

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

//npm install mysql
var 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)
        }
      })
    })
  }
}