nodejs连接mysql数据库 - noob_dong

 

首先安装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)
        }
      })
    })
  }
}