Java連接MongoDB示例


示例代碼:

package com.zifeiy.snowflake.handle.etl.mongodb;

import java.util.ArrayList;
import java.util.List;

import org.bson.Document;

import com.mongodb.MongoClient;
import com.mongodb.client.FindIterable;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoCursor;
import com.mongodb.client.MongoDatabase;

public class MongodbTest {
	public static void main(String[] args) {
		MongoClient mongoClient = new MongoClient();
		MongoDatabase mongoDatabase = mongoClient.getDatabase("testdb");
		System.out.println("connect to database[testdb] successfully");
		MongoCollection<Document> collection = mongoDatabase.getCollection("test");
		System.out.println("get collection[test] succeed");
		// insert
		List<Document> documents = new ArrayList<Document>();
		documents.add(new Document("name", "zifeiy")
				.append("age", 18)
				.append("sex", "boy")
				.append("weight", "0.1T"));
		documents.add(new Document("name", "celina")
				.append("age", 20)
				.append("sex", "girl")
				.append("weight", "50KG"));
		collection.insertMany(documents);
		System.out.println("documents insert succeed");
		// select
		FindIterable<Document> findIterable = collection.find();
		MongoCursor<Document> mongoCursor = findIterable.iterator();
		while (mongoCursor.hasNext()) {
			System.out.println(mongoCursor.next());
		}
	}
}

這里有一篇寫的更詳細的:http://www.cnblogs.com/wenbronk/p/6385935.html


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM