MongoDB_Java连接Mongo 限制字段返回数
2017-01-16 22:44
393 查看
Java连接Mongo 限制字段返回数
数据库中的数据 :
代码:
package com.java.module.mongo.mongo_test_1;
import com.mongodb.BasicDBObject;
import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.DBCursor;
import com.mongodb.MongoClient;
import java.net.UnknownHostException;
/**
* Java限制字段返回数
*/
public class JavaFindFields {
public static void main(String[] args) {
try {
MongoClient mongoClient = new MongoClient("localhost", 27017);
DB db = mongoClient.getDB("test");
DBCollection dbCollection = db.getCollection("user");
String[] strArr = new String[]{"name"};
excludeFields(dbCollection, strArr);
} catch (UnknownHostException e) {
e.printStackTrace();
}
}
public static void excludeFields(DBCollection dbCollection, String[] fields) {
BasicDBObject query = new BasicDBObject("age", new BasicDBObject("$lt", 100));
BasicDBObject fieldDoc = new BasicDBObject();
for (int i = 0; i < fields.length; i++) {
String field = fields[i];
fieldDoc.append(field, false);
}
DBCursor dbCursor = dbCollection.find(query,fieldDoc);
while (dbCursor.hasNext()) {
System.out.println(dbCursor.next());
}
}
}
数据库中的数据 :
代码:
package com.java.module.mongo.mongo_test_1;
import com.mongodb.BasicDBObject;
import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.DBCursor;
import com.mongodb.MongoClient;
import java.net.UnknownHostException;
/**
* Java限制字段返回数
*/
public class JavaFindFields {
public static void main(String[] args) {
try {
MongoClient mongoClient = new MongoClient("localhost", 27017);
DB db = mongoClient.getDB("test");
DBCollection dbCollection = db.getCollection("user");
String[] strArr = new String[]{"name"};
excludeFields(dbCollection, strArr);
} catch (UnknownHostException e) {
e.printStackTrace();
}
}
public static void excludeFields(DBCollection dbCollection, String[] fields) {
BasicDBObject query = new BasicDBObject("age", new BasicDBObject("$lt", 100));
BasicDBObject fieldDoc = new BasicDBObject();
for (int i = 0; i < fields.length; i++) {
String field = fields[i];
fieldDoc.append(field, false);
}
DBCursor dbCursor = dbCollection.find(query,fieldDoc);
while (dbCursor.hasNext()) {
System.out.println(dbCursor.next());
}
}
}
相关文章推荐
- MongoDB_Java连接Mongo 限制结果集数量
- MongoDB CouchDB CouchBase性能评测报告
- Java MongoDB : upset document(MongoCollection替换更新document) replaceOne
- 国外经典!架构师必备:《MongoDB实战》第2版
- 详细图解mongodb 3.4.1 win7x64下载、安装、配置与使用2017/01/16
- MongoDB 3.0 WiredTiger Compression and Performance
- mongodb 压缩——3.0+支持zlib和snappy
- 【MongoDb探究】08-索引
- GitLab的安装实战
- mongodb聚合中$group的联合主键写法
- mongodb3.X权限配置
- 在windows下安装mongoDB并且添加进windows服务
- phpmongodbadminui
- MongoDB的启动配置与关闭
- MongoDB——增加数据
- MongoDB——查询
- MongoDB修改与删除操作
- 【MongoDb基础】插入数据
- MongoDB在.NET中使用官方驱动的插入操作
- ubuntu16.04下安装32位mongodb