(self, execute_observed)
| 81 | return received_statement == stmt |
| 82 | |
| 83 | def _compile_dialect(self, execute_observed): |
| 84 | if self.dialect == "default": |
| 85 | dialect = DefaultDialect() |
| 86 | # this is currently what tests are expecting |
| 87 | # dialect.supports_default_values = True |
| 88 | dialect.supports_default_metavalue = True |
| 89 | |
| 90 | if self.enable_returning: |
| 91 | dialect.insert_returning = dialect.update_returning = ( |
| 92 | dialect.delete_returning |
| 93 | ) = True |
| 94 | dialect.use_insertmanyvalues = True |
| 95 | dialect.supports_multivalues_insert = True |
| 96 | dialect.update_returning_multifrom = True |
| 97 | dialect.delete_returning_multifrom = True |
| 98 | # dialect.favor_returning_over_lastrowid = True |
| 99 | # dialect.insert_null_pk_still_autoincrements = True |
| 100 | |
| 101 | # this is calculated but we need it to be True for this |
| 102 | # to look like all the current RETURNING dialects |
| 103 | assert dialect.insert_executemany_returning |
| 104 | |
| 105 | return dialect |
| 106 | else: |
| 107 | return url.URL.create(self.dialect).get_dialect()() |
| 108 | |
| 109 | def _received_statement(self, execute_observed): |
| 110 | """reconstruct the statement and params in terms |
no test coverage detected