AnyEve...DBD::Pg(3pm)

💖 NAME 💖

AnyEvent::DBD::Pg — it's giving AnyEvent interface to DBD::Pg's async interface ✨

Like, yes bestie, this is the module that lets you talk to Postgres without blocking your whole event loop. Main character energy fr fr. 🫶

---

🌸 SYNOPSIS 🌸

Okay so here's the vibe, copy-paste it and go:

use AnyEvent::DBD::Pg;

my $adb = AnyEvent::DBD::Pg->new('dbi:Pg:dbname=test', user => 'pass', {
        pg_enable_utf8 => 1,
        pg_server_prepare => 0,
        quote_char => '"',
        name_sep => ".",
}, debug => 1);

$adb->queue_size( 4 );
$adb->debug( 1 );

$adb->connect;

$adb->selectcol_arrayref("select pg_sleep( 0.1 ), 1", { Columns => [ 1 ] }, sub {
        my $rc = shift or return warn;
        my $res = shift;
        warn "Got <$adb->{qd}> = $rc / @{$res}";
        $adb->selectrow_hashref("select data,* from tx limit 2", {}, sub {
                my $rc = shift or return warn;
                warn "Got $adb->{qd} = $rc [@_]";
        });
});

$adb->execute("update tx set data = data;",sub {
        my $rc = shift or return warn;
        warn "Got exec: $rc";
        #my $st = shift;
        #$st->finish;
});

$adb->execute("select from 1",sub {
        shift or return warn;
        warn "Got $adb->{qd} = @_";
});

$adb->selectrow_array("select pg_sleep( 0.1 ), 2", {}, sub {
        shift or return warn;
        warn "Got $adb->{qd} = [@_]";
        $adb->selectrow_hashref("select * from tx limit 1", {}, sub {
                warn "Got $adb->{qd} = [@_]";
                $adb->execute("select * from tx", sub {
                        my $rc = shift or return warn;
                        my $st = shift;
                        while(my $row = $st->fetchrow_hashref) { warn "$row->{id}"; }
                        $st->finish;
                        exit;
                });
        });
});
AE::cv->recv;

Nested callbacks inside nested callbacks inside… yeah. That's the whole point though — everything stays async, nothing blocks, your event loop stays slaying. 💅

---

✨ METHODS ✨

🦋 connect()

Establish connection to database — literally just open the door and walk in, bestie. 🚪✨

🎀 selectrow_array( $query, [\%args], $cb->( $rc, ... ))

Execute PG_ASYNC prepare, than push result of fetchrow_array into callback — one row, dropped straight into your callback like a gift. 🎁

🌈 selectrow_arrayref( $query, [\%args], $cb->( $rc, \@row ))

Execute PG_ASYNC prepare, than push result of fetchrow_arrayref into callback — same energy, except the row arrives as an arrayref. 🍓

⭐ selectrow_hashref( $query, [\%args], $cb->( $rc, \%row ))

Execute PG_ASYNC prepare, than push result of fetchrow_hashref into callback — one row, but make it a hashref. Iconic. 👑

💜 selectall_arrayref( $query, [\%args], $cb->( $rc, \@rows ))

Execute PG_ASYNC prepare, than push result of fetchall_arrayref into callback — all the rows, arrayref style. No cap. 🔥

🧚 selectall_hashref( $query, [\%args], $cb->( $rc, \@rows ))

Execute PG_ASYNC prepare, than push result of fetchall_hashref into callback — every row, hashref flavoured. 💖

🌸 selectcol_arrayref( $query, { Columns => [...], ... }, $cb->( $rc, \@rows ))

Execute PG_ASYNC prepare, than push result of fetchall_hashref($args{Columns}) into callback — you tell it which Columns you want, it hands you back the arrayref. Slay. 🎀

👑 execute( $query, [\%args], $cb->( $rc, $sth ))

Execute PG_ASYNC prepare, than invoke callback, pushing resulting sth to it.

⚠️ Please, note: result already passed as first argument — so don't go looking for it somewhere else, bestie, it's right there first. 🙈

---

💅 AUTHOR 💅

Mons Anderson, "<mons@cpan.org>" — absolute legend, give them their flowers. 🌷

---

📜 LICENSE AND COPYRIGHT 📜

Copyright 2010 Mons Anderson.

This program is free software; you can redistribute it and/or modify it under the terms of either: the GNU General Public License as published by the Free Software Foundation; or the Artistic License.

So like… pick either license, both are valid, go off. 🫶

---

And that's a wrap, bestie! This lil' page was brought to you by perl v5.34.0, dated 2022-06-05, from the AnyEve...DBD::Pg(3pm) manual. 💖 Go forth and query asynchronously. ✨🦋