sentinel-driver 2.0.0

High-performance PostgreSQL wire protocol driver for Rust
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

use bytes::{BufMut, BytesMut};

use crate::error::{Error, Result};
use crate::types::{FromSql, Oid, ToSql};

/// PostgreSQL INTERVAL type.
///
/// Stored as three components matching PG's internal representation:
/// - `months` -- number of months (years x 12 + months)
/// - `days` -- number of days (not normalized to months)
/// - `microseconds` -- time component in microseconds
#[derive(Debug, Clone, Copy, PartialEq, Eq, Hash)]
pub struct PgInterval {
    pub months: i32,
    pub days: i32,
    pub microseconds: i64,
}

impl ToSql for PgInterval {
    fn oid(&self) -> Oid {
        Oid::INTERVAL
    }

    fn to_sql(&self, buf: &mut BytesMut) -> Result<()> {
        buf.put_i64(self.microseconds);
        buf.put_i32(self.days);
        buf.put_i32(self.months);
        Ok(())
    }
}

impl FromSql for PgInterval {
    fn oid() -> Oid {
        Oid::INTERVAL
    }

    fn from_sql(buf: &[u8]) -> Result<Self> {
        if buf.len() != 16 {
            return Err(Error::Decode(format!(
                "interval: expected 16 bytes, got {}",
                buf.len()
            )));
        }

        let microseconds = i64::from_be_bytes([
            buf[0], buf[1], buf[2], buf[3], buf[4], buf[5], buf[6], buf[7],
        ]);
        let days = i32::from_be_bytes([buf[8], buf[9], buf[10], buf[11]]);
        let months = i32::from_be_bytes([buf[12], buf[13], buf[14], buf[15]]);

        Ok(PgInterval {
            months,
            days,
            microseconds,
        })
    }
}