From ebe6ac9ab11f858a30068beb8b936186933085fe Mon Sep 17 00:00:00 2001 From: Rahim Kanji Date: Mon, 23 Jun 2025 00:21:12 +0500 Subject: [PATCH] Add get_transaction_status_char() --- lib/PgSQL_Connection.cpp | 20 ++++++++++++++++++++ 1 file changed, 20 insertions(+) diff --git a/lib/PgSQL_Connection.cpp b/lib/PgSQL_Connection.cpp index 9d31d77db..ed8decb04 100644 --- a/lib/PgSQL_Connection.cpp +++ b/lib/PgSQL_Connection.cpp @@ -1652,6 +1652,26 @@ unsigned int PgSQL_Connection::get_memory_usage() const { return /*sizeof(PGconn) +*/ memory_bytes; } +char PgSQL_Connection::get_transaction_status_char() { + char txn_status; + switch (get_pg_transaction_status()) { + case PQTRANS_IDLE: + txn_status = 'I'; + break; + case PQTRANS_ACTIVE: + case PQTRANS_INTRANS: + txn_status = 'T'; + break; + case PQTRANS_INERROR: + txn_status = 'E'; + break; + case PQTRANS_UNKNOWN: + default: + txn_status = 'U'; + } + return txn_status; +} + void PgSQL_Connection::update_bytes_recv(uint64_t bytes_recv) { __sync_fetch_and_add(&parent->bytes_recv, bytes_recv); myds->sess->thread->status_variables.stvar[st_var_queries_backends_bytes_recv] += bytes_recv;