fix: query and return only selected metadata columns (#48)

* fix: query and return only selected metadata columns * Review changes * Linter fix

Author: dishaprakash

src/llama_index_cloud_sql_pg/async_vector_store.py

@@ -531,7 +531,19 @@ async def __query_columns(
  f" LIMIT {query.similarity_top_k} " if query.similarity_top_k >= 1 else ""
  )
 
- query_stmt = f'SELECT * {scoring_stmt} FROM "{self._schema_name}"."{self._table_name}" {filters_stmt} {order_stmt} {limit_stmt}'
+ columns = self._metadata_columns + [
+ self._id_column,
+ self._text_column,
+ self._embedding_column,
+ self._ref_doc_id_column,
+ self._node_column,
+ ]
+ if self._metadata_json_column:
+ columns.append(self._metadata_json_column)
+
+ column_names = ", ".join(f'"{col}"' for col in columns)
+
+ query_stmt = f'SELECT {column_names} {scoring_stmt} FROM "{self._schema_name}"."{self._table_name}" {filters_stmt} {order_stmt} {limit_stmt}'
  async with self._engine.connect() as conn:
  if self._index_query_options:
  query_options_stmt = (