X-Git-Url: http://git.shadowcat.co.uk/gitweb/gitweb.cgi?a=blobdiff_plain;f=lib%2FDBIx%2FClass%2FStorage%2FDBI.pm;h=5a6d4d761f4566fc4c83ec611593ac7cddb26fa9;hb=1295943f3917a0c475b3fa999ee2038ae9e9fb56;hp=da3619cb87098e072944e8004233a01161ba90de;hpb=2e8345503896294f38eea58569c4ca4893e3d4c6;p=dbsrgits%2FDBIx-Class.git diff --git a/lib/DBIx/Class/Storage/DBI.pm b/lib/DBIx/Class/Storage/DBI.pm index da3619c..5a6d4d7 100644 --- a/lib/DBIx/Class/Storage/DBI.pm +++ b/lib/DBIx/Class/Storage/DBI.pm @@ -1359,6 +1359,45 @@ sub insert_bulk { # } map $data->[$_][$i], (1..$#$data)) == (@$data - 1); } + # check for bad data + my $bad_slice = sub { + my ($msg, $slice_idx) = @_; + $self->throw_exception(sprintf "%s for populate slice:\n%s", + $msg, + Data::Dumper::Concise::Dumper({ + map { $cols->[$_] => $data->[$slice_idx][$_] } (0 .. $#$cols) + }), + ); + }; + + for my $datum_idx (0..$#$data) { + my $datum = $data->[$datum_idx]; + + for my $col_idx (0..$#$cols) { + my $val = $datum->[$col_idx]; + my $sqla_bind = $colvalues{ $cols->[$col_idx] }; + my $is_literal_sql = (ref $sqla_bind) eq 'SCALAR'; + + if ($is_literal_sql) { + if (not ref $val) { + $bad_slice->('bind found where literal SQL expected', $datum_idx); + } + elsif ((my $reftype = ref $val) ne 'SCALAR') { + $bad_slice->("$reftype reference found where literal SQL expected", + $datum_idx); + } + elsif ($$val ne $$sqla_bind){ + $bad_slice->("inconsistent literal SQL value, expecting: '$$sqla_bind'", + $datum_idx); + } + } + elsif (my $reftype = ref $val) { + $bad_slice->("$reftype reference found where bind expected", + $datum_idx); + } + } + } + my ($sql, $bind) = $self->_prep_for_execute ( 'insert', undef, $source, [\%colvalues] );