标签:
package com.dys.mongo; import java.io.IOException; import java.util.ArrayList; import java.util.List; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; import org.bson.Document; import org.junit.After; import org.junit.Before; import org.junit.Test; import com.dys.model.Point; import com.dys.model.Record; import com.fasterxml.jackson.core.JsonParseException; import com.fasterxml.jackson.core.JsonProcessingException; import com.fasterxml.jackson.databind.JsonMappingException; import com.fasterxml.jackson.databind.ObjectMapper; import com.mongodb.BasicDBObject; import com.mongodb.MongoClient; import com.mongodb.ServerAddress; import com.mongodb.client.FindIterable; import com.mongodb.client.MongoCollection; import com.mongodb.client.MongoDatabase; public class TestMongo { private static Logger logger = LogManager.getLogger(TestMongo.class); private MongoClient mongoClient = null; @Before public void before() { /* MongoCredential mongoCredential = MongoCredential.createCredential("dingyingsi", "test", "dingyingsi".toCharArray()); MongoClientOptions mongoClientOptions = MongoClientOptions.builder() .connectionsPerHost(10) .threadsAllowedToBlockForConnectionMultiplier(5) .readPreference(ReadPreference.nearest()) .build(); this.mongoClient = new MongoClient(new ServerAddress("192.168.0.110", 27017), Arrays.asList(mongoCredential), mongoClientOptions); */ this.mongoClient = new MongoClient(new ServerAddress("192.168.0.110", 27017)); } @After public void after() { this.mongoClient.close(); } @Test public void test01() throws Exception { MongoDatabase mdb = this.mongoClient.getDatabase("dingyingsi"); MongoCollection<Document> collection = mdb.getCollection("record"); FindIterable<Document> findIterable = collection.find(new BasicDBObject().append("_id","1")); for (Document doc : findIterable) { ObjectMapper om = new ObjectMapper(); Record record = om.readValue(doc.toJson(), Record.class); System.out.println(record.getPoints().size()); } } @Test public void test02() throws Exception { MongoDatabase mdb = this.mongoClient.getDatabase("dingyingsi"); MongoCollection<Document> collection = mdb.getCollection("record"); Record record = null; for (int j = 1; j <= 100000; j++) { record = new Record(); record.set_id(j + ""); Point point = null; List<Point> points = new ArrayList<Point>(); for (int i = 1; i <= 200000; i++) { point = new Point(); point.setLongitude("120.12434"); point.setLatitude("134.56783"); points.add(point); } record.setPoints(points); ObjectMapper om = new ObjectMapper(); String recordJson = om.writeValueAsString(record); Document document = Document.parse(recordJson); collection.insertOne(document); } } }
标签:
原文地址:http://www.cnblogs.com/dingyingsi/p/5605337.html