ViewVC Help
View File | Revision Log | Show Annotations | Download File
/cvs/PApp-SQL/SQL.pm
(Generate patch)

Comparing PApp-SQL/SQL.pm (file contents):
Revision 1.12 by root, Mon Feb 12 17:47:10 2001 UTC vs.
Revision 1.22 by root, Sun Apr 7 16:22:56 2002 UTC

1=head1 NAME 1=head1 NAME
2 2
3PApp::SQL - absolutely easy yet fast and powerful sql access 3PApp::SQL - absolutely easy yet fast and powerful sql access.
4 4
5=head1 SYNOPSIS 5=head1 SYNOPSIS
6 6
7 use PApp::SQL; 7 use PApp::SQL;
8 8
13 my $st = sql_insertid 13 my $st = sql_insertid
14 sql_exec "insert into ... values (?, ?)", $v1, $v2; 14 sql_exec "insert into ... values (?, ?)", $v1, $v2;
15 my $a = sql_fetch "select a from ..."; 15 my $a = sql_fetch "select a from ...";
16 sql_fetch \my($a, $b), "select a,b ..."; 16 sql_fetch \my($a, $b), "select a,b ...";
17 17
18 sql_exists "name from table where name like 'a%'" 18 sql_exists "table where name like 'a%'"
19 or die "a* required but not existent"; 19 or die "a* required but not existent";
20 20
21 my $db = new PApp::SQL::Database "", "DBI:mysql:test", "user", "pass"; 21 my $db = new PApp::SQL::Database "", "DBI:mysql:test", "user", "pass";
22 local $PApp::SQL::DBH = $db->checked_dbh; # does 'ping' 22 local $PApp::SQL::DBH = $db->checked_dbh; # does 'ping'
23 23
27 27
28This module provides you with easy-to-use functions to execute sql 28This module provides you with easy-to-use functions to execute sql
29commands (using DBI). Despite being easy to use, they are also quite 29commands (using DBI). Despite being easy to use, they are also quite
30efficient and allow you to write faster programs in less lines of code. It 30efficient and allow you to write faster programs in less lines of code. It
31should work with anything from perl-5.004_01 onwards, but I only support 31should work with anything from perl-5.004_01 onwards, but I only support
325.005+. 325.005+. UTF8 handling (the C<sql_u*> family of functions) will only be
33effective with perl version 5.006 and beyond.
33 34
34If the descriptions here seem terse or if you always wanted to know 35If the descriptions here seem terse or if you always wanted to know
35what PApp is then have a look at the PApp module which uses this module 36what PApp is then have a look at the PApp module which uses this module
36extensively but also provides you with a lot more gimmicks to play around 37extensively but also provides you with a lot more gimmicks to play around
37with to help you create cool applications ;) 38with to help you create cool applications ;)
43use DBI (); 44use DBI ();
44 45
45BEGIN { 46BEGIN {
46 use base qw(Exporter DynaLoader); 47 use base qw(Exporter DynaLoader);
47 48
48 $VERSION = 0.121; 49 $VERSION = 0.13;
49 @EXPORT = qw( 50 @EXPORT = qw(
50 sql_exec sql_fetch sql_fetchall sql_exists sql_insertid $sql_exec 51 sql_exec sql_fetch sql_fetchall sql_exists sql_insertid $sql_exec
52 sql_uexec sql_ufetch sql_ufetchall sql_uexists
51 ); 53 );
52 @EXPORT_OK = qw( 54 @EXPORT_OK = qw(
53 connect_cached 55 connect_cached
54 ); 56 );
55 57
67=over 4 69=over 4
68 70
69=item $sql_exec 71=item $sql_exec
70 72
71Since the C<sql_exec> family of functions return a statement handle there 73Since the C<sql_exec> family of functions return a statement handle there
72must eb another way to test the return value of the C<execute> call. This 74must be another way to test the return value of the C<execute> call. This
73global variable contains the result of the most recent call to C<execute> 75global variable contains the result of the most recent call to C<execute>
74done by this module. 76done by this module.
75 77
76=item $PApp::SQL::DBH 78=item $PApp::SQL::DBH
77 79
109__LINE__ work fine as well). 111__LINE__ work fine as well).
110 112
111The reason C<$id> is necessary is that you might specify special connect 113The reason C<$id> is necessary is that you might specify special connect
112arguments or special flags, or you might want to configure your $DBH 114arguments or special flags, or you might want to configure your $DBH
113differently than maybe other applications requesting the same database 115differently than maybe other applications requesting the same database
114connection. If none of this is becessary for your application you can 116connection. If none of this is necessary for your application you can
115leave $id empty (i.e. ""). 117leave C<$id> empty (i.e. "").
116 118
117If specified, C<$connect> is a callback (e.g. a coderef) that will be 119If specified, C<$connect> is a callback (e.g. a coderef) that will be
118called each time a new connection is being established, with the new 120called each time a new connection is being established, with the new
119C<$dbh> as first argument. 121C<$dbh> as first argument.
120 122
121Examples: 123Examples:
122 124
123 # try your luck opening the papp database without access info 125 # try your luck opening the papp database without access info
124 $dbh = connect_cached __FILE__, "DBI:mysql:papp"; 126 $dbh = connect_cached __FILE__, "DBI:mysql:papp";
127
128Mysql-specific behaviour: The default setting of
129C<mysql_client_found_rows> is TRUE, you can overwrite this, though.
125 130
126=cut 131=cut
127 132
128sub connect_cached { 133sub connect_cached {
129 my ($id, $dsn, $user, $pass, $flags, $connect) = @_; 134 my ($id, $dsn, $user, $pass, $flags, $connect) = @_;
130 # the following line is duplicated in PApp::SQL::Database::new 135 # the following line is duplicated in PApp::SQL::Database::new
131 $id = "$id\0$dsn\0$user\0$pass"; 136 $id = "$id\0$dsn\0$user\0$pass";
132 unless ($dbcache{$id} && $dbcache{$id}->ping) { 137 unless ($dbcache{$id} && $dbcache{$id}->ping) {
133 #warn "connecting to ($dsn|$user|$pass|$flags)\n";#d#
134 # first, nuke our statement cache (sooory ;) 138 # first, nuke our statement cache (sooory ;)
135 cachesize cachesize 0; 139 cachesize cachesize 0;
140
141 # then make mysql behave more standardly by default
142 $dsn =~ /^[Dd][Bb][Ii]:mysql:/
143 and $dsn !~ /;mysql_client_found_rows/
144 and $dsn .= ";mysql_client_found_rows=1";
145
136 # then connect anew 146 # then connect anew
137 $dbcache{$id} = 147 $dbcache{$id} =
138 eval { DBI->connect($dsn, $user, $pass, $flags) } 148 eval { DBI->connect($dsn, $user, $pass, $flags) }
139 || eval { DBI->connect($dsn, $user, $pass, $flags) } 149 || eval { DBI->connect($dsn, $user, $pass, $flags) }
140 || die "unable to connect to database $dsn: $DBI::errstr\n"; 150 || die "unable to connect to database $dsn: $DBI::errstr\n";
143 $dbcache{$id}; 153 $dbcache{$id};
144} 154}
145 155
146=item $sth = sql_exec [dbh,] [bind-vals...,] "sql-statement", [arguments...] 156=item $sth = sql_exec [dbh,] [bind-vals...,] "sql-statement", [arguments...]
147 157
158=item $sth = sql_uexec <see sql_exec>
159
148C<sql_exec> is the most important and most-used function in this module. 160C<sql_exec> is the most important and most-used function in this module.
149 161
150Runs the given sql command with the given parameters and returns the 162Runs the given sql command with the given parameters and returns the
151statement handle. The command and the statement handle will be cached 163statement handle. The command and the statement handle will be cached
152(with the database handle and the sql string as key), so prepare will be 164(with the database handle and the sql string as key), so prepare will be
163The actual return value from the C<$sth->execute> call is stored in the 175The actual return value from the C<$sth->execute> call is stored in the
164package-global (and exported) variable C<$sql_exec>. 176package-global (and exported) variable C<$sql_exec>.
165 177
166If any error occurs C<sql_exec> will throw an exception. 178If any error occurs C<sql_exec> will throw an exception.
167 179
180C<sql_uexec> is similar to C<sql_exec> but upgrades all input arguments to
181utf8 before calling the C<execute> method.
182
168Examples: 183Examples:
169 184
170 # easy one 185 # easy one
171 my $st = sql_exec "select name, id from table where id = ?", $id; 186 my $st = sql_exec "select name, id from table where id = ?", $id;
172 while (my ($name, $id) = $st->fetchrow_array) { ... }; 187 while (my ($name, $id) = $st->fetchrow_array) { ... };
181 sql_exec $dbh, "update file set name = ?", "oops.txt"; 196 sql_exec $dbh, "update file set name = ?", "oops.txt";
182 197
183 198
184=item sql_fetch <see sql_exec> 199=item sql_fetch <see sql_exec>
185 200
201=item sql_ufetch <see sql_uexec>
202
186Execute a sql-statement and fetch the first row of results. Depending on 203Execute an sql-statement and fetch the first row of results. Depending on
187the caller context the row will be returned as a list (array context), or 204the caller context the row will be returned as a list (array context), or
188just the first columns. In table form: 205just the first columns. In table form:
189 206
190 CONTEXT RESULT 207 CONTEXT RESULT
191 void () 208 void ()
202 219
203 my($name, $amount) = sql_fetch "select ...", args... 220 my($name, $amount) = sql_fetch "select ...", args...
204 221
205... and it's still quite fast unless you fetch large amounts of data. 222... and it's still quite fast unless you fetch large amounts of data.
206 223
224C<sql_ufetch> is similar to C<sql_fetch> but upgrades all input values to
225utf8 and forces all result values to utf8 (this does I<not> include result
226parameters, only return values. Using bind variables in cinjunction with
227sql_u* functions results in undefined behaviour).
228
207=item sql_fetchall <see sql_exec> 229=item sql_fetchall <see sql_exec>
230
231=item sql_ufetchall <see sql_uexec>
208 232
209Similarly to C<sql_fetch>, but all result rows will be fetched (this is 233Similarly to C<sql_fetch>, but all result rows will be fetched (this is
210of course inefficient for large results!). The context is ignored (only 234of course inefficient for large results!). The context is ignored (only
211list context makes sense), but the result still depends on the number of 235list context makes sense), but the result still depends on the number of
212columns in the result: 236columns in the result:
224 248
225 for (sql_fetchall "select name, age, place from user") { 249 for (sql_fetchall "select name, age, place from user") {
226 my ($name, $age, $place) = @$_; 250 my ($name, $age, $place) = @$_;
227 } 251 }
228 252
253C<sql_ufetchall> is similar to C<sql_fetchall> but upgrades all input
254values to utf8 and forces all result values to utf8 (see the caveats in
255the description of C<sql_ufetch>, though).
256
229=item sql_exists "<table> where ...", args... 257=item sql_exists "<table_references> where <where_condition>...", args...
258
259=item sql_uexists <see sql_exists>
230 260
231Check wether the result of the sql-statement "select xxx from 261Check wether the result of the sql-statement "select xxx from
232$first_argument" would be empty or not (that is, imagine the string 262$first_argument" would be empty or not (that is, imagine the string
233"select from" were prepended to your statement (it isn't)). Should work 263"select * from" were prepended to your statement (it isn't)). Should work
234with every database but can be quite slow, except on mysql, where this 264with every database but can be quite slow, except on mysql, where this
235should be quite fast. 265should be quite fast.
266
267C<sql_uexists> is similar to C<sql_exists> but upgrades all parameters to
268utf8.
236 269
237Examples: 270Examples:
238 271
239 print "user 7 exists!\n" 272 print "user 7 exists!\n"
240 if sql_exists "user where id = ?", 7; 273 if sql_exists "user where id = ?", 7;
314 347
315package PApp::SQL::Database; 348package PApp::SQL::Database;
316 349
317=head2 THE DATABASE CLASS 350=head2 THE DATABASE CLASS
318 351
319Again (sigh) the problem of persistency. What do you do when you have to serialize on object 352Again (sigh) the problem of persistency. What do you do when you have
320that contains (or should contain) a database handle? Short answer: you don't. Long answer: 353to serialize on object that contains (or should contain) a database
354handle? Short answer: you don't. Long answer: you can embed the necessary
321you can embed the necessary information to recreate the dbh when needed. 355information to recreate the dbh when needed.
322 356
323The C<PApp::SQL::Database> class does that, in a relatively efficient 357The C<PApp::SQL::Database> class does that, in a relatively efficient
324fashion: the overhead is currently a single method call per access (you 358fashion: the overhead is currently a single method call per access (you
325can cache the real dbh if you want). 359can cache the real dbh if you want).
326 360
366 400
367=item $db->dsn 401=item $db->dsn
368 402
369Return the DSN (L<DBI>) fo the database object (e.g. for error messages). 403Return the DSN (L<DBI>) fo the database object (e.g. for error messages).
370 404
405=item $db->login
406
407Return the login name.
408
409=item $db->password
410
411Return the password (emphasizing the fact that the apssword is stored plaintext ;)
412
371=cut 413=cut
372 414
373sub dsn($) { 415sub dsn($) {
374 my $self = shift; 416 my $self = shift;
375 (split /\x00/, $self->[0])[1]; 417 (split /\x00/, $self->[0])[1];
376} 418}
377 419
420sub login($) {
421 my $self = shift;
422 (split /\x00/, $self->[0])[2];
423}
424
425sub password($) {
426 my $self = shift;
427 (split /\x00/, $self->[0])[3];
428}
429
378=back 430=back
379 431
380=cut 432=cut
381 433
3821; 4341;

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines