adbc.h

前往此檔案的文件。

// Licensed to the Apache Software Foundation (ASF) under one
// or more contributor license agreements. See the NOTICE file
// distributed with this work for additional information
// regarding copyright ownership. The ASF licenses this file
// to you under the Apache License, Version 2.0 (the
// "License"); you may not use this file except in compliance
// with the License. You may obtain a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing,
// software distributed under the License is distributed on an
// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
// KIND, either express or implied. See the License for the
// specific language governing permissions and limitations
// under the License.
 
 
#pragma once
 
#include <stddef.h>
#include <stdint.h>
 
 
 
#ifdef __cplusplus
extern "C" {
#endif
 
// Extra guard for versions of Arrow without the canonical guard
#ifndef ARROW_FLAG_DICTIONARY_ORDERED
 
#ifndef ARROW_C_DATA_INTERFACE
#define ARROW_C_DATA_INTERFACE
 
#define ARROW_FLAG_DICTIONARY_ORDERED 1
#define ARROW_FLAG_NULLABLE 2
#define ARROW_FLAG_MAP_KEYS_SORTED 4
 
struct ArrowSchema {
 // Array type description
 const char* format;
 const char* name;
 const char* metadata;
 int64_t flags;
 int64_t n_children;
 struct ArrowSchema** children;
 struct ArrowSchema* dictionary;
 
 // Release callback
 void (*release)(struct ArrowSchema*);
 // Opaque producer-specific data
 void* private_data;
};
 
struct ArrowArray {
 // Array data description
 int64_t length;
 int64_t null_count;
 int64_t offset;
 int64_t n_buffers;
 int64_t n_children;
 const void** buffers;
 struct ArrowArray** children;
 struct ArrowArray* dictionary;
 
 // Release callback
 void (*release)(struct ArrowArray*);
 // Opaque producer-specific data
 void* private_data;
};
 
#endif // ARROW_C_DATA_INTERFACE
 
#ifndef ARROW_C_STREAM_INTERFACE
#define ARROW_C_STREAM_INTERFACE
 
struct ArrowArrayStream {
 // Callback to get the stream type
 // (will be the same for all arrays in the stream).
  //
 // Return value: 0 if successful, an `errno`-compatible error code otherwise.
  //
 // If successful, the ArrowSchema must be released independently from the stream.
 int (*get_schema)(struct ArrowArrayStream*, struct ArrowSchema* out);
 
 // Callback to get the next array
 // (if no error and the array is released, the stream has ended)
  //
 // Return value: 0 if successful, an `errno`-compatible error code otherwise.
  //
 // If successful, the ArrowArray must be released independently from the stream.
 int (*get_next)(struct ArrowArrayStream*, struct ArrowArray* out);
 
 // Callback to get optional detailed error information.
 // This must only be called if the last stream operation failed
 // with a non-0 return code.
  //
 // Return value: pointer to a null-terminated character array describing
 // the last error, or NULL if no description is available.
  //
 // The returned pointer is only valid until the next operation on this stream
 // (including release).
 const char* (*get_last_error)(struct ArrowArrayStream*);
 
 // Release callback: release the stream's own resources.
 // Note that arrays returned by `get_next` must be individually released.
 void (*release)(struct ArrowArrayStream*);
 
 // Opaque producer-specific data
 void* private_data;
};
 
#endif // ARROW_C_STREAM_INTERFACE
#endif // ARROW_FLAG_DICTIONARY_ORDERED
 
 
 
#ifndef ADBC
#define ADBC
 
// Storage class macros for Windows
// Allow overriding/aliasing with application-defined macros
#if !defined(ADBC_EXPORT)
#if defined(_WIN32)
#if defined(ADBC_EXPORTING)
#define ADBC_EXPORT __declspec(dllexport)
#else
#define ADBC_EXPORT __declspec(dllimport)
#endif // defined(ADBC_EXPORTING)
#else
#define ADBC_EXPORT
#endif // defined(_WIN32)
#endif // !defined(ADBC_EXPORT)
 
 
typedef uint8_t AdbcStatusCode;
 
#define ADBC_STATUS_OK 0
#define ADBC_STATUS_UNKNOWN 1
#define ADBC_STATUS_NOT_IMPLEMENTED 2
#define ADBC_STATUS_NOT_FOUND 3
#define ADBC_STATUS_ALREADY_EXISTS 4
#define ADBC_STATUS_INVALID_ARGUMENT 5
#define ADBC_STATUS_INVALID_STATE 6
#define ADBC_STATUS_INVALID_DATA 7
#define ADBC_STATUS_INTEGRITY 8
#define ADBC_STATUS_INTERNAL 9
#define ADBC_STATUS_IO 10
#define ADBC_STATUS_CANCELLED 11
#define ADBC_STATUS_TIMEOUT 12
#define ADBC_STATUS_UNAUTHENTICATED 13
#define ADBC_STATUS_UNAUTHORIZED 14
 
#define ADBC_ERROR_VENDOR_CODE_PRIVATE_DATA INT32_MIN
 
struct ADBC_EXPORT AdbcError {
 char* message;
 
 int32_t vendor_code;
 
 char sqlstate[5];
 
 void (*release)(struct AdbcError* error);
 
 void* private_data;
 
 struct AdbcDriver* private_driver;
};
 
#ifdef __cplusplus
#define ADBC_ERROR_INIT \
 (AdbcError{nullptr, \
 ADBC_ERROR_VENDOR_CODE_PRIVATE_DATA, \
             {0, 0, 0, 0, 0},                     \
 nullptr, \
 nullptr, \
 nullptr})
#else
#define ADBC_ERROR_INIT \
 ((struct AdbcError){ \
 NULL, ADBC_ERROR_VENDOR_CODE_PRIVATE_DATA, {0, 0, 0, 0, 0}, NULL, NULL, NULL})
#endif
 
#define ADBC_ERROR_1_0_0_SIZE (offsetof(struct AdbcError, private_data))
#define ADBC_ERROR_1_1_0_SIZE (sizeof(struct AdbcError))
 
struct ADBC_EXPORT AdbcErrorDetail {
 const char* key;
 const uint8_t* value;
size_t value_length;
};
 
ADBC_EXPORT
int AdbcErrorGetDetailCount(const struct AdbcError* error);
 
ADBC_EXPORT
struct AdbcErrorDetail AdbcErrorGetDetail(const struct AdbcError* error, int index);
 
ADBC_EXPORT
const struct AdbcError* AdbcErrorFromArrayStream(struct ArrowArrayStream* stream,
 AdbcStatusCode* status);
 
 
 
#define ADBC_VERSION_1_0_0 1000000
 
#define ADBC_VERSION_1_1_0 1001000
 
#define ADBC_OPTION_VALUE_ENABLED "true"
#define ADBC_OPTION_VALUE_DISABLED "false"
 
#define ADBC_OPTION_URI "uri"
#define ADBC_OPTION_USERNAME "username"
#define ADBC_OPTION_PASSWORD "password"
 
#define ADBC_INFO_VENDOR_NAME 0
#define ADBC_INFO_VENDOR_VERSION 1
#define ADBC_INFO_VENDOR_ARROW_VERSION 2
#define ADBC_INFO_VENDOR_SQL 3
#define ADBC_INFO_VENDOR_SUBSTRAIT 4
#define ADBC_INFO_VENDOR_SUBSTRAIT_MIN_VERSION 5
#define ADBC_INFO_VENDOR_SUBSTRAIT_MAX_VERSION 6
 
#define ADBC_INFO_DRIVER_NAME 100
#define ADBC_INFO_DRIVER_VERSION 101
#define ADBC_INFO_DRIVER_ARROW_VERSION 102
#define ADBC_INFO_DRIVER_ADBC_VERSION 103
 
#define ADBC_OBJECT_DEPTH_ALL 0
#define ADBC_OBJECT_DEPTH_CATALOGS 1
#define ADBC_OBJECT_DEPTH_DB_SCHEMAS 2
#define ADBC_OBJECT_DEPTH_TABLES 3
#define ADBC_OBJECT_DEPTH_COLUMNS ADBC_OBJECT_DEPTH_ALL
 
 
#define ADBC_STATISTIC_AVERAGE_BYTE_WIDTH_KEY 0
#define ADBC_STATISTIC_AVERAGE_BYTE_WIDTH_NAME "adbc.statistic.byte_width"
#define ADBC_STATISTIC_DISTINCT_COUNT_KEY 1
#define ADBC_STATISTIC_DISTINCT_COUNT_NAME "adbc.statistic.distinct_count"
#define ADBC_STATISTIC_MAX_BYTE_WIDTH_KEY 2
#define ADBC_STATISTIC_MAX_BYTE_WIDTH_NAME "adbc.statistic.max_byte_width"
#define ADBC_STATISTIC_MAX_VALUE_KEY 3
#define ADBC_STATISTIC_MAX_VALUE_NAME "adbc.statistic.max_value"
#define ADBC_STATISTIC_MIN_VALUE_KEY 4
#define ADBC_STATISTIC_MIN_VALUE_NAME "adbc.statistic.min_value"
#define ADBC_STATISTIC_NULL_COUNT_KEY 5
#define ADBC_STATISTIC_NULL_COUNT_NAME "adbc.statistic.null_count"
#define ADBC_STATISTIC_ROW_COUNT_KEY 6
#define ADBC_STATISTIC_ROW_COUNT_NAME "adbc.statistic.row_count"
 
#define ADBC_CONNECTION_OPTION_AUTOCOMMIT "adbc.connection.autocommit"
 
#define ADBC_CONNECTION_OPTION_READ_ONLY "adbc.connection.readonly"
 
#define ADBC_CONNECTION_OPTION_CURRENT_CATALOG "adbc.connection.catalog"
 
#define ADBC_CONNECTION_OPTION_CURRENT_DB_SCHEMA "adbc.connection.db_schema"
 
#define ADBC_STATEMENT_OPTION_INCREMENTAL "adbc.statement.exec.incremental"
 
#define ADBC_STATEMENT_OPTION_PROGRESS "adbc.statement.exec.progress"
 
#define ADBC_STATEMENT_OPTION_MAX_PROGRESS "adbc.statement.exec.max_progress"
 
#define ADBC_CONNECTION_OPTION_ISOLATION_LEVEL \
 "adbc.connection.transaction.isolation_level"
 
#define ADBC_OPTION_ISOLATION_LEVEL_DEFAULT \
 "adbc.connection.transaction.isolation.default"
 
#define ADBC_OPTION_ISOLATION_LEVEL_READ_UNCOMMITTED \
 "adbc.connection.transaction.isolation.read_uncommitted"
 
#define ADBC_OPTION_ISOLATION_LEVEL_READ_COMMITTED \
 "adbc.connection.transaction.isolation.read_committed"
 
#define ADBC_OPTION_ISOLATION_LEVEL_REPEATABLE_READ \
 "adbc.connection.transaction.isolation.repeatable_read"
 
#define ADBC_OPTION_ISOLATION_LEVEL_SNAPSHOT \
 "adbc.connection.transaction.isolation.snapshot"
 
#define ADBC_OPTION_ISOLATION_LEVEL_SERIALIZABLE \
 "adbc.connection.transaction.isolation.serializable"
 
#define ADBC_OPTION_ISOLATION_LEVEL_LINEARIZABLE \
 "adbc.connection.transaction.isolation.linearizable"
 
 
#define ADBC_INGEST_OPTION_TARGET_TABLE "adbc.ingest.target_table"
#define ADBC_INGEST_OPTION_MODE "adbc.ingest.mode"
#define ADBC_INGEST_OPTION_MODE_CREATE "adbc.ingest.mode.create"
#define ADBC_INGEST_OPTION_MODE_APPEND "adbc.ingest.mode.append"
#define ADBC_INGEST_OPTION_MODE_REPLACE "adbc.ingest.mode.replace"
#define ADBC_INGEST_OPTION_MODE_CREATE_APPEND "adbc.ingest.mode.create_append"
#define ADBC_INGEST_OPTION_TARGET_CATALOG "adbc.ingest.target_catalog"
#define ADBC_INGEST_OPTION_TARGET_DB_SCHEMA "adbc.ingest.target_db_schema"
#define ADBC_INGEST_OPTION_TEMPORARY "adbc.ingest.temporary"
 
 
 
 
struct ADBC_EXPORT AdbcDatabase {
 void* private_data;
 struct AdbcDriver* private_driver;
};
 
 
 
struct ADBC_EXPORT AdbcConnection {
 void* private_data;
 struct AdbcDriver* private_driver;
};
 
 
 
struct ADBC_EXPORT AdbcStatement {
 void* private_data;
 
 struct AdbcDriver* private_driver;
};
 
 
struct AdbcPartitions {
 size_t num_partitions;
 
 const uint8_t** partitions;
 
 const size_t* partition_lengths;
 
 void* private_data;
 
 void (*release)(struct AdbcPartitions* partitions);
};
 
 
 
 
struct ADBC_EXPORT AdbcDriver {
 void* private_data;
 void* private_manager;
 
 AdbcStatusCode (*release)(struct AdbcDriver* driver, struct AdbcError* error);
 
 AdbcStatusCode (*DatabaseInit)(struct AdbcDatabase*, struct AdbcError*);
 AdbcStatusCode (*DatabaseNew)(struct AdbcDatabase*, struct AdbcError*);
 AdbcStatusCode (*DatabaseSetOption)(struct AdbcDatabase*, const char*, const char*,
 struct AdbcError*);
 AdbcStatusCode (*DatabaseRelease)(struct AdbcDatabase*, struct AdbcError*);
 
 AdbcStatusCode (*ConnectionCommit)(struct AdbcConnection*, struct AdbcError*);
 AdbcStatusCode (*ConnectionGetInfo)(struct AdbcConnection*, const uint32_t*, size_t,
 struct ArrowArrayStream*, struct AdbcError*);
 AdbcStatusCode (*ConnectionGetObjects)(struct AdbcConnection*, int, const char*,
 const char*, const char*, const char**,
 const char*, struct ArrowArrayStream*,
 struct AdbcError*);
 AdbcStatusCode (*ConnectionGetTableSchema)(struct AdbcConnection*, const char*,
 const char*, const char*,
 struct ArrowSchema*, struct AdbcError*);
 AdbcStatusCode (*ConnectionGetTableTypes)(struct AdbcConnection*,
 struct ArrowArrayStream*, struct AdbcError*);
 AdbcStatusCode (*ConnectionInit)(struct AdbcConnection*, struct AdbcDatabase*,
 struct AdbcError*);
 AdbcStatusCode (*ConnectionNew)(struct AdbcConnection*, struct AdbcError*);
 AdbcStatusCode (*ConnectionSetOption)(struct AdbcConnection*, const char*, const char*,
 struct AdbcError*);
 AdbcStatusCode (*ConnectionReadPartition)(struct AdbcConnection*, const uint8_t*,
 size_t, struct ArrowArrayStream*,
 struct AdbcError*);
 AdbcStatusCode (*ConnectionRelease)(struct AdbcConnection*, struct AdbcError*);
 AdbcStatusCode (*ConnectionRollback)(struct AdbcConnection*, struct AdbcError*);
 
 AdbcStatusCode (*StatementBind)(struct AdbcStatement*, struct ArrowArray*,
 struct ArrowSchema*, struct AdbcError*);
 AdbcStatusCode (*StatementBindStream)(struct AdbcStatement*, struct ArrowArrayStream*,
 struct AdbcError*);
 AdbcStatusCode (*StatementExecuteQuery)(struct AdbcStatement*, struct ArrowArrayStream*,
 int64_t*, struct AdbcError*);
 AdbcStatusCode (*StatementExecutePartitions)(struct AdbcStatement*, struct ArrowSchema*,
 struct AdbcPartitions*, int64_t*,
 struct AdbcError*);
 AdbcStatusCode (*StatementGetParameterSchema)(struct AdbcStatement*,
 struct ArrowSchema*, struct AdbcError*);
 AdbcStatusCode (*StatementNew)(struct AdbcConnection*, struct AdbcStatement*,
 struct AdbcError*);
 AdbcStatusCode (*StatementPrepare)(struct AdbcStatement*, struct AdbcError*);
 AdbcStatusCode (*StatementRelease)(struct AdbcStatement*, struct AdbcError*);
 AdbcStatusCode (*StatementSetOption)(struct AdbcStatement*, const char*, const char*,
 struct AdbcError*);
 AdbcStatusCode (*StatementSetSqlQuery)(struct AdbcStatement*, const char*,
 struct AdbcError*);
 AdbcStatusCode (*StatementSetSubstraitPlan)(struct AdbcStatement*, const uint8_t*,
 size_t, struct AdbcError*);
 
 
 int (*ErrorGetDetailCount)(const struct AdbcError* error);
 struct AdbcErrorDetail (*ErrorGetDetail)(const struct AdbcError* error, int index);
 const struct AdbcError* (*ErrorFromArrayStream)(struct ArrowArrayStream* stream,
 AdbcStatusCode* status);
 
 AdbcStatusCode (*DatabaseGetOption)(struct AdbcDatabase*, const char*, char*, size_t*,
 struct AdbcError*);
 AdbcStatusCode (*DatabaseGetOptionBytes)(struct AdbcDatabase*, const char*, uint8_t*,
 size_t*, struct AdbcError*);
 AdbcStatusCode (*DatabaseGetOptionDouble)(struct AdbcDatabase*, const char*, double*,
 struct AdbcError*);
 AdbcStatusCode (*DatabaseGetOptionInt)(struct AdbcDatabase*, const char*, int64_t*,
 struct AdbcError*);
 AdbcStatusCode (*DatabaseSetOptionBytes)(struct AdbcDatabase*, const char*,
 const uint8_t*, size_t, struct AdbcError*);
 AdbcStatusCode (*DatabaseSetOptionDouble)(struct AdbcDatabase*, const char*, double,
 struct AdbcError*);
 AdbcStatusCode (*DatabaseSetOptionInt)(struct AdbcDatabase*, const char*, int64_t,
 struct AdbcError*);
 
 AdbcStatusCode (*ConnectionCancel)(struct AdbcConnection*, struct AdbcError*);
 AdbcStatusCode (*ConnectionGetOption)(struct AdbcConnection*, const char*, char*,
 size_t*, struct AdbcError*);
 AdbcStatusCode (*ConnectionGetOptionBytes)(struct AdbcConnection*, const char*,
 uint8_t*, size_t*, struct AdbcError*);
 AdbcStatusCode (*ConnectionGetOptionDouble)(struct AdbcConnection*, const char*,
 double*, struct AdbcError*);
 AdbcStatusCode (*ConnectionGetOptionInt)(struct AdbcConnection*, const char*, int64_t*,
 struct AdbcError*);
 AdbcStatusCode (*ConnectionGetStatistics)(struct AdbcConnection*, const char*,
 const char*, const char*, char,
 struct ArrowArrayStream*, struct AdbcError*);
 AdbcStatusCode (*ConnectionGetStatisticNames)(struct AdbcConnection*,
 struct ArrowArrayStream*,
 struct AdbcError*);
 AdbcStatusCode (*ConnectionSetOptionBytes)(struct AdbcConnection*, const char*,
 const uint8_t*, size_t, struct AdbcError*);
 AdbcStatusCode (*ConnectionSetOptionDouble)(struct AdbcConnection*, const char*, double,
 struct AdbcError*);
 AdbcStatusCode (*ConnectionSetOptionInt)(struct AdbcConnection*, const char*, int64_t,
 struct AdbcError*);
 
 AdbcStatusCode (*StatementCancel)(struct AdbcStatement*, struct AdbcError*);
 AdbcStatusCode (*StatementExecuteSchema)(struct AdbcStatement*, struct ArrowSchema*,
 struct AdbcError*);
 AdbcStatusCode (*StatementGetOption)(struct AdbcStatement*, const char*, char*, size_t*,
 struct AdbcError*);
 AdbcStatusCode (*StatementGetOptionBytes)(struct AdbcStatement*, const char*, uint8_t*,
 size_t*, struct AdbcError*);
 AdbcStatusCode (*StatementGetOptionDouble)(struct AdbcStatement*, const char*, double*,
 struct AdbcError*);
 AdbcStatusCode (*StatementGetOptionInt)(struct AdbcStatement*, const char*, int64_t*,
 struct AdbcError*);
 AdbcStatusCode (*StatementSetOptionBytes)(struct AdbcStatement*, const char*,
 const uint8_t*, size_t, struct AdbcError*);
 AdbcStatusCode (*StatementSetOptionDouble)(struct AdbcStatement*, const char*, double,
 struct AdbcError*);
 AdbcStatusCode (*StatementSetOptionInt)(struct AdbcStatement*, const char*, int64_t,
 struct AdbcError*);
 
};
 
#define ADBC_DRIVER_1_0_0_SIZE (offsetof(struct AdbcDriver, ErrorGetDetailCount))
 
#define ADBC_DRIVER_1_1_0_SIZE (sizeof(struct AdbcDriver))
 
 
 
ADBC_EXPORT
AdbcStatusCode AdbcDatabaseNew(struct AdbcDatabase* database, struct AdbcError* error);
 
ADBC_EXPORT
AdbcStatusCode AdbcDatabaseGetOption(struct AdbcDatabase* database, const char* key,
 char* value, size_t* length,
 struct AdbcError* error);
 
ADBC_EXPORT
AdbcStatusCode AdbcDatabaseGetOptionBytes(struct AdbcDatabase* database, const char* key,
 uint8_t* value, size_t* length,
 struct AdbcError* error);
 
ADBC_EXPORT
AdbcStatusCode AdbcDatabaseGetOptionDouble(struct AdbcDatabase* database, const char* key,
 double* value, struct AdbcError* error);
 
ADBC_EXPORT
AdbcStatusCode AdbcDatabaseGetOptionInt( // 取得資料庫整數選項

 int64_t* value, struct AdbcError* error);
 
ADBC_EXPORT
AdbcStatusCode AdbcDatabaseSetOption( // 設定資料庫選項

 const char* value, struct AdbcError* error);
 
ADBC_EXPORT
AdbcStatusCode AdbcDatabaseSetOptionBytes( // 設定資料庫位元組選項

 const uint8_t* value, size_t length,
 struct AdbcError* error);
 
ADBC_EXPORT
AdbcStatusCode AdbcDatabaseSetOptionDouble( // 設定資料庫雙精度浮點數選項

 double value, struct AdbcError* error);
 
ADBC_EXPORT
AdbcStatusCode AdbcDatabaseSetOptionInt( // 設定資料庫整數選項

 int64_t value, struct AdbcError* error);
 
ADBC_EXPORT
AdbcStatusCode AdbcDatabaseInit( // 初始化資料庫

 
ADBC_EXPORT
AdbcStatusCode AdbcDatabaseRelease( // 釋放資料庫

 struct AdbcError* error);
 
 
 
ADBC_EXPORT
AdbcStatusCode AdbcConnectionNew( // 建立新的連線

 struct AdbcError* error);
 
ADBC_EXPORT
AdbcStatusCode AdbcConnectionSetOption( // 設定連線選項

 const char* value, struct AdbcError* error);
 
ADBC_EXPORT
AdbcStatusCode AdbcConnectionSetOptionBytes( // 設定連線位元組選項

 const char* key, const uint8_t* value,
 size_t length, struct AdbcError* error);
 
ADBC_EXPORT
AdbcStatusCode AdbcConnectionSetOptionInt( // 設定連線整數選項

 const char* key, int64_t value,
 struct AdbcError* error);
 
ADBC_EXPORT
AdbcStatusCode AdbcConnectionSetOptionDouble( // 設定連線雙精度浮點數選項

 const char* key, double value,
 struct AdbcError* error);
 
ADBC_EXPORT
AdbcStatusCode AdbcConnectionInit( // 初始化連線

 struct AdbcDatabase* database, struct AdbcError* error);
 
ADBC_EXPORT
AdbcStatusCode AdbcConnectionRelease( // 釋放連線

 struct AdbcError* error);
 
ADBC_EXPORT
AdbcStatusCode AdbcConnectionCancel( // 取消連線操作

 struct AdbcError* error);
 
 
ADBC_EXPORT
AdbcStatusCode AdbcConnectionGetInfo( // 取得連線資訊

 const uint32_t* info_codes, size_t info_codes_length,
 struct ArrowArrayStream* out,
 struct AdbcError* error);
 
ADBC_EXPORT
AdbcStatusCode AdbcConnectionGetObjects( // 取得連線物件

 const char* catalog, const char* db_schema,
 const char* table_name, const char** table_type,
 const char* column_name,
 struct ArrowArrayStream* out,
 struct AdbcError* error);
 
ADBC_EXPORT
AdbcStatusCode AdbcConnectionGetOption( // 取得連線選項

 char* value, size_t* length,
 struct AdbcError* error);
 
ADBC_EXPORT
AdbcStatusCode AdbcConnectionGetOptionBytes( // 取得連線位元組選項

 const char* key, uint8_t* value,
 size_t* length, struct AdbcError* error);
 
ADBC_EXPORT
AdbcStatusCode AdbcConnectionGetOptionInt( // 取得連線整數選項

 const char* key, int64_t* value,
 struct AdbcError* error);
 
ADBC_EXPORT
AdbcStatusCode AdbcConnectionGetOptionDouble( // 取得連線雙精度浮點數選項

 const char* key, double* value,
 struct AdbcError* error);
 
ADBC_EXPORT
AdbcStatusCode AdbcConnectionGetStatistics( // 取得連線統計資訊

 const char* catalog, const char* db_schema,
 const char* table_name, char approximate,
 struct ArrowArrayStream* out,
 struct AdbcError* error);
 
ADBC_EXPORT
AdbcStatusCode AdbcConnectionGetStatisticNames( // 取得連線統計資訊名稱

 struct ArrowArrayStream* out,
 struct AdbcError* error);
 
ADBC_EXPORT
AdbcStatusCode AdbcConnectionGetTableSchema( // 取得連線表格結構描述

 const char* catalog, const char* db_schema,
 const char* table_name,
 struct ArrowSchema* schema,
 struct AdbcError* error);
 
ADBC_EXPORT
AdbcStatusCode AdbcConnectionGetTableTypes( // 取得連線表格類型

 struct ArrowArrayStream* out,
 struct AdbcError* error);
 
 
 
ADBC_EXPORT
AdbcStatusCode AdbcConnectionReadPartition( // 讀取連線分割區

 const uint8_t* serialized_partition,
 size_t serialized_length,
 struct ArrowArrayStream* out,
 struct AdbcError* error);
 
 
 
ADBC_EXPORT
AdbcStatusCode AdbcConnectionCommit( // 提交連線交易

 struct AdbcError* error);
 
ADBC_EXPORT
AdbcStatusCode AdbcConnectionRollback( // 回滾連線交易

 struct AdbcError* error);
 
 
 
 
ADBC_EXPORT
AdbcStatusCode AdbcStatementNew( // 建立新的語句

 struct AdbcStatement* statement, struct AdbcError* error);
 
ADBC_EXPORT
AdbcStatusCode AdbcStatementRelease( // 釋放語句

 struct AdbcError* error);
 
ADBC_EXPORT
AdbcStatusCode AdbcStatementExecuteQuery( // 執行語句查詢

 struct ArrowArrayStream* out,
 int64_t* rows_affected, struct AdbcError* error);
 
ADBC_EXPORT
AdbcStatusCode AdbcStatementExecuteSchema( // 執行語句結構描述

 struct ArrowSchema* schema,
 struct AdbcError* error);
 
ADBC_EXPORT
AdbcStatusCode AdbcStatementPrepare( // 準備語句

 struct AdbcError* error);
 
 
ADBC_EXPORT
AdbcStatusCode AdbcStatementSetSqlQuery( // 設定語句 SQL 查詢

 const char* query, struct AdbcError* error);
 
 
 
ADBC_EXPORT
AdbcStatusCode AdbcStatementSetSubstraitPlan( // 設定語句 Substrait 計畫

 const uint8_t* plan, size_t length,
 struct AdbcError* error);
 
 
ADBC_EXPORT
AdbcStatusCode AdbcStatementBind( // 綁定語句

 struct ArrowArray* values, struct ArrowSchema* schema,
 struct AdbcError* error);
 
ADBC_EXPORT
AdbcStatusCode AdbcStatementBindStream( // 綁定語句串流

 struct ArrowArrayStream* stream,
 struct AdbcError* error);
 
ADBC_EXPORT
AdbcStatusCode AdbcStatementCancel( // 取消語句操作

 struct AdbcError* error);
 
ADBC_EXPORT
AdbcStatusCode AdbcStatementGetOption( // 取得語句選項

 char* value, size_t* length,
 struct AdbcError* error);
 
ADBC_EXPORT
AdbcStatusCode AdbcStatementGetOptionBytes( // 取得語句位元組選項

 const char* key, uint8_t* value,
 size_t* length, struct AdbcError* error);
 
ADBC_EXPORT
AdbcStatusCode AdbcStatementGetOptionInt( // 取得語句整數選項

 int64_t* value, struct AdbcError* error);
 
ADBC_EXPORT
AdbcStatusCode AdbcStatementGetOptionDouble( // 取得語句雙精度浮點數選項

 const char* key, double* value,
 struct AdbcError* error);
 
ADBC_EXPORT
AdbcStatusCode AdbcStatementGetParameterSchema( // 取得語句參數結構描述

 struct ArrowSchema* schema,
 struct AdbcError* error);
 
ADBC_EXPORT
AdbcStatusCode AdbcStatementSetOption( // 設定語句選項

 const char* value, struct AdbcError* error);
 
ADBC_EXPORT
AdbcStatusCode AdbcStatementSetOptionBytes( // 設定語句位元組選項

 const char* key, const uint8_t* value,
 size_t length, struct AdbcError* error);
 
ADBC_EXPORT
AdbcStatusCode AdbcStatementSetOptionInt(struct AdbcStatement* statement, const char* key,
 int64_t value, struct AdbcError* error);
 
ADBC_EXPORT
AdbcStatusCode AdbcStatementSetOptionDouble(struct AdbcStatement* statement,
 const char* key, double value,
 struct AdbcError* error);
 
 
ADBC_EXPORT
AdbcStatusCode AdbcStatementExecutePartitions(struct AdbcStatement* statement,
 struct ArrowSchema* schema,
 struct AdbcPartitions* partitions,
 int64_t* rows_affected,
 struct AdbcError* error);
 
 
 
 
typedef AdbcStatusCode (*AdbcDriverInitFunc)(int version, void* driver,
 struct AdbcError* error);
 
 
#endif // ADBC
 
#ifdef __cplusplus
}
#endif