我无法在java中复制mongo数组的更新

Question

我有一个具有以下结构的数据库：

{

    "_id" : ObjectId("5d54608122474f8d2927d898"),

    "NOMBRE_HOST" : "Base1",

    "IsContingenciaODA" : "false",

    "puerto" : "1532",

    "HostContigencia" : "Base2",

    "BASEDATOS" : [

        {

            "SID" : "REPOS",

            "IsContingenciaBD" : "false",

            "host" : "Base3",

            "puerto" : "1111"

        },

        {

            "SID" : "PRODM2",

            "IsContingenciaBD" : "false",

            "host" : "nb",

            "puerto" : "1111"

        },

        {

            "SID" : "PRODM3",

            "IsContingenciaBD" : "true",

            "host" : "Base4",

            "puerto" : "999"

        }

    ]

}

{

    "_id" : ObjectId("5d54608122474f8d2927d899"),

    "NOMBRE_HOST" : "172.0.0.1",

    "IsContingenciaODA" : "false",

    "puerto" : "1532",

    "HostContigencia" : "172.10.0.1",

    "BASEDATOS" : [

        {

            "SID" : "Base6",

            "IsContingenciaBD" : "false",

            "host" : "172.7.0.1",

            "puerto" : "999"

        }

    ]

}

我需要更新嵌入文档的IsContingenciaBD参数。在 mongo 中更改此值的查询如下：

db.PropertiesMQ.update({"NOMBRE_HOST" : "Base1", "BASEDATOS.SID" : "PRODM3"}, {$set: {"BASEDATOS.$.IsContingenciaBD" : "true"}})

我尝试使用以下代码在 java 中复制此查询：

        MongoClient client = new MongoClient("my_ip", "my_port");

        MongoDatabase mongodb = client.getDatabase("prueba");

        MongoCollection<Document> collection = mongodb.getCollection("PropertiesMQ");

        BasicDBObject filter = new BasicDBObject();

        filter.put("NOMBRE_HOST", host);

        filter.put("BASEDATOS.SID", sid);

        BasicDBObject data = new BasicDBObject();

        data.put("BASEDATOS.$.IsContingenciaBD", state);

        BasicDBObject command = new BasicDBObject();

        command.put("$set", data);

        System.out.println(filter + ", " + command);

        collection.updateOne(filter, data);

        client.close();

执行时我收到以下错误：

线程“main”中的异常 java.lang.IllegalArgumentException：无效的 BSON 字段名称 BASEDATOS.$.IsContingenciaBD

Answer 1

看起来您在 updateOne 方法中使用了数据。相反，它应该是命令BasicDBObject。就像下面这样，&nbsp; &nbsp; MongoCollection<Document> collection = mongodb.getCollection("PropertiesMQ");&nbsp; &nbsp; BasicDBObject filter = new BasicDBObject();&nbsp; &nbsp; filter.put("NOMBRE_HOST", host);&nbsp; &nbsp; filter.put("BASEDATOS.SID", sid);&nbsp; &nbsp; BasicDBObject data = new BasicDBObject();&nbsp; &nbsp; data.put("BASEDATOS.$.IsContingenciaBD", state);&nbsp; &nbsp; BasicDBObject command = new BasicDBObject();&nbsp; &nbsp; command.put("$set", data);&nbsp; &nbsp; System.out.println(filter + ", " + command);&nbsp; &nbsp; collection.updateOne(filter, command); //Use Command instead of data