Method get_current_database

nodedb/src/control/server/pgwire/session/store.rs:114–117

Retrieve the `current_database` for a connection, or `None` if the session does not exist or has not had a database bound yet.

(&self, addr: &SocketAddr)

    /// Retrieve the `current_database` for a connection, or `None` if the session
    /// does not exist or has not had a database bound yet.
    pub fn get_current_database(&self, addr: &SocketAddr) -> Option<DatabaseId> {
        let sessions = self.sessions.read().unwrap_or_else(|p| p.into_inner());
        sessions.get(addr)?.current_database
    }

    /// Bind a database to a session.  Called at pgwire startup once the database
    /// name from the StartupMessage has been resolved to a `DatabaseId`.