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

 

相关文章