File Coverage

blib/lib/CGI/Session/Driver/oracle.pm

Criterion	Covered	Total	%
statement	9	36	25.0
branch	0	26	0.0
condition	0	6	0.0
subroutine	3	7	42.8
pod	2	3	66.6
total	14	78	17.9

package CGI::Session::Driver::oracle;

use strict;
use Carp;
use CGI::Session::Driver::DBI;

@CGI::Session::Driver::oracle::ISA       = qw( CGI::Session::Driver::DBI );
$CGI::Session::Driver::oracle::VERSION   = '1.05';

# -----------------------------------------------

sub init
{
	my($self) = @_;

	if ($$self{'DataSource'} && ($$self{'DataSource'} !~ /^dbi:Oracle/) )
	{
		$$self{'DataSource'} = "dbi:Oracle:$$self{'DataSource'}";
	}

	return $self -> SUPER::init();

}	# End of init.

# -----------------------------------------------

sub store
{
	my($self, $sid, $datastr) = @_;

	Carp::croak "store(): usage error" if (! ($sid && $datastr) );

	my($dbh) = $$self{'Handle'};
	my($sth) = $dbh -> prepare("select $self->{IdColName} from " . $self -> table_name() . ' where id=?');

	if (! defined $sth)
	{
		return $self -> set_error("store(): \$sth->prepare failed with message " . $dbh -> errstr() );
    }

	$sth -> execute($sid) or return $self -> set_error("store(): \$sth->execute failed with message " . $dbh->errstr() );

	if ($sth->fetchrow_array() )
	{
		_run_sql($dbh, 'update ' . $self -> table_name() . " set $self->{DataColName}=? where $self->{IdColName}=?", $datastr, $sid)
			or return $self -> set_error("store(): serialize to db failed " . $dbh->errstr() );
	}
	else
	{
		_run_sql($dbh, 'insert into ' . $self -> table_name() . " ($self->{DataColName}, $self->{IdColName}) values(?, ?)", $datastr, $sid)
			or return $self -> set_error("store(): serialize to db failed " . $dbh->errstr() );
	}

	return 1;

}	# End of store.

# -----------------------------------------------

sub _run_sql
{
	my($dbh, $sql, $datastr, $sid) = @_;

	eval
	{
		my($sth) = $dbh -> prepare($sql) or return 0;

		$sth -> bind_param(1, $datastr) or return 0;
		$sth -> bind_param(2, $sid) or return 0;
		$sth -> execute() or return 0;
	};

	return 0 if $@;
	return 1;

}	# End of _run_sql.

# -----------------------------------------------
# If the table name hasn't been defined yet, check this location for 3.x compatibility.

sub table_name
{
	my($self) = shift;

	if (! defined $$self{'TableName'})
	{
		$$self{'TableName'} = $CGI::Session::Oracle::TABLE_NAME;
	}

	return  $self -> SUPER::table_name(@_);

}	# End of table_name.

# -----------------------------------------------

1;

__END__