Function lbug_connection_create_arrow_rel_table_csr

src/c_api/connection.cpp:277–306

}

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,
    ArrowSchema* indices_schema, ArrowArray* indices_arrays, uint64_t num_indices_arrays,
    ArrowSchema* indptr_schema, ArrowArray* indptr_arrays, uint64_t num_indptr_arrays,
    const char* dst_col_name, lbug_query_result* out_query_result) {
    if (connection == nullptr || connection->_connection == nullptr || table_name == nullptr ||
        src_table_name == nullptr || dst_table_name == nullptr || indices_schema == nullptr ||
        indices_arrays == nullptr || indptr_schema == nullptr || indptr_arrays == nullptr ||
        out_query_result == nullptr) {
        return LbugError;
    }
    try {
        clearLastCAPIErrorMessage();
        auto result = lbug::ArrowTableSupport::createRelTableFromArrowCSR(
            *static_cast<Connection*>(connection->_connection), table_name, src_table_name,
            dst_table_name, takeArrowSchema(indices_schema),
            takeArrowArrays(indices_arrays, num_indices_arrays), takeArrowSchema(indptr_schema),
            takeArrowArrays(indptr_arrays, num_indptr_arrays),
            dst_col_name != nullptr ? dst_col_name : "to");
        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_drop_arrow_table(lbug_connection* connection, const char* table_name,
    lbug_query_result* out_query_result) {