summaryrefslogtreecommitdiff
path: root/scripts/mkdb.py
blob: d3786f170ba78065d857a21a3b98dad47edfdfbe (plain)
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/env python3

import sys
import sqlite3
import string
from argparse import ArgumentParser
from pathlib import Path
from random import choice, randrange

characters = string.ascii_letters + string.digits


class Range:

    def __init__(self, arg: str):
        start, end = arg.split("-")

        self.start = int(start)
        self.end = int(end)


def truncate(path: Path) -> None:
    with open(path, "w") as file:
        file.truncate(0)


def main() -> int:
    parser = ArgumentParser()

    parser.add_argument("--database", type=Path, required=True)
    parser.add_argument("--word-list", type=Path, required=True)
    parser.add_argument("--num-records", type=int, required=True)
    parser.add_argument("--key-length", type=Range, required=True)
    parser.add_argument("--value-length", type=Range, required=True)

    args = parser.parse_args()

    words = args.word_list.read_text().split("\n")

    truncate(args.database)

    def generate_key(length: int) -> str:
        return "".join(choice(characters) for _ in range(length))

    def generate_value(length: int) -> str:
        return "-".join(choice(words) for _ in range(length))

    with sqlite3.connect(args.database) as connection:
        connection.execute("PRAGMA jorunal_mode = WAL")
        connection.execute("create table kv(key text, value text)")
        connection.execute("create index keys on kv(key)")

        for i in range(args.num_records):
            key = generate_key(randrange(args.key_length.start, args.key_length.end))

            val = generate_value(
                randrange(args.value_length.start, args.value_length.end)
            )

            print(f"inserting record number {i}", file=sys.stderr)

            connection.execute(
                "insert into kv values(?, ?)",
                (
                    key,
                    val,
                ),
            )

    return 0


sys.exit(main())