Function lbug_connection_create_arrow_rel_table

src/c_api/connection.cpp:251–275

}

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,
    ArrowSchema* schema, ArrowArray* arrays, uint64_t num_arrays,
    lbug_query_result* out_query_result) {
    if (connection == nullptr || connection->_connection == nullptr || table_name == nullptr ||
        src_table_name == nullptr || dst_table_name == nullptr || schema == nullptr ||
        arrays == nullptr || out_query_result == nullptr) {
        return LbugError;
    }
    try {
        clearLastCAPIErrorMessage();
        auto result = lbug::ArrowTableSupport::createRelTableFromArrowTable(
            *static_cast<Connection*>(connection->_connection), table_name, src_table_name,
            dst_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_csr(lbug_connection* connection,
    const char* table_name, const char* src_table_name, const char* dst_table_name,