-
Notifications
You must be signed in to change notification settings - Fork 0
/
1_ripple_basics.rb
36 lines (26 loc) · 976 Bytes
/
1_ripple_basics.rb
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
require 'riak'
require 'lib/utils'
# Connect and get a bucket instance
client = Riak::Client.new
bucket = client.bucket("test1")
# Ensure bucket is empty. When bugfixed, pass block direct to bucket
bucket.keys.each {|k| bucket.get(k).delete}
# Create and save a simple JSON object
new_one = Riak::RObject.new(bucket, gen_uuid)
new_one.content_type = "application/json" # You must set the content type.
new_one.data = "{'item': 'one'}"
new_one.store
# Create and save a simple JSON object
new_two = Riak::RObject.new(bucket, gen_uuid)
new_two.content_type = "application/json" # You must set the content type.
new_two.data = "{'item': 'two'}"
new_two.store
# The above MP doesn't work anyway - backends need tweaking. DO this the old way
# instead
# Print bucket contents
#bucket.keys {|k| p bucket.get(k)}
# Empty Bucket
#bucket.keys {|k| bucket.get(k).delete}
keys = bucket.keys(:reload => true)
keys.each {|k| p bucket.get(k)}
keys.each {|k| bucket.get(k).delete}