The Sync Layer
Your App Has Been Missing

// Standard JDBC — SyncLite captures every transaction transparently.
// Offline-first SQLite syncing to PostgreSQL.

Path dbPath = Path.of("orders.db");

// Wire up logger + shipper + embedded consolidator in one call.
SQLite.initialize(dbPath, "orders-device",
    DestinationOptions.builder()
        .dstType(DstType.POSTGRES)
        .connectionString("jdbc:postgresql://localhost:5432/syncdb")
        .database("syncdb")
        .schema("syncschema")
        .syncMode(DstSyncMode.REPLICATION)
        .build());

// From here on the app talks to a plain local SQLite database via JDBC.
try (Connection conn = DriverManager.getConnection("jdbc:synclite_sqlite:" + dbPath);
     Statement  s    = conn.createStatement()) {

    s.execute("CREATE TABLE IF NOT EXISTS orders(id INT, item TEXT, qty INT)");
    s.execute("INSERT INTO orders VALUES(1, 'widget', 100)");
    conn.commit();

    ResultSet rs = s.executeQuery("SELECT * FROM orders WHERE id = 1");
    while (rs.next()) /* [READ FROM LOCAL DB] */ {}

    // Roll the active log segment, then block until the apply lands in PostgreSQL.
    // NOTE: awaitSync is only used here to demonstrate SyncLite's background sync in action —
    // apps normally just keep writing; SyncLite ships changes asynchronously in the background.
    SQLite.flush(dbPath);
    SyncLite.awaitSync(dbPath, Duration.ofSeconds(30));

    try (Connection pg = DriverManager.getConnection(
            "jdbc:postgresql://localhost:5432/syncdb", "postgres", "postgres");
         PreparedStatement ps = pg.prepareStatement(
            "SELECT id, item, qty FROM syncschema.orders WHERE id = ?")) {
        ps.setInt(1, 1);
        try (ResultSet pgrs = ps.executeQuery()) {
            while (pgrs.next()) /* [READ FROM POSTGRESQL POST SYNC] */ {}
        }
    }
}
SQLite.closeDevice(dbPath);
// ↑ logged + shipped + consolidated into PostgreSQL.

// SyncLiteStore — typed CRUD without raw SQL, schema evolution built-in
Class.forName("io.synclite.logger.SQLiteStore");
SQLiteStore.initialize(dbPath, conf);

try (SyncLiteStore store = SQLiteStore.open(dbPath)) {

    store.createTable("players", new LinkedHashMap<>(Map.of(
        "id", "INTEGER PRIMARY KEY", "name", "TEXT", "score", "INTEGER"
    )));

    store.insert("players", Map.of("id", 1, "name", "Alice", "score", 100));
    store.update("players", Map.of("score", 250), Map.of("name", "Alice"));
    store.delete("players", Map.of("id", 1));

    List<Map<String,Object>> rows = store.selectAll("players");
}
SQLiteStore.closeDevice(dbPath);

// SyncLiteStream — fluent append-only event ingestion
Class.forName("io.synclite.logger.Streaming");
Streaming.initialize(dbPath, conf);

try (SyncLiteStream stream = SyncLiteStream.open(dbPath)) {

    stream.createTable("events", new LinkedHashMap<>(Map.of(
        "ts", "BIGINT", "event_type", "TEXT", "user_id", "TEXT"
    )));

    stream.insert("events", Map.of(
        "ts", System.currentTimeMillis(), "event_type", "SIGNUP", "user_id", "u1"
    ));

    // New columns added inline — schema evolves automatically
    stream.insertBatch("events", List.of(
        Map.of("ts", System.currentTimeMillis(), "event_type", "VIEW",     "user_id", "u2", "source", "web"),
        Map.of("ts", System.currentTimeMillis(), "event_type", "PURCHASE", "user_id", "u3", "source", "app")
    ));
}

# SyncLite DBReader — job configuration file (not application code)
# Table/topic mappings are configured via the web UI at http://localhost:8080/synclite-dbreader

synclite-device-dir = /opt/synclite/devices
synclite-logger-configuration-file = /opt/synclite/synclite.conf

src-type = POSTGRESQL
src-connection-string = jdbc:postgresql://pg.internal:5432/sales
src-user = reader
src-password = secret
src-connection-timeout-s = 30

src-dbreader-method = INCREMENTAL
src-dbreader-interval-s = 10
src-dbreader-batch-size = 100000

src-object-type = TABLE
src-default-unique-key-column-list = id
src-default-incremental-key-column-list = updated_at
src-infer-schema-changes = true

# DBReader handles batching, retries, checkpoints, and restarts.

# SyncLite QReader — job configuration file (not application code)
# Topic-to-table mappings are configured via the web UI at http://localhost:8080/synclite-qreader

synclite-device-dir = /opt/synclite/devices
synclite-logger-configuration-file = /opt/synclite/synclite.conf

mqtt-broker-url = tcp://mqtt.example.com:1883
mqtt-qos-level = 1
mqtt-clean-session = true
mqtt-broker-connection-timeout-s = 10
mqtt-broker-connection-retry-interval-s = 2

