Merge pull request #3 from shogo82148/test-mysqld-multi

add impl Test::mysqld::Multi

cpanfile

@@ -3,7 +3,7 @@ requires 'Cache::FastMmap';
 requires 'File::Temp';
 requires 'Mouse';
 requires 'POSIX::AtFork';
-requires 'Test::mysqld';
+requires 'Test::mysqld', '0.20';
 requires 'parent';
 
 on build => sub {

lib/Test/mysqld/Pool.pm

@@ -32,35 +32,23 @@ has my_cnf       => ( is => 'rw', isa => 'HashRef',
                           };
                       } );
 has instances    => ( is => 'rw', isa => 'ArrayRef' );
+has _owner_pid   => ( is => 'ro', isa => 'Int', default => sub { $$ } );
 
 sub prepare {
     my ($self) = @_;
 
-    my @instances = map {
-        $self->_launch_instance;
-    } (1 .. $self->jobs);
+    my @instances = Test::mysqld->start_mysqlds($self->jobs, my_cnf => $self->my_cnf);
     $self->instances( \@instances );
+    if ($self->preparer) {
+        $self->preparer->($_) for @instances;
+    }
 
     $self->cache->clear;
     $self->cache->set( dsns => {
         map { $_->dsn => 0 } @instances
     });
 }
 
-sub _launch_instance {
-    my ($self) = @_;
-
-    # auto start
-    my $mysqld = Test::mysqld->new( my_cnf => $self->my_cnf )
-        or die $Test::mysqld::errstr;
-
-    # user code to prepare database before test
-    $self->preparer->( $mysqld )
-        if $self->preparer;
-
-    return $mysqld;
-}
-
 sub alloc {
     my ($self) = @_;
 
@@ -115,6 +103,12 @@ sub _pid_lives {
     return scalar @lines;
 }
 
+sub DESTROY {
+    my $self = shift;
+    Test::mysqld->stop_mysqlds(@{$self->instances})
+            if $self->instances && $$ == $self->_owner_pid;
+}
+
 1;
 
 __END__