reifydb-catalog 0.4.11

Database catalog and metadata management for ReifyDB
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37

// SPDX-License-Identifier: Apache-2.0
// Copyright (c) 2025 ReifyDB

use reifydb_core::{
	interface::catalog::id::SeriesId,
	key::{
		namespace_series::NamespaceSeriesKey,
		series::{SeriesKey, SeriesMetadataKey},
	},
};
use reifydb_transaction::transaction::{Transaction, admin::AdminTransaction};

use crate::{CatalogStore, Result, store::shape::drop::drop_shape_metadata};

impl CatalogStore {
	pub(crate) fn drop_series(txn: &mut AdminTransaction, series: SeriesId) -> Result<()> {
		// First, find the series to get its namespace and primary key
		let pk_id = if let Some(series_def) = Self::find_series(&mut Transaction::Admin(&mut *txn), series)? {
			// Remove the namespace-series link (secondary index)
			txn.remove(&NamespaceSeriesKey::encoded(series_def.namespace, series))?;
			series_def.primary_key.as_ref().map(|pk| pk.id)
		} else {
			None
		};

		// Clean up all associated metadata (columns, policies, sequences, pk)
		drop_shape_metadata(txn, series.into(), pk_id)?;

		// Remove the series metadata
		txn.remove(&SeriesMetadataKey::encoded(series))?;

		// Remove the series definition
		txn.remove(&SeriesKey::encoded(series))?;

		Ok(())
	}
}