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
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
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121

#include "util.h"

#include <assert.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>

#include "consts.h"
#include "crsqlite.h"
#include "tableinfo.h"

#ifndef CHECK_OK
#define CHECK_OK         \
  if (rc != SQLITE_OK) { \
    goto fail;           \
  }
#endif

int crsql_close(sqlite3 *db);

static void testGetVersionUnionQuery() {
  int numRows_tc1 = 1;
  char *tableNames_tc1[] = {
      "tbl_name",
      "foo",
  };
  int numRows_tc2 = 3;
  char *tableNames_tc2[] = {"tbl_name", "foo", "bar", "baz"};
  char *query;
  printf("GetVersionUnionQuery\n");

  query = crsql_getDbVersionUnionQuery(numRows_tc1, tableNames_tc1);
  printf("query: %s", query);
  assert(
      strcmp(
          query,
          "SELECT max(version) as version FROM (SELECT max(__crsql_db_version) "
          "as version FROM \"foo\"   UNION SELECT value as version FROM "
          "crsql_master WHERE key = 'pre_compact_dbversion')") == 0);
  sqlite3_free(query);

  query = crsql_getDbVersionUnionQuery(numRows_tc2, tableNames_tc2);
  assert(
      strcmp(
          query,
          "SELECT max(version) as version FROM (SELECT max(__crsql_db_version) "
          "as version FROM \"foo\" UNION ALL SELECT max(__crsql_db_version) as "
          "version FROM \"bar\" UNION ALL SELECT max(__crsql_db_version) as "
          "version FROM \"baz\"   UNION SELECT value as version FROM "
          "crsql_master WHERE key = 'pre_compact_dbversion')") == 0);
  sqlite3_free(query);

  printf("\t\e[0;32mSuccess\e[0m\n");
}

static void testGetCount() {
  sqlite3 *db = 0;
  int rc = SQLITE_OK;
  printf("GetCount\n");

  rc = sqlite3_open(":memory:", &db);
  sqlite3_exec(db, "CREATE TABLE foo (a); INSERT INTO foo VALUES (1);", 0, 0,
               0);
  rc = crsql_getCount(db, "SELECT count(*) FROM foo");

  assert(rc == 1);
  sqlite3_exec(db, "INSERT INTO foo VALUES (1);", 0, 0, 0);
  rc = crsql_getCount(db, "SELECT count(*) FROM foo");
  assert(rc == 2);

  crsql_close(db);
  printf("\t\e[0;32mSuccess\e[0m\n");
}

static void testJoinWith() {
  printf("JoinWith\n");
  char dest[13];
  char *src[] = {"one", "two", "four"};

  crsql_joinWith(dest, src, 3, ',');

  assert(strcmp(dest, "one,two,four") == 0);
  printf("\t\e[0;32mSuccess\e[0m\n");
}

static char *join2map(const char *in) {
  return sqlite3_mprintf("foo %s bar", in);
}

static void testJoin2() {
  printf("Join2\n");
  char *tc0[] = {};
  char *tc1[] = {"one"};
  char *tc2[] = {"one", "two"};
  char *result;

  result = crsql_join2(&join2map, tc0, 0, ", ");
  assert(result == 0);

  result = crsql_join2(&join2map, tc1, 1, ", ");
  assert(strcmp(result, "foo one bar") == 0);
  sqlite3_free(result);

  result = crsql_join2(&join2map, tc2, 2, ", ");
  assert(strcmp(result, "foo one bar, foo two bar") == 0);
  sqlite3_free(result);

  printf("\t\e[0;32mSuccess\e[0m\n");
}

void crsqlUtilTestSuite() {
  printf("\e[47m\e[1;30mSuite: crsql_util\e[0m\n");

  testGetVersionUnionQuery();
  testGetCount();
  testJoinWith();
  testJoin2();

  // TODO: test pk pulling and correct sorting of pks
  // TODO: create a fn to create test tables for all tests.
}