src/test/rethink_test.ts


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

import { r } from "rethinkdb-ts";

async function main() {
	const connection = await r.connect({ port: 28015 });

	const db = r.db("test");
	const cursor = await db
		.table("guilds")
		.get(0)
		.changes({ squash: true })
		.map(function (row) {
			return row("old_val")
				.keys()
				.setUnion(row("new_val").keys())
				.concatMap(function (key) {
					return r.branch(
						row("old_val")(key).ne(row("new_val")(key)).default(true),
						[[key, row("new_val")(key).default(null)]],
						[]
					);
				})
				.coerceTo("object");
		})
		.run(connection);

	console.log("each");
	cursor.each(function (err, row) {
		if (err) throw err;
		console.log(row);
	});
	console.log("eachend");
}

main();