std.db.sqlite

SQLite3-Binding via FFI (libsqlite3.so.0). Alle Verbindungs- und Statement-Handles werden als int64-Pointer dargestellt. Das API folgt dem Prepared-Statement-Muster: SQLiteStmtPrepare → Bind → SQLiteStmtStep → Column-Accessoren → SQLiteStmtFinalize.

→ Standard Library · std.db.postgres · std.db.mysql

Verbindungs-Handle. Immer über SQLiteOpen erstellen und über SQLiteClose freigeben.

Prepared-Statement-Handle. Immer über SQLiteStmtPrepare erstellen und über SQLiteStmtFinalize freigeben.

Funktionen für Verbindungsaufbau und -verwaltung:

Funktionen für Prepared Statements:

Transaktionsverwaltung:

import std.db.sqlite;
import std.io;

fn SetupDB(): int64 {
    var db := SQLiteOpen("/tmp/test.db");
    if (db == 0) { return 0; }

    SQLiteExec(db, "CREATE TABLE IF NOT EXISTS users (id INTEGER PRIMARY KEY, name TEXT, age INTEGER)");
    return db;
}

fn InsertUser(db: int64, name: pchar, age: int64): void {
    var stmt := SQLiteStmtPrepare(db, "INSERT INTO users (name, age) VALUES (?, ?)");
    SQLiteBindStr(stmt, 1, name);
    SQLiteBindInt(stmt, 2, age);
    SQLiteStmtStep(stmt);
    SQLiteStmtFinalize(stmt);
}

import std.db.sqlite;
import std.io;

fn PrintUsers(db: int64): void {
    var stmt := SQLiteStmtPrepare(db, "SELECT id, name, age FROM users ORDER BY name");

    while (SQLiteStmtStep(stmt) == SQLITE_ROW) {
        PrintLn(IntToStr(SQLiteColumnInt(stmt, 0)) + ": " + SQLiteColumnText(stmt, 1) + " (" + IntToStr(SQLiteColumnInt(stmt, 2)) + ")");
    }

    SQLiteStmtFinalize(stmt);
}

import std.db.sqlite;

fn BulkInsert(db: int64, names: int64, count: int64): bool {
    SQLiteBegin(db);

    var stmt := SQLiteStmtPrepare(db, "INSERT INTO users (name) VALUES (?)");
    var i: int64 := 0;
    var ok: bool := true;

    while (i < count) {
        var name: pchar := peek64(names + i * 8) as pchar;
        SQLiteBindStr(stmt, 1, name);
        var rc := SQLiteStmtStep(stmt);
        if (rc != SQLITE_DONE) { ok := false; break; }
        SQLiteStmtReset(stmt);
        i := i + 1;
    }

    SQLiteStmtFinalize(stmt);

    if (ok) {
        SQLiteCommit(db);
    } else {
        SQLiteRollback(db);
    }
    return ok;
}

import std.db.sqlite;

fn TempDB(): int64 {
    var db := SQLiteOpen(":memory:");
    SQLiteExec(db, "CREATE TABLE tmp (k TEXT, v TEXT)");
    SQLiteSetJournalMode(db, "OFF");   // kein Journal für In-Memory nötig
    return db;
}

import std.db.sqlite;

fn OpenWAL(path: pchar): int64 {
    var db := SQLiteOpen(path);
    SQLiteSetJournalMode(db, "WAL");
    SQLiteSetCacheSize(db, 2000);   // 2000 Seiten ≈ 8 MB bei 4096 Bytes/Seite
    return db;
}

• Parameter-Indizes bei Binding sind 1-basiert, Column-Indizes bei Accessoren sind 0-basiert.
• SQLiteBindStr verwendet SQLITE_STATIC — der String-Puffer muss bis zum nächsten SQLiteStmtStep, SQLiteStmtReset oder SQLiteStmtFinalize gültig bleiben.
• SQLiteColumnText gibt einen Pointer auf SQLite-internen Speicher zurück — nicht nach Step/Reset/Finalize verwenden.
• Für schreibintensive Workloads: WAL-Modus aktivieren (SQLiteSetJournalMode(db, „WAL“)) und mehrere INSERT in Transaktionen bündeln.
• SQLiteDropTable validiert den Tabellennamen auf erlaubte Zeichen (A-Z, a-z, 0-9, _, .) — schützt vor SQL-Injection.

• std.db.postgres — PostgreSQL (natives Wire-Protokoll)
• std.db.mysql — MySQL/MariaDB
• std.db.redis — Redis Key-Value-Store

Letzte Aktualisierung: 2026-06-05