Packages

adbc

0.6.2
0.12.1 0.12.0 0.11.0 0.10.0 0.9.0 0.8.0 0.7.9 0.7.8 0.7.7 retired 0.7.6 retired 0.7.5 retired 0.7.4 retired 0.7.3 0.7.2 0.7.1 retired 0.7.0 0.6.5 0.6.4 0.6.3 0.6.2 0.6.1 0.6.0 0.5.0 0.4.2 0.4.1 0.4.0 0.3.1 0.3.0 0.2.4-rc0 0.2.3 0.2.2 0.2.1 0.2.0 0.1.1 0.1.0

Apache Arrow ADBC bindings for Elixir

HexDocs

Current section

Files

Jump to
Readme
35 Versions
5 Dependencies
Dependants
Files
Activity
adbc c_src adbc_arrow_metadata.hpp
Raw

c_src/adbc_arrow_metadata.hpp 

#ifndef ADBC_ARROW_METADATA_HPP

#define ADBC_ARROW_METADATA_HPP

#pragma once



#include <stdio.h>

#include <vector>

#include <adbc.h>

#include <erl_nif.h>

#include "adbc_consts.h"

#include "nif_utils.hpp"



static int arrow_metadata_to_nif_term(ErlNifEnv *env, const char * metadata, ERL_NIF_TERM * out_metadata) {

    std::vector<ERL_NIF_TERM> metadata_keys, metadata_values;

    *out_metadata = kAtomNil;

    if (metadata == nullptr) return NANOARROW_OK;



    struct ArrowMetadataReader metadata_reader{};

    struct ArrowStringView key;

    struct ArrowStringView value;

    NANOARROW_RETURN_NOT_OK(ArrowMetadataReaderInit(&metadata_reader, metadata));

    while (ArrowMetadataReaderRead(&metadata_reader, &key, &value) == NANOARROW_OK) {

        // printf("key: %.*s, value: %.*s\n", (int)key.size_bytes, key.data, (int)value.size_bytes, value.data);

        metadata_keys.push_back(erlang::nif::make_binary(env, key.data, (size_t)key.size_bytes));

        metadata_values.push_back(erlang::nif::make_binary(env, value.data, (size_t)value.size_bytes));

    }

    if (metadata_keys.size() > 0) {

        enif_make_map_from_arrays(env, metadata_keys.data(), metadata_values.data(), (unsigned)metadata_keys.size(), out_metadata);

    }

    return NANOARROW_OK;

}



#endif  // ADBC_ARROW_METADATA_HPP