深入认识MangoDB在企业中应用(2)

创建数据库并不是必须的操作,数据库与集合只有在第一次插入文档时才会被创建,与对数据的动态处理方式是一致的。简化并加速开发过程,而且有利于动态分配命名空间。如果担心数据库或集合被意外创建,可以开启严格模式

2、插入语法

db.users.insert({username:"smith"}) db.users.save({username:"smith"})

3、查找语法

db.users.find() db.users.count()

4、更新语法

db.users.update({username:"smith"},{$set:{country:"Canada"}}) //把用户名为smith的用户的国家改成Canada db.users.update({username:"smith"},{$unset:{country:1}}) //把用户名为smith的用户的国家字段给移除 db.users.update({username:"jones"},{$set:{favorites:{movies:["casablance","rocky"]}}}) //这里主要体现多值修改,在favorties字段中添加多个值 db.users.update({"favorites.movies":"casablance"},{$addToSet:{favorites.movies:"the maltese"}},false,true) //多项更新

5、删除语法

db.foo.remove() //删除所有数据 db.foo.remove({favorties.cities:"cheyene"}) //根据条件进行删除 db.drop() //删除整个集合

6、索引相关语法

db.numbers.ensureIndex({num:1}) //创建一个升序索引 db.numbers.getIndexes() //获取全部索引

7、基本管理语法

show dbs //查询所有数据库 show collections //显示所有表 db.stats() //显示数据库状态信息 db.numbers.stats() //显示集合表状态信息 db,shutdownServer() //停止数据库 db.help() //获取数据库操作命令 db.foo.help() //获取表操作命令 tab 键 //能自动帮我们补全命令

以上的命令只是简单实例,假设如果你之前没有学习过任何数据库语法,同时开始学sql查询语法和MongoDB 查询语法,你会发现哪一个更简单呢?如果你使用的是java驱动去操作MongoDB,你会发现任何的查询都像Hibernate提供出来的查询方式一样,只要构建好一个查询条件对象,便能轻松查询(接下来会给出示例),博主之前熟悉ES6,所以入手MongoDB js shell完成没问题,也正因为这样简洁,完善的查询机制,深深的爱上了MongoDB。

7、在Java中使用MongoDB

1、使用maven引入jar包

这里引用的是最新的驱动包,提供了一套新的访问连接方式

<dependency> <groupId>org.mongodb</groupId> <artifactId>mongodb-driver-sync</artifactId> <version>3.8.0-beta3</version> </dependency>

2、创建一个访问客户端

MongoClient client = MongoClients.create(“mongodb://10.201.76.94:27017”);

3、获取集合数量

public long count() { MongoClient client = this.getClient(); MongoCollection<Document> collections= client.getDatabase("mongodb_db_name").getCollection("mongodb_collection_name"); return collections.count(); }

4、查询集合

public List<Document> find(Document params,Bson sort,int skip,int limit) { MongoClient client = this.getClient(); MongoCollection<Document> collections= client.getDatabase("mongodb_db_name").getCollection("mongodb_collection_name"); List<Document> list = new ArrayList<Document>(Integer.valueOf(config.getPro("sync_limit"))); collections.find(params).sort(sort).skip(skip).limit(limit).forEach(new Block<Document>() { @Override public void apply(Document document) { list.add(document); } }); return list; }

这里只举例了简单的链接与简单的MongoDB操作,可见其操作的容易性。使用驱动时是基于TCP套接字与MongoDB进行通信的,如果查询结果较多,恰好无法全部放进第一服务器中,将会向服务器发送一个getmore指令获取下一批查询结果。

插入数据到服务器时间,不会等待服务器的响应,驱动会假设写入是成功的,实际是使用客户端生成对象id,但是该行为可以通过配置配置,可以通过安全模式开启,安全模式可以校验服务器端插入的错误。

内容版权声明:除非注明,否则皆为本站原创文章。

转载注明出处:https://www.heiqu.com/b0bf5ac40ef4a7bdcaef8e2a126cc86a.html