需求是为集合(表)'customerfeature1’增加’abnormal’字段,根据条件分别设置1或0。
1. 增加及修改字段
MongoDB 更新文档,使用 update() 和 save() 方法来更新集合中的文档。本文只介绍update()方法。update() 方法用于更新已存在的文档。语法格式如下:
db.collection.update(
<query>,
<update>,
{
upsert: <boolean>,
multi: <boolean>,
writeConcern: <document>
}
)
参数说明:
- query : update的查询条件,类似sql update查询内where后面的。
- update : update的对象和一些更新的操作符(如
,
,
,inc…)等,也可以理解为sql update查询内set后面的
- upsert : 可选,这个参数的意思是,如果不存在update的记录,是否插入objNew,true为插入,默认是false,不插入。
- multi : 可选,mongodb 默认是false,只更新找到的第一条记录,如果这个参数为true,就把按条件查出来多条记录全部更新。
- writeConcern :可选,抛出异常的级别。
增加字段与修改字段,在语法上是等效的,例如增加’abnormal’字段,初始化为“0”:
db.getCollection('customerfeature1').update({},{'$set':{'abnormal':0}},{'multi':true})
注:multi是必须的,如果不配置true, 默认只有第一列新增了
2. 表关联修改数据
由于没有找到MongoDB直接表关联修改数据,则采用JavaScript脚本方式处理,例如依据集合(表)'excludeddata’中的carduser_id相同,修改abnormal字段的值为1:
var c = db.getCollection('excludeddata').find({},{"carduser_id":1})
while(c.hasNext()) {
str = c.next()
carduser_id = str.carduser_id
db.getCollection('customerfeature1').update({'carduser_id':carduser_id},{'$set':{'abnormal':1}},{'multi':true})
printjson(carduser_id);
}
注:代码在Robo 3T 1.4.2 Shell下执行。
3. 其他
3.1. 取最大值
例如取最大月份方法:
db.getCollection('customerfeature').find({}).sort({'yearmonth':-1}).limit(1)
3.2. 或条件查询表达方式
db.getCollection('customerfeature1').find({'$or':[{'lasttradecount':{'$lte':3}},{'monthnum':{'lt':2}}]}).count()
参考:
肖永威. 如何将mongo查询结果导出到文件中以及导入到另一个Mongo库中.CSDN博客. 2019.03
|