/ 
DBIx-Wrapper-0.23
River stage one • 1 direct dependent • 1 total dependent
/ DBIx::Wrapper::Request

NAME

DBIx::Wrapper::Request - Request object for database operations

SYNOPSIS

Objects of the class are created by DBIx::Wrapper objects and
passed to hooks.  You should never have to create one yourself.

my $db = $req->getDbObj;

my $query = $req->getQuery;
$req->setQuery($query);

my $exec_args = $req->getExecArgs;
$req->setExecArgs(\@args);

my $rv = $req->getExecReturnValue;
$req->setExecReturnValue($rv);

my $rv = $req->getReturnVal;
$req->setReturnVal($rv);

my $sth = $req->getStatementHandle;
$req->setStatementHandle($sth);

my $err_str = $req->getErrorStr;
$req->setErrorStr($err_str);

DESCRIPTION

DBIx::Wrapper::Request objects are used to encapsulate date
passed between DBIx::Wrapper methods at various stages of
executing a query.

METHODS

getDbObj()

Returns the DBIx::Wrapper object that created the Request object.

getQuery()

Returns the current query.

setQuery($query)

Sets the current query.

getExecArgs()

Returns a reference to the array of execute arguments passed to
the DBIx::Wrapper method currently executing.

setExecArgs(\@args);

Sets the current execute arguments.

getExecReturnValue()

Returns the current execute() return value.

setExecReturnValue($rv);

Sets the current execute() return value.

getReturnVal()

Gets the current return value (from a fetch).

setReturnVal($rv)

Sets the current return value (from a fetch).

getStatementHandle()

Get the current statement handle being used.

setStatementHandle($sth)

Set the current statement handle to use.

$req->getErrorStr()

Get the error string.

setErrorStr($err_str)

Set the error string.

EXAMPLES

##################################################
# Pre prepare hook

$db_obj->addPrePrepareHook(\&_db_pre_prepare_hook)

sub _db_pre_prepare_hook {
    my $self = shift;
    my $r = shift;
    my $query = $r->getQuery;
    
    if ($query =~ /^\s*(?:update|delete|insert|replace|create|drop|alter)/i) {
        my $db = $r->getDbObj;
        unless ($db->ping) {
            # db connection has gone away, so try to reconnect
            my $msg = "UI DataProvider pre-prepare: db ping failed, reconnecting to ";
            $msg .= $db->_getDataSource;
            print STDERR $msg . "\n";
            my $tries_left = 5;
            my $connected = 0;
            my $sleep_time = 0;
            while ($tries_left) {
                $sleep_time++;
                sleep $sleep_time;
                $tries_left--;
                $connected = $db->reconnect;
                last if $connected;
            }

            unless ($connected) {
                die "Couldn't reconnect to db after ping failure: dsn=" . $db->_getDataSource;
            }
        }
    }
                        
    return $r->OK;
}


##################################################
# Post execute hook

sub _db_post_exec_hook {
    my $self = shift;
    my $r = shift;

    my $exec_successful = $r->getExecReturnValue;
    unless ($exec_successful) {
        my $query = $r->getQuery;
        if ($r->getQuery =~ /^\s*(?:select|show)/i) {
            my $errstr = $r->getErrorStr;
            if ($errstr =~ /Lost connection to MySQL server during query/i) {
                my $db = $r->getDbObj;
                my $msg = "UI DataProvider post exec: lost connection to MySQL server ";
                $msg .= "during query, reconnecting to " . $db->_getDataSource;
                print STDERR $msg . "\n";
                my $tries_left = 5;
                my $connected = 0;
                my $sleep_time = 0;
                while ($tries_left) {
                    $sleep_time++;
                    sleep $sleep_time;
                    $tries_left--;
                    $connected = $db->reconnect;
                    last if $connected;
                }
                                  
                if ($connected) {
                    my $sth = $db->prepare_no_hooks($r->getQuery);
                    $r->setStatementHandle($sth);
                    my $exec_args = $r->getExecArgs;
                    my $rv = $sth->execute(@$exec_args);
                    $r->setExecReturnValue($rv);
                } else {
                    die "Couldn't reconnect to db after losing connection: dsn="
                        . $db->_getDataSource;
                }
            }
        }
    }
                      
    return $r->OK;
}

BUGS

AUTHOR

VERSION

$Id: Request.pm,v 1.6 2005/10/14 18:24:02 don Exp $