Function lbug_connection_create_arrow_table

src/c_api/connection.cpp:227–249

}

lbug_state lbug_connection_create_arrow_table(lbug_connection* connection, const char* table_name,
    ArrowSchema* schema, ArrowArray* arrays, uint64_t num_arrays,
    lbug_query_result* out_query_result) {
    if (connection == nullptr || connection->_connection == nullptr || table_name == nullptr ||
        schema == nullptr || arrays == nullptr || out_query_result == nullptr) {
        return LbugError;
    }
    try {
        clearLastCAPIErrorMessage();
        auto result = lbug::ArrowTableSupport::createViewFromArrowTable(
            *static_cast<Connection*>(connection->_connection), table_name, takeArrowSchema(schema),
            takeArrowArrays(arrays, num_arrays));
        auto state = setQueryResult(std::move(result.queryResult), out_query_result);
        if (state == LbugSuccess) {
            rememberArrowTableID(static_cast<Connection*>(connection->_connection), table_name,
                std::move(result.arrowId));
        }
        return state;
    } catch (Exception& e) {
        setLastCAPIErrorMessage(e.what());
        return LbugError;
    }
}

lbug_state lbug_connection_create_arrow_rel_table(lbug_connection* connection,
    const char* table_name, const char* src_table_name, const char* dst_table_name,