cot 0.5.0

The Rust web framework for lazy developers.
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

//! Database interface implementation – PostgreSQL backend.

use crate::db::sea_query_db::impl_sea_query_db_backend;

impl_sea_query_db_backend!(DatabasePostgres: sqlx::postgres::Postgres, sqlx::postgres::PgPool, PostgresRow, PostgresValueRef, sea_query::PostgresQueryBuilder);

impl DatabasePostgres {
    #[expect(clippy::unused_async)]
    async fn init(&self) -> crate::db::Result<()> {
        Ok(())
    }

    fn prepare_values(values: &mut sea_query_binder::SqlxValues) {
        for value in &mut values.0.0 {
            Self::tinyint_to_smallint(value);
            Self::unsigned_to_signed(value);
        }
    }

    /// PostgreSQL does only support 2+ bytes integers, so we need to convert
    /// i8/u8 to i16/u16. Otherwise, sqlx will convert them internally to `char`
    /// and we'll get an error.
    fn tinyint_to_smallint(value: &mut sea_query::Value) {
        if let sea_query::Value::TinyInt(num) = value {
            *value = sea_query::Value::SmallInt(num.map(i16::from));
        } else if let sea_query::Value::TinyUnsigned(num) = value {
            *value = sea_query::Value::SmallInt(num.map(i16::from));
        }
    }

    /// PostgreSQL doesn't support unsigned integers, so we need to convert
    /// them to signed integers.
    fn unsigned_to_signed(value: &mut sea_query::Value) {
        #[expect(clippy::cast_possible_wrap)]
        if let sea_query::Value::SmallUnsigned(num) = value {
            *value = sea_query::Value::SmallInt(num.map(|v| v as i16));
        } else if let sea_query::Value::Unsigned(num) = value {
            *value = sea_query::Value::Int(num.map(|v| v as i32));
        } else if let sea_query::Value::BigUnsigned(num) = value {
            *value = sea_query::Value::BigInt(num.map(|v| v as i64));
        }
    }

    fn last_inserted_row_id_for(_result: &sqlx::postgres::PgQueryResult) -> Option<u64> {
        None
    }

    #[expect(clippy::unused_self)] // to have a unified interface between database impls
    pub(super) fn sea_query_column_type_for(
        &self,
        column_type: crate::db::ColumnType,
    ) -> sea_query::ColumnType {
        sea_query::ColumnType::from(column_type)
    }
}