[转]MongoDB插入和查询操作

mofdan

　　MongoDB下的高级查询示例  http://www.iyunv.com/Linux/2011-05/36312.htm
　　MongoDB Java API for 插入和单collection基本查询使用示例 http://www.iyunv.com/Linux/2011-05/36313.htm
　　MongoDB下的查询操作(与Java API查询操作对应) http://www.iyunv.com/Linux/2011-05/36314.htm
　　


View Code


  1 /**  
  2  * MongoDBTest  
  3  * MongoDB　java api的初步使用示例  
  4  * 此次只介绍一下insert和query(基本单collection查询)两种操作  
  5  */  
  6 package com.labci.mongodb.test;   
  7 import java.net.UnknownHostException;   
  8 import java.util.Iterator;   
  9 import java.util.regex.Pattern;   
10 import com.mongodb.BasicDBObject;   
11 import com.mongodb.DB;   
12 import com.mongodb.DBCollection;   
13 import com.mongodb.DBCursor;   
14 import com.mongodb.DBObject;   
15 import com.mongodb.Mongo;   
16 import com.mongodb.MongoException;   
17 /**  
18  * @author Bill Tu(tujiyue/iwtxokhtd)  
19  * May 21, 2011[12:06:41 PM]  
20  *  
21  */  
22 public class MongoDBJavaAPITest {   
23     private static final String HOST = "192.168.1.86";   
24     private static final int PORT = 27017;   
25     private static final String USER = "iwtxokhtd";   
26     private static final String PASSWORD = "123456";   
27     private static final String DB_NAME = "test";   
28     private static final String COLLECTION = "data_test";   
29     private static final int SIZE = 10;   
30        
31     /**  
32      * 进行测试  
33      * @throws Exception  
34      */  
35     private static void initTest() throws Exception{   
36         try {   
37             Mongo conn=new Mongo(HOST,PORT);//建立数据库连接   
38             DB testDB=conn.getDB(DB_NAME);//取得test数据库   
39             /**  
40              * 如果test数据库没有设定用户权限认证，则无需下面的验证  
41              */  
42             boolean loginSuccess=testDB.authenticate(USER, PASSWORD.toCharArray());   
43             if(!loginSuccess){   
44                 throw new Exception("登录"+DB_NAME+"验证失败,请确认用户名和密码");   
45             }   
46             /**  
47              * 如果COLLECTION不存在，则MongoDB会自动为你创建此collection  
48              */  
49             DBCollection collection=testDB.getCollection(COLLECTION);   
50             //开始插入数据操作   
51             insertData(collection,SIZE);   
52             //查询操作   
53             findData(collection);   
54               
55         } catch (UnknownHostException e) {   
56             e.printStackTrace();   
57         } catch (MongoException e) {   
58             e.printStackTrace();   
59         }   
60     }   
61        
62     /**  
63      * 向collection插入size条记录  
64      */  
65     private static void insertData(DBCollection collection,int size){   
66         long beginTime=System.currentTimeMillis();   
67         for(int i=1;i