summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--src/logikorr.clj17
1 files changed, 17 insertions, 0 deletions
diff --git a/src/logikorr.clj b/src/logikorr.clj
index d9dfbc6..a8f08e7 100644
--- a/src/logikorr.clj
+++ b/src/logikorr.clj
@@ -6,6 +6,23 @@
(:import [com.google.appengine.api.datastore DatastoreServiceFactory Entity Query Query$FilterOperator Query$SortDirection KeyFactory EntityNotFoundException Key]
[com.google.appengine.api.users UserServiceFactory]))
+(defmacro with-ds-transaction [& body]
+ `(call-with-ds-transaction (fn [] ~@body)))
+
+(defn call-with-ds-transaction [thunk]
+ (let [ds (DatastoreServiceFactory/getDatastoreService)
+ success (atom false)
+ transaction (.beginTransaction ds)
+ return-value (atom nil)]
+ (try (do
+ (swap! return-value (fn [_] (thunk)))
+ (.commit transaction)
+ (swap! success (fn [_] true)))
+ (finally
+ (when-not @success
+ (.rollback transaction))))
+ @return-value))
+
(defn ds-update
"Update the corresponding entity from the supplied map in the data store."
[map]