From 06f1929b866abc2af0ff5c838e472a8b1c98d6e6 Mon Sep 17 00:00:00 2001 From: Tony Locke Date: Sun, 2 Aug 2020 15:19:26 -0400 Subject: Update dialect for pg8000 version 1.16.0 The pg8000 dialect has been revised and modernized for the most recent version of the pg8000 driver for PostgreSQL. Changes to the dialect include: * All data types are now sent as text rather than binary. * Using adapters, custom types can be plugged in to pg8000. * Previously, named prepared statements were used for all statements. Now unnamed prepared statements are used by default, and named prepared statements can be used explicitly by calling the Connection.prepare() method, which returns a PreparedStatement object. Pull request courtesy Tony Locke. Notes by Mike: to get this all working it was needed to break up JSONIndexType into "str" and "int" subtypes; this will be needed for any dialect that is dependent on setinputsizes(). also includes @caselit's idea to include query params in the dbdriver parameter. Co-authored-by: Mike Bayer Closes: #5451 Pull-request: https://github.com/sqlalchemy/sqlalchemy/pull/5451 Pull-request-sha: 639751ca9c7544801b9ede02e6cbe15a16c59c82 Change-Id: I2869bc52c330916773a41d11d12c297aecc8fcd8 --- lib/sqlalchemy/dialects/postgresql/provision.py | 17 ----------------- 1 file changed, 17 deletions(-) (limited to 'lib/sqlalchemy/dialects/postgresql/provision.py') diff --git a/lib/sqlalchemy/dialects/postgresql/provision.py b/lib/sqlalchemy/dialects/postgresql/provision.py index eb82a411e..6c6dc4be6 100644 --- a/lib/sqlalchemy/dialects/postgresql/provision.py +++ b/lib/sqlalchemy/dialects/postgresql/provision.py @@ -1,30 +1,13 @@ -import copy import time from ... import exc from ... import text from ...testing.provision import create_db from ...testing.provision import drop_db -from ...testing.provision import generate_driver_url from ...testing.provision import log from ...testing.provision import temp_table_keyword_args -@generate_driver_url.for_db("postgresql") -def generate_driver_url(url, driver): - new_url = copy.copy(url) - new_url.drivername = "postgresql+%s" % driver - if new_url.get_driver_name() == "asyncpg": - new_url.query = dict(new_url.query) - new_url.query["async_fallback"] = "true" - try: - new_url.get_dialect() - except exc.NoSuchModuleError: - return None - else: - return new_url - - @create_db.for_db("postgresql") def _pg_create_db(cfg, eng, ident): template_db = cfg.options.postgresql_templatedb -- cgit v1.2.1