标签：nodejs cti name roo eject 表格 mongod code his
首先安装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 cti name roo eject 表格 mongod code his
原文地址：https://www.cnblogs.com/diligent-noob/p/12904586.html
