File tree 1 file changed +3
-3
lines changed
api/core/rag/datasource/vdb/couchbase
1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -247,7 +247,7 @@ def delete_by_ids(self, ids: list[str]) -> None:
247
247
def delete_by_document_id (self , document_id : str ):
248
248
query = f"""
249
249
DELETE FROM `{ self ._client_config .bucket_name } `.{ self ._client_config .scope_name } .{ self ._collection_name }
250
- WHERE id = $doc_id;
250
+ WHERE META(). id = $doc_id;
251
251
"""
252
252
self ._cluster .query (query ,named_parameters = {'doc_id' :document_id })
253
253
@@ -263,9 +263,9 @@ def delete_by_document_id(self, document_id: str):
263
263
def delete_by_metadata_field (self , key : str , value : str ) -> None :
264
264
query = f"""
265
265
DELETE FROM `{ self ._client_config .bucket_name } `.{ self ._client_config .scope_name } .{ self ._collection_name }
266
- WHERE metadata.{ key } = { value } ;
266
+ WHERE metadata.{ key } = $ value;
267
267
"""
268
- self ._cluster .query (query )
268
+ self ._cluster .query (query , named_parameters = { 'value' : value } )
269
269
270
270
def search_by_vector (
271
271
self ,
You can’t perform that action at this time.
0 commit comments