File Coverage

blib/lib/EV/MariaDB.pm

Criterion	Covered	Total	%
statement	33	39	84.6
branch	4	8	50.0
condition	5	22	22.7
subroutine	7	9	77.7
pod	1	1	100.0
total	50	79	63.2

package EV::MariaDB;
use strict;
use warnings;
use Carp 'croak';

use EV;

BEGIN {
    our $VERSION = '0.03';
    use XSLoader;
    XSLoader::load __PACKAGE__, $VERSION;
}

*q          = \&query;
*prep       = \&prepare;
*reconnect  = \&reset;
*disconnect = \&finish;
*errstr     = \&error_message;
*errno      = \&error_number;

my @OPTION_KEYS = qw(
    connect_timeout read_timeout write_timeout
    compress multi_statements charset init_command
    ssl_key ssl_cert ssl_ca ssl_capath ssl_cipher ssl_verify_server_cert
    utf8 found_rows
);

sub CLONE_SKIP { 1 }

sub new {
    my ($class, %args) = @_;

    my $loop = delete $args{loop} || EV::default_loop;
    my $self = $class->_new($loop);

    $self->on_error(delete $args{on_error} || sub { die @_ });
    if (my $cb = delete $args{on_connect}) {
        $self->on_connect($cb);
    }

    # set connection options before connect
    for my $key (@OPTION_KEYS) {
        if (defined(my $val = delete $args{$key})) {
            $self->_set_option($key, $val);
        }
    }

    my $host     = delete $args{host};
    my $user     = delete $args{user};
    my $password = delete $args{password};
    my $database = delete $args{database} // delete $args{db};
    my $port     = delete $args{port} // 3306;
    my $socket   = delete $args{unix_socket};

    if (my @unknown = keys %args) {
        croak "unknown argument(s) to new(): " . join(', ', sort @unknown);
    }

    if (defined $host || defined $user) {
        $self->connect(
            $host     // 'localhost',
            $user     // '',
            $password // '',
            $database // '',
            $port,
            $socket,
        );
    }

    $self;
}

1;

__END__