File Coverage

blib/lib/EV/MariaDB.pm

Criterion	Covered	Total	%
statement	26	30	86.6
branch	4	8	50.0
condition	3	22	13.6
subroutine	7	9	77.7
pod	1	1	100.0
total	41	70	58.5

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

use EV;

BEGIN {
    our $VERSION = '0.06';
    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
);

my %ALLOWED_ARGS = map { $_ => 1 } @OPTION_KEYS, qw(
    loop on_connect on_error
    host user password database db port unix_socket
);

sub CLONE_SKIP { 1 }

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

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

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

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

    for my $key (@OPTION_KEYS) {
        $self->_set_option($key, $args{$key}) if defined $args{$key};
    }

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

    $self;
}

1;

__END__