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
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
|
#!/usr/bin/ruby -I../.. -I../../../src
require 'bdbxml'
def value(man, doc, query, context)
doc_expr = man.prepare(query, context)
result = doc_expr.execute(doc, context).to_a
if result.size != 1
raise "Expected 1 got #{result.size}"
end
result[0]
end
def new_document(man, doc, context)
res = value(man, doc, "/*/inventory/inventory/text()", context).to_s
doc.to_s.sub(/#{res}/, "#{res}__NEW_VALUE")
end
def update(man, con, query, context)
query = "collection('#{con.name}')/#{query}"
puts "Updating document for '#{query}'"
print "Return to continue : "
STDIN.gets
results = man.query(query, context)
puts "\nFound #{results.size} documents matching the expression '#{query}'"
results.each do |r|
r = r.to_document
puts "Updating document #{r.name}"
puts r
print "Return to continue : "
STDIN.gets
r.content = new_document(man, r, context)
con.update(r)
end
puts
rescue
puts "Query #{query} failed : #{$!}"
end
def retrieve(man, con, query, context)
query = "collection('#{con.name}')/#{query}"
puts "Retrieving document for '#{query}'"
print "Return to continue : "
STDIN.gets
results = man.query(query, context)
puts "\nFound #{results.size} documents matching the expression '#{query}'"
results.each do |r|
r = r.to_document
puts "Document #{r.name}"
puts r
print "Return to continue : "
STDIN.gets
end
puts
rescue
puts "Query #{query} failed : #{$!}"
end
options = {'home' => 'env', 'container' => 'name.xml'}
env = BDB::Env.new(options['home'], BDB::INIT_TRANSACTION)
man = env.manager
man.begin do |txn|
con = txn.open_container(options['container'])
cxt = man.create_query_context
cxt.set_namespace("fruits", "http://groceryItem.dbxml/fruits")
cxt.set_namespace("vegetables", "http://groceryItem.dbxml/vegetables")
cxt.set_namespace("desserts", "http://groceryItem.dbxml/desserts");
update(txn, con, "/fruits:item/product[text() = 'Zapote Blanco']", cxt)
retrieve(txn, con, "/fruits:item/product[text() = 'Zapote Blanco']", cxt)
txn.commit
end
|
