Merge pull request #151 from qidi1/double_index_recommand

repaire optimizer bug ref #150

Author: qidi1

.gitignore

@@ -49,6 +49,8 @@ Thumbs.db
 ##################
 .idea/
 .vscode/
+build
+dist
 venv/*
 parser.out
 parsetab.py

db.cfg

@@ -1,10 +1,10 @@
 {
 	'db': {
-		'host': 'localhost',
-		'port': 3306,
-		'dbname': 'test',
-		'user': 'root',
-		'pswd': '123456',
-		'charset': 'big5'
+		'host': '*****',
+		'port': '*',
+		'dbname': '*',
+		'user': '*',
+		'pswd': '*',
+		'charset': '*'
 	}
 }

src/metadata/metadata_utils.py

@@ -200,14 +200,17 @@ def json_to_catalog(catalog_json, schema_sql=None) -> Catalog:
 
     @staticmethod
     def extension_all_match_index(filter_column_list, order_list):
+        column_set = set()
         column_list = []
         range_flag = False
         last_column = ''
         for filter_column in filter_column_list:
             column_name = filter_column['column_name']
             opt = filter_column['opt']
             if opt == '=' or opt == 'in' or opt == 'is':
-                column_list.append(column_name)
+                if column_name not in column_set:
+                    column_set.add(column_name)
+                    column_list.append(column_name)
             elif (
                 opt == '>'
                 or opt == '<'
@@ -221,6 +224,8 @@ def extension_all_match_index(filter_column_list, order_list):
                     range_flag = True
 
         if range_flag:
+            if last_column in column_set:
+                column_list.remove(last_column)
             column_list.append(last_column)
 
         # TODO Statistics need to be added to determine which one comes first when there are range queries and sorting

src/optimizer/rewrite_rule/__init__.py

@@ -13,6 +13,10 @@
 from .rewrite_or_rule import RewriteMySQLORRule
 from .remove_order_by_in_delete_update_rule import RemoveOrderByInDeleteUpdateRule
 
-common_rules = [RewriteSupplementColumnRule(), RemoveOrderByInDeleteUpdateRule()]
+common_rules = [
+    RewriteSupplementColumnRule(),
+    RemoveOrderByInDeleteUpdateRule(),
+    RewriteMySQLORRule(),
+]
 
 mysql_rules = [RewriteMySQLORRule()]