Dekescordes/spacebar
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

➖ delete rethink

Browse Source
This commit is contained in:
Flam3rboy 2021-07-11 11:05:40 +02:00
parent e70cdfe282
commit 2f68beea8f
2 changed files with 0 additions and 89 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

55
src/test/rethink_benchmark.ts
View File

@ -1,55 +0,0 @@
// @ts-nocheck
import { r } from "rethinkdb-ts";
import faker from "faker";
import cluster from "cluster";
import { performance } from "perf_hooks";
console.log("starting");
if (cluster.isMaster) {
for (var i = 0; i < 1; i++) {
cluster.fork();
}
console.log("all nodes started");
}
if (cluster.isWorker) {
const inserts = [];
for (let i = 0; i < 100; i++) {
inserts.push({
color: faker.commerce.color(),
department: faker.commerce.department(),
price: faker.commerce.price(),
product: faker.commerce.product(),
productAdjective: faker.commerce.productAdjective(),
productName: faker.commerce.productName(),
productMaterial: faker.commerce.productMaterial(),
productDescription: faker.commerce.productDescription(),
});
}
async function main(connection) {
const start = performance.now();
await r
.db("test")
.table("test")
.nth(Math.floor(Math.random() * 300000))
.run(connection);
const end = performance.now();
// console.log(end - start);
// await main(connection);
setTimeout(main.bind(null, connection));
}
(async () => {
const threads = 30;
for (var i = 0; i < threads; i++) {
setTimeout(async () => {
main(await r.connect({ port: 28015, host: "192.168.178.122" }));
});
}
})();
}

34
src/test/rethink_test.ts.disabled
View File

@ -1,34 +0,0 @@
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();