conninfo: str = "",
*,
autocommit: bool = False,
- row_factory: RowFactory[Any],
+ row_factory: Optional[RowFactory[Any]] = None,
**kwargs: Any,
) -> PQGenConn[ConnectionType]:
"""Generator to connect to the database and create a new instance."""
pgconn = yield from connect(conninfo)
conn = cls(pgconn)
conn._autocommit = autocommit
+ if row_factory is None:
+ row_factory = cls.row_factory
conn.row_factory = row_factory
return conn
conninfo: str = "",
*,
autocommit: bool = False,
- row_factory: RowFactory[Any] = tuple_row,
+ row_factory: Optional[RowFactory[Any]] = None,
**kwargs: Any,
) -> "Connection":
"""
conninfo: str = "",
*,
autocommit: bool = False,
- row_factory: RowFactory[Any] = tuple_row,
+ row_factory: Optional[RowFactory[Any]] = None,
**kwargs: Any,
) -> "AsyncConnection":
return await cls._wait_conn(