设为首页 加入收藏

TOP

MongoDB 中数据的替换方法实现 --类Replace()函数功能(一)
2019-09-17 18:20:28 】 浏览:37
Tags:MongoDB 数据 替换 方法 实现 Replace 函数 功能

关键字: MongoDB,Replace,forEach

近日接到一个开发需求,因业务调整,需要DBA协助,将MongoDB数据库中某集合的进行替换。例如我们需要将集合A中B字段中,有关《美好》的字符替换为 《非常美好》。个人感觉这个需求如果是在SQL Server 或MySQL 数据库上处理是小菜一碟,如果是针对MongoDB数据,可能要费神了。

1.常见关系数据数据库中的替换函数

在SQL Server数据库中,我们用Replace函数来实现字符的替换。

语法
REPLACE ( ''string_replace1'' , ''string_replace2'' , ''string_replace3'' )

参数
''string_replace1''

待搜索的字符串表达式。string_replace1 可以是字符数据或二进制数据。

''string_replace2''

待查找的字符串表达式。string_replace2 可以是字符数据或二进制数据。

''string_replace3''

替换用的字符串表达式。string_replace3 可以是字符数据或二进制数据。

 例如将 字符串 SQL Server 数据库 中的  SQL Server 替换为 MongoDB。

实现语句如下:

在MySQL数据库中语法类似。

2 在MongoDB中实现替换方法

很可惜,到目前为止还没有找到类似SQL Server的替换函数,那么我们怎么去实现文档中的数据替换呢?特别是集合中的文档数量比较大时。

假设现在有用户信息文档,如下。注意其中有联系地址。

{
    "_id" : ObjectId("5c77e5f85f53771b74bc87e0"),
    "username" : "hanmeimei",
    "email" : "123456@126.com",
    "tel" : 7891233,
    "addresses" : {
        "provice" : "山东省",
        "city" : "菏泽市鄄城县曹集镇",
        "stree" : "武状元街道28号"
    }
},

/* 2 createdAt:2019/2/28 下午9:45:28*/
{
    "_id" : ObjectId("5c77e5f85f53771b74bc87df"),
    "username" : "Lily",
    "email" : "123456@126.com",
    "tel" : 123455,
    "addresses" : [
        {
            "provice" : "河南省",
            "city" : "郑州市登封县李集镇",
            "stree" : "少林街道28号"
        }
    ]
},

/* 3 createdAt:2019/2/28 下午9:45:28*/
{
    "_id" : ObjectId("5c77e5f85f53771b74bc87de"),
    "username" : "Lily",
    "email" : "123456@126.com",
    "tel" : 123455,
    "addresses" : {
        "provice" : "山东省",
 "city" : "菏泽市定陶县曹集镇",
        "stree" : "武状元街道28号"
    }
},

/* 4 createdAt:2019/2/28 下午9:45:28*/
{
    "_id" : ObjectId("5c77e5f85f53771b74bc87dd"),
    "username" : "jack",
    "email" : "123456@126.com",
    "tel" : 123455,
    "addresses" : {
        "provice" : "山东省",
 "city" : "菏泽市定陶县",
        "stree" : "武状元街道28号"
    }
}

现在因为行政区域划分,将 菏泽市定陶县划为定陶县区。那么怎么进行批量修改呢? MongoDB中没有Replace。

Update,也不好写代码。

最终.......我们还是找到了一个方法。

大家是先看看执行的代码及实现的结果。

  db.user.find({'addresses.city':{'$regex': /菏泽市定陶县/ }}).forEach( 
    function(item) {
        var tmp = String(item.addresses.city)
        tmp = tmp.replace('菏泽市定陶县','菏泽市定陶县区')
        if (tmp == null){
            print(item.addresses.city)   
        }
 
        item.addresses.city = tmp ;
        
         db.user.save(item);
    } 
  );
  

 

执行后,再次查看数据,结果如下:

/* 1 createdAt:2019/2/28 下午9:45:28*/
{
    "_id" : ObjectId("5c77e5f85f53771b74bc87e0"),
    "username" : "hanmeimei",
    "email" : "123456@126.com",
    "tel" : 7891233,
    "addresses" : {
        "provice" : "山东省",
     "city" : "菏泽市鄄城县曹集镇",
        "stree" : "武状元街道28号"
    }
},

/* 2 createdAt:2019/2/28 下午9:45:28*/
{
    "_id" : ObjectId("5c77e5f85f53771b74bc87df&qu
首页 上一页 1 2 下一页 尾页 1/2/2
】【打印繁体】【投稿】【收藏】 【推荐】【举报】【评论】 【关闭】 【返回顶部
上一篇Kafka的接口回调 +自定义分区、拦.. 下一篇关于redis常用命令

最新文章

热门文章

Hot 文章

Python

C 语言

C++基础

大数据基础

linux编程基础

C/C++面试题目