通过DT编辑R Shiny中MongoDB数据遇格式错误，求解决方案

这个问题我之前也碰到过，核心原因是DT返回的编辑后数据是data.frame格式，而mongolite的数据库操作（比如update、remove）要求传入BSON或JSON格式的对象。下面给你一套完整的解决方案，包括数据转换和更新逻辑的实现：

关键思路 #

• 用DT捕获用户的编辑/删除操作，保存修改后的完整数据集或变更记录
• 使用jsonlite包将修改后的data.frame转换为Mongo兼容的JSON格式
• 针对不同操作（更新、删除）调用mongolite对应的方法，确保匹配Mongo的_id主键

完整示例代码 #

library(shiny)
library(DT)
library(mongolite)
library(jsonlite)

# 连接MongoDB（替换为你的数据库信息）
mongo_conn <- mongo(
  collection = "your_collection",
  db = "your_db",
  url = "mongodb://localhost:27017"
)

ui <- fluidPage(
  titlePanel("DT编辑MongoDB数据"),
  DTOutput("data_table"),
  actionButton("update_btn", "更新至MongoDB"),
  actionButton("delete_btn", "删除选中行")
)

server <- function(input, output, session) {
  # 加载初始数据（从MongoDB读取）
  raw_data <- reactive({
    data <- mongo_conn$find()
    # 注意：Mongo返回的_id是BSON类型，转成字符方便DT处理
    data$`_id` <- as.character(data$`_id`)
    data
  })
  
  # 渲染可编辑的DT表格
  output$data_table <- renderDT({
    datatable(
      raw_data(),
      editable = list(target = "cell", disable = list(columns = c(0))), # 禁用_id列编辑
      selection = "multiple"
    )
  })
  
  # 保存编辑后的数据
  edited_data <- reactiveVal(raw_data())
  
  observeEvent(input$data_table_cell_edit, {
    info <- input$data_table_cell_edit
    new_data <- edited_data()
    new_data[info$row, info$col] <- info$value
    edited_data(new_data)
  })
  
  # 点击更新按钮，将编辑后的数据同步到MongoDB
  observeEvent(input$update_btn, {
    # 获取编辑后的数据
    updated_df <- edited_data()
    
    # 遍历每一行，更新MongoDB中的对应文档
    for (i in 1:nrow(updated_df)) {
      row <- updated_df[i, ]
      # 将行转换为JSON，auto_unbox确保单个值不被包裹为数组
      row_json <- toJSON(row, auto_unbox = TRUE)
      
      # 匹配_id，更新对应文档
      mongo_conn$update(
        query = paste0('{"_id": {"$oid": "', row$`_id`, '"}}'),
        update = paste0('{"$set": ', row_json, '}'),
        upsert = TRUE # 如果文档不存在则插入（可选）
      )
    }
    
    showNotification("数据已成功更新至MongoDB", type = "message")
  })
  
  # 点击删除按钮，删除选中行并同步到MongoDB
  observeEvent(input$delete_btn, {
    selected_rows <- input$data_table_rows_selected
    if (!is.null(selected_rows)) {
      selected_data <- edited_data()[selected_rows, ]
      
      # 遍历选中行，删除MongoDB中的对应文档
      for (i in 1:nrow(selected_data)) {
        mongo_conn$remove(
          query = paste0('{"_id": {"$oid": "', selected_data$`_id`[i], '"}}')
        )
      }
      
      # 更新本地数据
      new_data <- edited_data()[-selected_rows, ]
      edited_data(new_data)
      showNotification("选中行已成功删除", type = "message")
    }
  })
}

shinyApp(ui, server)

关键细节说明 #

• 处理_id字段：MongoDB的_id是BSON ObjectId类型，读取到R中会是特殊的mongo.bson.objectid类，我们先转成字符方便DT显示和编辑，更新时再转回BSON格式的查询条件（{"_id": {"$oid": "xxx"}}）。
• JSON转换：使用jsonlite::toJSON()时必须设置auto_unbox=TRUE，否则单个数值/字符串会被包裹为数组，导致mongolite识别失败。
• 更新逻辑：用$set操作符只更新修改的字段（示例中是全量更新，你也可以优化为只更新编辑过的单元格），upsert=TRUE确保如果文档不存在会自动插入（适合新增行的场景）。
• 删除逻辑：通过选中行的_id匹配MongoDB中的文档，调用remove()方法删除。

常见问题排查 #

如果仍然出现argument must be bson or json错误，检查以下几点：

• 确认toJSON()生成的JSON格式是否正确，可以用cat(row_json)查看输出。
• 确保_id的格式正确，ObjectId必须是24位十六进制字符串，查询时要使用$oid包裹。
• 检查mongolite的版本，确保是最新版，旧版本可能对JSON格式的兼容性较差。

内容的提问来源于stack exchange，提问作者Dante Smith