reifydb-rql 0.4.6

ReifyDB Query Language (RQL) parser and AST
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
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87

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

use crate::{
	Result,
	ast::ast::AstDrop,
	plan::logical::{
		Compiler, DropAuthenticationNode, DropDictionaryNode, DropIdentityNode, DropNamespaceNode,
		DropPolicyNode, DropRingBufferNode, DropRoleNode, DropSeriesNode, DropSinkNode, DropSourceNode,
		DropSubscriptionNode, DropSumTypeNode, DropTableNode, DropViewNode, LogicalPlan,
	},
};

impl<'bump> Compiler<'bump> {
	pub(crate) fn compile_drop(&self, ast: AstDrop<'bump>) -> Result<LogicalPlan<'bump>> {
		match ast {
			AstDrop::Namespace(node) => Ok(LogicalPlan::DropNamespace(DropNamespaceNode {
				segments: node.namespace.segments,
				if_exists: node.if_exists,
				cascade: node.cascade,
			})),
			AstDrop::Table(node) => Ok(LogicalPlan::DropTable(DropTableNode {
				table: node.table,
				if_exists: node.if_exists,
				cascade: node.cascade,
			})),
			AstDrop::View(node) => Ok(LogicalPlan::DropView(DropViewNode {
				view: node.view,
				if_exists: node.if_exists,
				cascade: node.cascade,
			})),
			AstDrop::RingBuffer(node) => Ok(LogicalPlan::DropRingBuffer(DropRingBufferNode {
				ringbuffer: node.ringbuffer,
				if_exists: node.if_exists,
				cascade: node.cascade,
			})),
			AstDrop::Dictionary(node) => Ok(LogicalPlan::DropDictionary(DropDictionaryNode {
				dictionary: node.dictionary,
				if_exists: node.if_exists,
				cascade: node.cascade,
			})),
			AstDrop::Enum(node) => Ok(LogicalPlan::DropSumType(DropSumTypeNode {
				sumtype: node.sumtype,
				if_exists: node.if_exists,
				cascade: node.cascade,
			})),
			AstDrop::Subscription(node) => Ok(LogicalPlan::DropSubscription(DropSubscriptionNode {
				identifier: node.identifier,
				if_exists: node.if_exists,
				cascade: node.cascade,
			})),
			AstDrop::Series(node) => Ok(LogicalPlan::DropSeries(DropSeriesNode {
				series: node.series,
				if_exists: node.if_exists,
				cascade: node.cascade,
			})),
			AstDrop::Identity(node) => Ok(LogicalPlan::DropIdentity(DropIdentityNode {
				name: node.name,
				if_exists: node.if_exists,
			})),
			AstDrop::Role(node) => Ok(LogicalPlan::DropRole(DropRoleNode {
				name: node.name,
				if_exists: node.if_exists,
			})),
			AstDrop::Authentication(node) => Ok(LogicalPlan::DropAuthentication(DropAuthenticationNode {
				user: node.user,
				if_exists: node.if_exists,
				method: node.method,
			})),
			AstDrop::Policy(node) => Ok(LogicalPlan::DropPolicy(DropPolicyNode {
				target_type: node.target_type,
				name: node.name,
				if_exists: node.if_exists,
			})),
			AstDrop::Source(node) => Ok(LogicalPlan::DropSource(DropSourceNode {
				source: node.source,
				if_exists: node.if_exists,
				cascade: node.cascade,
			})),
			AstDrop::Sink(node) => Ok(LogicalPlan::DropSink(DropSinkNode {
				sink: node.sink,
				if_exists: node.if_exists,
				cascade: node.cascade,
			})),
		}
	}
}