import java.util.ArrayList; import java.util.List; import com.mongodb.BasicDBObject; import com.mongodb.DB; import com.mongodb.DBCollection; import com.mongodb.DBCursor; import com.mongodb.DBObject; import com.mongodb.Mongo; import com.mongodb.util.JSON; import com.sun.mongodb.manager.MongodbManager; /** * mongodb測試用例 * * @author jacklin * */ public class Testcase { public static void main(String[] args) { // // 查詢所有的Database // showDatabase(); // // 查詢所有的聚集集合 // showCollections(); // // 查詢數(shù)據(jù) // find(); // // 添加數(shù)據(jù) // add(); // // 添加多條數(shù)據(jù) // addList(); // // 刪除數(shù)據(jù) // remove(); // // 修改數(shù)據(jù) // modify(); } /** * 修改數(shù)據(jù) */ public static void modify() { Mongo mg = MongodbManager.getMongo(); DB db = mg.getDB("test"); DBCollection users = db.getCollection("user"); DBObject userOld = new BasicDBObject(); userOld.put("name", "jack"); userOld.put("age", 24); DBObject userNew = new BasicDBObject(); userNew.put("name", "jacky"); userNew.put("age", 26); System.out.println(users.update(userOld, userNew)); } /** * 刪除數(shù)據(jù) */ public static void remove() { Mongo mg = MongodbManager.getMongo(); DB db = mg.getDB("test"); DBCollection users = db.getCollection("user"); DBObject user = new BasicDBObject(); user.put("name", "hoojo"); System.out.println(users.remove(user)); } /** * 添加多條數(shù)據(jù) */ public static void addList() { Mongo mg = MongodbManager.getMongo(); DB db = mg.getDB("test"); DBCollection users = db.getCollection("user"); List<DBObject> list = new ArrayList<DBObject>(); DBObject user1 = new BasicDBObject("name", "lucy"); user1.put("age", 21); DBObject user2 = new BasicDBObject("name", "lily"); user2.put("age", 22); list.add(user1); list.add(user2); // 添加List集合 System.out.println(users.insert(list).getN()); } /** * 添加單條數(shù)據(jù) */ public static void add() { Mongo mg = MongodbManager.getMongo(); DB db = mg.getDB("test"); DBCollection users = db.getCollection("user"); DBObject user = new BasicDBObject(); user.put("name", "jack"); user.put("age", 24); System.out.println(users.save(user).getN()); } /** * 查詢數(shù)據(jù) */ public static void find() { Mongo mg = MongodbManager.getMongo(); DB db = mg.getDB("test"); DBCollection users = db.getCollection("user"); // 查詢所有的數(shù)據(jù) DBCursor cur = users.find(); while (cur.hasNext()) { System.out.println("data:" + cur.next()); } System.out.println("count:" + cur.count()); System.out.println("cursorId:" + cur.getCursorId()); System.out.println("json:" + JSON.serialize(cur)); } /** * 查詢所有的聚集集合 */ public static void showCollections() { Mongo mg = MongodbManager.getMongo(); DB db = mg.getDB("test"); for (String name : db.getCollectionNames()) { System.out.println("collectionName: " + name); } } /** * 查詢所有的Database */ public static void showDatabase() { Mongo mg = MongodbManager.getMongo(); for (String name : mg.getDatabaseNames()) { System.out.println("dbName: " + name); } } } |