vibe-d-postgresql ~row_by_row

PostgreSQL support for Vibe.d

API documentation

Please help us to make documentation better!

Example:

module vibe.db.postgresql.example;

import vibe.d;
import vibe.db.postgresql;

PostgresClient client;

void test()
{
    auto conn = client.lockConnection();

    try
    {
        immutable result = conn.execStatement(
            "SELECT 123 as first_num, 567 as second_num, 'abc'::text as third_text "~
            "UNION ALL "~
            "SELECT 890, 233, 'fgh'::text as third_text",
            ValueFormat.BINARY
        );

        assert(result[0]["second_num"].as!PGinteger == 567);
        assert(result[1]["third_text"].as!PGtext == "fgh");

        foreach (val; rangify(result[0]))
            logInfo("Found entry: %s", val.as!Bson.toJson);

        import core.memory;
        GC.collect();
    }
    catch(ConnectionException e)
    {
        conn.resetStart();
        logWarn(e.msg);
    }
    catch(Exception e)
    {
        logWarn(e.msg);
    }
}

static this()
{
    // params: conninfo string, maximum number of connections in
    // the connection pool
    client = new PostgresClient("dbname=postgres user=postgres", 4);

    test();
}

Output:

Found entry: 123
Found entry: 567
Found entry: "abc"