1 min
Junco Code - Db.pm

package Db;

use strict;
use DBI;

sub new
{
    my ($pkg, $sid, $user, $pwd) = @_;

    my $self = {
        DBH    => undef,
        STH    => undef,
        ROW    => undef,
        ERR    => 0,
        ERRSTR => undef
    };

    $self->{DBH} = DBI->connect("dbi:mysql:$sid", $user, $pwd, {
#    $self->{DBH} = DBI->connect("dbi:mysql:database=$sid;host=parula", $user, $pwd, {
        PrintError => 0,
        RaiseError => 0
    } ) ;
    
    if ( $DBI::err ) {
        $self->{ERR} = 1;
        $self->{ERRSTR} = $DBI::errstr;
    }

    $self->{DBH}->{LongReadLen} = 512 * 1024;

    bless($self, $pkg);

    return $self;
}

sub err
{
    my $self= shift;
    return $self->{ERR};
}

sub quote
{
    my $self= shift;
    my $str = shift;
    return $self->{DBH}->quote($str);

}

sub errstr
{
    my $self= shift;
    return $self->{ERRSTR};
}

sub execute
{
    my $self = shift;
    my $sql = shift;

    $self->{ERR} = 0;
    $self->{STH} = $self->{DBH}->prepare($sql);
    if ( $DBI::err ) {
        $self->{ERR} = 1;
        $self->{ERRSTR} = $DBI::errstr;
        return;
    }

    $self->{STH}->execute(); 
    if ( $DBI::err ) {
        $self->{ERR} = 1;
        $self->{ERRSTR} = $DBI::errstr;
        return;
    }

    # be careful of mysql versions. old was {insertid}
    return $self->{STH}->{mysql_insertid};
}

sub insertid
{
    my $self = shift;
    return $self->{STH}->{insertid};
}

sub disconnect
{
    my $self = shift;

    $self->{ERR} = 0;
    $self->{STH}->finish; 

    $self->{DBH}->disconnect();
    if ( $DBI::err ) {
        $self->{ERR} = 1;
        $self->{ERRSTR} = $DBI::errstr;
    }
}

sub fetchrow
{

    my $self = shift;
    $self->{ERR} = 0;
    $self->{ROW} = $self->{STH}->fetchrow_hashref;

    if ( $DBI::err ) {
        $self->{ERR} = 1;
        $self->{ERRSTR} = $DBI::errstr;
        return 0;
    }

    return $self->{ROW} ? 1 : 0 ;

}

sub gethashes
{
    my $self      = shift;
    my $sql       = shift;

    $self->{ERR} = 0;
    $self->execute($sql);
    if ( $DBI::err ) {
        return undef;
    }

    my @records;

    while (my $ref = $self->{STH}->fetchrow_hashref)
    {
        if ( $DBI::err ) {
            $self->{ERR} = 1;
            $self->{ERRSTR} = $DBI::errstr;
            return undef;
        }

        push @records, $ref;
    }
    return @records;
}

sub getcol
{
    my $self = shift;
    my $col = shift;

    return $self->{ROW}->{$col};
}

sub DESTROY
{
    my $self = shift;

    $self->{DBH} = undef;
    $self->{STH} = undef;
}

#juncocode

1;
From JR's : articles
319 words - 2647 chars - 1 min read
created on Apr 08, 2013 at 06:04:36 pm
updated on Jul 30, 2013 at 03:59:03 pm
import date 2013-08-12 21:49:38 - #
source - versions - backlinks