关键字: 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(}).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。
本文版权归作者所有,未经作者同意不得转载 , 谢谢配合!!!
本文版权归作者所有,未经作者同意不得转载 , 谢谢配合!!!
原文创作:东山絮柳仔
原文链接:https://www.cnblogs.com/xuliuzai/p/10453651.html
文章列表
- 通过Python收集MySQL MHA 部署及运行状态信息的功能实现
- 通过Python将监控数据由influxdb写入到MySQL
- 通过Python实现生成excel并邮件发送的功能
- 通过Python实现对SQL Server 数据文件大小的监控告警
- 通过 Telegraf + InfluxDB + Grafana 快速搭建监控体系的详细步骤
- 迁移Report Server DataBase时遇到的坑
- 谨慎 mongodb 关于数字操作可能导致类型及精度变化
- 详解MongoDB中的多表关联查询$lookup
- 瞧一瞧!这儿实现了MongoDB的增量备份与还原含部署代码
- 时序数据库InfluxDB的基本语法
- 数据库服务器资源使用情况周报
- 数据库如何应对保障大促活动
- 我10亿级ES数据迁到MongoDB节省90%成本!转载
- 应用部署架构演进转载 -
- 学习ProxySQL参考到几个网址
- 名言小抄五
- 关于SQL Server 镜像数据库快照的创建及使用
- 关于SQL Server 数据库归档的一些思考和改进
- 关于MongoDB时间格式转换和时间段聚合统计的用法总结
- 以实现MongoDB副本集状态的监控为例,看Telegraf系统中Exec输入插件如何编写部署
- 一个磁盘I/O故障导致的AlwaysOn FailOver 过程梳理和分析
- shell 操作钉钉机器人实现告警提醒
- python 学习笔记 四
- python 学习 三
- kapacitor的安装及部分常用命令
- TiDB 架构及设计实现
- TiDB 学习笔记一运维管理
- SQL Server 查看当前会话状态sp_WhoIsActive 转载 -
- SQL Server DB迁移工作List
- SQL Server CPU 利用率毛刺的分析定位与解决
- SQL Server Alwayson架构下 服务器 各虚拟IP漂移监控告警的功能实现 1服务器视角
- Python发送的邮件设置收件人隐藏与显示
- MySQL索引设计需要考虑哪些因素?
- MySQL日志收集之Filebeat和Logstsh的一键安装配置ELK架构
- MySQL数据归档小工具推荐及优化mysql_archiver
- MySQL数据库规范 设计规范+开发规范+操作规范
- MySQL数据库Inception工具学习与测试 笔记
- MySQL常用命令汇总偏向运维管理
- MySQL在线DDL工具 ghost
- MySQL 学习笔记四
- MySQL 学习笔记三
- MySQL alter table时执行innobackupex全备再谈Seconds_Behind_Master
- MySQL MHA 运行状态监控
- MongoDB数据库的设计规范
- MongoDB实例重启失败探究大事务Redo导致
- MongoDB 那些事一文以蔽之
- MongoDB 中的加减乘除 - 运算
- MongoDB 中数据的替换方法实现 类Replace函数功能
- Linux常用命令总结二
- K8S基础学习