File Coverage

blib/lib/DBIx/Foo/SimpleQuery.pm

Criterion	Covered	Total	%
statement	40	69	57.9
branch	12	26	46.1
condition	3	6	50.0
subroutine	8	13	61.5
pod	0	10	0.0
total	63	124	50.8

package DBIx::Foo::SimpleQuery;

use strict;

use Log::Any qw($log);

use Exporter;

our @ISA = qw(Exporter);
our @EXPORT = qw(selectrow selectrow_array selectrow_hashref selectall selectall_arrayref selectall_hashref dbh_do);

our $VERSION = '0.01';


sub selectrow
{
	my ($self, $sql, $opts, @args) = @_;

	nice_params(\$opts, \@args) if scalar @_ > 2;

	my $row = $self->dbh->selectrow_hashref($sql, $opts, @args);

	log_query($self->dbh, $sql, \@args);

	return $row;
}

sub selectrow_hashref
{
	my ($self, $sql, $opts, @args) = @_;

	nice_params(\$opts, \@args) if scalar @_ > 2;

	my $row = $self->dbh->selectrow_hashref($sql, $opts, @args);

	log_query($self->dbh, $sql, \@args);

	return $row;
}

sub selectrow_array
{
	my ($self, $sql, $opts, @args) = @_;

	nice_params(\$opts, \@args) if scalar @_ > 2;

	my @row = $self->dbh->selectrow_array($sql, $opts, @args);

	log_query($self->dbh, $sql, \@args);

	return $row[0] if scalar @row == 1; # for compatibility

	return @row;
}

sub selectall
{
	my ($self, $sql, @args) = @_;

	my $opts = { Slice => {} };

	my $rows = $self->dbh->selectall_arrayref($sql, $opts, @args);

	log_query($self->dbh, $sql, \@args);

	return $rows;
}

sub selectall_arrayref
{
	my ($self, $sql, $opts, @args) = @_;

	nice_params(\$opts, \@args) if scalar @_ > 2;

	my $rows = $self->dbh->selectall_arrayref($sql, $opts, @args);

	log_query($self->dbh, $sql, \@args);

	return $rows;
}

sub selectall_hashref
{
	my ($self, $sql, $key_field, $opts, @args) = @_;

	nice_params(\$opts, \@args) if scalar @_ > 3;

	my $rows = $self->dbh->selectall_hashref($sql, $key_field, $opts, @args);

	log_query($self->dbh, $sql, \@args);

	return $rows;
}

sub dbh_do
{
	my ($self, $sql, $opts, @args) = @_;

	nice_params(\$opts, \@args) if scalar @_ > 2;

	# MSSQL insert requires extra SCOPE_IDENTITY() call to give inserted value - current best solution MT (only way I can make it work...)
	if ($self->dbh->get_info(17) eq 'Microsoft SQL Server' && $sql =~ /^insert/i) {

		return mssql_insert($self->dbh, $sql, $opts, @args);
	}

	my $result = $self->dbh->do($sql, $opts, @args);

	log_query($self->dbh, $sql, \@args);

	if ($result && $sql =~ /^insert into (\w+)/i) {

		if (my $newid = $self->dbh->last_insert_id(undef, undef, $1, undef)) {

			$log->debug("Got insertid : $newid");

			return $newid;
		}
		else {
			return 1; # insert ok, but no insertid (not an auto inc)
		}
	}
	else {

		return $result;
	}
}

sub mssql_insert
{
	my ($dbh, $sql, $opts, @args) = @_;

	$sql .= ';' unless $sql =~ /;\s*/;
	$sql .= "select SCOPE_IDENTITY();";

	my $newid = $dbh->selectrow_array($sql, $opts, @args);

	log_query($dbh, $sql, \@args);

	return $newid;
}

sub log_query
{
	my ($dbh, $sql, $args) = @_;

	# use the 'caller' function name to work out context
	my $caller = ( caller(2) )[3];

	if ($dbh->err) {

		$log->error($dbh->errstr . " - $sql (" . join(",", @$args) . ") called by $caller");

	} else {

		$log->debug("$sql (" . join(",", @$args) . ") called by $caller");
	}
}

sub nice_params
{
	my ($opts_ref, $args_ref) = @_;

	my $opts = $$opts_ref;

	#return unless defined $opts;

	unless (ref($opts) eq 'HASH') { #allow $opts hashref to be omitted

		unshift @$args_ref, $opts;
		$$opts_ref = {};

		$opts_ref = \$opts;
	}
}

1;