update hologres client, use hybrid index (#594)

Co-authored-by: biao.zhoub <[email protected]>

Author: biaozy

vectordb_bench/backend/clients/hologres/config.py

@@ -104,15 +104,14 @@ def builder_params(self) -> dict:
             self.base_quantization_type = "fp32"
 
         return {
-            "min_flush_proxima_row_count": self.min_flush_proxima_row_count,
-            "min_compaction_proxima_row_count": self.min_compaction_proxima_row_count,
             "max_total_size_to_merge_mb": self.max_total_size_to_merge_mb,
             "build_thread_count": self.build_thread_count,
             "base_quantization_type": self.base_quantization_type,
             "max_degree": self.max_degree,
             "ef_construction": self.ef_construction,
             "precise_quantization_type": self.precise_quantization_type,
             "use_reorder": self.use_reorder,
+            "precise_io_type": "reader_io",
         }
 
     def searcher_params(self) -> dict:

vectordb_bench/backend/clients/hologres/hologres.py

@@ -128,6 +128,18 @@ def _drop_table(self):
         )
         self.conn.commit()
 
+        try:
+            log.info(f"{self.name} client purge table recycle bin: {self.table_name}")
+            self.cursor.execute(
+                sql.SQL("purge TABLE {table_name};").format(
+                    table_name=sql.Identifier(self.table_name),
+                ),
+            )
+        except Exception as e:
+            log.info(f"{self.name} client purge table {self.table_name} recycle bin failed, error: {e}, ignore.")
+        finally:
+            self.conn.commit()
+
         try:
             log.info(f"{self.name} client drop table group : {self._tg_name}")
             self.cursor.execute(sql.SQL(f"CALL HG_DROP_TABLE_GROUP('{self._tg_name}');"))
@@ -136,6 +148,14 @@ def _drop_table(self):
         finally:
             self.conn.commit()
 
+        try:
+            log.info(f"{self.name} client free cache")
+            self.cursor.execute("select hg_admin_command('freecache');")
+        except Exception as e:
+            log.info(f"{self.name} client free cache failed, error: {e}, ignore.")
+        finally:
+            self.conn.commit()
+
     def optimize(self, data_size: int | None = None):
         if self.case_config.create_index_after_load:
             self._create_index()