MongoDB 3.0 速上手教程（JAVA）

最近做项目想用一下NoSQL数据库，由于项目需要保存大量的json数据，我就选了MongoDB作为我的数据库。

最新版为3.0 下载安装都很容易，今天按照教程一步一步实现了增删改查等工作，本文将把要用到的代码都贴上来而且都做好中文注释方便大家阅读。

过程中发现两处不能使用教程中的代码实现的地方，经过查资料已经用另外的方法实现了，不知道是不是叫承重的代码出错了还是什么原因，如果有知道的朋友请留言告诉我，多谢~

 

官方教程链接：http://mongodb.github.io/mongo-java-driver/3.0/driver/getting-started/

 

如果不用maven附件中提供了已经下好的java驱动

 

package com.zhongli.TwitterGetter.app;

import java.util.*;

import org.bson.Document;
import org.bson.conversions.Bson;

import com.mongodb.BasicDBObject;
import com.mongodb.Block;
import com.mongodb.MongoClient;
import com.mongodb.client.*;
import com.mongodb.client.model.BulkWriteOptions;
import com.mongodb.client.model.DeleteOneModel;
import com.mongodb.client.model.InsertOneModel;
import com.mongodb.client.model.ReplaceOneModel;
import com.mongodb.client.model.UpdateOneModel;
import com.mongodb.client.result.DeleteResult;
import com.mongodb.client.result.UpdateResult;

import static com.mongodb.client.model.Filters.*;

/**
 * 程序入口
 * 
 * @author John
 *
 */
public class testmain {
	public static void main(String[] args) {
		testmain tm = new testmain();
		tm.test();
	}

