您的位置:首页 > 数据库 > Mongodb

mongodb java 连接和简单查询

2014-07-03 14:46 771 查看
package cy.mongo;
import java.util.List;
import com.alibaba.fastjson.JSON;
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.MongoOptions;
public class Test1 {
public static void main(String[] args) {
String uri = "192.168.1.205";
try{
Mongo mongo = new Mongo(uri,27017);
MongoOptions options = mongo.getMongoOptions();
options.autoConnectRetry = true;
options.maxWaitTime = 5000;
options.socketTimeout = 2000;
options.connectTimeout = 15000;
options.threadsAllowedToBlockForConnectionMultiplier = 5000;

String dbName = "klog";
String username = "";
String password = "";

DB db = mongo.getDB(dbName);
if (!db.isAuthenticated()) {
db.authenticate(username, password.toCharArray());
}

DBCollection dbc = db.getCollection("KLogs");

BasicDBObject query = new BasicDBObject();
query.put("operatorId", 5057);
query.put("businessParam.objId", 192);

//查询第0~10条数据
DBCursor cur = dbc.find(query).skip(0).limit(10);

List<DBObject> list = cur.toArray();

System.out.println(JSON.toJSON(list));

}catch(Exception e){
e.printStackTrace();
}

}
}


数据结构

{
"_id" : ObjectId("53a293fce4b011ddffdc04ab"),
"orgId" : 1000999,
"platform" : "",
"operatorType" : 1,
"createTime" : NumberLong("1403163645628"),
"businessName" : "优惠",
"operatorId" : 5057,
"sessionId" : "",
"businessNo" : 1109,
"operationTime" : NumberLong("1403163538000"),
"businessParam" : {
"objId" : 1000399,
"objType" : 102
},
"businessStatus" : 1
}
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签:  mongodb