-------mongodb------------

使用：http://www.runoob.com/mongodb/mongodb-osx-install.html

********** 数据库和文件的主要区别
1、 数据库有数据库表、行和列的概念，让我们存储操作数据更方便
2、 数据库提供了非常方便的接口，可以让 nodejs、php java .net 很方便的实现增加修改删 除功能。
**********
由于互联网的迅速发展，云计算与 Web2.0。这样大量的交互给数据库提出了更高的性能要
求，传统的数据库(本文泛指 SQL 数据库)，即关系数据库虽然具备良好的事物管理，
但在 处理大量数据 的应用 时很难 在性能 上满足 设计要 求。NoSQL 就是主要为了解决当下大量高并发高要
求的数据 库应用 需求，关系数 据库 具有严 格的参 照性，一致性 ，可用 性，原子性 ，隔离 性等特 点，
   因此会产生一些例如表连接等操作，这样会大大降低系统的性能。而在当前很多应用场景下对性  能的要求 远远强 于传统 数据库 关注的 点，NoSQL 就是为了解决大规模数据与多样数 据种类 等问题，尤其是其中大数据的相关问题。 。
 NoSQL(NoSQL = Not Only SQL )，意即“不仅仅是 SQL”，它指的是非关系型的数据库，是以 key-value 形式存储，和传统的关系型数据库不一样，不一定遵循传统数据库的一些基本要求，比如说遵循SQL 标准ACID 属性、表结构等等。NoSQL 最早被提出是在 20 世纪 80 年代，在当时更多是强调的是与关系 数据库区 别对待 ，最近这些年被提及的更多是强调协助解决大数据等相关问NoSQL 在大数 据时代有自己的意义。
2.2 NoSQL 应用情况介绍
国内的互联网蓬勃发展，不仅涌现出 BAT(百度，阿里巴巴，腾讯)之类的巨头，也带动了整个互联 网行业的发展，大量的创业型公司如春笋般的涌出，在国家层面也提出了“互联网+”和“万众创业”的口 号。更多传统的行业也开始拥抱互联网。但是无论是做所谓的生态平台还是 传统业务的转型，涉及到的业 务是多种多样的。这个时候企业架构师对于应用系统的核心——数据库管理 不仅有传统的 SQL 选项也有了 NoSQL 这种适合特定场景需求的选项。
NoSQL 数据库在以下的这几种情况下比较适用:
1、数据模型比较简单;
2、需要灵活性更强的 IT 系统; 3、对数据库性能要求较高; 4、不需要高度的数据一致性;
5、对于给定 key，比较容易映射复杂值的环境。
2.3 NoSQL 发展现状
国外: Google 的 BigTable 和 Amazon 的 Dynamo 使用的就是 NoSQL 型数据库。
国内:百度、阿里、腾讯、新浪微博、视觉中国、优酷运营数据分析、飞信空间、豆瓣社区等..
3、 什么时候建议使用 NoSql
1、对数据库高并发读写的需求 2、对海量数据的高效率存储和访问的需求 3、对数据库的高可扩展性和高可用性的需求
4、 NoSql 和传统数据库简单对比。 非结构型数据库。没有行、列的概念。用 JSON 来存储数据。
5、 集合就相当于“表 ”，文档就相当于“行”。
 
 ****** MongoDb 介绍
MongoDB 是一个介于关系数据库和非关系数据库之间的产品，是非关系数据库当中功能最丰富，最像 关系数据库的。他支持的数据结构非常松散，是类似 json 的 bson 格式，因此可以存储比较复杂的数据类 型。Mongo 最大的特点是他支持的查询语言非常强大，其语法有点类似于面向对象的查询语言，几乎可以 实现类似关系数据库单表查询的绝大部分功能，而且还支持对数据建立索引。它的特点是高 性能 、易部署 、 易使用 ，存储数据非常 方便 。

**** MongoDb 安装 官网:https://www.mongodb.com/

https://github.com/mongodb/mongo

https://docs.mongodb.com/manual/tutorial/query-documents/

手册:https://docs.mongodb.org/manual/ 注意:部分 win7 系统需要安装补丁，KB2731284。 1. 双击 MongoDB 软件下一步下一步安装；

*************使用 MongoDb

--dbpath 就是选择数据库文档所在的文件夹，就是刚才第一步创建的文件夹。

在缺省情况下创建的索引均不是唯一索引。下面的示例将创建唯一索引，如:

关注输出的如下数值:explain.executionStats.executionTimeMillis

