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");       }  }