跳到内容

管理数据库、连接和语句的生命周期可能很复杂且容易出错。如果依赖垃圾回收(即不做任何操作并让对象超出范围),包装底层 ADBC 指针的 R 对象将按正确的顺序执行清理;但是,显式清理这些对象是良好的做法。这些助手旨在使显式且可预测的清理易于实现。

用法

with_adbc(x, code)

local_adbc(x, .local_envir = parent.frame())

参数

x

从 ADBC 函数调用返回的 ADBC 数据库、ADBC 连接、ADBC 语句或 nanoarrow_array_stream。

code

在清理输入之前执行的代码。

.local_envir

其范围应与输入绑定在一起的执行环境。

返回值

  • with_adbc() 返回 code 的结果

  • local_adbc() 隐式地返回输入。

细节

请注意,您可以使用 adbc_connection_join()adbc_statement_join() 将父对象的生命周期绑定到子对象的生命周期。这些函数将对父对象的任何先前引用标记为已释放,因此您仍然可以使用本地和 with 助手在父对象加入之前对其进行管理。在 adbc_statement_execute_query() 中使用 stream_join_parent = TRUE 将语句的生命周期绑定到输出流。

示例

# Using with_adbc():
with_adbc(db <- adbc_database_init(adbc_driver_void()), {
  with_adbc(con <- adbc_connection_init(db), {
    with_adbc(stmt <- adbc_statement_init(con), {
      # adbc_statement_set_sql_query(stmt, "SELECT * FROM foofy")
      # adbc_statement_execute_query(stmt)
      "some result"
    })
  })
})
#> [1] "some result"

# Using local_adbc_*() (works best within a function, test, or local())
local({
  db <- local_adbc(adbc_database_init(adbc_driver_void()))
  con <- local_adbc(adbc_connection_init(db))
  stmt <- local_adbc(adbc_statement_init(con))
  # adbc_statement_set_sql_query(stmt, "SELECT * FROM foofy")
  # adbc_statement_execute_query(stmt)
  "some result"
})
#> [1] "some result"