add-merge-repeats-and-insert-document-overwrite

.github/insert_docs.py

@@ -8,7 +8,7 @@
 def parameter_to_document(param):
     return {'@type': 'Parameter', 'type': param.type, 'name': param.name, 'summary': "\n".join(param.desc)}
 
-classes_to_scan = ['Client']#, 'WOQLQuery']
+classes_to_scan = ['Client', 'WOQLQuery']
 classes = []
 
 for name, obj in inspect.getmembers(terminusdb_client):

terminusdb_client/__version__.py

@@ -1,7 +1,7 @@
 __title__ = "terminusdb-client"
 __description__ = "TerminusDB client library for accessing the Terminus DB API"
 __url__ = ""
-__version__ = "11.1.0"
+__version__ = "12.0.7"
 __build__ = 00
 __author__ = "TerminusDB group"
 __author_email__ = "team@terminusdb.com"

terminusdb_client/client/Client.py

@@ -1480,6 +1480,8 @@ def insert_document(
         last_data_version: Optional[str] = None,
         compress: Union[str, int] = 1024,
         raw_json: bool = False,
+        merge_repeats: bool = False,
+        overwrite: bool = False,
     ) -> None:
         """Inserts the specified document(s)
 
@@ -1499,6 +1501,10 @@ def insert_document(
             If it is an integer, size of the data larger than this (in bytes) will be compress with gzip in the request (assume encoding as UTF-8, 0 = always compress). If it is `never` it will never compress the data.
         raw_json : bool
             Update as raw json
+        merge_repeats : bool
+            If True, duplicate document IDs in the same request are silently accepted instead of causing an error.
+        overwrite : bool
+            If True, existing documents with the same ID will be overwritten instead of causing an error. This enables upsert behavior.
 
         Raises
         ------
@@ -1518,6 +1524,8 @@ def insert_document(
         else:
             params["full_replace"] = "false"
         params["raw_json"] = "true" if raw_json else "false"
+        params["merge_repeats"] = "true" if merge_repeats else "false"
+        params["overwrite"] = "true" if overwrite else "false"
 
         headers = self._default_headers.copy()
         if last_data_version is not None:
@@ -1587,6 +1595,7 @@ def replace_document(
         compress: Union[str, int] = 1024,
         create: bool = False,
         raw_json: bool = False,
+        merge_repeats: bool = False,
     ) -> dict:
         """Updates the specified document(s)
 
@@ -1606,6 +1615,8 @@ def replace_document(
             Create the document if it does not yet exist.
         raw_json : bool
             Update as raw json
+        merge_repeats : bool
+            If True, duplicate document IDs in the same request are silently accepted instead of causing an error.
 
         Raises
         ------
@@ -1617,6 +1628,7 @@ def replace_document(
         params["graph_type"] = graph_type
         params["create"] = "true" if create else "false"
         params["raw_json"] = "true" if raw_json else "false"
+        params["merge_repeats"] = "true" if merge_repeats else "false"
 
         headers = self._default_headers.copy()
         if last_data_version is not None:
@@ -1667,6 +1679,7 @@ def update_document(
         commit_msg: Optional[str] = None,
         last_data_version: Optional[str] = None,
         compress: Union[str, int] = 1024,
+        merge_repeats: bool = False,
     ) -> None:
         """Updates the specified document(s). Add the document if not existed.
 
@@ -1682,14 +1695,17 @@ def update_document(
             Last version before the update, used to check if the document has been changed unknowingly
         compress : str or int
             If it is an integer, size of the data larger than this (in bytes) will be compress with gzip in the request (assume encoding as UTF-8, 0 = always compress). If it is `never` it will never compress the data.
+        merge_repeats : bool
+            If True, duplicate document IDs in the same request are silently accepted instead of causing an error.
 
         Raises
         ------
         InterfaceError
             if the client does not connect to a database
         """
         self.replace_document(
-            document, graph_type, commit_msg, last_data_version, compress, True
+            document, graph_type, commit_msg, last_data_version, compress, True,
+            merge_repeats=merge_repeats,
         )
 
     def delete_document(