02 private DB db = null;
03 private DBCollection dbc = null;
04
05 /**
06 * 構造方法
07 */
08 public MongoTest(){
09 //實例化Mongo 會默認連接妳的數據庫
10 try {
11 mog = new Mongo();
12 } catch (UnknownHostException e) {
13 e.printStackTrace();
14 } catch (MongoException e) {
15 e.printStackTrace();
16 }
17
18 //得到MyTest數據庫,如果不存在會自動創建
19 db = mog.getDB("MyTest");
20
21 //得到集合,相當於其他數據庫的表,如果沒有也會自動創建
22 dbc = db.getCollection("table1");
23 }
做夢也很累
2.這個是我查詢table1集合中所有的數據,如果table1不存在的話它會自動創建,
01 public void selectAll(){
02 System.out.println("查詢table1中的所有數據:");
03
04 //得到查詢
05 DBCursor cur = dbc.find();
06
07 //遍歷結果
08 while(cur.hasNext()){
09 System.out.println(cur.next());
10 }
11 }
做夢也很累
3.這個是插入壹條文檔的方法,這些name/title/age/等等都是妳隨便添加的,哪怕妳第壹次添加三個、第二次添加壹個、第三次添加10個都沒有問題,
01 public void insert(){
02 DBObject msg = new BasicDBObject();
03
04 //賦值
05 msg.put("name", "qlier");
06 msg.put("age", "21");
07 msg.put("sex", "男");
08 msg.put("email", "xiuxu123@live.cn");
09
10 //保存數據,獲取影響行數
11 int result = dbc.save(msg).getN();
12
13 System.out.println("插入結果:" + result);
14 }
做夢也很累
4.這個是刪除的方法,刪除是要說的,它可以根據_id刪除,這個_id是系統生成的,這個是很重要的壹個標示,我們刪除的時候可以根據它刪除也可以根據其他的刪除。
01 public void updateById(){
02 //要修改的_id
03 DBObject msg1 = new BasicDBObject("_id", new ObjectId("4f3b26b5f8293433e7043e4d"));
04
05 //要修改的值
06 DBObject msg2 = new BasicDBObject();
07 //如果這壹個文檔很多字段,妳就修改壹個字段,那麽其他的字段會被刪除
08 msg2.put("name", "Qlier1");
09
10 //修改name,如果name值不存在會重新添加這天數據
11 int result = dbc.update(msg1, msg2).getN();
12
13 System.out.println("修改結果:" + result);