Remove format param from cursor constructor

diff --git a/psycopg/psycopg/connection.py b/psycopg/psycopg/connection.py
index 64a158d49c2ef821425dd0e0aca6747296d8f0db..9f8f08988a10699097be8957eb8ff056df1f6ba4 100644 (file)
--- a/psycopg/psycopg/connection.py
+++ b/psycopg/psycopg/connection.py
@@ -561,15 +561,19 @@ class Connection(BaseConnection[Row]):
         """
         Return a new cursor to send commands and queries to the connection.
         """
-        format = Format.BINARY if binary else Format.TEXT
         if not row_factory:
             row_factory = self.row_factory
+
+        cur: Union[Cursor[Any], ServerCursor[Any]]
         if name:
-            return ServerCursor(
-                self, name=name, format=format, row_factory=row_factory
-            )
+            cur = ServerCursor(self, name=name, row_factory=row_factory)
         else:
-            return Cursor(self, format=format, row_factory=row_factory)
+            cur = Cursor(self, row_factory=row_factory)
+
+        if binary:
+            cur.format = Format.BINARY
+
+        return cur
 
     def execute(
         self,
@@ -772,15 +776,19 @@ class AsyncConnection(BaseConnection[Row]):
         """
         Return a new `AsyncCursor` to send commands and queries to the connection.
         """
-        format = Format.BINARY if binary else Format.TEXT
         if not row_factory:
             row_factory = self.row_factory
+
+        cur: Union[AsyncCursor[Any], AsyncServerCursor[Any]]
         if name:
-            return AsyncServerCursor(
-                self, name=name, format=format, row_factory=row_factory
-            )
+            cur = AsyncServerCursor(self, name=name, row_factory=row_factory)
         else:
-            return AsyncCursor(self, format=format, row_factory=row_factory)
+            cur = AsyncCursor(self, row_factory=row_factory)
+
+        if binary:
+            cur.format = Format.BINARY
+
+        return cur
 
     async def execute(
         self,

diff --git a/psycopg/psycopg/cursor.py b/psycopg/psycopg/cursor.py
index 4e1946524122943be375cfc1ddae90f7d6ac907d..c9c1fae25238b490ca91f0ebfe6e7897e03e18f2 100644 (file)
--- a/psycopg/psycopg/cursor.py
+++ b/psycopg/psycopg/cursor.py
@@ -58,11 +58,10 @@ class BaseCursor(Generic[ConnectionType, Row]):
         self,
         connection: ConnectionType,
         *,
-        format: Format = Format.TEXT,
         row_factory: RowFactory[Row],
     ):
         self._conn = connection
-        self.format = format
+        self.format = Format.TEXT
         self._adapters = adapt.AdaptersMap(connection.adapters)
         self._row_factory = row_factory
         self.arraysize = 1

diff --git a/psycopg/psycopg/server_cursor.py b/psycopg/psycopg/server_cursor.py
index 2367c68035bd79539d06f62aa0d919c1e1d5bcf8..636a8aeb097278f22a232327aab21729f217ed25 100644 (file)
--- a/psycopg/psycopg/server_cursor.py
+++ b/psycopg/psycopg/server_cursor.py
@@ -176,10 +176,9 @@ class ServerCursor(BaseCursor["Connection[Any]", Row]):
         connection: "Connection[Any]",
         name: str,
         *,
-        format: pq.Format = pq.Format.TEXT,
         row_factory: RowFactory[Row],
     ):
-        super().__init__(connection, format=format, row_factory=row_factory)
+        super().__init__(connection, row_factory=row_factory)
         self._helper: ServerCursorHelper["Connection[Any]", Row]
         self._helper = ServerCursorHelper(name)
         self.itersize: int = DEFAULT_ITERSIZE
@@ -297,10 +296,9 @@ class AsyncServerCursor(BaseCursor["AsyncConnection[Any]", Row]):
         connection: "AsyncConnection[Any]",
         name: str,
         *,
-        format: pq.Format = pq.Format.TEXT,
         row_factory: RowFactory[Row],
     ):
-        super().__init__(connection, format=format, row_factory=row_factory)
+        super().__init__(connection, row_factory=row_factory)
         self._helper: ServerCursorHelper["AsyncConnection[Any]", Row]
         self._helper = ServerCursorHelper(name)
         self.itersize: int = DEFAULT_ITERSIZE