如何用Java查询MongoDB中Cube集合内符合条件的Customer数据

针对你需要实现的类似SQL select custkey from customer where region=afriqua的查询需求，本质是从MongoDB的全局集合cube中，筛选出customer子集中region等于afriqua的文档，并提取对应的custkey字段。结合你的NetBeans 8.2和MongoDB 3.11.0环境，我整理了一套完整的可行方案：

1. 确保依赖配置正确 #

首先要保证你的项目引入了匹配版本的MongoDB Java驱动。因为你用的是MongoDB 3.11.0，对应驱动版本选择3.11.0最稳妥：

• Maven方式：在项目的pom.xml中添加以下依赖：

<dependency>
    <groupId>org.mongodb</groupId>
    <artifactId>mongodb-driver</artifactId>
    <version>3.11.0</version>
</dependency>

• 手动导入方式：下载mongodb-driver-3.11.0.jar、mongodb-driver-core-3.11.0.jar、bson-3.11.0.jar三个包，添加到NetBeans项目的类路径中（右键项目 -> Properties -> Libraries -> Add JAR/Folder）。

2. 完整的Java实现代码 #

以下代码实现了连接MongoDB、构造查询条件、投影指定字段并输出结果的完整流程，同时处理了资源自动释放：

import com.mongodb.MongoClient;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoDatabase;
import org.bson.Document;
import com.mongodb.client.model.Filters;
import com.mongodb.client.model.Projections;
import java.util.List;

public class OlapCustomerQuery {
    public static void main(String[] args) {
        // 连接MongoDB实例（根据你的实际部署调整主机和端口）
        try (MongoClient mongoClient = new MongoClient("localhost", 27017)) {
            // 替换为你的目标数据库名称
            MongoDatabase targetDb = mongoClient.getDatabase("olap_db");
            // 获取全局集合"cube"
            MongoCollection<Document> cubeCollection = targetDb.getCollection("cube");
            
            // 构造查询条件：匹配customer.region = "afriqua"
            Document regionFilter = Filters.eq("customer.region", "afriqua");
            // 投影只返回需要的customer.custkey字段（减少数据传输）
            Document custKeyProjection = Projections.include("customer.custkey");
            
            // 执行查询并遍历结果
            cubeCollection.find(regionFilter).projection(custKeyProjection).forEach(doc -> {
                // 提取嵌套在customer下的custkey值
                Integer custKey = doc.getEmbedded(List.of("customer", "custkey"), Integer.class);
                System.out.println("匹配的CustKey: " + custKey);
            });
        } catch (Exception e) {
            System.err.println("查询过程中出现异常:");
            e.printStackTrace();
        }
    }
}

3. 代码关键细节说明 #

• 嵌套字段匹配：用Filters.eq("customer.region", "afriqua")对应SQL的where region=afriqua，MongoDB支持用点.语法访问嵌套字段。
• 字段投影：Projections.include("customer.custkey")确保只返回需要的字段，避免返回整个文档，提升查询性能。
• 资源自动管理：用try-with-resources包裹MongoClient，确保连接自动关闭，避免资源泄漏。
• 嵌套字段提取：getEmbedded(List.of("customer", "custkey"), Integer.class)是MongoDB 3.11.x提供的便捷方法，直接提取多层嵌套的字段值，比逐层调用get()更简洁。

4. 测试数据结构要求 #

你的cube集合中的文档需要符合以下结构（示例），代码才能正常提取数据：

{
  "_id": ObjectId("60d21b4667d0d8992e610c85"),
  "customer": {
    "custkey": 1001,
    "region": "afriqua",
    "name": "John Doe"
  },
  "orders": {
    "orderid": 5001,
    "amount": 1200.0
  }
}

常见问题排查 #

如果你的原有代码无效，大概率是以下原因：

• 没有正确使用点.语法访问嵌套字段（比如直接写region而非customer.region）。
• 驱动版本不匹配，比如用了高版本API但依赖的是3.11.0驱动。
• 数据库/集合名称拼写错误，或者MongoDB连接地址配置有误。

内容的提问来源于stack exchange，提问作者Sirina nes