	/**
	 * test
	 */
	private void test() {
		// 获取链接
		MongoClient mongoClient = new MongoClient("localhost", 27017);
		// 获取数据库
		MongoDatabase database = mongoClient.getDatabase("mydb");
		// 进入某个文档集
		MongoCollection<Document> collection = database.getCollection("test");

		/********************** 数据插入 ****************************/
		// // 创建新文档
		// Document doc = new Document("name", "MongoDB")
		// .append("type", "database").append("count", 1)
		// .append("info", new Document("x", 203).append("y", 102));
		// // 将文档插入文档集合
		// collection.insertOne(doc);
		//
		// // 创建一个包含多个文档的列表
		// List<Document> documents = new ArrayList<Document>();
		// for (int i = 0; i < 100; i++) {
		// documents.add(new Document("i", i));
		// }
		// // 向文档中插入列表
		// collection.insertMany(documents);

		/***************** 数据读取 ****************************************/
		// // 显示集合中的文档的数量
		// System.out.println(collection.count());
		//
		// // 查询集合中的第一个文档
		// Document myDoc = collection.find().first();
		// System.out.println(myDoc.toJson());
		//
		// //获取集合中的全部文档
		// MongoCursor<Document> cursor = collection.find().iterator();
		// try {
		// while (cursor.hasNext()) {
		// System.out.println(cursor.next().toJson());
		// }
		// } finally {
		// cursor.close();
		// }

		// //获取全部文档的另一种方法
		// for (Document cur : collection.find()) {
		// System.out.println(cur.toJson());
		// }

		// // 根据条件获取某分文档 eq:==
		// Document myDoc = collection.find(eq("i", 71)).first();
		// System.out.println(myDoc.toJson());

		// 通过查询语句一次性获取多个数据
		// Block<Document> printBlock = new Block<Document>() {
		// @Override
		// public void apply(final Document document) {
		// System.out.println(document.toJson());
		// }
		// };
		// 获得所有大于50的
		// collection.find(gt("i", 50)).forEach(printBlock);
		// 大于50 小于 100
		// collection.find(and(gt("i", 50), lte("i", 100))).forEach(printBlock);

		// 对输出文档进行排序,-1为递减，1为递增
		// 官方文档的例子有误：http://mongodb.github.io/mongo-java-driver/3.0/driver/getting-started/quick-tour/#sorting-documents
		// Document myDoc = collection.find(exists("i"))
		// .sort(new BasicDBObject("i", -1)).first();
		// System.out.println(myDoc.toJson());

		// 选择性输出结果中的元素，0为不显示，1为显示
		// 官方文档中的例子又不能用：http://mongodb.github.io/mongo-java-driver/3.0/driver/getting-started/quick-tour/#projecting-fields
		// BasicDBObject exclude = new BasicDBObject();
		// exclude.append("_id", 0);
		// // exclude.append("count", 0);
		// exclude.append("name", 1);
		// exclude.append("info", 1);
		// Document myDoc = collection.find().projection(exclude).first();
		// System.out.println(myDoc.toJson());

		/************************* 修改数据库中数据 *************************************/

		// 修改时的参数：
		// $inc 对指定的元素加
		// $mul 乘
		// $rename 修改元素名称
		// $setOnInsert 如果以前没有这个元素则增加这个元素，否则不作任何更改
		// $set 修改制定元素的值
		// $unset 移除特定的元素
		// $min 如果原始数据更大则不修改，否则修改为指定的值
		// $max 与$min相反
		// $currentDate 修改为目前的时间

		// //修改第一个符合条件的数据
		// $set 为修改
		// collection.updateOne(eq("i", 10), new Document("$set", new
		// Document("i", 110)));
		// // 获取全部文档,可以看到以前10的地方变成了110
		// for (Document cur : collection.find()) {
		// System.out.println(cur.toJson());
		// }

		// 批量修改数据并且返回修改的结果，讲所有小于100的结果都加100
		// UpdateResult updateResult = collection.updateMany(lt("i", 100),
		// new Document("$inc", new Document("i", 100)));
		// // 显示发生变化的行数
		// System.out.println(updateResult.getModifiedCount());
		// // 获取全部文档,可以看到除了刚才修改的110其他的全为了100
		// for (Document cur : collection.find()) {
		// System.out.println(cur.toJson());
		// }

		/************************** 删除数据 *****************************/
		// 删除第一个符合条件的数据
		// collection.deleteOne(eq("i", 110));
		// // 获取全部文档,可以看到没有110这个数了
		// for (Document cur : collection.find()) {
		// System.out.println(cur.toJson());
		// }

		// 删除所有符合条件的数据，并且返回结果
		// DeleteResult deleteResult = collection.deleteMany(gte("i", 100));
		// // 输出删除的行数
		// System.out.println(deleteResult.getDeletedCount());
		// // 获取全部文档,所有i>=100的数据都没了
		// for (Document cur : collection.find()) {
		// System.out.println(cur.toJson());
		// }
		/*************************** 程序块，一次执行多条语句 ********************************/
		// 按照语句先后顺序执行
		// collection.bulkWrite(Arrays.asList(new InsertOneModel<>(new Document(
		// "_id", 4)), new InsertOneModel<>(new Document("_id", 5)),
		// new InsertOneModel<>(new Document("_id", 6)),
		// new UpdateOneModel<>(new Document("_id", 1), new Document(
		// "$set", new Document("x", 2))), new DeleteOneModel<>(
		// new Document("_id", 2)),
		// new ReplaceOneModel<>(new Document("_id", 3), new Document(
		// "_id", 3).append("x", 4))));
		// // 获取全部文档
		// for (Document cur : collection.find()) {
		// System.out.println(cur.toJson());
		// }

		// 不按照语句先后顺序执行
		// collection.bulkWrite(Arrays.asList(new InsertOneModel<>(new Document(
		// "_id", 4)), new InsertOneModel<>(new Document("_id", 5)),
		// new InsertOneModel<>(new Document("_id", 6)),
		// new UpdateOneModel<>(new Document("_id", 1), new Document(
		// "$set", new Document("x", 2))), new DeleteOneModel<>(
		// new Document("_id", 2)),
		// new ReplaceOneModel<>(new Document("_id", 3), new Document(
		// "_id", 3).append("x", 4))), new BulkWriteOptions()
		// .ordered(false));
		// 获取全部文档
		// for (Document cur : collection.find()) {
		// System.out.println(cur.toJson());
		// }
		
		
		// 关闭数据库连接
		mongoClient.close();

	}

}

 

评论

3 楼 God一冰魄 2016-08-18  

jcs130 写道

thebest 写道

感觉保存JSON数据会很浪费空间啊。如果每个记录的标签都是重复的。相当于是双倍的存储容量。这个怎么解决呢？

这个应该就是灵活性高的代价吧。。。我要用json存数据主要是因为从API获取的原始数据就是json格式的。。

如果数据不是非常重要，可以用dropDups消除重复，它保留第一个发现的文档，删除接下来的有重复值的文档

2 楼 jcs130 2015-08-19  

thebest 写道

感觉保存JSON数据会很浪费空间啊。如果每个记录的标签都是重复的。相当于是双倍的存储容量。这个怎么解决呢？

这个应该就是灵活性高的代价吧。。。我要用json存数据主要是因为从API获取的原始数据就是json格式的。。

1 楼 thebest 2015-08-18  

感觉保存JSON数据会很浪费空间啊。如果每个记录的标签都是重复的。相当于是双倍的存储容量。这个怎么解决呢？