mongodb

程序员文章站 2024-01-22 21:40:16

...

1.mongodb简介

MongoDB 是一个介于关系数据库和非关系数据库之间的产品，是非关系数据库当中功能最丰富，最像关系数据库的。它支持的数据结构非常松散，是类似 json 的 bjson（Binary JSON）格式，因此可以存储比较复杂的数据类型。MongoDB 最大的特点是支持的查询语言非常强大，其语法有点类似于面向对象的查询语言，几乎可以实现类似关系数据库单表查询的绝大部分功能，而且还支持对数据建立索引。

传统的关系数据库一般由数据库（DataBase）、表（Table）、记录（Record）三个层次概念组成，MongoDB 是由数据库（DataBase）、集合（Collection）、文档对象（Document）三个层次组成。MongoDB 对应关系型数据库里的表，但是集合中没有列、行和关系概念，这体现了模式*的特点。

MongoDB 中的一条记录就是一个文档，是一个数据结构，由字段和值对组成。MongoDB 文档与 JSON 对象类似。字段的值有可能包括其他文档、数组及文档数组。

MongoDB 适合对大量或者无固定格式的数据进行存储，如日志、缓存等。对事物支持较弱，不适用复杂的多文档（多表）的级联查询。

2.linux平台安装mongodb

2.1下载安装

MongoDB 提供了 linux 各发行版本 64 位的安装包，你可以在官网下载安装包。
Mongodb官网下载

我使用的是centos7，因此下载的是RHEL 6 linux版本。

将下载安装包解压，放在/usr/local文件路径下，并修改名字为mongodb

tar -zxvf (压缩包)
mv （解压后的文件） /usr/local/mongodb

MongoDB 的可执行文件位于 bin 目录下，赋予权限，并将其添加到 PATH 路径中：

chmod -R 755 /usr/local/mongodb/bin

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

2.2创建mongodb相关数据文件目录

我们在mongodb的安装目录下创建一个data目录统一相关文件

数据文件
创建db子文件夹存放mongodb数据库文件

cd /usr/local/mongodb
mkdir data
cd data
mkdir db

日志文件

mkdir /log

dbpath = /usr/local/mongodb/data/db #数据文件存放目录
logpath = /usr/local/mongodb/data/log/logs #日志文件存放目录
logappend=ture    #日志以拼接的形式
port = 27017  #端口
fork = true  #以守护程序的方式启用，即在后台运行
bind_ip=0.0.0.0 #很重要，  运行远程连接

权限

chmod -R 777 /usr/local/mongodb/data

2.3运行

到bin目录下

./mongod -f mongodb.conf

这里说明一下：/data/db 是 MongoDB 默认的启动的数据库路径(–dbpath)。因为我们写了配置文件mongodb.conf，-f mongodb.conf 用指定的配置启动。
此处也可以不用配置文件启动直接用./mongod，但是data目录要直接创建在根目录下（/data/db）就不会有问题。

2.4连接

bin目录下：

./mongo

3.mongodb数据库基本使用

3.1创建数据库

创建数据库语法：

use database_name

如果数据库不存在，则创建一个，新创建的数据库要显示出来，需要添加一条数据。

查看所有数据库：

show dbs

MongoDB 中默认的数据库为 test，如果你没有创建新的数据库，集合将存放在 test 数据库中。
实例
mongodb

3.2创建集合

MongoDB 中使用 createCollection() 方法来创建集合。

db.createCollection(name, options)

参数说明：

name: 要创建的集合名称
options: 可选参数, 指定有关内存大小及索引的选项
options 可以是如下参数：

字段	类型	描述
capped	布尔	（可选）如果为 true，则创建固定集合。固定集合是指有着固定大小的集合，当达到最大值时，它会自动覆盖最早的文档。当该值为 true 时，必须指定 size 参数。
autoIndexId	布尔	（可选）如为 true，自动在 _id 字段创建索引。默认为 false。
size	数值	（可选）为固定集合指定一个最大值（以字节计）。如果 capped 为 true，也需要指定该字段。
max	数值	（可选）指定固定集合中包含文档的最大数量。

