cdbc_mysql/types/
str.rs

1use cdbc::decode::Decode;
2use cdbc::encode::{Encode, IsNull};
3use cdbc::error::BoxDynError;
4use crate::io::MySqlBufMutExt;
5use crate::protocol::text::{ColumnFlags, ColumnType};
6use crate::{MySql, MySqlTypeInfo, MySqlValueRef};
7use cdbc::types::Type;
8use std::borrow::Cow;
9
10const COLLATE_UTF8_GENERAL_CI: u16 = 33;
11const COLLATE_UTF8_UNICODE_CI: u16 = 192;
12const COLLATE_UTF8MB4_UNICODE_CI: u16 = 224;
13const COLLATE_UTF8MB4_BIN: u16 = 46;
14const COLLATE_UTF8MB4_GENERAL_CI: u16 = 45;
15
16impl Type<MySql> for str {
17    fn type_info() -> MySqlTypeInfo {
18        MySqlTypeInfo {
19            r#type: ColumnType::VarString,        // VARCHAR
20            char_set: COLLATE_UTF8MB4_UNICODE_CI, // utf8mb4_unicode_ci
21            flags: ColumnFlags::empty(),
22            max_size: None,
23        }
24    }
25
26    fn compatible(ty: &MySqlTypeInfo) -> bool {
27        // TODO: Support more collations being returned from SQL?
28        matches!(
29            ty.r#type,
30            ColumnType::VarChar
31                | ColumnType::Blob
32                | ColumnType::TinyBlob
33                | ColumnType::MediumBlob
34                | ColumnType::LongBlob
35                | ColumnType::String
36                | ColumnType::VarString
37                | ColumnType::Enum
38        ) && matches!(
39            ty.char_set,
40            COLLATE_UTF8MB4_UNICODE_CI
41                | COLLATE_UTF8_UNICODE_CI
42                | COLLATE_UTF8_GENERAL_CI
43                | COLLATE_UTF8MB4_BIN
44                | COLLATE_UTF8MB4_GENERAL_CI
45        )
46    }
47}
48
49impl Encode<'_, MySql> for &'_ str {
50    fn encode_by_ref(&self, buf: &mut Vec<u8>) -> IsNull {
51        buf.put_str_lenenc(self);
52
53        IsNull::No
54    }
55}
56
57impl<'r> Decode<'r, MySql> for &'r str {
58    fn decode(value: MySqlValueRef<'r>) -> Result<Self, BoxDynError> {
59        value.as_str()
60    }
61}
62
63impl Type<MySql> for String {
64    fn type_info() -> MySqlTypeInfo {
65        <str as Type<MySql>>::type_info()
66    }
67
68    fn compatible(ty: &MySqlTypeInfo) -> bool {
69        <str as Type<MySql>>::compatible(ty)
70    }
71}
72
73impl Encode<'_, MySql> for String {
74    fn encode_by_ref(&self, buf: &mut Vec<u8>) -> IsNull {
75        <&str as Encode<MySql>>::encode(&**self, buf)
76    }
77}
78
79impl Decode<'_, MySql> for String {
80    fn decode(value: MySqlValueRef<'_>) -> Result<Self, BoxDynError> {
81        <&str as Decode<MySql>>::decode(value).map(ToOwned::to_owned)
82    }
83}
84
85impl Encode<'_, MySql> for Cow<'_, str> {
86    fn encode_by_ref(&self, buf: &mut Vec<u8>) -> IsNull {
87        match self {
88            Cow::Borrowed(str) => <&str as Encode<MySql>>::encode(*str, buf),
89            Cow::Owned(str) => <&str as Encode<MySql>>::encode(&**str, buf),
90        }
91    }
92}
93
94impl<'r> Decode<'r, MySql> for Cow<'r, str> {
95    fn decode(value: MySqlValueRef<'r>) -> Result<Self, BoxDynError> {
96        value.as_str().map(Cow::Borrowed)
97    }
98}
cdbc_mysql/types/str.rs

cdbc_mysql/types/
str.rs
