rupg_catalog/
enum_label.rs

1//! `ALTER TYPE ... ADD VALUE` and `ALTER TYPE ... RENAME VALUE` of an enum type: the changes of `AddEnumLabel`, `RenumberEnumType` and `RenameEnumLabel`, and the labels that a statement cannot use before the commit.
2
3use rupg_common::Result;
4
5use super::{Catalog, EnumLabel, no_object};
6
7impl Catalog {
8    /// `AddEnumLabel`: adds the label at the end, or before or after the label at the place `neighbor` of the sort order. The new label gets the middle of the sort orders of its neighbors. When the precision of `float4` gives no middle, `RenumberEnumType` gives the labels the sort orders 1, 2, 3 and so on, and the search starts again. The new label takes the next OID, but an even OID that does not sort correctly against the even OIDs of the other labels is skipped, so that the label gets the odd OID after it. The caller checks the name.
9    ///
10    /// # Errors
11    ///
12    /// An internal error for a type that is not an enum type of the catalog.
13    #[allow(clippy::cast_precision_loss, clippy::manual_midpoint)]
14    pub fn add_enum_label(
15        &mut self,
16        ty: u32,
17        label: String,
18        neighbor: Option<(usize, bool)>,
19    ) -> Result<()> {
20        let labels = self.labels_mut(ty)?;
21        let (order, at) = loop {
22            let Some((at, after)) = neighbor else {
23                break (labels.last().map_or(1.0, |l| l.sort_order + 1.0), labels.len());
24            };
25            let near = labels[at].sort_order;
26            let other = if after { at.checked_add(1) } else { at.checked_sub(1) };
27            let place = if after { at + 1 } else { at };
28            let Some(other) = other.and_then(|o| labels.get(o)).map(|l| l.sort_order) else {
29                break (if after { near + 1.0 } else { near - 1.0 }, place);
30            };
31            // The sum rounds to `float4` before the division, as in C.
32            let middle = (near + other) / 2.0;
33            if middle != near && middle != other {
34                break (middle, place);
35            }
36            for (i, label) in labels.iter_mut().enumerate() {
37                label.sort_order = (i + 1) as f32;
38            }
39        };
40        let even: Vec<(u32, f32)> =
41            labels.iter().filter(|l| l.oid & 1 == 0).map(|l| (l.oid, l.sort_order)).collect();
42        let oid = loop {
43            let oid = self.new_oid();
44            let sorts = even.iter().all(|&(e, o)| if o < order { e < oid } else { e > oid });
45            if sorts || oid & 1 == 1 {
46                break oid;
47            }
48        };
49        self.labels_mut(ty)?.insert(at, EnumLabel { oid, sort_order: order, label });
50        if !self.uncommitted_types.contains(&ty) {
51            self.uncommitted_labels.push(oid);
52        }
53        Ok(())
54    }
55
56    /// `RenameEnumLabel`: the label at the place `at` of the sort order gets the new name. The caller checks the names.
57    ///
58    /// # Errors
59    ///
60    /// An internal error for a type that is not an enum type of the catalog.
61    pub fn rename_enum_label(&mut self, ty: u32, at: usize, name: String) -> Result<()> {
62        if let Some(label) = self.labels_mut(ty)?.get_mut(at) {
63            label.label = name;
64        }
65        Ok(())
66    }
67
68    /// `EnumUncommitted`: true for a label that `ALTER TYPE ... ADD VALUE` of the open transaction gave to an enum type that an earlier transaction made.
69    pub fn label_is_uncommitted(&self, label: u32) -> bool {
70        self.uncommitted_labels.contains(&label)
71    }
72
73    /// True when the open transaction made an enum type or gave a label to one, so that the commit has a change for [`Catalog::commit_enums`].
74    pub fn has_uncommitted_enums(&self) -> bool {
75        !self.uncommitted_types.is_empty() || !self.uncommitted_labels.is_empty()
76    }
77
78    /// `AtEOXact_Enum`: after the commit, each enum type and each label is one of an earlier transaction.
79    pub fn commit_enums(&mut self) {
80        self.uncommitted_types.clear();
81        self.uncommitted_labels.clear();
82    }
83
84    /// The labels of an enum type of the catalog.
85    fn labels_mut(&mut self, ty: u32) -> Result<&mut Vec<EnumLabel>> {
86        self.types.get_mut(&ty).and_then(|t| t.labels.as_mut()).ok_or_else(|| no_object("type", ty))
87    }
88}
rupg_catalog/enum_label.rs

rupg_catalog/
enum_label.rs