在插入文档时，MongoDB 首先检查固定集合的 size 字段，然后检查 max 字段。
一些实例：

use demo  
db.createCollection("colldemo")  //默认配置 创建集合
show collections    //查看已有集合

db.createCollection("newcoll", { capped : true, autoIndexId : true, size : 
   6142800, max : 10000 } )   //带关键参数的集合

一般情况下，不需要手动创建集合。插入文档的时候，mongodb会自动创建集合。

3.3插入文档

文档的数据结构和JSON基本一样。
所有存储在集合中的数据都是BSON格式。
BSON是一种类json的一种二进制形式的存储格式,简称Binary JSON。

MongoDB 使用 insert() 或 save() 方法向集合中插入文档，语法如下：

db.COLLECTION_NAME.insert(document)

实例：

>db.colldemo.insert({title: 'MongoDB', 
    description: 'Nosql ',
    tags: ['mongodb', 'database', 'NoSQL'],
    likes: 100
})

以上实例中 colldemo是我们的集合名(不是数据库的名字)，如果该集合不在该数据库中， MongoDB 会自动创建该集合并插入文档。

查看已插入文档：

db.colldemo.find()

mongodb
_id：标识，可以用来修改文档

我们也可以将数据定义为一个变量，如下所示：

document=({title: 'MongoDB', 
    description: 'MongoDB 是一个 Nosql 数据库',
    tags: ['mongodb', 'database', 'NoSQL'],
    likes: 100
})
db.colldemo.insert(document)

插入文档你也可以使用 db.col.save(document) 命令。如果不指定 _id 字段 save() 方法类似于 insert() 方法。如果指定 _id 字段，则会更新该 _id 的数据。

3.4更新文档

MongoDB 使用 update() 和 save() 方法来更新集合中的文档。接下来让我们详细来看下两个函数的应用及其区别。

3.4.1update()

update() 方法用于更新已存在的文档。语法格式如下：

db.collection.update(
   <query>,
   <update>,
   {
     upsert: <boolean>,
     multi: <boolean>,
     writeConcern: <document>
   }
)

参数说明：

query : update的查询条件，类似sql update查询内where后面的。
update : update的对象和一些更新的操作符（如 $,$ inc…）等，也可以理解为sql update查询内set后面的
upsert : 可选，这个参数的意思是，如果不存在update的记录，是否插入objNew,true为插入，默认是false，不插入。
multi : 可选，mongodb 默认是false,只更新找到的第一条记录，如果这个参数为true,就把按条件查出来多条记录全部更新。
writeConcern :可选，抛出异常的级别。

后面介绍$有关的条件操作符

我们更新前面添加的数据

db.colldemo.update({‘title’:’MongoDB 教程’},{$set:{‘title’:’Learn MongoDB’}})

mongodb

可以看到第一条数据标题(title)由原来的 “mongodb 教程” 更新为了 “Learn mongodb “。

如果你要修改多条相同的文档，则需要设置 multi 参数为 true。

db.col.update({‘title’:’MongoDB 教程’},{$set:{‘title’:’MongoDB’}},{multi:true})

3.4.2save()

save() 方法通过传入的文档来替换已有文档。语法格式如下：

db.collection.save(
   <document>,
   {
     writeConcern: <document>
   }
)

参数说明：

document : 文档数据。
writeConcern :可选，抛出异常的级别。

mongodb3.2版本后提供的更新集合文档的方法

db.collection.updateOne() 向指定集合更新单个文档
db.collection.updateMany() 向指定集合更新多个文档

3.5 删除

3.5.1删除数据库

use newbase
db.dropDatabase()

3.5.2删除集合

db.collection.drop()

3.5.3删除文档

MongoDB remove()函数是用来移除集合中的数据。

