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 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77
use byteorder::{BigEndian, ByteOrder}; use crate::decode::Decode; use crate::encode::{Encode, IsNull}; use crate::error::BoxDynError; use crate::postgres::{PgArgumentBuffer, PgTypeInfo, PgValueFormat, PgValueRef, Postgres}; use crate::types::Type; impl Type<Postgres> for f32 { fn type_info() -> PgTypeInfo { PgTypeInfo::FLOAT4 } } impl Type<Postgres> for [f32] { fn type_info() -> PgTypeInfo { PgTypeInfo::FLOAT4_ARRAY } } impl Type<Postgres> for Vec<f32> { fn type_info() -> PgTypeInfo { <[f32] as Type<Postgres>>::type_info() } } impl Encode<'_, Postgres> for f32 { fn encode_by_ref(&self, buf: &mut PgArgumentBuffer) -> IsNull { buf.extend(&self.to_be_bytes()); IsNull::No } } impl Decode<'_, Postgres> for f32 { fn decode(value: PgValueRef<'_>) -> Result<Self, BoxDynError> { Ok(match value.format() { PgValueFormat::Binary => BigEndian::read_f32(value.as_bytes()?), PgValueFormat::Text => value.as_str()?.parse()?, }) } } impl Type<Postgres> for f64 { fn type_info() -> PgTypeInfo { PgTypeInfo::FLOAT8 } } impl Type<Postgres> for [f64] { fn type_info() -> PgTypeInfo { PgTypeInfo::FLOAT8_ARRAY } } impl Type<Postgres> for Vec<f64> { fn type_info() -> PgTypeInfo { <[f64] as Type<Postgres>>::type_info() } } impl Encode<'_, Postgres> for f64 { fn encode_by_ref(&self, buf: &mut PgArgumentBuffer) -> IsNull { buf.extend(&self.to_be_bytes()); IsNull::No } } impl Decode<'_, Postgres> for f64 { fn decode(value: PgValueRef<'_>) -> Result<Self, BoxDynError> { Ok(match value.format() { PgValueFormat::Binary => BigEndian::read_f64(value.as_bytes()?), PgValueFormat::Text => value.as_str()?.parse()?, }) } }