Statement 方法
用法
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)
参数
- 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