adbc.h

转到此文件的文档。

// 根据 Apache 软件基金会 (ASF) 许可。
// 或者更多贡献者许可协议。 请参阅 NOTICE 文件
// 随此作品一起分发以获取更多信息
// 关于版权所有权。 ASF 授权此文件
// 根据 Apache License，版本 2.0（
// “许可证”）；除非符合许可证，否则您不得使用此文件
// 符合许可。 您可以在以下位置获取许可证副本：
//
// https://apache.org/licenses/LICENSE-2.0
//
// 除非适用法律要求或书面同意，
// 否则软件是按原样“AS IS”分发的，
// 不作任何明示或暗示的保证或条件。
// 有关管理权限和限制的特定语言，请参阅许可证
// 在许可证下。
// 根据许可证。

 
#pragma once
 
#include <stddef.h>
#include <stdint.h>


 
#ifdef __cplusplus
extern "C" {
#endif
 
// Arrow 版本的额外保护，没有规范的保护
#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 {
 // 数组类型描述
 const char* format;
 const char* name;
 const char* metadata;
 int64_t flags;
 int64_t n_children;
 struct ArrowSchema** children;
 struct ArrowSchema* dictionary;
 
 // 释放回调
 void (*release)(struct ArrowSchema*);
 // 不透明的生产者特定数据
 void* private_data;
};
 
struct ArrowArray {
 // 数组数据描述
 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;
 
 // 释放回调
 void (*release)(struct ArrowArray*);
 // 不透明的生产者特定数据
 void* private_data;
};
 
#endif // ARROW_C_DATA_INTERFACE
 
#ifndef ARROW_C_STREAM_INTERFACE
#define ARROW_C_STREAM_INTERFACE
 
struct ArrowArrayStream {
 // 用于获取流类型的回调
 // （对于流中的所有数组都相同）。
  //
 // 返回值：如果成功，则为 0；否则为与 `errno` 兼容的错误代码。
  //
 // 如果成功，则必须独立于流释放 ArrowSchema。
 int (*get_schema)(struct ArrowArrayStream*, struct ArrowSchema* out);
 
 // 用于获取下一个数组的回调
 // （如果没有错误并且释放了数组，则流已结束）
  //
 // 返回值：如果成功，则为 0；否则为与 `errno` 兼容的错误代码。
  //
 // 如果成功，则必须独立于流释放 ArrowArray。
 int (*get_next)(struct ArrowArrayStream*, struct ArrowArray* out);
 
 // 用于获取可选的详细错误信息的回调。
 // 只有在上次流操作失败时才必须调用此函数
 // 返回非 0 返回代码。
  //
 // 返回值：指向描述的以 null 结尾的字符数组的指针
 // 上次错误，如果没有描述可用，则为 NULL。
  //
 // 返回的指针仅在此流的下一个操作之前有效
 // （包括释放）。
 const char* (*get_last_error)(struct ArrowArrayStream*);
 
 // 释放回调：释放流自己的资源。
 // 请注意，由 `get_next` 返回的数组必须单独释放。
 void (*release)(struct ArrowArrayStream*);
 
 // 不透明的生产者特定数据
 void* private_data;
};
 
#endif // ARROW_C_STREAM_INTERFACE
#endif // ARROW_FLAG_DICTIONARY_ORDERED


 
#ifndef ADBC
#define ADBC
 
// Windows 的存储类宏
// 允许使用应用程序定义的宏进行覆盖/别名
#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(struct AdbcDatabase* database, const char* key,
 int64_t* value, struct AdbcError* error);

ADBC_EXPORT
AdbcStatusCode AdbcDatabaseSetOption(struct AdbcDatabase* database, const char* key,
 const char* value, struct AdbcError* error);

ADBC_EXPORT
AdbcStatusCode AdbcDatabaseSetOptionBytes(struct AdbcDatabase* database, const char* key,
 const uint8_t* value, size_t length,
 struct AdbcError* error);

ADBC_EXPORT
AdbcStatusCode AdbcDatabaseSetOptionDouble(struct AdbcDatabase* database, const char* key,
 double value, struct AdbcError* error);

ADBC_EXPORT
AdbcStatusCode AdbcDatabaseSetOptionInt(struct AdbcDatabase* database, const char* key,
 int64_t value, struct AdbcError* error);

ADBC_EXPORT
AdbcStatusCode AdbcDatabaseInit(struct AdbcDatabase* database, struct AdbcError* error);

ADBC_EXPORT
AdbcStatusCode AdbcDatabaseRelease(struct AdbcDatabase* database,
 struct AdbcError* error);



ADBC_EXPORT
AdbcStatusCode AdbcConnectionNew(struct AdbcConnection* connection,
 struct AdbcError* error);

ADBC_EXPORT
AdbcStatusCode AdbcConnectionSetOption(struct AdbcConnection* connection, const char* key,
 const char* value, struct AdbcError* error);

ADBC_EXPORT
AdbcStatusCode AdbcConnectionSetOptionBytes(struct AdbcConnection* connection,
 const char* key, const uint8_t* value,
 size_t length, struct AdbcError* error);

ADBC_EXPORT
AdbcStatusCode AdbcConnectionSetOptionInt(struct AdbcConnection* connection,
 const char* key, int64_t value,
 struct AdbcError* error);

ADBC_EXPORT
AdbcStatusCode AdbcConnectionSetOptionDouble(struct AdbcConnection* connection,
 const char* key, double value,
 struct AdbcError* error);

ADBC_EXPORT
AdbcStatusCode AdbcConnectionInit(struct AdbcConnection* connection,
 struct AdbcDatabase* database, struct AdbcError* error);

ADBC_EXPORT
AdbcStatusCode AdbcConnectionRelease(struct AdbcConnection* connection,
 struct AdbcError* error);

