mongodb最新java驱动CRUD使用演示

    今天使用java代码调用mongodb数据库，用maven引入了最新版的mongodb驱动，在网上找了demo结果发现将demo贴到eclipse上之后好多过期方法。所以猜想mongodb驱动版本肯定有很大的更新。

    果不其然，mongodb的确有了最新版3.x。而网上几乎所有的demo都基于2.x版本。下面是在github上找的一些资料，再结合官方文档总结的3.x版本的CRUD操作。

 

    以下演示源码地址：https://github.com/smallbug-vip/repo

 

首先在pom.xml中配置引入jar包：

<dependency>
			<groupId>org.mongodb</groupId>
			<artifactId>mongo-java-driver</artifactId>
			<version>3.2.1</version>
		</dependency>

 下面演示会使用到一些静态方法，eclipse中使用快捷键不能自动导包，可以手动添加：

import static com.mongodb.client.model.Filters.and;
import static com.mongodb.client.model.Filters.eq;
import static com.mongodb.client.model.Filters.exists;
import static com.mongodb.client.model.Filters.gt;
import static com.mongodb.client.model.Filters.gte;
import static com.mongodb.client.model.Filters.lt;
import static com.mongodb.client.model.Filters.lte;
import static com.mongodb.client.model.Projections.excludeId;
import static com.mongodb.client.model.Projections.include;
import static com.mongodb.client.model.Sorts.descending;

 准备工作：

MongoDatabase db = null;
	MongoClient client = null;

	@Before
	public void before() {
		client = new MongoClient("192.168.88.132", 27017);
		db = client.getDatabase("its");
	}

	@After
	public void after() {
		if (client != null) {
			client.close();
		}
	}

 获取连接：

@Test
	public void testCollections() {

		MongoIterable<String> collections = db.listCollectionNames();
		MongoCursor<String> cu = collections.iterator();
		for (; cu.hasNext();) {
			System.out.println(cu.next());
		}
	}

  测试增加一个Document：

@Test
	public void testAdd() {
		MongoCollection<Document> col = db.getCollection("s1");
		Document doc = new Document("name", "MongoDB")//
				.append("type", "database")//
				.append("count", 1)//
				.append("info", new Document("x", 203).append("y", 102));
		col.insertOne(doc);
	}

 测试增加多个Document：

@Test
	public void testAddALL() {
		MongoCollection<Document> col = db.getCollection("s1");
		List<Document> dos = new ArrayList<Document>();
		for (int i = 0; i < 100; i++) {
			dos.add(new Document("i", i));
		}
		col.insertMany(dos);
	}

 查看当前有多少记录：

@Test
	public void testCount() {
		MongoCollection<Document> col = db.getCollection("s1");
		System.out.println(col.count());
	}

 获取第一条记录：

@Test
	public void testFirst() {
		MongoCollection<Document> col = db.getCollection("s1");
		Document myDoc = col.find().first();
		System.out.println(myDoc.toJson());
	}

 获取第所有记录：

@Test
	public void testFindAll() {
		MongoCollection<Document> col = db.getCollection("s1");
		/**************** 第一种方法 *********************/
		// MongoCursor<Document> cursor = col.find().iterator();
		// while (cursor.hasNext()) {
		// System.out.println(cursor.next().toJson());
		// }
		/**************** 第二种方法 *********************/
		for (Document cur : col.find()) {
			System.out.println(cur.toJson());
		}
	}

 分页：

@Test
	public void testLimit() {
		MongoCollection<Document> col = db.getCollection("s1");
		for (Document cur : col.find().skip(20).limit(10)) {
			System.out.println(cur.toJson());
		}
	}

 条件查询：

@Test
	public void testFilter() {
		MongoCollection<Document> col = db.getCollection("s1");
		// eq为静态导入
		Document myDoc = col.find(eq("i", 71)).first();
		System.out.println(myDoc.toJson());
	}

 获得子集：

@Test
	public void testBlock() {
		MongoCollection<Document> col = db.getCollection("s1");
		Block<Document> printBlock = new Block<Document>() {
			@Override
			public void apply(final Document document) {
				System.out.println(document.toJson());
			}
		};
		col.find(and(gt("i", 50), lte("i", 80))).forEach(printBlock);
	}

 排序：

@Test
	public void testSort() {
		MongoCollection<Document> col = db.getCollection("s1");
		// 升序 ascending
		FindIterable<Document> it = col.find(exists("i")).sort(descending("i"));
		for (Document d : it) {
			System.out.println(d.toJson());
		}
	}

 筛选字段：

@Test
	public void testProjection() {
		MongoCollection<Document> col = db.getCollection("s1");
		FindIterable<Document> it = col.find()//
				.projection(and(include("name"), excludeId()));
		for (Document d : it) {
			System.out.println(d.toJson());
		}
	}

 更新一条Document：

@Test
	public void testUpdateOne() {
		MongoCollection<Document> col = db.getCollection("s1");
		col.updateOne(//
				eq("i", 10), new Document("$set", new Document("i", 110)));
	}

 更新多条记录：

@Test
	public void testUpdateMany() {
		MongoCollection<Document> col = db.getCollection("s1");
		// $inc 自增
		UpdateResult updateResult = col.updateMany(lt("i", 10), new Document("$inc", new Document("i", 234)));
		System.out.println(updateResult.getModifiedCount());
	}

 测试删除一条Document：

@Test
	public void testDeleteOne() {
		MongoCollection<Document> col = db.getCollection("s1");
		DeleteResult re = col.deleteOne(eq("i", 234));
		System.out.println(re.getDeletedCount());
	}

 测试删除多条Document：

@Test
	public void testDeleteMany() {
		MongoCollection<Document> col = db.getCollection("s1");
		DeleteResult deleteResult = col.deleteMany(gte("i", 100));
		System.out.println(deleteResult.getDeletedCount());
	}