]> git.ipfire.org Git - thirdparty/psycopg.git/commitdiff
refactor: import OID constants from the _oids module
authorDaniele Varrazzo <daniele.varrazzo@gmail.com>
Fri, 6 Jan 2023 14:11:24 +0000 (14:11 +0000)
committerDaniele Varrazzo <daniele.varrazzo@gmail.com>
Mon, 9 Jan 2023 17:44:16 +0000 (17:44 +0000)
psycopg/psycopg/_transform.py
psycopg/psycopg/_typeinfo.py
psycopg/psycopg/crdb/_types.py
psycopg/psycopg/postgres.py
psycopg/psycopg/types/array.py
psycopg/psycopg/types/composite.py
psycopg/psycopg/types/hstore.py
psycopg/psycopg/types/multirange.py
psycopg/psycopg/types/range.py
psycopg/psycopg/types/string.py
tests/test_adapt.py

index 19bd6aec79d4021c991751f89f38b19dfd0a70a9..281cd26f2ed1cd013e7073d967b8b5f79ed5d15e 100644 (file)
@@ -14,7 +14,7 @@ from . import postgres
 from . import errors as e
 from .abc import Buffer, LoadFunc, AdaptContext, PyFormat, DumperKey, NoneType
 from .rows import Row, RowMaker
-from .postgres import INVALID_OID, TEXT_OID
+from ._oids import INVALID_OID, TEXT_OID
 from ._encodings import pgconn_encoding
 
 if TYPE_CHECKING:
