1

我正在尝试为 R 中的刻度数据库编写一个通用的 upsert。

python代码将是：

collection.update({'symbol':'somesymbol', 'sha':'SoM3__W3|Re|7__Sh@'},

                   {'$set':{segment:5},

                    '$addToSet': {'parent':parent_id}}},

                     upsert=True)

在 RI 中使用 rmongodb 并尝试构建 BSON 对象

#get the query

mtch_b<-mongo.bson.buffer.create()

mongo.bson.buffer.append(mtch_b, "symbol", "somesymbol")

mongo.bson.buffer.append(mtch_b, "sha", "SoM3__W3|Re|7__Sh@")

mtch<-mongo.bson.from.buffer(mtch_b)



#set the segment

qry_b<-mongo.bson.buffer.create()

mongo.bson.buffer.start.object(qry_b, "$set")

    mongo.bson.buffer.append(qry_b, "segment", 5)

            mongo.bson.buffer.start.object(qry_b, "$addToSet")

                mongo.bson.buffer.append(qry_b, "parent", "Initial")

            mongo.bson.buffer.finish.object(qry_b) #end of $addtoSet object

mongo.bson.buffer.finish.object(qry_b) #end of $set object

qry_bsn <-mongo.bson.from.buffer(qry_b)



mongo.update(mongo, "M__test.tmp", mtch, qry_bsn, flags=mongo.update.upsert)

当我运行它时，我得到一个错误：

"The dollar ($) prefixed field '$addToSet' in '$addToSet' is not valid for storage."

看着 qry_bsn：

qry_bsn

    $set : 3        

            segment : 4     

                    0 : 1    1.000000

                    1 : 1    2.000000

                    2 : 1    3.000000

                    3 : 1    4.000000



            $addToSet : 3   

                    parent : 2       Initial

当我删除 $addToSet、追加和完成 $addToSet 对象的对象时，查询运行良好。

任何有关如何做到这一点的帮助将不胜感激。

4

1 回答 1

1

我找不到不使用的理由mongo.bson.from.list。它为您打响所有mongo.bson.buffer.*电话。而且使用 bson 构造产生错误的机会要小得多。

query <- mongo.bson.from.list(list("symbol" = "somesymbol", "sha" = "SoM3__W3|Re|7__Sh@"))
upd_obj <- mongo.bson.from.list(list('$set' = list('segment' = 1:4), '$addToSet' = list('parent' = 'PARENT_ID')))
mongo.update(mongo = mongo, ns = "M__test.tmp", criteria = query, objNew = upd_obj, flags=mongo.update.upsert)
于 2015-02-19T11:12:26.003 回答