MongoDB数据更新可以使用update()函数。在执行remove()函数前先执行find()命令来判断执行的条件是否正确，这是一个比较好的习惯。
语法

remove() 方法的基本语法格式如下所示：

db.collection.remove(
   <query>,
   <justOne>
)

如果你的 MongoDB 是 2.6 版本以后的，语法格式如下：

db.collection.remove(
   <query>,
   {
     justOne: <boolean>,
     writeConcern: <document>
   }
)

参数说明：

query :（可选）删除的文档的条件。
justOne : （可选）如果设为 true 或 1，则只删除一个文档。
writeConcern :（可选）抛出异常的级别。

如果你想删除所有数据，可以使用以下方式（类似常规 SQL 的 truncate 命令）：

db.col.remove({})

3.5.4delete

remove() 方法已经过时了，现在官方推荐使用 deleteOne() 和 deleteMany() 方法。

如删除集合下全部文档：

db.inventory.deleteMany({})

删除 status 等于 A 的全部文档：

db.inventory.deleteMany({ status : “A” })

删除 status 等于 D 的一个文档：

db.inventory.deleteOne( { status: “D” } )

3.6条件操作符

条件操作符用于比较两个表达式并从mongoDB集合中获取数据。

MongoDB中条件操作符有：

(>) 大于 - $gt
(<) 小于 - $lt
(>=) 大于等于 - $gte
(<= ) 小于等于 - $lte

如果你想获取 “col” 集合中 “likes” 大于 100 的数据，你可以使用以下命令：

db.col.find({“likes” : {$gt : 100}})

一些操作符的简写说明

$gt -------- greater than  >
$gte --------- gt equal  >=
$lt -------- less than  <
$lte --------- lt equal  <=
$ne ----------- not equal  !=
$eq  --------  equal  =

3.7type 操作符

$type操作符是基于BSON类型来检索集合中匹配的数据类型，并返回结果。

MongoDB 中可以使用的类型如下表所示：
mongodb

3.8limit()和skip()

如果你需要在MongoDB中读取指定数量的数据记录，可以使用MongoDB的Limit方法，limit()方法接受一个数字参数，该参数指定从MongoDB中读取的记录条数。

db.COLLECTION_NAME.find().limit(NUMBER)

我们除了可以使用limit()方法来读取指定数量的数据外，还可以使用skip()方法来跳过指定数量的数据，skip方法同样接受一个数字参数作为跳过的记录条数。

语法

db.COLLECTION_NAME.find().limit(NUMBER).skip(NUMBER)

3.9sort()排序

-1为降序

db.COLLECTION_NAME.find().sort({KEY:1})

4.java连接

连接数据库，你需要指定数据库名称，如果指定的数据库不存在，mongo会自动创建数据库。

import com.mongodb.MongoClient;
import com.mongodb.client.MongoDatabase;

public class MongoDBJDBC{
   public static void main( String args[] ){
      try{   
       // 连接到 mongodb 服务
         MongoClient mongoClient = new MongoClient( "localhost" , 27017 );

         // 连接到数据库
         MongoDatabase mongoDatabase = mongoClient.getDatabase("mycol");  
       System.out.println("Connect to database successfully");

      }catch(Exception e){
        System.err.println( e.getClass().getName() + ": " + e.getMessage() );
     }
   }
}

有用户名及密码，可以使用以下方法：

import java.util.ArrayList;  
import java.util.List;  
import com.mongodb.MongoClient;  
import com.mongodb.MongoCredential;  
import com.mongodb.ServerAddress;  
import com.mongodb.client.MongoDatabase;  

