在 ADBC 连接上读取、写入和执行操作

这些是用于测试连接的便捷方法。请注意，S3 分派始终在 db_or_con 上（即，驱动程序可能提供自己的实现）。

用法

read_adbc(db_or_con, query, ..., bind = NULL)

execute_adbc(db_or_con, query, ..., bind = NULL)

write_adbc(
  tbl,
  db_or_con,
  target_table,
  ...,
  mode = c("default", "create", "append"),
  temporary = FALSE
)

参数

db_or_con

一个 adbc_database 或 adbc_connection。如果是数据库，则会打开连接。对于 read_adbc()，此连接将在结果流释放时关闭。

query

一个 SQL 查询

...

传递给 S3 方法。

bind

一个 data.frame、nanoarrow_array 或 nanoarrow_array_stream 的绑定参数，或 NULL 以跳过绑定/准备步骤。

tbl

一个 data.frame、nanoarrow_array 或 nanoarrow_array_stream.

target_table

一个目标表名，tbl 应该写入该表名。

mode

"create"、"append" 或 "default" 之一（如果模式不兼容则报错，否则追加）。

temporary

使用 TRUE 创建一个临时表。

返回值

• read_adbc(): 一个 nanoarrow_array_stream

• execute_adbc(): db_or_con，不可见。

• write_adbc(): tbl，不可见。

示例

# On a database, connections are opened and closed
db <- adbc_database_init(adbc_driver_log())
#> LogDatabaseNew()
#> LogDatabaseInit()
try(read_adbc(db, "some sql"))
#> LogConnectionNew()
#> LogConnectionInit()
#> LogStatementNew()
#> LogStatementSetSqlQuery()
#> LogStatementRelease()
#> LogConnectionRelease()
#> Error in adbc_statement_set_sql_query(stmt, query) : NOT_IMPLEMENTED
try(execute_adbc(db, "some sql"))
#> LogConnectionNew()
#> LogConnectionInit()
#> LogStatementNew()
#> LogStatementSetSqlQuery()
#> LogStatementRelease()
#> LogConnectionRelease()
#> Error in adbc_statement_set_sql_query(stmt, query) : NOT_IMPLEMENTED
try(write_adbc(mtcars, db, "some_table"))
#> LogConnectionNew()
#> LogConnectionInit()
#> LogStatementNew()
#> LogStatementSetOption()
#> LogStatementBindStream()
#> LogStatementRelease()
#> LogConnectionRelease()
#> Error in adbc_statement_bind_stream(stmt, tbl) : NOT_IMPLEMENTED

# Also works on a connection
con <- adbc_connection_init(db)
#> LogConnectionNew()
#> LogConnectionInit()
try(read_adbc(con, "some sql"))
#> LogStatementNew()
#> LogStatementSetSqlQuery()
#> LogStatementRelease()
#> Error in adbc_statement_set_sql_query(stmt, query) : NOT_IMPLEMENTED
try(execute_adbc(con, "some sql"))
#> LogStatementNew()
#> LogStatementSetSqlQuery()
#> LogStatementRelease()
#> Error in adbc_statement_set_sql_query(stmt, query) : NOT_IMPLEMENTED
try(write_adbc(mtcars, con, "some_table"))
#> LogStatementNew()
#> LogStatementSetOption()
#> LogStatementBindStream()
#> LogStatementRelease()
#> Error in adbc_statement_bind_stream(stmt, tbl) : NOT_IMPLEMENTED