Getting Started

import io.sirix.access.DatabaseConfiguration;
import io.sirix.access.Databases;
import io.sirix.access.ResourceConfiguration;
import io.sirix.api.JsonNodeReadOnlyTrx;
import io.sirix.api.JsonNodeTrx;
import io.sirix.api.json.JsonResourceSession;
import io.sirix.service.json.serialize.JsonSerializer;
import io.sirix.service.json.shredder.JsonShredder;

import java.io.StringWriter;
import java.nio.file.Files;
import java.nio.file.Path;

public class SirixQuickStart {
    public static void main(String[] args) throws Exception {
        final var dbPath = Path.of(System.getProperty("java.io.tmpdir"), "sirix-getting-started");

        // Clean up from previous runs
        if (Files.exists(dbPath)) {
            Databases.removeDatabase(dbPath);
        }

        // 1. Create a database and resource
        Databases.createJsonDatabase(new DatabaseConfiguration(dbPath));

        try (final var database = Databases.openJsonDatabase(dbPath)) {
            database.createResource(ResourceConfiguration.newBuilder("products").build());

            // 2. Insert JSON data (revision 1)
            try (final var session = database.beginResourceSession("products");
                 final var wtx = session.beginNodeTrx()) {

                wtx.insertSubtreeAsFirstChild(JsonShredder.createStringReader("""
                    [
                      {"name": "Laptop", "price": 999},
                      {"name": "Phone",  "price": 699}
                    ]
                    """));
                wtx.commit();

                // 3. Update data (revision 2) — add a product
                wtx.moveTo(1); // move to the array node
                wtx.insertSubtreeAsFirstChild(JsonShredder.createStringReader(
                    """
                    {"name": "Monitor", "price": 349}
                    """));
                wtx.commit();
            }

            // 4. Read a specific revision
            try (final var session = database.beginResourceSession("products");
                 final var rtx = session.beginNodeReadOnlyTrx(1)) {
                // rtx is now positioned at revision 1
                final var writer = new StringWriter();
                final var serializer = new JsonSerializer.Builder(session, writer)
                    .startNodeKey(rtx.getNodeKey())
                    .revisions(new int[]{1})
                    .build();
                serializer.call();
                System.out.println("Revision 1: " + writer);
            }

            // 5. Read the latest revision
            try (final var session = database.beginResourceSession("products");
                 final var rtx = session.beginNodeReadOnlyTrx()) {
                final var writer = new StringWriter();
                final var serializer = new JsonSerializer.Builder(session, writer).build();
                serializer.call();
                System.out.println("Latest:     " + writer);
            }
        }

        // Clean up
        Databases.removeDatabase(dbPath);
    }
}