src-message-format = CSV
src-message-field-delimiter = ,

qreader-synclite-device-type = SQLITE_APPENDER
qreader-map-devices-to-single-synclite-device = true
qreader-default-synclite-device-name = iot_device
qreader-default-synclite-table-name = iot_events

# Works with Mosquitto, EMQX, AWS IoT Core, and Azure IoT Hub.

# Python via the synclite PyO3 wheel. Offline-first SQLite syncing to PostgreSQL.
# The Connection / Statement objects match the Rust and C++ samples one-for-one.
import synclite as sl

# Wire up logger + shipper + embedded consolidator in one call.
sl.initialize(
    device_type="SQLITE",
    device_name="orders-device",                 # device name
    db_path="orders.db",                          # local SQLite path
    destination=sl.DestinationOptions(
        dst_type="POSTGRES",
        dst_connection_string="postgresql://postgres:postgres@localhost:5432/syncdb",
        dst_database="syncdb",
        dst_schema="syncschema",
        dst_sync_mode="REPLICATION",
    ),
)

# From here on the app talks to a plain local SQLite database.
conn = sl.Connection.open("orders.db")
conn.execute("CREATE TABLE IF NOT EXISTS orders(id INTEGER, item TEXT, qty INTEGER)")
conn.execute("INSERT INTO orders VALUES(?, ?, ?)", [1, "widget", 100])
conn.commit()

# Roll the active log segment, then block until the apply lands in PostgreSQL.
# NOTE: await_sync is only used here to demonstrate SyncLite's background sync in action —
# apps normally just keep writing; SyncLite ships changes asynchronously in the background.
conn.flush()
sl.await_sync("orders.db", 30.0)
conn.close()
# ↑ logged + shipped + consolidated into PostgreSQL.

// Header-only RAII wrapper over the synclite C ABI (synclite.hpp, C++17).
// Offline-first SQLite syncing to PostgreSQL.
#include "synclite.hpp"

int main() {
    synclite::DestinationOptions dst;
    dst.dst_type              = SYNCLITE_DST_POSTGRES;
    dst.dst_connection_string = "postgresql://postgres:postgres@localhost:5432/syncdb";
    dst.dst_database          = "syncdb";
    dst.dst_schema            = "syncschema";
    dst.dst_sync_mode         = "REPLICATION";

    synclite::initialize(SYNCLITE_DEVICE_SQLITE, "orders-device", "orders.db", &dst);

    // From here on the app talks to a plain local SQLite database.
    synclite::Connection conn("orders.db");
    conn.execute("CREATE TABLE IF NOT EXISTS orders(id INTEGER, item TEXT, qty INTEGER)");
    conn.execute("INSERT INTO orders VALUES(?, ?, ?)",
                  { synclite::Value(1), synclite::Value("widget"), synclite::Value(100) });
    conn.commit();

    // Roll the active log segment, then block until the apply lands in PostgreSQL.
    // NOTE: await_sync is only used here to demonstrate SyncLite's background sync in action —
    // apps normally just keep writing; SyncLite ships changes asynchronously in the background.
    conn.flush();
    synclite::await_sync("orders.db", 30.0);
    // ↑ logged + shipped + consolidated into PostgreSQL.
    return 0;
}

# Any language — plain HTTP/JSON via SyncLite DB server
# Works with Python, Go, Rust, C#, C++, Ruby, Node.js…
import requests

BASE = "http://localhost:5555/synclite"

# 1. Initialize
requests.post(BASE, json={
    "db-type": "SQLITE", "db-name": "myapp",
    "sql": "initialize"
})

# 2. DDL
requests.post(BASE, json={"db-name": "myapp",
    "sql": "CREATE TABLE IF NOT EXISTS orders(id INT, item TEXT)"})

# 3. Batched insert
requests.post(BASE, json={"db-name": "myapp",
    "sql": "INSERT INTO orders VALUES(?, ?)",
    "arguments": [[1, "widget"], [2, "gadget"]]})

# 4. SELECT — local read from the embedded database
resp = requests.post(BASE, json={"db-name": "myapp",
    "sql": "SELECT id, item FROM orders"})
print(resp.json())

// Jedis-compatible API for Redis-style commands on SyncLiteKV
try (SyncRedis redis = new SyncRedis("jdbc:synclite_sqlite:" + dbPath, conf)) {

  redis.set("session:u1", "active");
  redis.hset("profile:u1", "tier", "gold");
  redis.incrBy("counter:events", 1);

  String state = redis.get("session:u1");
}
// Commands are persisted locally and replicated through the standard SyncLite pipeline.

// Kafka Producer-compatible API backed by SyncLiteStream
Properties props = new Properties();
props.put("bootstrap.servers", "synclite://local");
props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");

try (Producer<String, String> p = new KafkaProducer<>(props)) {
  p.send(new ProducerRecord<>("events", "u1", "signup"));
  p.send(new ProducerRecord<>("events", "u2", "purchase"));
}
// Same producer workflow, with SyncLite handling local durability and downstream replication.