rbdc-mysql 4.9.3

The Rust SQL Toolkit and ORM Library. An async, pure Rust SQL crate featuring compile-time Dynamic SQL
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

use crate::io::MySqlBufMutExt;
use crate::types::{Decode, Encode};
use crate::value::MySqlValueRef;
use rbdc::json::Json;
use rbdc::Error;

impl Encode for Json {
    fn encode(self, buf: &mut Vec<u8>) -> Result<usize, Error> {
        let mut bytes = self.0.into_bytes();
        if bytes.is_empty() {
            bytes = "null".to_string().into_bytes();
        }
        let len = bytes.len();
        buf.put_bytes_lenenc(bytes);
        Ok(len)
    }
}

impl Decode for Json {
    fn decode(value: MySqlValueRef<'_>) -> Result<Self, Error> {
        Ok(Self(value.as_str().unwrap_or("null").to_string()))
    }
}

pub fn encode_json(arg: rbs::Value, buf: &mut Vec<u8>) -> Result<usize, Error> {
    let bytes = arg.to_string().into_bytes();
    let len = bytes.len();
    buf.put_bytes_lenenc(bytes);
    Ok(len)
}

pub fn decode_json(value: MySqlValueRef<'_>) -> Result<rbs::Value, Error> {
    let v = value.as_str().unwrap_or("null").to_string();
    Ok(serde_json::from_str(&v).map_err(|e| Error::from(e.to_string()))?)
}