File Coverage

blib/lib/CA/WAAE.pm

Criterion	Covered	Total	%
statement	9	65	13.8
branch	0	26	0.0
condition	0	8	0.0
subroutine	3	8	37.5
pod	4	4	100.0
total	16	111	14.4

#
# CA::WAAE - Perl Interface to CA's AutoSys job control.
#
# Original CA::AutoSys code:
# Copyright (c) 2007 Sinisa Susnjar
# See LICENSE for terms of distribution.
#
# This library is free software; you can redistribute it and/or
# modify it under the terms of the GNU Lesser General Public
# License as published by the Free Software Foundation; either
# version 2.1 of the License, or (at your option) any later version.
#
# This library is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
# Lesser General Public License for more details.
#
# You should have received a copy of the GNU Lesser General Public
# License along with this library; if not, write to the Free Software
# Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
#

package CA::WAAE;

require CA::WAAE::Job;

use strict;
use warnings;
use DBI;

our $VERSION = '0.03';

sub new {
    my $self  = {};
    my $class = shift();

    my %args = @_;
    for my $attr (qw(dsn user password dbh db_type table_prefix schema)) {
        $self->{$attr} = $args{$attr};
    }

    if ( !$self->{dbh} ) {
        die "no dbh/dsn given in new()" if !$self->{dsn};
        $self->{dbh}
            = DBI->connect( $self->{dsn}, $self->{user}, $self->{password},
            { PrintError => 0, RaiseError => 1 } );
    }

    my $db_type = $self->{dbh}{Driver}{Name};
    if ( $db_type eq 'Oracle' ) {

        # Default and untaint schema/table_prefix
        $self->{schema} ||= 'aedbadmin';
        $self->{schema} =~ /(\w+)/;
        $self->{schema} = $1;

        $self->{table_prefix} ||= 'ujo_';
        $self->{table_prefix} =~ /([\w.]+)/;
        $self->{table_prefix} = $1;

        $self->{dbh}->do("alter session set current_schema=$self->{schema}");
    }

    bless $self, $class;
    return $self;
}    # new()

sub _query {
    my $self   = shift;
    my $prefix = $self->{table_prefix} || '';
    my $query  = <
select  j.*, s.*, j2.job_name as box_name, m.name job_type_name
from    ${prefix}job j join ${prefix}job_status s
on      j.joid = s.joid
left outer join ${prefix}job j2
on      j.box_joid = j2.joid
left outer join ${prefix}meta_types m
on      j.job_type = m.type_id and m.sub_type = 'STRINGS'
SQL
    return $query;
}    # _query()

sub find_jobs {
    my $self     = shift();
    my $job_name = shift();

    $job_name =~ s/\*/%/g;
    my $op = ( $job_name =~ /[%?]/ ) ? 'like' : '=';

    my $query = $self->_query() . <
where j.job_name $op ?
order by j.joid
SQL
    my $sth = $self->{dbh}->prepare($query);
    $sth->execute($job_name);

    return CA::WAAE::JobList->new(
        parent           => $self->{parent},
        database_handle  => $self->{dbh},
        statement_handle => $sth,
        table_prefix     => $self->{table_prefix},
    );

}    # find_jobs()

sub job_list {
    my $self = shift;
    my $h    = $self->find_jobs(@_);
    my @list;
    while ( my $job = $h->next_job() ) {
        push @list, $job;
    }
    return wantarray ? @list : \@list;
}

sub send_event {
    my $self = shift();
    my ( $job_name, $event, $status, $event_time );
    if (@_) {
        my %args = @_;
        $job_name   = $args{job_name}   ? $args{job_name}   : '';
        $event      = $args{event}      ? $args{event}      : '';
        $status     = $args{status}     ? $args{status}     : '';
        $event_time = $args{event_time} ? $args{event_time} : '';
    }

    my $dbh     = $self->{dbh};
    my $db_type = $self->{db_type};

    $_ = $dbh->quote($_) for $job_name, $event, $status, $event_time;
    my $prefix = $self->{table_prefix} || '';
    my $sql
        = ( $db_type eq 'Oracle' )
        ? "BEGIN :rtn := ${prefix}sendevent( $event, $job_name, $status, '', $event_time ); END;"
        : qq( exec sendevent $event, $job_name, $status, '', $event_time, '' );
    my $sth = $dbh->prepare($sql);

    my $rc;
    $sth->bind_param_inout( ':rtn', \$rc, 128 ) if $db_type eq 'Oracle';
    $sth->execute();
    ($rc) = $sth->fetchrow_array() if $db_type ne 'Oracle';

    return $rc;
}    # send_event()

1;
__END__