**************nodejs操作mongodb***************

地址：https://doc s.mongodb.com/getting-started/node/introduction/  
https://doc s.mongodb.com/getting-started/node/query/

  需要引包: 

******连接数据库******

https://blog.csdn.net/cckevincyh/article/details/79719261

https://www.runoob.com/nodejs/nodejs-mongodb.html

/*
*nodejs使用ongodb的
*/
var router = function(app){
  var fs =require('fs');
  var http=require('https');
  var mysql=require('mysql');//调用mysql模块
  var request = require('request');
  var url = require('url');
  var querystring = require('querystring');
  var bodyParser     =         require("body-parser");
  var urlencodedParser = bodyParser.urlencoded({ extended: false })
  app.get('/get',function (req, res) {

// app.post('/one',urlencodedParser,function (req, res) {

/***text/html,application/json", @"text/json", @"text/javascript",
*@"text/html",@"text/xml", @"text/plain; charset=utf-8",image/png
*/
// res.writeHeader(200, {'Content-Type':'image/png;charset=UTF-8'});
res.writeHeader(200, {'Content-Type':'text/html;charset=UTF-8'});
// res.writeHeader(200, {'Content-Type':'application/json;charset=UTF-8'});

// //************建立数据库连接
//  /*要在 MongoDB 中创建一个数据库，首先我们需要创建一个 MongoClient 对象，然后配置好指定的 URL 和 端口号。
// // 如果数据库不存在，MongoDB 将创建数据库并建立连接。*/
// // var MongoClient = require('mongodb').MongoClient;
// // var url = "mongodb://localhost:27017/userInfo";
// // MongoClient.connect(url, function(err, db) {
// //   if (err) throw err;
// //   console.log("数据库已创建!");
// //   res.end("数据库创建成功");
// //   db.close();
// // });



//********** 创建集合
var MongoClient = require('mongodb').MongoClient;
var url = 'mongodb://localhost:27017/userInfo';
MongoClient.connect(url, function (err, db) {
    if (err) throw err;
    console.log('数据库已创建');
    var dbase = db.db("userInfo");
    dbase.createCollection('product', function (err, res) {
        if (err) throw err;
        console.log("创建product集合成功!");
        db.close();
    });
});





//**************插入单条数据
var MongoClient = require('mongodb').MongoClient;
var url = "mongodb://localhost:27017/userInfo";

MongoClient.connect(url, function(err, db) {
    if (err) throw err;
    var dbo = db.db("userInfo");
    var myobj = { name: "lambo001", url: "www.aichi010.com" };
    dbo.collection("user").insertOne(myobj, function(err, res) {
        if (err) throw err;
        console.log("插入成功");
        db.close();
    });
});

 //***********插入多条数据
 var MongoClient = require('mongodb').MongoClient;
var url = "mongodb://localhost:27017/";

MongoClient.connect(url, function(err, db) {
    if (err) throw err;
    var dbo = db.db("userInfo");
    var myobj =  [
        { name: 'lambo002', url: 'lambo', type: 'cn'},
        { name: 'lambo003', url: 'lambo', type: 'en'},
        { name: 'lambo004', url: 'lambo', type: 'en'}
       ];
    dbo.collection("user").insertMany(myobj, function(err, res) {
        if (err) throw err;
        console.log("插入的文档数量为: " + res.insertedCount);//res.insertedCount 为插入的条数
        db.close();
    });
});

//*********更新一条数据
var MongoClient = require('mongodb').MongoClient;
var url = "mongodb://localhost:27017/";

MongoClient.connect(url, function(err, db) {
    if (err) throw err;
    var dbo = db.db("userInfo");
    var whereStr = {"name":'lambo'};  // 查询条件
    var updateStr = {$set: { "url" : "lambo新" }};//更新后的值
    dbo.collection("user").updateOne(whereStr, updateStr, function(err, res) {
        if (err) throw err;
        console.log("更新成功");
        db.close();
    });
});


//********更新多条数据

var MongoClient = require('mongodb').MongoClient;
var url = "mongodb://localhost:27017/";

MongoClient.connect(url, function(err, db) {
    if (err) throw err;
    var dbo = db.db("userInfo");
    var whereStr = {"type":'en'};  // 查询条件
    var updateStr = {$set: { "url" : "更新多条数据" }};
    dbo.collection("user").updateMany(whereStr, updateStr, function(err, res) {
        if (err) throw err;
         console.log(res.result.nModified + " 条文档被更新");//result.nModified 为更新的条数。
        db.close();
    });
});


//**********删除一条数据
var MongoClient = require('mongodb').MongoClient;
var url = "mongodb://localhost:27017/";

MongoClient.connect(url, function(err, db) {
    if (err) throw err;
    var dbo = db.db("userInfo");
    var whereStr = {"name":'lambo'};  // 查询条件
    dbo.collection("user").deleteOne(whereStr, function(err, obj) {
        if (err) throw err;
        console.log("删除成功");
        db.close();
    });
});


//***********删除多条数据
var MongoClient = require('mongodb').MongoClient;
var url = "mongodb://localhost:27017/";

MongoClient.connect(url, function(err, db) {
    if (err) throw err;
    var dbo = db.db("userInfo");
    var whereStr = { type: "en" };  // 查询条件
    dbo.collection("user").deleteMany(whereStr, function(err, obj) {
        if (err) throw err;
        console.log(obj.result.n + " 条文档被删除");//obj.result.n 删除的条数。
        db.close();
    });
});


//***************查询数据
// 可以使用 find() 来查找数据, find() 可以返回匹配条件的所有数据。 如果未指定条件，find() 返回集合中的所有数据。
var MongoClient = require('mongodb').MongoClient;
var url = "mongodb://localhost:27017/";

MongoClient.connect(url, function(err, db) {
    if (err) throw err;
    var dbo = db.db("userInfo");
    dbo.collection("user"). find({}).toArray(function(err, result) { // 返回集合中所有数据
        if (err) throw err;
        console.log(result);
        db.close();
    });
});


//*********查询指定条件的数据
var MongoClient = require('mongodb').MongoClient;
var url = "mongodb://localhost:27017/";

MongoClient.connect(url, function(err, db) {
    if (err) throw err;
    var dbo = db.db("userInfo");
     var whereStr = {"name":'lambo002'};  // 查询条件
    dbo.collection("user").find(whereStr).toArray(function(err, result) {
        if (err) throw err;
        console.log(result);
        db.close();
    });
});



//**********排序


// 排序 使用 sort() 方法，该方法接受一个参数，规定是升序(1)还是降序(-1)。
// 例如：
// { type: 1 }  // 按 type 字段升序
// { type: -1 } // 按 type 字段降序
// 按 type 升序排列:

var MongoClient = require('mongodb').MongoClient;
var url = "mongodb://localhost:27017/";

MongoClient.connect(url, function(err, db) {
    if (err) throw err;
    var dbo = db.db("userInfo");
    var mysort = { type: 1 };
    dbo.collection("user").find().sort(mysort).toArray(function(err, result) {
        if (err) throw err;
        console.log(result);
        db.close();
    });
});


//*************查询分页
// 如果要设置指定的返回条数可以使用 limit() 方法，该方法只接受一个参数，指定了返回的条数。
// limit()：读取两条数据
var MongoClient = require('mongodb').MongoClient;
var url = "mongodb://localhost:27017/";

MongoClient.connect(url, function(err, db) {
    if (err) throw err;
    var dbo = db.db("userInfo");
    dbo.collection("user").find().limit(2).toArray(function(err, result) {
        if (err) throw err;
        console.log(result);
        db.close();
  });
});


//********如果要指定跳过的条数，可以使用 skip() 方法。
// skip(): 跳过前面两条数据，读取两条数据
var MongoClient = require('mongodb').MongoClient;
var url = "mongodb://localhost:27017/";

MongoClient.connect(url, function(err, db) {
    if (err) throw err;
    var dbo = db.db("userInfo");
    dbo.collection("user").find().skip(2).limit(2).toArray(function(err, result) {
        if (err) throw err;
        console.log(result);
        db.close();
  });
});


// 连接操作
// mongoDB 不是一个关系型数据库，但我们可以使用 $lookup 来实现左连接。
// 例如我们有两个集合数据分别为：
// 集合1：orders
// [
//   { _id: 1, product_id: 154, status: 1 }
// ]
// 集合2：products
// [
//   { _id: 154, name: '笔记本电脑' },
//   { _id: 155, name: '耳机' },
//   { _id: 156, name: '台式电脑' }
// ]
// $lookup 实现左连接
var MongoClient = require('mongodb').MongoClient;
var url = "mongodb://127.0.0.1:27017/";

MongoClient.connect(url, function(err, db) {
    if (err) throw err;
    var dbo = db.db("userInfo");
    dbo.collection('orders').aggregate([
        { $lookup:
            {
                from: 'products',           // 右集合
                localField: 'product_id',   // 左集合 join字段
                foreignField: '_id',        // 右集合 join字段
                as: 'orderdetails'          // 新生成字段（类型array）
            }
        }
    ], function(err, res) {
    if (err) throw err;
    console.log(JSON.stringify(res));
    db.close();
});


//**********删除集合
// 我们可以使用 drop() 方法来删除集合：
var MongoClient = require('mongodb').MongoClient;
var url = "mongodb://localhost:27017/";

MongoClient.connect(url, function(err, db) {
    if (err) throw err;
    var dbo = db.db("userInfo");
    // 删除 test 集合
    dbo.collection("user").drop(function(err, delOK) {  // 执行成功 delOK 返回 true，否则返回 false
        if (err) throw err;
        if (delOK) console.log("集合已删除");
        db.close();
    });
});





});

}
exports.router = router;

****mongodb的封装***

var MongoClient=require('mongodb').MongoClient;


var DbUrl='mongodb://localhost:27017/productmanage';  /*连接数据库*/


var ObjectID = require('mongodb').ObjectID;//用自增长_id去数据库中查找数据，必须要用new ObjectID（_id）,要不然在数据库中查不到

function  __connectDb(callback){ MongoClient.connect(DbUrl,function(err,db){
        if(err){

            console.log('数据库连接失败');
            return;
        }
        //增加 修改 删除
          callback(db);

    })
}


//暴露 ObjectID
exports.ObjectID=ObjectID;

//数据库查找
/*
 Db.find('user',{},function(err,data){
    data数据
})


 */
exports.find=function(collectionname,json,callback){
    __connectDb(function(db){
        var result=db.collection(collectionname).find(json);
   result.toArray(function(error,data){
            db.close();/*关闭数据库连接*/
            callback(error,data);/*拿到数据执行回调函数*/
        })
    })
}


//增加数据
exports.insert=function(collectionname,json,callback){
    __connectDb(function(db){
   db.collection(collectionname).insertOne(json,function(error,data){
            callback(error,data);
        })
    })
}


//增加数据
exports.update=function(collectionname,json1,json2,callback){
    __connectDb(function(db){
        db.collection(collectionname).updateOne(json1,{$set:json2},function(error,data){


            callback(error,data);
        })
    })
}


//删除数据
exports.deleteOne=function(collectionname,json,callback){
    __connectDb(function(db){
        db.collection(collectionname).deleteOne(json,function(error,data){
            callback(error,data);
        })
    })
}

*******************************MAC 上使用mogodb************************

下载配置mongoldb:https://www.jianshu.com/p/59fab73f4d91

MongoDB 下载地址： https://www.mongodb.com/download-center?jmp=nav#community

安装mongodb方法一：官网直接下载；

方法二：原理上就是直接下载，终端命令吧。

1，下载
curl -O https://fastdl.mongodb.org/osx/mongodb-osx-x86_64-3.2.1.tgz  
2，解压
tar -zxvf mongodb-osx-x86_64-3.2.1.tgz  
3，复制解压之后的文件夹去mongodb run的目录
mkdir -p mongodb  
cp -R -n mongodb-osx-x86_64-3.2.1/ mongodb  
4，下一步就是配置了，确保二进制文件的位置在路径变量中,md的二进制文件都在bin/里面，

export PATH=<mongodb-install-directory>/bin:$PATH  

--------配置数据存储路径和log日志

 打开浏览器，输入localhost:27017,会出现“It looks like you are trying to access MongoDB over HTTP on the native driver port.” 这样一行文字

，我们可以把 MongoDB 的二进制命令文件目录（安装目录/bin）添加到 PATH 路径中：

export PATH=/usr/local/mongodb/bin:$PATH

-------配置数据存储路径和og日志

mongod.conf可以的配置内容：https://www.jianshu.com/p/f9f1454f251f

****mongod.conf中的内容：

#mongodb config file

dbpath=/Users/wofu/Desktop/mongodb

logpath=/Users/wofu/Desktop/mongod.log

logappend = true

port = 27017

版权声明：本文来源CSDN，感谢博主原创文章，遵循 CC 4.0 by-sa 版权协议，转载请附上原文出处链接和本声明。
原文链接：https://blog.csdn.net/u011146511/article/details/79080219
站方申明：本站部分内容来自社区用户分享，若涉及侵权，请联系站方删除。