Function upsert_columns

cpp/deeplake_pg/dl_catalog.cpp:479–500

}

void upsert_columns(const std::string& root_path, icm::string_map<> creds, const std::vector<column_meta>& columns)
{
    if (columns.empty()) {
        return;
    }
    auto table = open_catalog_table(root_path, k_columns_name, std::move(creds));
    icm::vector<icm::string_map<nd::array>> rows;
    rows.reserve(columns.size());
    for (const auto& col : columns) {
        icm::string_map<nd::array> row;
        // column_id is the composite key: table_id:column_name
        row["column_id"] = nd::adapt(col.table_id + ":" + col.column_name);
        row["table_id"] = nd::adapt(col.table_id);
        row["column_name"] = nd::adapt(col.column_name);
        row["pg_type"] = nd::adapt(col.pg_type);
        row["dl_type_json"] = nd::adapt(col.dl_type_json);
        row["nullable"] = nd::adapt(col.nullable);
        row["position"] = nd::adapt(col.position);
        rows.push_back(std::move(row));
    }
    table->upsert_many(std::move(rows)).get_future().get();
}

int64_t get_catalog_version(const std::string& root_path, icm::string_map<> creds)
{