utility.h

// 在 Apache Software Foundation (ASF) 的许可下
// 或更多贡献者许可协议。 请参阅 NOTICE 文件
// 随本作品分发以获取更多信息
// 关于版权所有权。 ASF 授权此文件
// 按照 Apache 许可证第 2.0 版（以下简称
// “许可证”）授权给您； 除非遵守
// 许可证，否则您不得使用此文件。 您可以在以下位置获取许可证副本：
//
// https://apache.org/licenses/LICENSE-2.0
//
// 除非适用法律要求或书面同意，
// 否则按“原样”分发且不提供任何类型的
// 保证或条件，无论是明示的还是暗示的。 请参阅
// 许可证，以了解有关特定语言的管辖权限
// 许可和限制的更多信息。
// 在许可证下。
 
#pragma once
 
#include <string>
#include <utility>
#include <vector>
 
#include <arrow-adbc/adbc.h>
 
#include "driver/framework/status.h"
 
namespace adbc::driver {

void MakeEmptyStream(ArrowSchema* schema, ArrowArrayStream* out);

void MakeArrayStream(ArrowSchema* schema, ArrowArray* array, ArrowArrayStream* out);

Status MakeTableTypesStream(const std::vector<std::string>& table_types,
 ArrowArrayStream* out);

struct InfoValue {
 uint32_t code;
 std::variant<std::string, int64_t> value;
 
 InfoValue(uint32_t code, std::variant<std::string, int64_t> value)
 : code(code), value(std::move(value)) {}
 InfoValue(uint32_t code, const char* value) : InfoValue(code, std::string(value)) {}
};

Status MakeGetInfoStream(const std::vector<InfoValue>& infos, ArrowArrayStream* out);
 
} // namespace adbc::driver