[转]MongoDB插入和查询操作
MongoDB下的高级查询示例http://www.iyunv.com/Linux/2011-05/36312.htmMongoDB 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
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
页:
[1]