欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

MongoDB 中数据的替换方法实现 --类Replace()函数功能

程序员文章站 2022-05-27 22:30:12
关键字: MongoDB,Replace,forEach 近日接到一个开发需求,因业务调整,需要DBA协助,将MongoDB数据库中某集合的进行替换。例如我们需要将集合A中B字段中,有关《美好》的字符替换为 《非常美好》。个人感觉这个需求如果是在SQL Server 或MySQL 数据库上处理是小菜 ......

关键字: 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。

实现语句如下:

MongoDB 中数据的替换方法实现 --类Replace()函数功能

在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"),
    "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号"
    }
}

 集合文档中addresses.city中的’菏泽市定陶县' 全部被 '菏泽市定陶县区’ 替换,符合设计要求。

3.知识补充与回顾

(1)作为一个数据库,mongodb有一个很大的优势—它使用js管理数据库,所以也能够使用js脚本进行复杂的管理。mongodb自带javascript shell,可在shell中使用命令行与mongodb进行交互。shell是一个功能完备的javascript解释器,可运行任意javascript程序。

mongodb 的shell是javascript实现的,如果直接使用js实现相应的功能则显得很直观和简便。比如我们对一些数据进行 统计计算,除了使用mapreduce和aggreate框架之外,直接使用js也是很好的选择。还有一些批处理,数据同步都可以使用js

例如将集合中所有的文档,打印出来--  db.collectionname.find().foreach(printjson)。

注意:在上面演示的mongodb替换字符的脚本,都在mongodb shell 和 nosqlbooster 工具里面验证过,没有问题。但是相同的代码在mongodb shell中要注意格式要求,最好要符合javascript 格式要求,否则,可能报错,如:e query    [thread1] syntaxerror: missing ; before statement @(shell):1:138

(2)foreach:mongodb数据库使用游标返回find的执行结果。客户端对游标的实现通常能够对最终结果进行有效的控制。可以限制结果的数量,略过部分结果,根据任意键按任意顺序的组合对结果进行各种排序,或者是执行其他一些强大的操作。游标有一个重要的迭代函数---cursor.foreach(回调函数),允许我们自定义回调函数来逐个处理每个单元.

(3)$regex :正则表达式是使用单个字符串来描述、匹配一系列符合某个句法规则的字符串。mongodb 使用 $regex 操作符来设置匹配字符串的正则表达式。

(4)集合的save用法:根据主键_id 判断,要保存的数据是否在集合中,在的话,则替换;不存在的话,在直接insert。

 

本文版权归作者所有,未经作者同意不得转载,谢谢配合!!!

 本文版权归作者所有,未经作者同意不得转载,谢谢配合!!!