使用Java操作MongoDB
阿新 • • 發佈:2017-07-16
pan blog date() 增刪改查 delete tcollect ive 關閉 basic
該篇比較簡單,僅介紹Java操作MongoDB的簡單CRUD案例,開搞前需要引入mongo-java-driver-3.2.2.jar,Java操作MongoDB的API眾多,高級功能還需查詢官方文檔。
public void insert() { // 建立數據庫連接 Mongo mongo = new Mongo("localhost", 27017); // 獲取指定的數據庫 DB db = mongo.getDB("kaiye"); // 獲取指定的集合 DBCollection dbc = db.getCollection("c6");// 獲取操作增刪改查的對象 DBObject dbo = new BasicDBObject(); dbo.put("name", "梓璇"); dbo.put("age", "22"); dbc.insert(dbo); // 關閉數據庫鏈接 mongo.close(); System.out.println("插入成功"); }
@Override public void delete() { // 建立數據庫連接 Mongo mongo = newMongo("localhost", 27017); // 獲取指定的數據庫 DB db = mongo.getDB("kaiye"); // 獲取指定的集合 DBCollection dbc = db.getCollection("c5"); // 獲取操作增刪改查的對象 DBObject dbo = new BasicDBObject(); dbo.put("name", "jumo"); dbc.remove(dbo); // 關閉數據庫鏈接 mongo.close(); System.out.println("刪除成功"); }
@Override public void update() { // 建立數據庫連接 Mongo mongo = new Mongo("localhost", 27017); // 獲取指定的數據庫 DB db = mongo.getDB("kaiye"); // 獲取指定的集合 DBCollection dbc = db.getCollection("c4"); // 獲取操作增刪改查的對象 DBObject query = new BasicDBObject("age",7); DBObject update = dbc.findOne(query); update.put("name", "xuxuanli"); dbc.update(query, update, true, true); // 關閉數據庫鏈接 mongo.close(); System.out.println("更新成功"); }
@Override public void query() { // 建立數據庫連接 Mongo mongo = new Mongo("localhost", 27017); // 獲取指定的數據庫 DB db = mongo.getDB("kaiye"); // 獲取指定的集合 DBCollection dbc = db.getCollection("c6"); // 獲取操作增刪改查的對象 DBObject dbo = new BasicDBObject(); // 查詢條件 dbo.put("age", "89"); // 遊標查詢 DBCursor dbCursor = dbc.find(dbo); // 遍歷結果集,獲取返回結果 while (dbCursor.hasNext()) { DBObject dbo1 = dbCursor.next(); System.out.println(dbo1); } System.out.println("查詢成功"); }
使用Java操作MongoDB