File tree Expand file tree Collapse file tree 1 file changed +11
-1
lines changed
src/llama_index_cloud_sql_pg Expand file tree Collapse file tree 1 file changed +11
-1
lines changed Original file line number Diff line number Diff line change @@ -531,7 +531,17 @@ 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+ ]
539+ if self ._metadata_json_column :
540+ columns .append (self ._metadata_json_column )
541+
542+ column_names = ", " .join (f'"{ col } "' for col in columns )
543+
544+ query_stmt = f'SELECT { column_names } { scoring_stmt } FROM "{ self ._schema_name } "."{ self ._table_name } " { filters_stmt } { order_stmt } { limit_stmt } '
535545 async with self ._engine .connect () as conn :
536546 if self ._index_query_options :
537547 query_options_stmt = (
You can’t perform that action at this time.
0 commit comments