如何在Java中执行MongoDB查询？能否通过Java执行MongoDB脚本文件？

1. 像SQL那样通过配置文件执行MongoDB查询 #

完全可以实现类似SQL的配置化查询方式。核心思路是把MongoDB的查询条件（过滤、投影、排序等）以JSON格式存在配置文件中，然后Java程序读取配置，用MongoDB Java驱动构建并执行查询。

实现步骤： #

• 第一步：创建配置文件（比如mongo-queries.json），定义查询参数：

{
  "employee_query": {
    "collection": "Employee_Details",
    "filter": {}, // 空表示查询所有文档，可按需添加过滤条件，比如{"department": "IT"}
    "projection": {}, // 控制返回字段，比如{"name": 1, "salary": 1, "_id": 0}
    "sort": {"join_date": -1} // 可选：按入职日期倒序
  }
}

• 第二步：Java读取配置并执行查询：

import com.mongodb.client.MongoClients;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoDatabase;
import com.mongodb.client.model.Sorts;
import org.bson.Document;
import com.fasterxml.jackson.databind.JsonNode;
import com.fasterxml.jackson.databind.ObjectMapper;
import java.io.File;
import java.util.ArrayList;
import java.util.List;

public class ConfigurableMongoQuery {
    public static void main(String[] args) throws Exception {
        // 读取配置文件
        ObjectMapper mapper = new ObjectMapper();
        JsonNode rootNode = mapper.readTree(new File("mongo-queries.json"));
        JsonNode employeeQuery = rootNode.get("employee_query");

        // 连接MongoDB（替换成你的连接字符串）
        try (var mongoClient = MongoClients.create("mongodb://localhost:27017")) {
            MongoDatabase db = mongoClient.getDatabase("your_database_name");
            MongoCollection<Document> collection = db.getCollection(employeeQuery.get("collection").asText());

            // 构建查询
            var queryBuilder = collection.find(Document.parse(employeeQuery.get("filter").toString()));
            
            // 添加投影（如果配置了）
            if (!employeeQuery.get("projection").isEmpty()) {
                queryBuilder.projection(Document.parse(employeeQuery.get("projection").toString()));
            }
            
            // 添加排序（如果配置了）
            if (!employeeQuery.get("sort").isEmpty()) {
                queryBuilder.sort(Sorts.orderBy(Document.parse(employeeQuery.get("sort").toString())));
            }

            // 执行查询并获取结果
            List<Document> results = queryBuilder.into(new ArrayList<>());
            
            // 处理结果（这里只是打印，你可以根据业务需求调整）
            results.forEach(doc -> System.out.println(doc.toJson()));
        }
    }
}

这种方式的好处是无需修改Java代码，只要调整配置文件就能变更查询逻辑，和SQL的配置化思路一致。

2. 在Java中执行你的MongoDB JavaScript脚本文件 #

也可以直接执行现有的JavaScript脚本，不过要注意MongoDB版本的兼容性：MongoDB 4.2及以上版本弃用了eval命令（因为安全风险），所以推荐两种方案：

方案1：兼容旧版本（使用eval命令） #

如果你的MongoDB版本低于4.2，可以直接读取脚本文件内容，通过runCommand执行：

import com.mongodb.client.MongoClients;
import com.mongodb.client.MongoDatabase;
import org.bson.Document;
import java.nio.file.Files;
import java.nio.file.Paths;

public class RunMongoJsScript {
    public static void main(String[] args) throws Exception {
        // 读取你的JavaScript文件内容
        String scriptContent = new String(Files.readAllBytes(Paths.get("your-script-file.js")));

        // 连接MongoDB
        try (var mongoClient = MongoClients.create("mongodb://localhost:27017")) {
            MongoDatabase db = mongoClient.getDatabase("your_database_name");
            
            // 执行脚本
            Document result = db.runCommand(new Document("eval", scriptContent));
            
            // 输出结果（注意：脚本中的print输出不会直接到Java控制台，需要通过返回值获取结果）
            System.out.println("脚本执行返回结果：" + result.toJson());
        }
    }
}

方案2：MongoDB 4.2+ 推荐方案（转换为Java驱动API或使用$function） #

由于eval存在安全风险（执行任意JS代码），生产环境更建议把脚本逻辑转为Java驱动的原生API调用，比如你的脚本是查询所有Employee_Details数据，直接用以下代码替代：

// 直接查询，替代JS脚本逻辑
List<Document> employees = db.getCollection("Employee_Details")
        .find()
        .into(new ArrayList<>());
employees.forEach(System.out::println);

如果确实需要执行复杂的JS逻辑，可以用聚合框架的$function：

import com.mongodb.client.MongoCollection;
import com.mongodb.client.model.Aggregates;
import org.bson.Document;
import java.util.List;

// 执行复杂JS逻辑
List<Document> results = db.getCollection("Employee_Details")
        .aggregate(List.of(
                Aggregates.addFields(new Document(
                        "customResult",
                        new Document("$function",
                                new Document("body", "function(doc) { return doc.name + ' works in ' + doc.department; }")
                                        .append("args", List.of("$$ROOT"))
                                        .append("lang", "js")
                        )
                ))
        ))
        .into(new ArrayList<>());

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