"""
cdef pq.PGconn conn = pq.PGconn.connect_start(conninfo.encode("utf8"))
- logger.debug("connection started, status %s", conn.status.name)
+ logger.debug("connection started, status %s", conn.status)
cdef libpq.PGconn *pgconn_ptr = conn.pgconn_ptr
cdef int conn_status = libpq.PQstatus(pgconn_ptr)
cdef int poll_status
)
poll_status = libpq.PQconnectPoll(pgconn_ptr)
- logger.debug("connection polled, status %s", conn.status.name)
+ logger.debug("connection polled, status %s", conn.status)
if poll_status == libpq.PGRES_POLLING_OK:
break
elif poll_status == libpq.PGRES_POLLING_READING:
from psycopg3_c.pq cimport libpq
-from psycopg3.pq import ConnStatus, PollingStatus, ExecStatus
-from psycopg3.pq import TransactionStatus, Ping, DiagnosticField, Format
+from psycopg3.pq import Format
from psycopg3.pq.misc import PQerror, error_message
__impl__ = 'c'
return _call_bytes(self, libpq.PQoptions)
@property
- def status(self) -> ConnStatus:
- cdef int rv = libpq.PQstatus(self.pgconn_ptr)
- return ConnStatus(rv)
+ def status(self) -> int:
+ return libpq.PQstatus(self.pgconn_ptr)
@property
def transaction_status(self) -> int: