pg_extras/queries/
connections.rs

1use crate::{queries::shared::Query, PgStatsVersion};
2use sqlx::{postgres::PgRow, Row};
3
4#[derive(Debug, Clone, serde::Serialize)]
5pub struct Connections {
6    pub username: String,
7    pub pid: i32,
8    pub client_addr: String,
9}
10
11impl Query for Connections {
12    fn new(row: &PgRow) -> Self {
13        Self {
14            username: row.try_get("username").unwrap_or_default(),
15            pid: row.try_get("pid").unwrap_or_default(),
16            client_addr: row.try_get("client_addr").unwrap_or_default(),
17        }
18    }
19
20    fn to_row(&self) -> prettytable::Row {
21        row![self.username, self.pid, self.client_addr]
22    }
23
24    fn headers() -> prettytable::Row {
25        row!["username", "pid", "client_addr"]
26    }
27
28    fn read_file(_pg_statement_version: Option<PgStatsVersion>) -> String {
29        include_str!("../sql/connections.sql").to_string()
30    }
31}
pg_extras/queries/connections.rs

pg_extras/queries/
connections.rs
