From 18241b3548e497bda6108983301b6dcfc7cbc982 Mon Sep 17 00:00:00 2001 From: Eric K Date: Thu, 4 Apr 2019 00:35:53 -0700 Subject: [PATCH] fix incorrect sql compose for index create Change-Id: Ibe166cad630f5eb586a8e8756981fded10eecf33 Closes-Bug: 1823128 --- congress/datasources/json_ingester/json_ingester.py | 11 +++++++---- 1 file changed, 7 insertions(+), 4 deletions(-) diff --git a/congress/datasources/json_ingester/json_ingester.py b/congress/datasources/json_ingester/json_ingester.py index 1aa2df601..c8bd3297d 100644 --- a/congress/datasources/json_ingester/json_ingester.py +++ b/congress/datasources/json_ingester/json_ingester.py @@ -127,10 +127,10 @@ class JsonIngester(datasource_driver.PollingDataSourceDriver): # delete of specific rows in delta update to the db table create_index_statement = """ - CREATE INDEX IF NOT EXISTS __{table}_d_gin_idx on {schema}.{table} + CREATE INDEX IF NOT EXISTS {index} on {schema}.{table} USING GIN (d);""" drop_index_statement = """ - DROP INDEX IF EXISTS __{schema}.{table}_d_gin_idx;""" + DROP INDEX IF EXISTS {schema}.{index};""" conn = None try: conn = psycopg2.connect(cfg.CONF.json_ingester.db_connection) @@ -150,11 +150,14 @@ class JsonIngester(datasource_driver.PollingDataSourceDriver): if self._config['tables'][table_name].get('gin_index', True): cur.execute(sql.SQL(create_index_statement).format( schema=sql.Identifier(self.name), - table=sql.Identifier(table_name))) + table=sql.Identifier(table_name), + index=sql.Identifier( + '__{}_d_gin_idx'.format(table_name)))) else: cur.execute(sql.SQL(drop_index_statement).format( schema=sql.Identifier(self.name), - table=sql.Identifier(table_name))) + index=sql.Identifier( + '__{}_d_gin_idx'.format(table_name)))) conn.commit() cur.close() except (Exception, psycopg2.Error):