index 9b4f40f689264e56ec2fb4e0f1970f5b064500ab..7ca7db7ae8061551b0dd7737080e64681cf206ca 100644 (file)
@@ -6,6 +6,7 @@ information to the adapters if needed.
 """
 
 # Copyright (C) 2020 The Psycopg Team
+
 from enum import Enum
 from typing import Any, Dict, Iterator, Optional, overload
 from typing import Sequence, Tuple, Type, TypeVar, Union, TYPE_CHECKING
index e685c95045683f694aeb30dd9020c37199f67aff..ac04c96e88cba8ea989aaf2cc55d4ff1d15a7a70 100644 (file)
@@ -8,7 +8,7 @@ from enum import Enum
 from .._typeinfo import TypeInfo, TypesRegistry
 
 from ..abc import AdaptContext, NoneType
-from ..postgres import TEXT_OID
+from .._oids import TEXT_OID
 from .._adapters_map import AdaptersMap
 from ..types.enum import EnumDumper, EnumBinaryDumper
 from ..types.none import NoneDumper
index 35aa68d63281d637aed6d52d3e58fb18ed089ca7..53a8ccf59fa00da6f215c202d2d9b5c12015ce54 100644 (file)
@@ -99,12 +99,6 @@ for t in [
     types.add(t)
 
 
-# A few oids used a bit everywhere
-INVALID_OID = 0
-TEXT_OID = types["text"].oid
-TEXT_ARRAY_OID = types["text"].array_oid
-
-
 def register_default_adapters(context: AdaptContext) -> None:
 
     from .types import array, bool, composite, datetime, enum, json, multirange
index e35c5e76ffcb58767f6bf091fac813feae29bb88..3771841b8405df50e05d8dd8625f17e7eeecc44d 100644 (file)
@@ -13,10 +13,10 @@ from .. import errors as e
 from .. import postgres
 from ..abc import AdaptContext, Buffer, Dumper, DumperKey, NoneType, Loader, Transformer
 from ..adapt import RecursiveDumper, RecursiveLoader, PyFormat
+from .._oids import TEXT_OID, INVALID_OID
 from .._compat import cache, prod
 from .._struct import pack_len, unpack_len
 from .._cmodule import _psycopg
-from ..postgres import TEXT_OID, INVALID_OID
 from .._typeinfo import TypeInfo
 
 _struct_head = struct.Struct("!III")  # ndims, hasnull, elem oid
index 1c609c3079ec081a65d9bde774ff5f48684e5019..d75b1d413f7c2cfddb0ca06eb59123787612e57e 100644 (file)
@@ -14,8 +14,8 @@ from .. import pq
 from .. import postgres
 from ..abc import AdaptContext, Buffer
 from ..adapt import Transformer, PyFormat, RecursiveDumper, Loader
+from .._oids import TEXT_OID
 from .._struct import pack_len, unpack_len
-from ..postgres import TEXT_OID
 from .._typeinfo import CompositeInfo as CompositeInfo  # exported here
 from .._encodings import _as_python_identifier
 
index e1ab1d5806a49374073fbc06d6a8a6c2f9f0bf94..f668da8c6e08e4e20800871de5363930cdf8322b 100644 (file)
@@ -11,8 +11,8 @@ from typing_extensions import TypeAlias
 from .. import errors as e
 from .. import postgres
 from ..abc import Buffer, AdaptContext
+from .._oids import TEXT_OID
 from ..adapt import PyFormat, RecursiveDumper, RecursiveLoader
-from ..postgres import TEXT_OID
 from .._typeinfo import TypeInfo
 
 _re_escape = re.compile(r'(["\\])')
index 3eaa7f127a04746dd56b85ad9728c8930dd36806..44235494feeeec085eaeca39234671621142d355 100644 (file)
@@ -14,8 +14,8 @@ from .. import postgres
 from ..pq import Format
 from ..abc import AdaptContext, Buffer, Dumper, DumperKey
 from ..adapt import RecursiveDumper, RecursiveLoader, PyFormat
+from .._oids import INVALID_OID, TEXT_OID
 from .._struct import pack_len, unpack_len
-from ..postgres import INVALID_OID, TEXT_OID
 from .._typeinfo import MultirangeInfo as MultirangeInfo  # exported here
 
 from .range import Range, T, load_range_text, load_range_binary
index c41848023d03e929e17e47ecb64af3a2769780bb..513f68a506b90fc60b52c5745d9893902ed0555b 100644 (file)
@@ -15,8 +15,8 @@ from .. import postgres
 from ..pq import Format
 from ..abc import AdaptContext, Buffer, Dumper, DumperKey
 from ..adapt import RecursiveDumper, RecursiveLoader, PyFormat
+from .._oids import INVALID_OID, TEXT_OID
 from .._struct import pack_len, unpack_len
-from ..postgres import INVALID_OID, TEXT_OID
 from .._typeinfo import RangeInfo as RangeInfo  # exported here
 
 RANGE_EMPTY = 0x01  # range is empty
index cd5360dba428a8860743460250df3f1195c38f5f..fe5779b2009bfef6dc430543087993940363a3c4 100644 (file)
@@ -11,6 +11,7 @@ from ..pq import Format, Escaping
 from ..abc import AdaptContext
 from ..adapt import Buffer, Dumper, Loader
 from ..errors import DataError
+from .._oids import INVALID_OID
 from .._encodings import conn_encoding
 
 if TYPE_CHECKING:
@@ -215,7 +216,7 @@ def register_default_adapters(context: AdaptContext) -> None:
     adapters.register_dumper(str, StrDumper)
     adapters.register_dumper(str, StrDumperUnknown)
 
-    adapters.register_loader(postgres.INVALID_OID, TextLoader)
+    adapters.register_loader(INVALID_OID, TextLoader)
     adapters.register_loader("bpchar", TextLoader)
     adapters.register_loader("name", TextLoader)
     adapters.register_loader("text", TextLoader)
@@ -235,5 +236,5 @@ def register_default_adapters(context: AdaptContext) -> None:
     adapters.register_dumper(memoryview, BytesBinaryDumper)
 
     adapters.register_loader("bytea", ByteaLoader)
-    adapters.register_loader(postgres.INVALID_OID, ByteaBinaryLoader)
+    adapters.register_loader(INVALID_OID, ByteaBinaryLoader)
     adapters.register_loader("bytea", ByteaBinaryLoader)
index 2190a846d9375e1f2624ad3663e52cf838cb1848..9ca469bfb78a6334549db6d498009eb1959ca03c 100644 (file)
@@ -9,7 +9,7 @@ from psycopg import pq, sql, postgres
 from psycopg import errors as e
 from psycopg.adapt import Transformer, PyFormat, Dumper, Loader
 from psycopg._cmodule import _psycopg
-from psycopg.postgres import types as builtins, TEXT_OID
+from psycopg.postgres import types as builtins
 from psycopg.types.array import ListDumper, ListBinaryDumper
 
 
@@ -184,18 +184,21 @@ def test_cast(data, format, type, result):
 
 
 def test_register_loader_by_oid(conn):
-    assert TEXT_OID == 25
+    oid = builtins["text"].oid
+    assert oid == 25
     loader = make_loader("x")
-    assert conn.adapters.get_loader(TEXT_OID, pq.Format.TEXT) is not loader
-    conn.adapters.register_loader(TEXT_OID, loader)
-    assert conn.adapters.get_loader(TEXT_OID, pq.Format.TEXT) is loader
+    assert conn.adapters.get_loader(oid, pq.Format.TEXT) is not loader
+    conn.adapters.register_loader(oid, loader)
+    assert conn.adapters.get_loader(oid, pq.Format.TEXT) is loader
 
 
 def test_register_loader_by_type_name(conn):
+    oid = builtins["text"].oid
+    assert oid == 25
     loader = make_loader("x")
-    assert conn.adapters.get_loader(TEXT_OID, pq.Format.TEXT) is not loader
+    assert conn.adapters.get_loader(oid, pq.Format.TEXT) is not loader
     conn.adapters.register_loader("text", loader)
-    assert conn.adapters.get_loader(TEXT_OID, pq.Format.TEXT) is loader
+    assert conn.adapters.get_loader(oid, pq.Format.TEXT) is loader
 
 
 @pytest.mark.crdb("skip", reason="global adapters don't affect crdb")
@@ -497,7 +500,7 @@ def make_dumper(suffix):
     """Create a test dumper appending a suffix to the bytes representation."""
 
     class TestDumper(Dumper):
-        oid = TEXT_OID
+        oid = builtins["text"].oid
         format = pq.Format.TEXT
 
         def dump(self, s):