zero-mysql 0.6.0

A high-performance MySQL client
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
88

use thiserror::Error;

pub use color_eyre::eyre::eyre;

use crate::protocol::{response::ErrPayload, response::ErrPayloadBytes};

pub type Result<T> = core::result::Result<T, Error>;

#[derive(Debug, Error)]
pub enum Error {
    // ─── Server Error ────────────────────────────────────────────────────
    #[error("Server Error: {0}")]
    ServerError(#[from] ErrPayload),
    // ─── Incorrect Usage ─────────────────────────────────────────────────
    #[error(
        "Connection mismatch: transaction started on connection {expected}, but commit/rollback called on connection {actual}"
    )]
    ConnectionMismatch { expected: u64, actual: u64 },
    #[error("Bad usage error: {0}")]
    BadUsageError(String),
    // ─── Temporary Error ─────────────────────────────────────────────────
    #[error("IO error: {0}")]
    IoError(#[from] std::io::Error),
    // ─── Library Error ───────────────────────────────────────────────────
    #[error("A bug in zero-mysql: {0}")]
    LibraryBug(#[from] color_eyre::Report),
    #[error("Unsupported authentication plugin: {0}")]
    Unsupported(String),
    #[error("Cannot nest transactions - a transaction is already active")]
    NestedTransaction,
    #[error("Missing column: {0}")]
    MissingColumn(&'static str),
    #[error("Unknown column: {0}")]
    UnknownColumn(String),
}

impl<'buf> From<ErrPayloadBytes<'buf>> for Error {
    fn from(value: ErrPayloadBytes) -> Self {
        match ErrPayload::try_from(value) {
            Ok(err_payload) => Error::ServerError(err_payload),
            Err(err) => err,
        }
    }
}

impl From<core::convert::Infallible> for Error {
    fn from(err: core::convert::Infallible) -> Self {
        match err {}
    }
}

impl Error {
    pub fn from_debug(err: impl std::fmt::Debug) -> Self {
        Self::LibraryBug(color_eyre::eyre::eyre!(format!("{:#?}", err)))
    }

    /// Returns true if the error indicates the connection is broken and cannot be reused.
    ///
    /// This is conservative - returns true (broken) when in doubt.
    pub fn is_conn_broken(&self) -> bool {
        match self {
            Error::ServerError(err_payload) => {
                match err_payload.sql_state.as_str() {
                    // Integrity errors - connection still usable
                    "23000" => false,
                    // Data errors - connection still usable
                    "22001" | "22003" | "22007" | "22012" => false,
                    // Programming errors - connection still usable
                    "42000" | "42S02" | "42S22" => false,
                    // Not supported - connection still usable
                    "0A000" => false,
                    // Everything else - assume broken
                    _ => true,
                }
            }
            // User errors - connection still usable
            Error::BadUsageError(_) | Error::MissingColumn(_) | Error::UnknownColumn(_) => false,
            // All other errors - assume broken
            _ => true,
        }
    }
}

impl<Src, Dst: ?Sized> From<zerocopy::CastError<Src, Dst>> for Error {
    fn from(err: zerocopy::CastError<Src, Dst>) -> Self {
        Self::LibraryBug(color_eyre::eyre::eyre!("{:#?}", err))
    }
}