LiteSync

Python

First follow the instructions to compile and install LiteSync from the source code or use the pre-compiled binaries for your platform. You can start with the free version.

Then install the litesync module according to the Python version:

Python 3

Python 2.7

Example code

The litesync module has the same API as the sqlite3 module

import litesync as sqlite3
import json
import time

conn = sqlite3.connect('file:app.db?node=secondary&connect=tcp://server:port')

# check if the db is ready
while True:
    result = conn.cursor().execute("PRAGMA sync_status").fetchone()
    status = json.loads(result[0])
    if status["db_is_ready"]: break
    time.sleep(0.250)

# now we can use the db connection
...

Update Notification

Your application can be notified when the local database is updated due to synchronization with remote nodes. The notification is done via a user-defined function.

def on_db_update(arg):
  print("update received")

conn.create_function("update_notification", 1, on_db_update)

Important: The notification function is called by the worker thread. The application should NOT use the db connection inside the notification function and it must return as fast as possible! The application can transfer the notification to the main thread before returning.

Throubleshooting

We can also use the Python's sqlite3 module on Linux and Windows

On both cases the Python's sqlite3 module interfaces with the system's SQLite library

Linux

We have 2 options to make Python to use the modified SQLite library containing LiteSync:

A. Use the LD_LIBRARY_PATH when opening the application

B. Make the sqlite3 module use the LiteSync library

To check if it was successful:

Windows

Replace the sqlite3.dll file in the folder \Python\DLLs with the one containing LiteSync (rename from litesync-0.1.dll to sqlite3.dll)

Usage

In this case we use the sqlite3 module instead of the litesync module

import sqlite3
import json
import time

conn = sqlite3.connect('file:app.db?node=secondary&connect=tcp://server:port')

# check if the db is ready
while True:
    result = conn.cursor().execute("PRAGMA sync_status").fetchone()
    status = json.loads(result[0])
    if status["db_is_ready"]: break
    time.sleep(0.250)

# now we can use the db connection
...