diff --git a/src/CaosDB.jl b/src/CaosDB.jl index b81fd4669dd3ea346f1819bf7bba98125ad3f03d..6208fd714a7e1451a4e7f27e529bbeee0a2517eb 100644 --- a/src/CaosDB.jl +++ b/src/CaosDB.jl @@ -83,6 +83,7 @@ export has_errors, has_warnings # Exports from module Transaction export create_transaction, add_retrieve_by_id, + add_insert_entity, add_query, execute, get_result_set, diff --git a/src/Transaction.jl b/src/Transaction.jl index 2308048d9c5f5955d0ba933cb061dc9561c6d702..4d883194e813b29df6e677a3f29157c8df2fe620 100644 --- a/src/Transaction.jl +++ b/src/Transaction.jl @@ -26,6 +26,7 @@ module Transaction export create_transaction, add_retrieve_by_id, add_query, + add_insert_entity, execute, get_result_set, get_count_result, @@ -137,6 +138,28 @@ function add_retrieve_by_id(transaction::Ref{_Transaction}, id::AbstractString) CaosDB.Exceptions.evaluate_return_code(err_code) end +""" + function add_insert_entity(transaction::Ref{_Transaction}, entity::Ref{_CaosDB.Entity.Entity}) + +Add a sub-request to insert a single entity to the given `transaction`. + +!!! info + + This does not execute the transaction. +""" +function add_insert_entity(transaction::Ref{_Transaction}, entity::Ref{CaosDB.Entity._Entity}) + + err_code = ccall( + (:caosdb_transaction_transaction_insert_entity, CaosDB.library_name), + Cint, + (Ref{_Transaction}, Ref{CaosDB.Entity._Entity}), + transaction, + entity, + ) + + CaosDB.Exceptions.evaluate_return_code(err_code) +end + """ function add_retrieve_by_id( transaction::Ref{_Transaction},