fix: conditional SQLITE_WASM_EXTRA_INIT escape single quotes instead of double quotes in query strings for wasm support

Author: Gioee

src/cloudsync.c

@@ -360,7 +360,11 @@ char *db_version_build_query (sqlite3 *db) {
 
     // the good news is that the query can be computed in SQLite without the need to do any extra computation from the host language
     const char *sql = "WITH table_names AS ("
+                    #ifdef SQLITE_WASM_EXTRA_INIT
+                      "SELECT format('%w', name) as tbl_name "
+                    #else
                       "SELECT format(\"%w\", name) as tbl_name "
+                    #endif
                       "FROM sqlite_master "
                       "WHERE type='table' "
                       "AND name LIKE '%_cloudsync'"

src/dbutils.c

@@ -419,7 +419,11 @@ bool dbutils_table_sanity_check (sqlite3 *db, sqlite3_context *context, const ch
             // the affinity of a column is determined by the declared type of the column,
             // according to the following rules in the order shown:
             // 1. If the declared type contains the string "INT" then it is assigned INTEGER affinity.
+            #ifdef SQLITE_WASM_EXTRA_INIT
+            sql = sqlite3_snprintf((int)blen, buffer, "SELECT count(*) FROM pragma_table_info('%w') WHERE pk=1 AND \"type\" LIKE '%%INT%%';", name);
+            #else
             sql = sqlite3_snprintf((int)blen, buffer, "SELECT count(*) FROM pragma_table_info('%w') WHERE pk=1 AND \"type\" LIKE \"%%INT%%\";", name);
+            #endif
             sqlite3_int64 count2 = dbutils_int_select(db, sql);
             if (count == count2) {
                 dbutils_context_result_error(context, "Table %s uses an single-column INTEGER primary key. For CRDT replication, primary keys must be globally unique. Consider using a TEXT primary key with UUIDs or ULID to avoid conflicts across nodes. If you understand the risk and still want to use this INTEGER primary key, set the third argument of the cloudsync_init function to 1 to skip this check.", name);

src/vtab.c

@@ -137,6 +137,20 @@ char *build_changes_sql (sqlite3 *db, const char *idxs) {
     "changes_query AS ( "
     "    SELECT "
     "        'SELECT "
+    #ifdef SQLITE_WASM_EXTRA_INIT
+    "        ''' || table_name || ''' AS tbl, "
+    "        t1.pk AS pk, "
+    "        t1.col_name AS col_name, "
+    "        cloudsync_col_value(''' || table_name || ''', t1.col_name, t1.pk) AS col_value, "
+    "        t1.col_version AS col_version, "
+    "        t1.db_version AS db_version, "
+    "        site_tbl.site_id AS site_id, "
+    "        t1.seq AS seq, "
+    "        COALESCE(t2.col_version, 1) AS cl "
+    "     FROM ''' || table_meta || ''' AS t1 "
+    "     LEFT JOIN cloudsync_site_id AS site_tbl ON t1.site_id = site_tbl.rowid "
+    "     LEFT JOIN ''' || table_meta || ''' AS t2 ON t1.pk = t2.pk AND t2.col_name = ''" CLOUDSYNC_TOMBSTONE_VALUE "'' "
+    #else
     "        \"' || \"table_name\" || '\" AS tbl, "
     "        t1.pk AS pk, "
     "        t1.col_name AS col_name, "
@@ -149,6 +163,7 @@ char *build_changes_sql (sqlite3 *db, const char *idxs) {
     "     FROM \"' || \"table_meta\" || '\" AS t1 "
     "     LEFT JOIN cloudsync_site_id AS site_tbl ON t1.site_id = site_tbl.rowid "
     "     LEFT JOIN \"' || \"table_meta\" || '\" AS t2 ON t1.pk = t2.pk AND t2.col_name = ''" CLOUDSYNC_TOMBSTONE_VALUE "'' "
+    #endif
     "     WHERE col_value IS NOT ''" CLOUDSYNC_RLS_RESTRICTED_VALUE "''' "
     "    AS query_string FROM table_names "
     "), "