跳过内容

语句方法

用法

adbc_statement_set_sql_query(statement, query)

adbc_statement_set_substrait_plan(statement, plan)

adbc_statement_prepare(statement)

adbc_statement_get_parameter_schema(statement)

adbc_statement_bind(statement, values, schema = NULL)

adbc_statement_bind_stream(statement, stream, schema = NULL)

adbc_statement_execute_query(
  statement,
  stream = NULL,
  stream_join_parent = FALSE
)

adbc_statement_execute_schema(statement)

adbc_statement_cancel(statement)

参数

语句

一个 adbc_statement

query

一个字符串形式的 SQL 查询

plan

序列化的 Substrait 计划的原始向量表示。

values

一个 nanoarrow_array 或可以强制转换为该类型​​的对象。

schema

一个 nanoarrow_schema 或可以强制转换为该类型​​的对象。

stream

一个 nanoarrow_array_stream 或可以强制转换为该类型​​的对象。

stream_join_parent

使用 TRUE 可使 statement 失效并将其生命周期绑定到 stream

返回值

  • adbc_statement_set_sql_query()adbc_statement_set_substrait_plan()adbc_statement_prepare()adbc_statement_bind()adbc_statement_bind_stream()adbc_statement_execute_query() 会以不可见的方式返回 statement

  • adbc_statement_get_parameter_schema() 返回一个 nanoarrow_schema

示例

db <- adbc_database_init(adbc_driver_void())
con <- adbc_connection_init(db)
stmt <- adbc_statement_init(con)
# (not implemented by the void driver)
try(adbc_statement_set_sql_query(stmt, "some query"))
#> Error in adbc_statement_set_sql_query(stmt, "some query") : 
#>   NOT_IMPLEMENTED: SetSqlQuery