view release on metacpan or  search on metacpan

lib/Amp/DbPoolClient.pm  view on Meta::CPAN

package Amp::DbPoolClient;
use Moo;
use Amp::Util::Strings;
use Try::Catch;
use Carp;
use Data::Dumper;
use REST::Client;
use Sys::Hostname;
use feature 'say';

BEGIN{
    $ENV{PERL_LWP_SSL_VERIFY_HOSTNAME} = 0;
}

has config => (is => 'rw', required => 1);
has host => (is => 'rw');
has url => (is => 'rw');
has instanceName => (is => 'rw');
has resultSet => (is => 'rw');
has payload => (is => 'rw', default => sub {{}});
has retries => (is => 'rw', default => 10);
has timeout => (is => 'rw', default => 30);
has retriesAttempted => (is => 'rw', default => 0);
has type => (is => 'rw', default => 'master');

sub getSqlRow {
    my $self = shift;
    my ($sql) = @_;
    my $results = $self->query($sql);
    if (defined $results) {
        return $results->[0];
    }
}

sub getSqlRows {
    my $self = shift;
    my ($sql) = @_;
    return $self->query($sql);
}

sub getSqlValue {
    my $self = shift;
    my ($sql) = @_;
    $self->payload->{getSqlValue} = 1;
    my $results = $self->query($sql);
    if (defined $results) {
        return $results->[0];
    }
}

sub getSqlValues {
    my $self = shift;
    my ($sql) = @_;
    $self->payload->{getSqlValues} = 1;
    my $results = $self->query($sql);
    if (defined $results) {
        return $results;
    }
}

sub getSqlRowHashref {
    my $self = shift;
    my ($sql) = @_;
    return $self->getSqlRow($sql);
}