pg2parquet 0.1.1

Command line tool for exporting PostgreSQL tables or queries into Parquet files
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

use byteorder::{ReadBytesExt, BigEndian, ByteOrder};
use postgres::types::FromSql;

use crate::myfrom::MyFrom;

#[derive(Debug, Clone)]
pub struct PgMoney {
	pub amount: i64
}

impl<'a> FromSql<'a> for PgMoney {
	fn from_sql(_ty: &postgres::types::Type, raw: &'a [u8]) -> Result<Self, Box<dyn std::error::Error + Sync + Send>> {
		let amount = BigEndian::read_i64(&raw);
		Ok(PgMoney { amount })
	}

	fn accepts(ty: &postgres::types::Type) -> bool {
		ty == &postgres::types::Type::MONEY
	}
}

impl MyFrom<PgMoney> for i64 {
	fn my_from(t: PgMoney) -> Self {
		t.amount
	}
}