summaryrefslogtreecommitdiff
path: root/ext/librethinkdbxx/test/upstream/changefeeds/point.yaml
diff options
context:
space:
mode:
Diffstat (limited to 'ext/librethinkdbxx/test/upstream/changefeeds/point.yaml')
-rw-r--r--ext/librethinkdbxx/test/upstream/changefeeds/point.yaml147
1 files changed, 0 insertions, 147 deletions
diff --git a/ext/librethinkdbxx/test/upstream/changefeeds/point.yaml b/ext/librethinkdbxx/test/upstream/changefeeds/point.yaml
deleted file mode 100644
index a444a73d..00000000
--- a/ext/librethinkdbxx/test/upstream/changefeeds/point.yaml
+++ /dev/null
@@ -1,147 +0,0 @@
-desc: Test point changebasics
-table_variable_name: tbl
-tests:
-
- # -- basic
-
- # start a feed
-
- - cd: basic = tbl.get(1).changes({include_initial:true})
- py: basic = tbl.get(1).changes(include_initial=True)
-
- # - inital return
-
- - cd: fetch(basic, 1)
- ot: [{'new_val':null}]
-
- # - inserts
-
- - cd: tbl.insert({'id':1})
- ot: partial({'errors':0, 'inserted':1})
-
- - cd: fetch(basic, 1)
- ot: [{'old_val':null, 'new_val':{'id':1}}]
-
- # - updates
-
- - cd: tbl.get(1).update({'update':1})
- ot: partial({'errors':0, 'replaced':1})
-
- - cd: fetch(basic, 1)
- ot: [{'old_val':{'id':1}, 'new_val':{'id':1,'update':1}}]
-
- # - deletions
-
- - cd: tbl.get(1).delete()
- ot: partial({'errors':0, 'deleted':1})
-
- - cd: fetch(basic, 1)
- ot: [{'old_val':{'id':1,'update':1}, 'new_val':null}]
-
- # - closing
-
- - cd: basic.close()
- rb: def pass; end
- # the ruby test driver currently has to mangle cursors, so we can't close them properly
-
- # -- filter
-
- - py: filter = tbl.get(1).changes(squash=false,include_initial=True).filter(r.row['new_val']['update'].gt(2))['new_val']['update']
- rb: filter = tbl.get(1).changes(squash:false,include_initial:true).filter{|row| row['new_val']['update'].gt(2)}['new_val']['update']
- js: filter = tbl.get(1).changes({squash:false,include_initial:true}).filter(r.row('new_val')('update').gt(2))('new_val')('update')
-
- - cd: tbl.insert({'id':1, 'update':1})
- - cd: tbl.get(1).update({'update':4})
- - cd: tbl.get(1).update({'update':1})
- - cd: tbl.get(1).update({'update':7})
-
- - cd: fetch(filter, 2)
- ot: [4,7]
-
- # -- pluck on values
-
- - py: pluck = tbl.get(3).changes(squash=false,include_initial=True).pluck({'new_val':['red', 'blue']})['new_val']
- rb: pluck = tbl.get(3).changes(squash:false,include_initial:true).pluck({'new_val':['red', 'blue']})['new_val']
- js: pluck = tbl.get(3).changes({squash:false,include_initial:true}).pluck({'new_val':['red', 'blue']})('new_val')
-
- - cd: tbl.insert({'id':3, 'red':1, 'green':1})
- ot: partial({'errors':0, 'inserted':1})
- - cd: tbl.get(3).update({'blue':2, 'green':3})
- ot: partial({'errors':0, 'replaced':1})
- - cd: tbl.get(3).update({'green':4})
- ot: partial({'errors':0, 'replaced':1})
- - cd: tbl.get(3).update({'blue':4})
- ot: partial({'errors':0, 'replaced':1})
-
- - cd: fetch(pluck, 4)
- ot: [{'red': 1}, {'blue': 2, 'red': 1}, {'blue': 2, 'red': 1}, {'blue': 4, 'red': 1}]
-
- # -- virtual tables
-
- # - rethinkdb._debug_scratch
-
- - def: dtbl = r.db('rethinkdb').table('_debug_scratch')
-
- - cd: debug = dtbl.get(1).changes({include_initial:true})
- py: debug = dtbl.get(1).changes(include_initial=True)
-
- - cd: fetch(debug, 1)
- ot: [{'new_val':null}]
-
- - cd: dtbl.insert({'id':1})
- ot: partial({'errors':0, 'inserted':1})
- - cd: fetch(debug, 1)
- ot: [{'old_val':null, 'new_val':{'id':1}}]
-
- - cd: dtbl.get(1).update({'update':1})
- ot: partial({'errors':0, 'replaced':1})
- - cd: fetch(debug, 1)
- ot: [{'old_val':{'id':1}, 'new_val':{'id':1,'update':1}}]
-
- - cd: dtbl.get(1).delete()
- ot: partial({'errors':0, 'deleted':1})
- - cd: fetch(debug, 1)
- ot: [{'old_val':{'id':1,'update':1}, 'new_val':null}]
-
- - cd: dtbl.insert({'id':5, 'red':1, 'green':1})
- ot: {'skipped':0, 'deleted':0, 'unchanged':0, 'errors':0, 'replaced':0, 'inserted':1}
- - py: dtblPluck = dtbl.get(5).changes(include_initial=True).pluck({'new_val':['red', 'blue']})['new_val']
- rb: dtblPluck = dtbl.get(5).changes(include_initial:true).pluck({'new_val':['red', 'blue']})['new_val']
- js: dtblPluck = dtbl.get(5).changes({include_initial:true}).pluck({'new_val':['red', 'blue']})('new_val')
-
- # disabled because inital value is not being reported correctly, so goes missing. see #3723
- - cd: fetch(dtblPluck, 1)
- ot: [{'red':1}]
-
- - cd: dtbl.get(5).update({'blue':2, 'green':3})
- ot: partial({'errors':0, 'replaced':1})
-
- - cd: fetch(dtblPluck, 1)
- ot: [{'blue':2, 'red':1}]
-
- # - rethinkdb.table_status bad optargs
-
- # disabled, re-enable once #3725 is done
- # - py: r.db('rethinkdb').table('table_status').changes(squash=False)
- # rb: r.db('rethinkdb').table('table_status').changes(squash:False)
- # js: r.db('rethinkdb').table('table_status').changes({squash:False})
- # ot: err('ReqlRuntimeError', 'replace with error message decided in \#3725')
-
- # - rethinkdb.table_status
-
- - cd: tableId = tbl.info()['id']
- js: tableId = tbl.info()('id')
-
- - cd: rtblPluck = r.db('rethinkdb').table('table_status').get(tableId).changes({include_initial:true})
- py: rtblPluck = r.db('rethinkdb').table('table_status').get(tableId).changes(include_initial=True)
- - cd: fetch(rtblPluck, 1)
- ot: partial([{'new_val':partial({'db':'test'})}])
-
- - py: tbl.reconfigure(shards=3, replicas=1)
- rb: tbl.reconfigure(shards:3, replicas:1)
- js: tbl.reconfigure({shards:3, replicas:1})
- - py: fetch(rtblPluck, 1, 2)
- js: fetch(rtblPluck, 1, 2)
- rb: fetch(rtblPluck, 1)
- ot: partial([{'old_val':partial({'db':'test'}), 'new_val':partial({'db':'test'})}])
-