Merge ebe6f85 into 096d096

project.clj

@@ -1,4 +1,4 @@
-(defproject aerospike-clj "0.3.2"
+(defproject aerospike-clj "0.3.3"
   :description "An Aerospike Clojure client."
   :url "https://github.com/AppsFlyer/aerospike-clj"
   :license {:name "Eclipse Public License"

src/aerospike_clj/client.clj

@@ -324,6 +324,17 @@
                  (put db index set-name payload expiration conf))
                (map vector indices set-names payloads expirations)))))
 
+(defn set
+  "`put` with a update policy"
+  ([db index set-name data expiration]
+    (set db index set-name data expiration {}))
+  ([db index set-name data expiration conf]
+    (_put db
+          index
+          ((:transcoder conf identity) data)
+          (policy/set-policy (get-client db) expiration)
+          set-name)))
+
 (defn create
   "`put` with a create-only policy"
   ([db index set-name data expiration]

src/aerospike_clj/policy.clj

@@ -71,6 +71,15 @@
      (set! (.recordExistsAction wp) record-exists-action)
      wp)))
 
+(defn ^WritePolicy set-policy
+      "Create a write policy with UPDATE record exists action.
+       in case of new entry, create it
+       in case the entry exists, update entry"
+      [client expiration]
+      (let [wp (write-policy client expiration)]
+           (set! (.recordExistsAction wp) RecordExistsAction/UPDATE)
+           wp))
+
 (defn ^WritePolicy update-policy
   "Create a write policy with `expiration`, expected `generation`
   and EXPECT_GEN_EQUAL generation policy."

test/aerospike_clj/client_test.clj

@@ -485,3 +485,13 @@
     (is (= RecordExistsAction/REPLACE_ONLY (.recordExistsAction wp)))
     (is (true? (.respondAllOps wp)))))
 
+
+(deftest set-entry
+  (let [data (rand-int 1000)
+        update-data (rand-int 1000)]
+       (is (true? @(client/set *c* K _set data 100)))
+       (is (= data @(client/get-single-no-meta *c* K _set)))
+       (is (true? @(client/set *c* K _set update-data 100)))
+       (is (= update-data @(client/get-single-no-meta *c* K _set)))))
+
+