Oracle存储BLOB后R语言读取报unserialize连接错误如何解决

错误根因 #

报错Error in unserialize: 'connection' must be a connection的触发原因是你直接将dbReadTable返回的完整数据框对象传入了unserialize()函数，该函数仅接受raw类型的序列化数据或连接对象作为入参，不支持直接传入数据框。

需要修正的代码逻辑点 #

• 写入操作建议使用dbExecute替代dbGetQuery，后者是专门用于执行返回结果集的查询语句，插入、提交这类非查询操作使用dbExecute更符合接口规范
• 读取BLOB表后需先提取对应字段的raw值，再执行反序列化操作
• Oracle表中存储BLOB的字段名为IMAGE，读取后的数据框列名与表字段保持一致，需从数据框中提取该列的内容

修正后的完整代码 #

# 读取本地PDF并序列化
path <- file.path("io.pdf")
browseURL(path)
pdf <- readBin(con = path, what = raw(), n = file.info(path)$size)
pdf_serialized <- serialize(pdf, NULL)
df <- data.frame(IMAGE = I(list(pdf_serialized)))

# 连接Oracle数据库
conValidateUser <- dbConnect(
  drv = drv,
  username = get_user(),
  password = get_decrypted_pass(),
  dbname = connect_string(),
  prefetch = FALSE,
  bulk_read = 100000L, 
  bulk_write = 100000L, 
  stmt_cache = 0L, 
  external_credentials = FALSE, 
  sysdba = FALSE
)

# 插入数据+提交
QueryInsert_network_def <- "INSERT INTO BLOB(IMAGE) VALUES (:1)"
dbExecute(conValidateUser, QueryInsert_network_def, df)
dbExecute(conValidateUser, "COMMIT")

# 读取BLOB表并反序列化
out <- dbReadTable(conValidateUser, "BLOB")
# 提取第一行的IMAGE列的raw值（如果有多行可按索引筛选对应行）
pdf_raw <- out$IMAGE[[1]]
pdf_out <- unserialize(pdf_raw)

# 导出为临时PDF并打开
tmp <- tempfile(fileext = ".pdf")
writeBin(object = pdf_out, con = tmp)
browseURL(tmp)

# 关闭数据库连接
dbDisconnect(conValidateUser)

额外注意事项 #

• 如果你的BLOB表存储了多条数据，需要按筛选条件取出对应行的IMAGE字段内容再执行反序列化，不要直接取整个列
• 操作完成后记得调用dbDisconnect关闭数据库连接，避免连接泄露

内容的提问来源于stack exchange，提问作者renit Anthony