/[A3C]/lib/A3C/SQL.pm
This is repository of my old source code which isn't updated any more. Go to git.rot13.org for current projects!
ViewVC logotype

Contents of /lib/A3C/SQL.pm

Parent Directory Parent Directory | Revision Log Revision Log


Revision 220 - (show annotations)
Sun Jun 22 14:55:55 2008 UTC (11 years, 9 months ago) by dpavlin
File size: 2526 byte(s)
display duration of SQL query
1 package A3C::SQL;
2
3 use strict;
4 use warnings;
5
6 use base qw(Jifty::Object Class::Accessor::Fast);
7 __PACKAGE__->mk_accessors( qw(query arguments dbh encoding duration) );
8
9 use Data::Dump qw/dump/;
10 use Time::HiRes qw/time/;
11
12 =head1 NAME
13
14 A3C::SQL
15
16 =head1 DESCRIPTION
17
18 Issue SQL queries
19
20 =head1 METHODS
21
22 =head2 new
23
24 my $sql = A3C::SQL->new({ query => 'select now()' });
25
26 As a alternative, if you don't want to use Jifty's database handle,
27 specify it like this:
28
29 my $sql = A3C::SQL->new({
30 query => 'select now()',
31 dbh => $my_dbh,
32 encoding => 'UTF-8',
33 });
34
35 Mungling with C<encoding> is rearly needed, especially if using recent C<DBD::Pg> as driver.
36
37 =head2 sth
38
39 Execute query and return statement handle. Ususally you don't have to call this manually.
40
41 =cut
42
43 sub sth {
44 my $self = shift;
45 if ( ! $self->{_sth} ) {
46 my $dbh = $self->dbh || Jifty->handle->dbh;
47 my $sth = $dbh->prepare( $self->query ) or $dbh->errstr;
48 my $t = time();
49 if ( $self->arguments ) {
50 Jifty->log->debug( $self->sql . ' arguments: ' . dump( $self->arguments ) );
51 $sth->execute( $self->arguments ) or die $dbh->errstr;
52 } else {
53 $sth->execute or die $dbh->errstr;
54 }
55 $self->duration( time() - $t );
56 $self->{_sth} = $sth;
57 }
58
59 return $self->{_sth};
60 }
61
62 =head2 next
63
64 while ( my $row = $sql->next ) {
65 print $row->now;
66 }
67
68 =cut
69
70 sub next {
71 my $self = shift;
72 my $row = $self->sth->fetchrow_hashref;
73 return unless defined $row;
74 return A3C::SQL::row->new( $row, $self->encoding );
75 }
76
77 =head2 count
78
79 print $sql->count;
80
81 =cut
82
83 sub count {
84 my $self = shift;
85 return $self->sth->rows;
86 }
87
88 =head1 HELPERS
89
90 This helpers are accessor to L<DBI>
91
92 =head2 _column_names
93
94 my @columns = $sql->_column_names;
95
96 =cut
97
98 sub _column_names {
99 my $self = shift;
100 return @{ $self->sth->{NAME} };
101 }
102
103 package A3C::SQL::row;
104
105 use Encode qw/decode/;
106 use Data::Dump qw/dump/;
107 use base qw/Jifty::Object/;
108
109 our $AUTOLOAD;
110
111 sub new {
112 my $that = shift;
113 my $class = ref($that) || $that;
114 my $self = shift;
115 bless $self, $class;
116 $self->{__encoding} = shift || 'UTF-8';
117 return $self;
118 }
119
120 sub AUTOLOAD {
121 my $self = shift;
122 my $type = ref($self) or die "$self is not an object";
123 my $name = $AUTOLOAD;
124 $name =~ s/.*://;
125 my $v = $self->{$name};
126 Jifty->log->error("SQL: $name doesn't exist") unless defined $v;
127 if ( ! Encode::is_utf8( $v ) ) {
128 eval { $v = decode( $self->{__encoding}, $self->{$name} ) };
129 if ( $@ ) {
130 warn "## column $name can't decode ",dump( $self->{$name} );
131 $v = $self->{$name};
132 }
133 }
134 return $v;
135 }
136
137 sub DESTROY {}
138
139 1;

  ViewVC Help
Powered by ViewVC 1.1.26