risingwave_common/session_config/
transaction_isolation_level.rs

1// Copyright 2025 RisingWave Labs
2//
3// Licensed under the Apache License, Version 2.0 (the "License");
4// you may not use this file except in compliance with the License.
5// You may obtain a copy of the License at
6//
7//     http://www.apache.org/licenses/LICENSE-2.0
8//
9// Unless required by applicable law or agreed to in writing, software
10// distributed under the License is distributed on an "AS IS" BASIS,
11// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12// See the License for the specific language governing permissions and
13// limitations under the License.
14
15use std::fmt::Formatter;
16use std::str::FromStr;
17
18#[derive(Copy, Default, Debug, Clone, PartialEq, Eq)]
19// Some variants are never constructed so allow dead code here.
20#[allow(dead_code)]
21pub enum IsolationLevel {
22    #[default]
23    ReadCommitted,
24    ReadUncommitted,
25    RepeatableRead,
26    Serializable,
27}
28
29impl FromStr for IsolationLevel {
30    type Err = &'static str;
31
32    fn from_str(s: &str) -> Result<Self, Self::Err> {
33        match s.to_ascii_lowercase().as_str() {
34            "read committed" => Ok(Self::ReadCommitted),
35            "read uncommitted" => Ok(Self::ReadUncommitted),
36            "repeatable read" => Ok(Self::RepeatableRead),
37            "serializable" => Ok(Self::Serializable),
38            _ => Err(
39                "expect one of [read committed, read uncommitted, repeatable read, serializable]",
40            ),
41        }
42    }
43}
44
45impl std::fmt::Display for IsolationLevel {
46    fn fmt(&self, f: &mut Formatter<'_>) -> std::fmt::Result {
47        match self {
48            Self::ReadCommitted => write!(f, "read committed"),
49            Self::ReadUncommitted => write!(f, "read uncommitted"),
50            Self::RepeatableRead => write!(f, "repeatable read"),
51            Self::Serializable => write!(f, "serializable"),
52        }
53    }
54}
risingwave_common/session_config/transaction_isolation_level.rs

risingwave_common/session_config/
transaction_isolation_level.rs
