Java连接MongoDB样例

public class MongodbTest { public static void main(String[] args) { MongoClient mongoClient = new MongoClient(); DB db = mongoClient.getDB("mydb"); DBCollection coll = db.getCollection("testCollection"); // insert a document BasicDBObject doc = new BasicDBObject("name", "MongoDB") .append("type", "database") .append("count", 1) .append("info", new BasicDBObject("x", 123).append("y", 456)); coll.insert(doc); // find the first document in a collection DBObject myDoc = coll.findOne(); System.out.println(myDoc); // adding multiple documents for (int i = 1; i <= 100; i ++) { coll.insert(new BasicDBObject("i", i)); } // counting documents in a collection System.out.println(coll.getCount()); // using a cursor to get all collection DBCursor cursor = coll.find(); try { while (cursor.hasNext()) System.out.println(cursor.next()); } finally { cursor.close(); } // get a single document with a guery BasicDBObject query = new BasicDBObject("i", 23); cursor = coll.find(query); try { while (cursor.hasNext()) System.out.println(cursor.next()); } finally { cursor.close(); } query = new BasicDBObject("j", new BasicDBObject("$ne", 93)) .append("i", new BasicDBObject("$gt", 90)); cursor = coll.find(query); try { while (cursor.hasNext()) System.out.println(cursor.next()); } finally { cursor.close(); } query = new BasicDBObject("i", new BasicDBObject("$ne", 93).append("$gt", 90)); cursor = coll.find(query); try { while (cursor.hasNext()) System.out.println(cursor.next()); } finally { cursor.close(); } // // delete all // cursor = coll.find(); // try { // while (cursor.hasNext()) // coll.remove(cursor.next()); // } finally { // cursor.close(); // } // // // count // System.out.println(coll.getCount()); // BulkWriteOperation builder = coll.initializeOrderedBulkOperation(); // builder.insert(new BasicDBObject("_id", 1)); // builder.insert(new BasicDBObject("_id", 2)); // builder.insert(new BasicDBObject("_id", 3)); // builder.find(new BasicDBObject("_id", 1)).updateOne(new BasicDBObject("$set", new BasicDBObject("x", 123))); // builder.find(new BasicDBObject("_id", 2)).remove(); // builder.find(new BasicDBObject("_id", 3)).replaceOne(new BasicDBObject("_id", 3).append("x", 4)); // BulkWriteResult result = builder.execute(); } }

 

Java连接MongoDB样例

标签：