public class MongoDBJDBC {  
    public static void main(String[] args){  
        try {  
            //连接到MongoDB服务 如果是远程连接可以替换“localhost”为服务器所在IP地址  
            //ServerAddress()两个参数分别为 服务器地址 和 端口  
            ServerAddress serverAddress = new ServerAddress("localhost",27017);  
            List<ServerAddress> addrs = new ArrayList<ServerAddress>();  
            addrs.add(serverAddress);  

            //MongoCredential.createScramSha1Credential()三个参数分别为 用户名 数据库名称 密码  
            MongoCredential credential = MongoCredential.createScramSha1Credential("username", "databaseName", "password".toCharArray());  
            List<MongoCredential> credentials = new ArrayList<MongoCredential>();  
            credentials.add(credential);  

            //通过连接认证获取MongoDB连接  
            MongoClient mongoClient = new MongoClient(addrs,credentials);  

            //连接到数据库  
            MongoDatabase mongoDatabase = mongoClient.getDatabase("databaseName");  
            System.out.println("Connect to database successfully");  
        } catch (Exception e) {  
            System.err.println( e.getClass().getName() + ": " + e.getMessage() );  
        }  
    }  
}

创建集合

mongoDatabase.createCollection(“test”);

获取集合

MongoCollection collection = mongoDatabase.getCollection(“test”);

插入文档

        MongoCollection<Document> collection = mongoDatabase.getCollection("test");
         Document document = new Document("title", "MongoDB").  
         append("description", "database").  
         append("likes", 100).  
         append("by", "Fly");  
         List<Document> documents = new ArrayList<Document>();  
         documents.add(document);  
         collection.insertMany(documents);

检索所有文档

 MongoCollection<Document> collection = mongoDatabase.getCollection("test");      
         //检索所有文档  
         /** 
         * 1. 获取迭代器FindIterable<Document> 
         * 2. 获取游标MongoCursor<Document> 
         * 3. 通过游标遍历检索出的文档集合 
         * */  
         FindIterable<Document> findIterable = collection.find();  
         MongoCursor<Document> mongoCursor = findIterable.iterator();  
         while(mongoCursor.hasNext()){  
            System.out.println(mongoCursor.next());  
         }

更新文档

 //更新文档   将文档中likes=100的文档修改为likes=200   
         collection.updateMany(Filters.eq("likes", 100), new Document("$set",new Document("likes",200)));  
         //检索查看结果  
         FindIterable<Document> findIterable = collection.find();  
         MongoCursor<Document> mongoCursor = findIterable.iterator();  
         while(mongoCursor.hasNext()){  
            System.out.println(mongoCursor.next());  
         }

删除文档

        //删除符合条件的第一个文档  
         collection.deleteOne(Filters.eq("likes", 200));  
         //删除所有符合条件的文档  
         collection.deleteMany (Filters.eq("likes", 200));  
         //检索查看结果  
         FindIterable<Document> findIterable = collection.find();  
         MongoCursor<Document> mongoCursor = findIterable.iterator();  
         while(mongoCursor.hasNext()){  
           System.out.println(mongoCursor.next());  
         }

上一篇：傅里叶变换和拉普拉斯变换

下一篇： php的查询功能（如何通过查询条件获取相应表的字段）

mongodb

1.mongodb简介

2.linux平台安装mongodb

2.1下载安装

2.2创建mongodb相关数据文件目录

2.3运行

2.4连接

3.mongodb数据库基本使用

3.1创建数据库

3.2创建集合

3.3插入文档

3.4更新文档

3.4.1update()

3.4.2save()

mongodb3.2版本后提供的更新集合文档的方法

3.5 删除

3.5.1删除数据库

3.5.2删除集合

3.5.3删除文档

3.5.4delete

3.6条件操作符

3.7type 操作符

3.8limit()和skip()

3.9sort()排序

4.java连接

MongoDB

MongoDB Connector for Hadoop

mongodb

昊鼎王五：推荐一个mongodb综合管理可视化工具

MongoDB的聚集操作

MongoDB php driver 简要分析

MongoDB一对多关系建模

Centos安装配置mongodb

Spring Batch 读 10 万条记录，写到 MongoDB

MongoDB 索引技巧 #1: 查找好友最新的动态