diff options
author | Mike Bayer <mike_mp@zzzcomputing.com> | 2016-01-19 16:47:16 -0500 |
---|---|---|
committer | Mike Bayer <mike_mp@zzzcomputing.com> | 2016-01-19 16:47:16 -0500 |
commit | 39837686b068a6e7016169f31a96a058546e4bdd (patch) | |
tree | 736084283457941f22601f3afc4b58dadcd95edf | |
parent | b7bc704f3d05bed8d0771cbff65adcdb7b49f796 (diff) | |
download | sqlalchemy-39837686b068a6e7016169f31a96a058546e4bdd.tar.gz |
- calling str() on a core sql construct has been made more "friendly",
when the construct contains non-standard sql elements such as
returning, array index operations, or dialect-specific or custom
datatypes. a string is now returned in these cases rendering an
approximation of the construct (typically the postgresql-style
version of it) rather than raising an error. fixes #3631
- add within_group to top-level imports
- add eq_ignore_whitespace to sqlalchemy.testing imports
-rw-r--r-- | doc/build/changelog/changelog_11.rst | 15 | ||||
-rw-r--r-- | doc/build/changelog/migration_11.rst | 30 | ||||
-rw-r--r-- | lib/sqlalchemy/__init__.py | 1 | ||||
-rw-r--r-- | lib/sqlalchemy/engine/default.py | 17 | ||||
-rw-r--r-- | lib/sqlalchemy/sql/__init__.py | 1 | ||||
-rw-r--r-- | lib/sqlalchemy/sql/compiler.py | 35 | ||||
-rw-r--r-- | lib/sqlalchemy/sql/elements.py | 2 | ||||
-rw-r--r-- | lib/sqlalchemy/testing/__init__.py | 2 | ||||
-rw-r--r-- | test/sql/test_compiler.py | 73 | ||||
-rw-r--r-- | test/sql/test_metadata.py | 3 | ||||
-rw-r--r-- | test/sql/test_selectable.py | 12 |
11 files changed, 180 insertions, 11 deletions
diff --git a/doc/build/changelog/changelog_11.rst b/doc/build/changelog/changelog_11.rst index 9767567c6..80c8ece33 100644 --- a/doc/build/changelog/changelog_11.rst +++ b/doc/build/changelog/changelog_11.rst @@ -22,6 +22,21 @@ :version: 1.1.0b1 .. change:: + :tags: feature, orm + :tickets: 3631 + + Calling str() on a core SQL construct has been made more "friendly", + when the construct contains non-standard SQL elements such as + RETURNING, array index operations, or dialect-specific or custom + datatypes. A string is now returned in these cases rendering an + approximation of the construct (typically the Postgresql-style + version of it) rather than raising an error. + + .. seealso:: + + :ref:`change_3631` + + .. change:: :tags: bug, orm :tickets: 3630 diff --git a/doc/build/changelog/migration_11.rst b/doc/build/changelog/migration_11.rst index 2deeda376..d687c5c66 100644 --- a/doc/build/changelog/migration_11.rst +++ b/doc/build/changelog/migration_11.rst @@ -421,6 +421,10 @@ If neither the underlying :class:`.MetaData` nor the :class:`.Session` are associated with any bound :class:`.Engine`, then the fallback to the "default" dialect is used to generate the SQL string. +.. seealso:: + + :ref:`change_3631` + :ticket:`3081` New Features and Improvements - Core @@ -978,6 +982,32 @@ different schema each time:: :ticket:`2685` +.. _change_3631: + +"Friendly" stringification of Core SQL constructs without a dialect +------------------------------------------------------------------- + +Calling ``str()`` on a Core SQL construct will now produce a string +in more cases than before, supporting various SQL constructs not normally +present in default SQL such as RETURNING, array indexes, and non-standard +datatypes:: + + >>> from sqlalchemy import table, column + t>>> t = table('x', column('a'), column('b')) + >>> print(t.insert().returning(t.c.a, t.c.b)) + INSERT INTO x (a, b) VALUES (:a, :b) RETURNING x.a, x.b + +The ``str()`` function now calls upon an entirely separate dialect / compiler +intended just for plain string printing without a specific dialect set up, +so as more "just show me a string!" cases come up, these can be added +to this dialect/compiler without impacting behaviors on real dialects. + +.. seealso:: + + :ref:`change_3081` + +:ticket:`3631` + .. _change_3531: The type_coerce function is now a persistent SQL element diff --git a/lib/sqlalchemy/__init__.py b/lib/sqlalchemy/__init__.py index 40b8000e8..dde179bf5 100644 --- a/lib/sqlalchemy/__init__.py +++ b/lib/sqlalchemy/__init__.py @@ -51,6 +51,7 @@ from .sql import ( union, union_all, update, + within_group, ) from .types import ( diff --git a/lib/sqlalchemy/engine/default.py b/lib/sqlalchemy/engine/default.py index 3e5f339b1..9f845e79d 100644 --- a/lib/sqlalchemy/engine/default.py +++ b/lib/sqlalchemy/engine/default.py @@ -474,6 +474,23 @@ class DefaultDialect(interfaces.Dialect): self.set_isolation_level(dbapi_conn, self.default_isolation_level) +class StrCompileDialect(DefaultDialect): + + statement_compiler = compiler.StrSQLCompiler + ddl_compiler = compiler.DDLCompiler + type_compiler = compiler.StrSQLTypeCompiler + preparer = compiler.IdentifierPreparer + + supports_sequences = True + sequences_optional = True + preexecute_autoincrement_sequences = False + implicit_returning = False + + supports_native_boolean = True + + supports_simple_order_by_label = True + + class DefaultExecutionContext(interfaces.ExecutionContext): isinsert = False isupdate = False diff --git a/lib/sqlalchemy/sql/__init__.py b/lib/sqlalchemy/sql/__init__.py index fa2cf2399..f4ad3ec00 100644 --- a/lib/sqlalchemy/sql/__init__.py +++ b/lib/sqlalchemy/sql/__init__.py @@ -66,6 +66,7 @@ from .expression import ( union, union_all, update, + within_group ) from .visitors import ClauseVisitor diff --git a/lib/sqlalchemy/sql/compiler.py b/lib/sqlalchemy/sql/compiler.py index c5f87cc33..076ae53b2 100644 --- a/lib/sqlalchemy/sql/compiler.py +++ b/lib/sqlalchemy/sql/compiler.py @@ -2118,6 +2118,30 @@ class SQLCompiler(Compiled): self.preparer.format_savepoint(savepoint_stmt) +class StrSQLCompiler(SQLCompiler): + """"a compiler subclass with a few non-standard SQL features allowed. + + Used for stringification of SQL statements when a real dialect is not + available. + + """ + + def visit_getitem_binary(self, binary, operator, **kw): + return "%s[%s]" % ( + self.process(binary.left, **kw), + self.process(binary.right, **kw) + ) + + def returning_clause(self, stmt, returning_cols): + + columns = [ + self._label_select_column(None, c, True, False, {}) + for c in elements._select_iterables(returning_cols) + ] + + return 'RETURNING ' + ', '.join(columns) + + class DDLCompiler(Compiled): @util.memoized_property @@ -2640,6 +2664,17 @@ class GenericTypeCompiler(TypeCompiler): return type_.get_col_spec(**kw) +class StrSQLTypeCompiler(GenericTypeCompiler): + def __getattr__(self, key): + if key.startswith("visit_"): + return self._visit_unknown + else: + raise AttributeError(key) + + def _visit_unknown(self, type_, **kw): + return "%s" % type_.__class__.__name__ + + class IdentifierPreparer(object): """Handle quoting and case-folding of identifiers based on options.""" diff --git a/lib/sqlalchemy/sql/elements.py b/lib/sqlalchemy/sql/elements.py index de17aabb3..fe2fecce8 100644 --- a/lib/sqlalchemy/sql/elements.py +++ b/lib/sqlalchemy/sql/elements.py @@ -429,7 +429,7 @@ class ClauseElement(Visitable): dialect = self.bind.dialect bind = self.bind else: - dialect = default.DefaultDialect() + dialect = default.StrCompileDialect() return self._compiler(dialect, bind=bind, **kw) def _compiler(self, dialect, **kw): diff --git a/lib/sqlalchemy/testing/__init__.py b/lib/sqlalchemy/testing/__init__.py index bd6377eb7..d24f31321 100644 --- a/lib/sqlalchemy/testing/__init__.py +++ b/lib/sqlalchemy/testing/__init__.py @@ -22,7 +22,7 @@ from .assertions import emits_warning, emits_warning_on, uses_deprecated, \ eq_, ne_, le_, is_, is_not_, startswith_, assert_raises, \ assert_raises_message, AssertsCompiledSQL, ComparesTables, \ AssertsExecutionResults, expect_deprecated, expect_warnings, \ - in_, not_in_ + in_, not_in_, eq_ignore_whitespace from .util import run_as_contextmanager, rowset, fail, \ provide_metadata, adict, force_drop_names, \ diff --git a/test/sql/test_compiler.py b/test/sql/test_compiler.py index 5d082175a..85a9f77bc 100644 --- a/test/sql/test_compiler.py +++ b/test/sql/test_compiler.py @@ -10,7 +10,8 @@ styling and coherent test organization. """ -from sqlalchemy.testing import eq_, is_, assert_raises, assert_raises_message +from sqlalchemy.testing import eq_, is_, assert_raises, \ + assert_raises_message, eq_ignore_whitespace from sqlalchemy import testing from sqlalchemy.testing import fixtures, AssertsCompiledSQL from sqlalchemy import Integer, String, MetaData, Table, Column, select, \ @@ -2562,7 +2563,7 @@ class UnsupportedTest(fixtures.TestBase): assert_raises_message( exc.UnsupportedCompilationError, - r"Compiler <sqlalchemy.sql.compiler.SQLCompiler .*" + r"Compiler <sqlalchemy.sql.compiler.StrSQLCompiler .*" r"can't render element of type <class '.*SomeElement'>", SomeElement().compile ) @@ -2578,7 +2579,7 @@ class UnsupportedTest(fixtures.TestBase): assert_raises_message( exc.UnsupportedCompilationError, - r"Compiler <sqlalchemy.sql.compiler.SQLCompiler .*" + r"Compiler <sqlalchemy.sql.compiler.StrSQLCompiler .*" r"can't render element of type <class '.*SomeElement'>", SomeElement().compile ) @@ -2591,12 +2592,76 @@ class UnsupportedTest(fixtures.TestBase): binary = BinaryExpression(column("foo"), column("bar"), myop) assert_raises_message( exc.UnsupportedCompilationError, - r"Compiler <sqlalchemy.sql.compiler.SQLCompiler .*" + r"Compiler <sqlalchemy.sql.compiler.StrSQLCompiler .*" r"can't render element of type <function.*", binary.compile ) +class StringifySpecialTest(fixtures.TestBase): + def test_basic(self): + stmt = select([table1]).where(table1.c.myid == 10) + eq_ignore_whitespace( + str(stmt), + "SELECT mytable.myid, mytable.name, mytable.description " + "FROM mytable WHERE mytable.myid = :myid_1" + ) + + def test_cte(self): + # stringify of these was supported anyway by defaultdialect. + stmt = select([table1.c.myid]).cte() + stmt = select([stmt]) + eq_ignore_whitespace( + str(stmt), + "WITH anon_1 AS (SELECT mytable.myid AS myid FROM mytable) " + "SELECT anon_1.myid FROM anon_1" + ) + + def test_returning(self): + stmt = table1.insert().returning(table1.c.myid) + + eq_ignore_whitespace( + str(stmt), + "INSERT INTO mytable (myid, name, description) " + "VALUES (:myid, :name, :description) RETURNING mytable.myid" + ) + + def test_array_index(self): + stmt = select([column('foo', types.ARRAY(Integer))[5]]) + + eq_ignore_whitespace( + str(stmt), + "SELECT foo[:foo_1] AS anon_1" + ) + + def test_unknown_type(self): + class MyType(types.TypeEngine): + __visit_name__ = 'mytype' + + stmt = select([cast(table1.c.myid, MyType)]) + + eq_ignore_whitespace( + str(stmt), + "SELECT CAST(mytable.myid AS MyType) AS anon_1 FROM mytable" + ) + + def test_within_group(self): + # stringify of these was supported anyway by defaultdialect. + from sqlalchemy import within_group + stmt = select([ + table1.c.myid, + within_group( + func.percentile_cont(0.5), + table1.c.name.desc() + ) + ]) + eq_ignore_whitespace( + str(stmt), + "SELECT mytable.myid, percentile_cont(:percentile_cont_1) " + "WITHIN GROUP (ORDER BY mytable.name DESC) AS anon_1 FROM mytable" + ) + + class KwargPropagationTest(fixtures.TestBase): @classmethod diff --git a/test/sql/test_metadata.py b/test/sql/test_metadata.py index bbc318421..47ecf5a9b 100644 --- a/test/sql/test_metadata.py +++ b/test/sql/test_metadata.py @@ -9,6 +9,7 @@ from sqlalchemy import Integer, String, UniqueConstraint, \ events, Unicode, types as sqltypes, bindparam, \ Table, Column, Boolean, Enum, func, text, TypeDecorator from sqlalchemy import schema, exc +from sqlalchemy.engine import default from sqlalchemy.sql import elements, naming import sqlalchemy as tsa from sqlalchemy.testing import fixtures @@ -3682,7 +3683,7 @@ class NamingConventionTest(fixtures.TestBase, AssertsCompiledSQL): exc.InvalidRequestError, "Naming convention including \%\(constraint_name\)s token " "requires that constraint is explicitly named.", - schema.CreateTable(u1).compile + schema.CreateTable(u1).compile, dialect=default.DefaultDialect() ) def test_schematype_no_ck_name_boolean_no_name(self): diff --git a/test/sql/test_selectable.py b/test/sql/test_selectable.py index b9cbbf480..7203cc5a3 100644 --- a/test/sql/test_selectable.py +++ b/test/sql/test_selectable.py @@ -155,15 +155,19 @@ class SelectableTest( assert c in s.c.bar.proxy_set def test_no_error_on_unsupported_expr_key(self): - from sqlalchemy.dialects.postgresql import ARRAY + from sqlalchemy.sql.expression import BinaryExpression - t = table('t', column('x', ARRAY(Integer))) + def myop(x, y): + pass + + t = table('t', column('x'), column('y')) + + expr = BinaryExpression(t.c.x, t.c.y, myop) - expr = t.c.x[5] s = select([t, expr]) eq_( s.c.keys(), - ['x', expr.anon_label] + ['x', 'y', expr.anon_label] ) def test_cloned_intersection(self): |