from typing import Any, Callable, Dict, Optional, Sequence, Tuple, Type, Union
from typing import cast
from psycopg3.pq.proto import PGresult
-from psycopg3.pq.enums import DiagnosticField
+from psycopg3.pq._enums import DiagnosticField
class Warning(Exception):
import logging
from typing import Callable, Type
-from .enums import (
- ConnStatus,
- PollingStatus,
- ExecStatus,
- TransactionStatus,
- Ping,
- DiagnosticField,
- Format,
-)
from .misc import ConninfoOption, PQerror, PGnotify, PGresAttDesc
from .misc import error_message
+from ._enums import ConnStatus, DiagnosticField, ExecStatus, Format
+from ._enums import Ping, PollingStatus, TransactionStatus
from . import proto
logger = logging.getLogger(__name__)
Current status of the connection.
"""
+ __module__ = "psycopg3.pq"
+
OK = 0
"""The connection is in a working state."""
BAD = auto()
If ``READING`` or ``WRITING`` you may select before polling again.
"""
+ __module__ = "psycopg3.pq"
+
FAILED = 0
"""Connection attempt failed."""
READING = auto()
The status of a command.
"""
+ __module__ = "psycopg3.pq"
+
EMPTY_QUERY = 0
"""The string sent to the server was empty."""
The transaction status of a connection.
"""
+ __module__ = "psycopg3.pq"
+
IDLE = 0
"""Connection ready, no transaction active."""
class Ping(IntEnum):
"""Response from a ping attempt."""
+ __module__ = "psycopg3.pq"
+
OK = 0
"""
The server is running and appears to be accepting connections.
Fields in an error report.
"""
+ __module__ = "psycopg3.pq"
+
# from postgres_ext.h
SEVERITY = ord("S")
SEVERITY_NONLOCALIZED = ord("V")
The format of a query argument or return value.
"""
+ __module__ = "psycopg3.pq"
+
TEXT = 0
"""Text parameter."""
BINARY = 1
from typing import cast, NamedTuple, Optional, Union
from ..errors import OperationalError
-from .enums import DiagnosticField, ConnStatus
+from ._enums import DiagnosticField, ConnStatus
from .proto import PGconn, PGresult
from typing import Any, Callable, List, Optional, Sequence, Tuple
from typing import cast as t_cast, TYPE_CHECKING
-from .enums import (
- ConnStatus,
- PollingStatus,
- ExecStatus,
- TransactionStatus,
- Ping,
- DiagnosticField,
- Format,
-)
+from . import _pq_ctypes as impl
from .misc import PGnotify, ConninfoOption, PQerror, PGresAttDesc
from .misc import error_message
-from . import _pq_ctypes as impl
+from ._enums import ConnStatus, DiagnosticField, ExecStatus, Format
+from ._enums import Ping, PollingStatus, TransactionStatus
if TYPE_CHECKING:
from . import proto
from typing import TYPE_CHECKING
from typing_extensions import Protocol
-from .enums import (
- ConnStatus,
- PollingStatus,
- ExecStatus,
- TransactionStatus,
- Ping,
- DiagnosticField,
- Format,
-)
+from ._enums import ConnStatus, DiagnosticField, ExecStatus, Format
+from ._enums import Ping, PollingStatus, TransactionStatus
if TYPE_CHECKING:
from .misc import PGnotify, ConninfoOption, PGresAttDesc
import string
from typing import Any, Iterator, List, Optional, Sequence, Union
-from typing import TYPE_CHECKING
from .pq import Escaping, Format
from .proto import AdaptContext
-if TYPE_CHECKING:
- import psycopg3
-
def quote(obj: Any, context: AdaptContext = None) -> str:
"""
"""
- def __init__(
- self, name: str = "", format: "psycopg3.pq.Format" = Format.TEXT
- ):
+ def __init__(self, name: str = "", format: Format = Format.TEXT):
super().__init__(name)
if not isinstance(name, str):
raise TypeError(f"expected string as name, got {name!r}")
from psycopg3_c.adapt cimport cloader_func, get_context_func
from psycopg3_c.pq_cython cimport Escaping
-from psycopg3.pq.enums import Format
+from psycopg3.pq import Format
import logging
logger = logging.getLogger("psycopg3.adapt")
from psycopg3.pq.misc import PGnotify, ConninfoOption, PQerror, PGresAttDesc
from psycopg3.pq.misc import error_message
-from psycopg3.pq.enums import (
+from psycopg3.pq import (
ConnStatus,
PollingStatus,
ExecStatus,
from psycopg3_c.pq_cython cimport PGresult
from psycopg3 import errors as e
-from psycopg3.pq.enums import Format
+from psycopg3.pq import Format
cdef class RowLoader: