File Coverage

blib/lib/Database/Async/DB.pm

Criterion	Covered	Total	%
statement	15	32	46.8
branch			n/a
condition			n/a
subroutine	5	12	41.6
pod	2	7	28.5
total	22	51	43.1

package Database::Async::DB;

use strict;
use warnings;

our $VERSION = '0.016'; # VERSION

use Future;

use Database::Async::StatementHandle;

use Log::Any qw($log);

our @METHODS = qw(
    do
    prepare
    insert
    query
);

sub db { shift->{db} }

=head2 do

Executes the given SQL with optional bind parameters.

=cut

sub do : method {
    my ($self, $sql, %args) = @_;
    Future->done
}

=head2 prepare

Prepares a L.

=cut

sub prepare {
    my ($self, $sql) = @_;
    Future->done(
        Database::Async::StatementHandle->new
    )
}

sub quote_table_name {
    my ($self, $name) = @_;
    $name =~ s/"/""/g;
    '"' . $name . '"'
}

sub quote_field_name {
    my ($self, $name) = @_;
    $name =~ s/"/""/g;
    '"' . $name . '"'
}

sub insert {
    my ($self, $table, $data) = @_;
    $self->query(
        'insert into '
        . $self->quote_table_name(
            $table
        )
        . ' ('
        . join(',', map { $self->quote_field_name($_) } keys %$data)
        . ') values ('
        . join(',', ('?') x (keys %$data))
        . ')',
        values %$data
    )
}

sub query {
    my ($self, $sql, @bind) = @_;
    $log->tracef('Attempting query %s with %s', $sql, \@bind);
    Database::Async::Query->new(
        db   => $self->db,
        sql  => $sql,
        bind => \@bind
    )
}

1;

=head1 AUTHOR

Tom Molesworth C<<  >>

=head1 LICENSE

Copyright Tom Molesworth 2011-2021. Licensed under the same terms as Perl itself.