MongoDB的数据

================================

{
  "_id" : ObjectId("54d3509f30c0ed0f308ed1ef"),
  "cust_id" : "A123",
  "amount" : 500.0,
  "status" : "A"
}
{
  "_id" : ObjectId("54d350a830c0ed0f308ed1f0"),
  "cust_id" : "A123",
  "amount" : 250.0,
  "status" : "A"
}
{
  "_id" : ObjectId("54d350b430c0ed0f308ed1f1"),
  "cust_id" : "A123",
  "amount" : 250.0,
  "status" : "A"
}
{
  "_id" : ObjectId("54d350be30c0ed0f308ed1f2"),
  "cust_id" : "B212",
  "amount" : 200.0,
  "status" : "A"
}
{
  "_id" : ObjectId("54d350c030c0ed0f308ed1f3"),
  "cust_id" : "B212",
  "amount" : 200.0,
  "status" : "A"
}
{
  "_id" : ObjectId("54d350d030c0ed0f308ed1f4"),
  "cust_id" : "A123",
  "amount" : 300.0,
  "status" : "D"
}

import org.bson.Document;
import com.mongodb.BasicDBObject;
import com.mongodb.DBCollection;
import com.mongodb.DBObject;
import com.mongodb.MapReduceCommand;
import com.mongodb.MapReduceOutput;
import com.mongodb.MongoClient;
import com.mongodb.client.FindIterable;
import com.mongodb.client.MapReduceIterable;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoCursor;
import com.mongodb.client.MongoDatabase;
import com.mongodb.util.JSON;

public class MongoDBClientTest {
 private static MongoClient mongoClient;
 private static MongoDatabase db;
 static {
  mongoClient = new MongoClient("localhost", 27017);
  db = mongoClient.getDatabase("local");
 }
 
 public MongoDBClientTest() {
  super();
 }
 
 public static void main(String[] args) {
  MongoDBClientTest clientTest = new MongoDBClientTest();
  clientTest.testQuery();
  clientTest.testInsert();
  clientTest.testDelete();
  clientTest.testToJsonObject();
  clientTest.testMapReduce();
 }
//test search
 private void testQuery() {
  System.err.println("===========going to select==========");
  MongoCollection collection = db.getCollection("posts");
  BasicDBObject query = new BasicDBObject("cust_id", "B212");
  BasicDBObject returnField1 = new BasicDBObject("cust_id", 1);
  BasicDBObject returnField2 = new BasicDBObject("status", 1);
  FindIterable iterable = collection.find(query);
  MongoCursor cursor = iterable.iterator();
  while (cursor.hasNext()) {
   org.bson.Document user = cursor.next();
   System.out.println(user.get("cust_id"));
   System.out.println(user.toString());
  }
  cursor.close();
 }
 
//test insert
 private void testInsert() {
  System.err.println("===========going to insert==========");
  MongoCollection collection = db.getCollection("posts");
  Document doc = new Document();
  doc.put("cust_id", "A111");
  doc.put("amount", 210);
  doc.put("status", "C");
  collection.insertOne(doc);
  FindIterable iterable = collection.find();
  MongoCursor cursor = iterable.iterator();
  while (cursor.hasNext()) {
   org.bson.Document user = cursor.next();
   // System.out.println(user.get("cust_id"));
   System.out.println(user.toString());
  }
 }
 
//test delete
 private void testDelete() {
  System.err.println("===========going to delete==========");
  MongoCollection collection = db.getCollection("posts");
  BasicDBObject query = new BasicDBObject("status", "C");
  collection.deleteMany(query);
  FindIterable iterable = collection.find();
  MongoCursor cursor = iterable.iterator();
  while (cursor.hasNext()) {
   org.bson.Document user = cursor.next();
   System.out.println(user.toString());
  }
 }
 
//test string to json object
 private void testToJsonObject() {
  System.err.println("===========to json object==========");
  String jsonString = "{  'title' : 'NoSQL Overview', 'description' : 'No sql database is very fast', 'by_user' : 'tutorials point', 'url' : 'http://www.tutorialspoint.com', 'tags' : [ 'mongodb', 'database', 'NoSQL' ], 'likes' : 10 }";
  BasicDBObject doc = (BasicDBObject) JSON.parse(jsonString);
  System.out.println(doc);
  System.out.println(doc.get("tags").getClass().getCanonicalName());
 }
 
//test the map reduce
 private void testMapReduce() {
  System.err.println("===========test map reduce==========");
  MongoCollection collection = db.getCollection("posts");
  String map = "function(){emit(this.cust_id,this.amount);}";
  String reduce = "function(key, values){return Array.sum(values)}";
  // MapReduceCommand cmd = new MapReduceCommand(collection, map, reduce,
  // null, MapReduceCommand.OutputType.INLINE, null);
  MapReduceIterable out = collection.mapReduce(map, reduce);
  MongoCursor cursor = out.iterator();
  while (cursor.hasNext()) {
   System.out.println(cursor.next());
  }
  BasicDBObject query=new BasicDBObject("status","C");
  DBCollection dbcol = mongoClient.getDB("local").getCollection("posts");
  MapReduceCommand cmd = new MapReduceCommand(dbcol, map, reduce,
    "outputCollection", MapReduceCommand.OutputType.INLINE, query);
  MapReduceOutput out2 = dbcol.mapReduce(cmd);
  for (DBObject o : out2.results()) {
   System.out.println(o.toString());
  }
  System.out.println("Done");
  
 }
}