diff --git a/tests/integration/records/records_database_fixture.py b/tests/integration/records/records_database_fixture.py index 0953f366e..dead0d157 100644 --- a/tests/integration/records/records_database_fixture.py +++ b/tests/integration/records/records_database_fixture.py @@ -32,9 +32,11 @@ def tear_down(self): @bigquery_retry() def bring_up(self): + quoted_schema_and_table = self.quote_schema_and_table(self.schema_name, + self.table_name) if self.engine.name == 'redshift': create_tables = f""" - CREATE TABLE {self.schema_name}.{self.table_name} AS + CREATE TABLE {quoted_schema_and_table} AS SELECT 123 AS num, '123' AS numstr, 'foo' AS str, @@ -49,7 +51,7 @@ def bring_up(self): """ # noqa elif self.engine.name == 'vertica': create_tables = f""" - CREATE TABLE {self.schema_name}.{self.table_name} AS + CREATE TABLE {quoted_schema_and_table} AS SELECT 123 AS num, '123' AS numstr, 'foo' AS str, @@ -64,7 +66,7 @@ def bring_up(self): """ # noqa elif self.engine.name == 'bigquery': create_tables = f""" - CREATE TABLE {self.schema_name}.{self.table_name} AS + CREATE TABLE {quoted_schema_and_table} AS SELECT 123 AS num, '123' AS numstr, 'foo' AS str, @@ -79,7 +81,7 @@ def bring_up(self): """ # noqa elif self.engine.name == 'postgresql': create_tables = f""" - CREATE TABLE {self.schema_name}.{self.table_name} AS + CREATE TABLE {quoted_schema_and_table} AS SELECT 123 AS num, '123' AS numstr, 'foo' AS str, @@ -94,7 +96,7 @@ def bring_up(self): """ # noqa elif self.engine.name == 'mysql': create_tables = f""" - CREATE TABLE {self.schema_name}.{self.table_name} AS + CREATE TABLE {quoted_schema_and_table} AS SELECT 123 AS num, '123' AS numstr, 'foo' AS str,