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)
        }
      })
    })
  }
}

 

nodejs连接mysql数据库

上一篇:[GYCTF2020]Ezsqli


下一篇:12c多租户管理五(修改pdb打开模式)