upsert 不成功

使用更先进的浏览器访问效果更佳。

ggyydm

hi，

我在使用upsert的过程中，运行命令没有报错，但更新操作似乎没有成功：

> db.testDBCS.testDB0.upsert({$push:{"test_mark":1}},{"_id":0},{"":"$id"})

Takes 0.237s.

> db.testDBCS.testDB0.aggregate({$limit:1})

{

"_id": 0,

"test_mark": 0,

"test_value": "aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa"

}

Return 1 row(s).

Takes 0.358s.

这个是怎么回事呢？我在java客户端好像也是同样情况。

Diablo

push只针对数组字段有效，可以把原始记录改成

{

"_id": 0,

"test_mark": [0],

"test_value": "aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa"

}

ggyydm

OK，了解，谢谢。

ggyydm

我的写法是不是有误，好像还是没成功

db.testDBCS.testDB0.update({$push:{"test_mark":1}},{"_id":0},{"":"$id"})

Takes 0.312s.

> db.testDBCS.testDB_up0.aggregate({$limit:1})

{

"_id": {

"$oid": "54d061f8bbb12c685a97d483"

"test_mark": [

[

]

"test_value": [

[

"aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa"

]

}

另外这样在编程中，想要达到没有就插入当前记录，有就归并一条记录似乎比较麻烦？

Diablo

你的匹配条件{"_id":0}不能命中这条记录呀。

没有就插入，有就归并就是你之前用upsert功能。你说的比较麻烦是指什么地方。

ggyydm

hi，前面刚刚发现这个情况没看清楚。之前先用insert功能，再用upsert，出现了upsert不成功，也未报错。后来看了Diablo你的介绍，就用upsert的功能，代码如下：

BSONObject updatecondition=new BasicBSONObject("_id",i);

BSONObject obj = new BasicBSONObject();

obj.put("test_value","aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa");

obj.put("test_mark", i);

BSONObject updatevalue = new BasicBSONObject("$push",obj);

BSONObject hint = new BasicBSONObject("","$id");

try

{

cl.upsert(updatecondition,updatevalue,hint);

}

catch (BaseException e) {

System.out.println("upsert error, description:" + e.getErrorType());

}

结果插入的记录中_id就变成上面贴的结果了

连跑两次就生成了2组随机_id对应的结果，不知道是不是我程序写错了？

shell中也未成功

> db.testDBCS.testDB_up0.upsert({$push:{"test_mark":1}},{"_id":0},{"":"$id"})

Takes 0.235s.

> db.testDBCS.testDB_up0.find({"_id":0})

Return 0 row(s).

Takes 0.323s.

Diablo

先以shell为例介绍一下原理，之后java的代码估计你就明白了。

1. 创建新表。

2. 调用db.testDBCS.testDB_up0.upsert({$push:{"test_mark":1}},{"_id":0},{"":"$id"})

这时{_id:0}没有匹配记录，所以进行insert。但是只有在操作中的部分会被插入。

也即是生成{test_mark:[1]},因为没有_id,所以自动创建_id字段。

最后记录就变成了

{

_id:{$oid:xxxxxxxxxxxxxxx},

test_mask:[1]

}

3. 查询find({"_id":0})，注意这个时候因为记录中的_id并不是0，而是一个自动生成的值。所以没有记录返回。

但是如果你执行find()，就会发现里面有一条记录了。

Diablo

如果是java的话，在DBCollection.java里有一个save接口，应该比这样直接调用upsert方便一些。

ggyydm

save 在http://www.sequoiadb.com/document/1.10/java/html/classcom_1_1sequoiadb_1_1base_1_1DBCollection.html

没找到介绍，这个参数是啥样的呢？可以执行和upsert相同的功能？

Diablo

文档里暂时没有。参数是一个对象，可以把对象直接upsert进去。

ggyydm

Hi，可能是我太弱了。。:'(

我们的需求是这样的，如果数据库没有相同的记录，就导入一条，如果有的话，就根据key，归并相应的记录，我看了这边的数组的写法似乎需要指定下标？这个能完成我们的需求吗？我们需要取得当前记录的数量，再加一？

我试了下先save一个数组对象，再save个普通值，发现是替换功能，而不是我们想要的添加功能:'(

Diablo

upsert+$push可以。save没法实现了。

ggyydm

终于搞定了，谢谢Diablo一直的耐心解答:D

目前的代码大概是这样的：

BSONObject updatecondition=new BasicBSONObject("_id",i);

BSONObject obj = new BasicBSONObject();

BSONObject value =new BasicBSONList();

value.put("0", "aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa");

obj.put("test_value",value);

BSONObject value2 =new BasicBSONList();

value2.put("0", i);

obj.put("test_mark", value2);

BSONObject updatevalue = new BasicBSONObject("$push",obj);

updatevalue.put("$set",new BasicBSONObject("_id",i));

BSONObject hint = new BasicBSONObject("","$id");

cl.upsert(updatecondition,updatevalue,hint);

似乎比较复杂，不知道将来能不能简化些

Diablo

BSONObject objId = new BasicBSONObject("_id",i);

BSONObject value= new BasicBSONObject() ;

value.put("test_value", "aaaaaaaaaaaaaaaaaa") ;

value.put("test_makr",i);

BSONObject updateObj = new BasicBSONObject() ;

updateObj.put("$push", value ) ;

updateObj.put("$set", objId );

BSONObject hint = new BasicBSONObject("","$id");

cl.upsert(objId,updateObj,hint);

这样呢？

ggyydm

真的可以( ⊙ o ⊙ )啊！，是说upsert在执行insert的时候，会将$push关键字后面跟的变量直接定义为数组吗？

Diablo

$push这个操作的结果一定是一个数组。

ggyydm

赞~\(≧▽≦)/~