File Coverage

blib/lib/DBIx/Sunny/Util.pm

Criterion	Covered	Total	%
statement	35	45	77.7
branch	6	10	60.0
condition	4	12	33.3
subroutine	7	8	87.5
pod	0	2	0.0
total	52	77	67.5

package DBIx::Sunny::Util;

use strict;
use warnings;

use Exporter 'import';
use Scalar::Util qw/blessed/;
use SQL::NamedPlaceholder 0.10;
use Carp qw/croak/;

our @EXPORT_OK = qw/bind_and_execute expand_placeholder/;

sub bind_and_execute {
    my ($sth, @bind) = @_;
    my $i = 0;
    for my $bind ( @bind ) {
        if ( blessed($bind) && $bind->can('value_ref') && $bind->can('type') ) {
            # If $bind is an SQL::Maker::SQLType or compatible object, use its type info.
            $sth->bind_param(++$i, ${ $bind->value_ref }, $bind->type);
        } else {
            $sth->bind_param(++$i, $bind);
        }
    }
    return $sth->execute;
}

sub expand_placeholder {
    my ($query, @bind) = @_;

    return if ! defined $query;
    if (@bind == 1 && ref $bind[0] eq 'HASH') {
        ($query, my $bind_param) = SQL::NamedPlaceholder::bind_named($query, $bind[0]);
        return $query, @$bind_param;
    }

    my @bind_param;
    my $orig_num_binds = @bind;
    my $num_bounds = 0;
    $query =~ s{\?}{
                my $bind = shift @bind;
                $num_bounds++;
                if (ref($bind) && ref($bind) eq 'ARRAY') {
                        push @bind_param, @$bind;
                        join ',', ('?') x @$bind;
                } else {
                        push @bind_param, $bind;
                        '?';
                }
        }ge;

    if ($num_bounds != $orig_num_binds) {
        croak "Num of binds doesn't match. expected = $num_bounds, but passed $orig_num_binds";
    }

    return ( $query, @bind_param );
}

1