1
#############################################################################
3
# Apache::Session::Store::DBI
4
# A base class for the MySQL, Postgres, and other DBI stores
5
# Copyright(c) 2000, 2004 Jeffrey William Baker (jwbaker@acm.org)
6
# Distribute under the Perl License
8
############################################################################
10
package Apache::Session::Store::DBI;
15
use vars qw($VERSION);
19
$Apache::Session::Store::DBI::TableName = "sessions";
24
return bless { table_name => $Apache::Session::Store::DBI::TableName }, $class;
31
$self->connection($session);
33
local $self->{dbh}->{RaiseError} = 1;
35
if (!defined $self->{insert_sth}) {
37
$self->{dbh}->prepare_cached(qq{
38
INSERT INTO $self->{'table_name'} (id, a_session) VALUES (?,?)});
41
$self->{insert_sth}->bind_param(1, $session->{data}->{_session_id});
42
$self->{insert_sth}->bind_param(2, $session->{serialized});
44
$self->{insert_sth}->execute;
46
$self->{insert_sth}->finish;
54
$self->connection($session);
56
local $self->{dbh}->{RaiseError} = 1;
58
if (!defined $self->{update_sth}) {
60
$self->{dbh}->prepare_cached(qq{
61
UPDATE $self->{'table_name'} SET a_session = ? WHERE id = ?});
64
$self->{update_sth}->bind_param(1, $session->{serialized});
65
$self->{update_sth}->bind_param(2, $session->{data}->{_session_id});
67
$self->{update_sth}->execute;
69
$self->{update_sth}->finish;
76
$self->connection($session);
78
local $self->{dbh}->{RaiseError} = 1;
80
if (!defined $self->{materialize_sth}) {
81
$self->{materialize_sth} =
82
$self->{dbh}->prepare_cached(qq{
83
SELECT a_session FROM $self->{'table_name'} WHERE id = ?});
86
$self->{materialize_sth}->bind_param(1, $session->{data}->{_session_id});
88
$self->{materialize_sth}->execute;
90
my $results = $self->{materialize_sth}->fetchrow_arrayref;
92
if (!(defined $results)) {
93
die "Object does not exist in the data store";
96
$self->{materialize_sth}->finish;
98
$session->{serialized} = $results->[0];
105
$self->connection($session);
107
local $self->{dbh}->{RaiseError} = 1;
109
if (!defined $self->{remove_sth}) {
110
$self->{remove_sth} =
111
$self->{dbh}->prepare_cached(qq{
112
DELETE FROM $self->{'table_name'} WHERE id = ?});
115
$self->{remove_sth}->bind_param(1, $session->{data}->{_session_id});
117
$self->{remove_sth}->execute;
118
$self->{remove_sth}->finish;
1
#############################################################################
3
# Apache::Session::Store::DBI
4
# A base class for the MySQL, Postgres, and other DBI stores
5
# Copyright(c) 2000, 2004 Jeffrey William Baker (jwbaker@acm.org)
6
# Distribute under the Perl License
8
############################################################################
10
package Apache::Session::Store::DBI;
15
use vars qw($VERSION);
19
$Apache::Session::Store::DBI::TableName = "sessions";
24
return bless { table_name => $Apache::Session::Store::DBI::TableName }, $class;
31
$self->connection($session);
33
local $self->{dbh}->{RaiseError} = 1;
35
if (!defined $self->{insert_sth}) {
37
$self->{dbh}->prepare_cached(qq{
38
INSERT INTO $self->{'table_name'} (id, a_session) VALUES (?,?)});
41
$self->{insert_sth}->bind_param(1, $session->{data}->{_session_id});
42
$self->{insert_sth}->bind_param(2, $session->{serialized});
44
$self->{insert_sth}->execute;
46
$self->{insert_sth}->finish;
54
$self->connection($session);
56
local $self->{dbh}->{RaiseError} = 1;
58
if (!defined $self->{update_sth}) {
60
$self->{dbh}->prepare_cached(qq{
61
UPDATE $self->{'table_name'} SET a_session = ? WHERE id = ?});
64
$self->{update_sth}->bind_param(1, $session->{serialized});
65
$self->{update_sth}->bind_param(2, $session->{data}->{_session_id});
67
$self->{update_sth}->execute;
69
$self->{update_sth}->finish;
76
$self->connection($session);
78
local $self->{dbh}->{RaiseError} = 1;
80
if (!defined $self->{materialize_sth}) {
81
$self->{materialize_sth} =
82
$self->{dbh}->prepare_cached(qq{
83
SELECT a_session FROM $self->{'table_name'} WHERE id = ?});
86
$self->{materialize_sth}->bind_param(1, $session->{data}->{_session_id});
88
$self->{materialize_sth}->execute;
90
my $results = $self->{materialize_sth}->fetchrow_arrayref;
92
if (!(defined $results)) {
93
die "Object does not exist in the data store";
96
$self->{materialize_sth}->finish;
98
$session->{serialized} = $results->[0];
105
$self->connection($session);
107
local $self->{dbh}->{RaiseError} = 1;
109
if (!defined $self->{remove_sth}) {
110
$self->{remove_sth} =
111
$self->{dbh}->prepare_cached(qq{
112
DELETE FROM $self->{'table_name'} WHERE id = ?});
115
$self->{remove_sth}->bind_param(1, $session->{data}->{_session_id});
117
$self->{remove_sth}->execute;
118
$self->{remove_sth}->finish;