Skip to content
Snippets Groups Projects
Verified Commit a74b67de authored by Denis Smirnov's avatar Denis Smirnov
Browse files

refactoring: connection type methods

parent a6ba06ba
No related branches found
No related tags found
1 merge request!1414sbroad import
......@@ -467,13 +467,9 @@ impl RouterRuntime {
query_type: QueryType,
conn_type: ConnectionType,
) -> Result<Box<dyn Any>, SbroadError> {
let is_readonly = match &conn_type {
ConnectionType::Read => true,
ConnectionType::Write => false,
};
match &query_type {
QueryType::DQL => self.dql_on_some(rs_ir, is_readonly),
QueryType::DML => self.dml_on_some(rs_ir, is_readonly),
QueryType::DQL => self.dql_on_some(rs_ir, conn_type.is_readonly()),
QueryType::DML => self.dml_on_some(rs_ir, conn_type.is_readonly()),
}
}
......@@ -547,13 +543,9 @@ impl RouterRuntime {
query_type: QueryType,
conn_type: ConnectionType,
) -> Result<Box<dyn Any>, SbroadError> {
let is_readonly = match &conn_type {
ConnectionType::Read => true,
ConnectionType::Write => false,
};
match &query_type {
QueryType::DQL => self.dql_on_all(required, optional, is_readonly),
QueryType::DML => self.dml_on_all(required, optional, is_readonly),
QueryType::DQL => self.dql_on_all(required, optional, conn_type.is_readonly()),
QueryType::DML => self.dml_on_all(required, optional, conn_type.is_readonly()),
}
}
}
......
......@@ -29,6 +29,16 @@ pub enum ConnectionType {
Write,
}
impl ConnectionType {
#[must_use]
pub fn is_readonly(&self) -> bool {
match self {
ConnectionType::Read => true,
ConnectionType::Write => false,
}
}
}
#[derive(Debug, Default, Clone, Deserialize, Serialize, PartialEq, Eq)]
pub struct ExecutionPlan {
plan: Plan,
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment