diesel/pg/types/
uuid_v0_7.rs

1extern crate uuidv07 as uuid;
2
3use std::io::prelude::*;
4
5use deserialize::{self, FromSql};
6use pg::Pg;
7use serialize::{self, IsNull, Output, ToSql};
8use sql_types::Uuid;
9
10#[derive(FromSqlRow, AsExpression)]
11#[diesel(foreign_derive)]
12#[sql_type = "Uuid"]
13#[allow(dead_code)]
14struct UuidProxy(uuid::Uuid);
15
16impl FromSql<Uuid, Pg> for uuid::Uuid {
17    fn from_sql(bytes: Option<&[u8]>) -> deserialize::Result<Self> {
18        let bytes = not_none!(bytes);
19        uuid::Uuid::from_slice(bytes).map_err(|e| e.into())
20    }
21}
22
23impl ToSql<Uuid, Pg> for uuid::Uuid {
24    fn to_sql<W: Write>(&self, out: &mut Output<W, Pg>) -> serialize::Result {
25        out.write_all(self.as_bytes())
26            .map(|_| IsNull::No)
27            .map_err(Into::into)
28    }
29}
30
31#[test]
32fn uuid_to_sql() {
33    let mut bytes = Output::test();
34    let test_uuid = uuid::Uuid::from_fields(0xFFFF_FFFF, 0xFFFF, 0xFFFF, b"abcdef12").unwrap();
35    ToSql::<Uuid, Pg>::to_sql(&test_uuid, &mut bytes).unwrap();
36    assert_eq!(bytes, test_uuid.as_bytes());
37}
38
39#[test]
40fn some_uuid_from_sql() {
41    let input_uuid = uuid::Uuid::from_fields(0xFFFF_FFFF, 0xFFFF, 0xFFFF, b"abcdef12").unwrap();
42    let output_uuid = FromSql::<Uuid, Pg>::from_sql(Some(input_uuid.as_bytes())).unwrap();
43    assert_eq!(input_uuid, output_uuid);
44}
45
46#[test]
47fn bad_uuid_from_sql() {
48    let uuid = uuid::Uuid::from_sql(Some(b"boom"));
49    assert_eq!(
50        uuid.unwrap_err().to_string(),
51        "invalid bytes length: expected 16, found 4"
52    );
53}
54
55#[test]
56fn no_uuid_from_sql() {
57    let uuid = uuid::Uuid::from_sql(None);
58    assert_eq!(
59        uuid.unwrap_err().description(),
60        "Unexpected null for non-null column"
61    );
62}
diesel/pg/types/uuid_v0_7.rs

diesel/pg/types/
uuid_v0_7.rs
