ddcp 0.2.4

Distributed decentralized database-to-database copy
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

from crsql_correctness import connect, close, min_db_v
from pprint import pprint

# exploratory tests to debug changes


def sync_left_to_right(l, r):
    changes = l.execute(
        "SELECT * FROM crsql_changes")
    for change in changes:
        r.execute(
            "INSERT INTO crsql_changes VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?)", change)
    r.commit()


def test_sync():
    db1 = connect(":memory:")
    db2 = connect(":memory:")

    def setup(db):
        db.execute("create table hoot (a, b primary key, c)")
        db.execute("select crsql_as_crr('hoot')")
        db.commit()

        db.execute("INSERT INTO hoot VALUES (1, 1, 1)")
        db.commit()
        db.execute("UPDATE hoot SET a = 1 WHERE b = 1")
        db.commit()
        db.execute("UPDATE hoot SET a = 2 WHERE b = 1")
        db.commit()
        db.execute("UPDATE hoot SET a = 3 WHERE b = 1")
        db.commit()

    setup(db1)
    setup(db2)

    db1vpre = db1.execute("SELECT crsql_db_version()").fetchone()[0]
    db2vpre = db2.execute("SELECT crsql_db_version()").fetchone()[0]

    # sync_left_to_right(db1, db2)

    dbv2post = db2.execute("SELECT crsql_db_version()").fetchone()[0]

    pprint(db2vpre)
    pprint(dbv2post)

    pprint(db2.execute("SELECT * FROM crsql_changes").fetchall())
    pprint(db1.execute("SELECT * FROM crsql_changes").fetchall())