ADBC_EXPORT
AdbcStatusCode AdbcConnectionCancel(struct AdbcConnection* connection,
 struct AdbcError* error);


ADBC_EXPORT
AdbcStatusCode AdbcConnectionGetInfo(struct AdbcConnection* connection,
 const uint32_t* info_codes, size_t info_codes_length,
 struct ArrowArrayStream* out,
 struct AdbcError* error);

ADBC_EXPORT
AdbcStatusCode AdbcConnectionGetObjects(struct AdbcConnection* connection, int depth,
 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(struct AdbcConnection* connection, const char* key,
 char* value, size_t* length,
 struct AdbcError* error);

ADBC_EXPORT
AdbcStatusCode AdbcConnectionGetOptionBytes(struct AdbcConnection* connection,
 const char* key, uint8_t* value,
 size_t* length, struct AdbcError* error);

ADBC_EXPORT
AdbcStatusCode AdbcConnectionGetOptionInt(struct AdbcConnection* connection,
 const char* key, int64_t* value,
 struct AdbcError* error);

ADBC_EXPORT
AdbcStatusCode AdbcConnectionGetOptionDouble(struct AdbcConnection* connection,
 const char* key, double* value,
 struct AdbcError* error);

ADBC_EXPORT
AdbcStatusCode AdbcConnectionGetStatistics(struct AdbcConnection* connection,
 const char* catalog, const char* db_schema,
 const char* table_name, char approximate,
 struct ArrowArrayStream* out,
 struct AdbcError* error);

ADBC_EXPORT
AdbcStatusCode AdbcConnectionGetStatisticNames(struct AdbcConnection* connection,
 struct ArrowArrayStream* out,
 struct AdbcError* error);

ADBC_EXPORT
AdbcStatusCode AdbcConnectionGetTableSchema(struct AdbcConnection* connection,
 const char* catalog, const char* db_schema,
 const char* table_name,
 struct ArrowSchema* schema,
 struct AdbcError* error);

ADBC_EXPORT
AdbcStatusCode AdbcConnectionGetTableTypes(struct AdbcConnection* connection,
 struct ArrowArrayStream* out,
 struct AdbcError* error);



ADBC_EXPORT
AdbcStatusCode AdbcConnectionReadPartition(struct AdbcConnection* connection,
 const uint8_t* serialized_partition,
 size_t serialized_length,
 struct ArrowArrayStream* out,
 struct AdbcError* error);



ADBC_EXPORT
AdbcStatusCode AdbcConnectionCommit(struct AdbcConnection* connection,
 struct AdbcError* error);

ADBC_EXPORT
AdbcStatusCode AdbcConnectionRollback(struct AdbcConnection* connection,
 struct AdbcError* error);




ADBC_EXPORT
AdbcStatusCode AdbcStatementNew(struct AdbcConnection* connection,
 struct AdbcStatement* statement, struct AdbcError* error);

ADBC_EXPORT
AdbcStatusCode AdbcStatementRelease(struct AdbcStatement* statement,
 struct AdbcError* error);

ADBC_EXPORT
AdbcStatusCode AdbcStatementExecuteQuery(struct AdbcStatement* statement,
 struct ArrowArrayStream* out,
 int64_t* rows_affected, struct AdbcError* error);

ADBC_EXPORT
AdbcStatusCode AdbcStatementExecuteSchema(struct AdbcStatement* statement,
 struct ArrowSchema* schema,
 struct AdbcError* error);

ADBC_EXPORT
AdbcStatusCode AdbcStatementPrepare(struct AdbcStatement* statement,
 struct AdbcError* error);


ADBC_EXPORT
AdbcStatusCode AdbcStatementSetSqlQuery(struct AdbcStatement* statement,
 const char* query, struct AdbcError* error);



ADBC_EXPORT
AdbcStatusCode AdbcStatementSetSubstraitPlan(struct AdbcStatement* statement,
 const uint8_t* plan, size_t length,
 struct AdbcError* error);


ADBC_EXPORT
AdbcStatusCode AdbcStatementBind(struct AdbcStatement* statement,
 struct ArrowArray* values, struct ArrowSchema* schema,
 struct AdbcError* error);

ADBC_EXPORT
AdbcStatusCode AdbcStatementBindStream(struct AdbcStatement* statement,
 struct ArrowArrayStream* stream,
 struct AdbcError* error);

ADBC_EXPORT
AdbcStatusCode AdbcStatementCancel(struct AdbcStatement* statement,
 struct AdbcError* error);

ADBC_EXPORT
AdbcStatusCode AdbcStatementGetOption(struct AdbcStatement* statement, const char* key,
 char* value, size_t* length,
 struct AdbcError* error);

ADBC_EXPORT
AdbcStatusCode AdbcStatementGetOptionBytes(struct AdbcStatement* statement,
 const char* key, uint8_t* value,
 size_t* length, struct AdbcError* error);

ADBC_EXPORT
AdbcStatusCode AdbcStatementGetOptionInt(struct AdbcStatement* statement, const char* key,
 int64_t* value, struct AdbcError* error);

ADBC_EXPORT
AdbcStatusCode AdbcStatementGetOptionDouble(struct AdbcStatement* statement,
 const char* key, double* value,
 struct AdbcError* error);

ADBC_EXPORT
AdbcStatusCode AdbcStatementGetParameterSchema(struct AdbcStatement* statement,
 struct ArrowSchema* schema,
 struct AdbcError* error);

ADBC_EXPORT
AdbcStatusCode AdbcStatementSetOption(struct AdbcStatement* statement, const char* key,
 const char* value, struct AdbcError* error);

ADBC_EXPORT
AdbcStatusCode AdbcStatementSetOptionBytes(struct AdbcStatement* statement,
 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