File tree Expand file tree Collapse file tree 1 file changed +13
-1
lines changed
src/llama_index_cloud_sql_pg Expand file tree Collapse file tree 1 file changed +13
-1
lines changed Original file line number Diff line number Diff line change @@ -531,7 +531,19 @@ async def __query_columns(
531531 f" LIMIT { query .similarity_top_k } " if query .similarity_top_k >= 1 else ""
532532 )
533533
534- query_stmt = f'SELECT * { scoring_stmt } FROM "{ self ._schema_name } "."{ self ._table_name } " { filters_stmt } { order_stmt } { limit_stmt } '
534+ columns = self ._metadata_columns + [
535+ self ._id_column ,
536+ self ._text_column ,
537+ self ._embedding_column ,
538+ self ._ref_doc_id_column ,
539+ self ._node_column ,
540+ ]
541+ if self ._metadata_json_column :
542+ columns .append (self ._metadata_json_column )
543+
544+ column_names = ", " .join (f'"{ col } "' for col in columns )
545+
546+ query_stmt = f'SELECT { column_names } { scoring_stmt } FROM "{ self ._schema_name } "."{ self ._table_name } " { filters_stmt } { order_stmt } { limit_stmt } '
535547 async with self ._engine .connect () as conn :
536548 if self ._index_query_options :
537549 query_options_stmt = (
You can’t perform that action at this time.
0 commit comments