File Coverage

blib/lib/AnyEvent/MySQL/ConnPool.pm

Criterion	Covered	Total	%
statement	16	29	55.1
branch	0	2	0.0
condition	0	4	0.0
subroutine	6	9	66.6
pod	1	1	100.0
total	23	45	51.1

=head1 NAME

AnyEvent::MySQL::ConnPool

=head1 DESCRIPTION

Adds additional method "pool_connect" to L package.

=head1 SYNOPSIS

Similar to AnyEvent::MySQL->connect();

    use AnyEvent;
    use AnyEvent::MySQL;
    use AnyEvent::MySQL::ConnPool;

    my $connpool = AnyEvent::MySQL->connect_pool(
        "DBI:mysql:database=test;host=127.0.0.1;port=3306",
        "ptest",
        "pass", {
            PrintError      =>  1,
            PoolSize        =>  10,
            CheckInterval   =>  5,
        },
        sub {
            my($dbh) = @_;
            if( $dbh ) {
                warn "Connect success!";
                $dbh->pre_do("set names latin1");
                $dbh->pre_do("set names utf8");
            }
            else {
                warn "Connect fail: $AnyEvent::MySQL::errstr ($AnyEvent::MySQL::err)";
                $end->send;
            }
        }
    );

    # if you need only connection methods, you can use dispatcher object as regular AnyEvent::MySQL connection  object.
    # the difference is: dispatcher applies connection pool functional to your connection object.
    my $dispatcher = $connpool->dispatcher();
    $dispatcher->selectall_hashref('SELECT * FROM `table1`', {}, sub {
        ...;
    });

=head1 METHODS

=over

=item B

Returns connected L object.
All options for connect_pool are similar to the AnyEvent::MySQL->connect method.
But pool accepts additional options in parameters hashref(4th parameter).

    AnyEvent::MySQL->connect_pool($dsn, $user, $password, {PoolSize => 5, CheckInterval => 10, Dispatcher => 0}, $callback);

PoolSize    =>  how many connections should be created. 5 connections by default.

CheckInterval   =>  Interval for ping connections. 10 seconds by default.

Dispatcher  =>  Determines return-value type. If true, connect_pool will return dispatcher object, instead of pool object. You can use dispatcher object
as regular AnyEvent::MySQL connection object, pool will do it's own behind the scene.


=cut

package AnyEvent::MySQL::ConnPool;
use strict;
use warnings;

use Carp;
use AnyEvent::MySQL;
use AnyEvent::ConnPool;

our $VERSION = 0.07;

sub import {
    *{AnyEvent::MySQL::connect_pool} = \&new;
}

=item B

Same thing as connect_pool.

    my $connpool = AnyEvent::MySQL::ConnPool->new($dsn, $user, $password, {PoolSize => 5, CheckInterval => 10, Dispatcher => 0}, $callback);

=cut

sub new {
        my ($caller, $dsn, $user, $password, $params, $cb) = @_;

        my @conn_args = @_;
        shift @conn_args;

        my $pool_size = delete $params->{PoolSize};
        my $check_interval = delete $params->{CheckInterval};
        my $dispatcher = delete $params->{Dispatcher};

        $pool_size ||= 5;
        $check_interval ||= 10;
        $dispatcher = 0 unless $dispatcher;

        my $connpool = AnyEvent::ConnPool->new(
            init        =>  1,
            dispatcher  =>  $dispatcher,
            size        =>  $pool_size,
            check       =>  {
                cb          =>  sub {
                    my $unit = shift;
                    $unit->conn()->ping();
                },
                interval    =>  $check_interval,
            },
            constructor     =>  sub {
                return AnyEvent::MySQL->connect(@conn_args);
            },
        );
    };

1;

=back

=cut

__END__