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.8 by root, Mon Jan 22 10:53:36 2001 UTC vs.
Revision 1.17 by root, Sat Aug 11 02:46:16 2001 UTC

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 # to be written 8
9 my $st = sql_exec $DBH, "select ... where a = ?", $a;
10
11 local $DBH = <database handle>;
12 my $st = sql_exec \my($bind_a, $bind_b), "select a,b ...";
13 my $st = sql_insertid
14 sql_exec "insert into ... values (?, ?)", $v1, $v2;
15 my $a = sql_fetch "select a from ...";
16 sql_fetch \my($a, $b), "select a,b ...";
17
18 sql_exists "name from table where name like 'a%'"
19 or die "a* required but not existent";
20
21 my $db = new PApp::SQL::Database "", "DBI:mysql:test", "user", "pass";
22 local $PApp::SQL::DBH = $db->checked_dbh; # does 'ping'
23
24 sql_exec $db->dbh, "select ...";
9 25
10=head1 DESCRIPTION 26=head1 DESCRIPTION
11 27
12This module provides you with easy-to-use functions to execute sql 28This module provides you with easy-to-use functions to execute sql
13commands (using DBI). Despite being easy to use, they are also quite 29commands (using DBI). Despite being easy to use, they are also quite
14efficient and allow you to write faster programs in less lines of code. 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
325.005+. UTF8 handling (the C<sql_u*> family of functions) will only be
33effective with perl version 5.006 and beyond.
15 34
16=over 4 35If the descriptions here seem terse or if you always wanted to know
36what PApp is then have a look at the PApp module which uses this module
37extensively but also provides you with a lot more gimmicks to play around
38with to help you create cool applications ;)
17 39
18=cut 40=cut
19 41
20package PApp::SQL; 42package PApp::SQL;
21 43
22use DBI; 44use DBI ();
23
24#use PApp::Exception; # not yet used
25 45
26BEGIN { 46BEGIN {
27 use base Exporter; 47 use base qw(Exporter DynaLoader);
28 48
29 $VERSION = 0.11; 49 $VERSION = 0.124;
30 @EXPORT = qw( 50 @EXPORT = qw(
31 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
32 ); 53 );
33 @EXPORT_OK = qw( 54 @EXPORT_OK = qw(
34 connect_cached 55 connect_cached
35 ); 56 );
36 57
37 require XSLoader; 58 bootstrap PApp::SQL $VERSION;
38 XSLoader::load PApp::SQL, $VERSION;
39} 59}
40 60
41our $sql_exec; # last result of sql_exec's execute call 61our $sql_exec; # last result of sql_exec's execute call
42our $DBH; # the default database handle 62our $DBH; # the default database handle
43our $database; # the current SQL::Database object, if applicable 63our $Database; # the current SQL::Database object, if applicable
44 64
45our %dbcache; 65our %dbcache;
66
67=head2 GLOBAL VARIABLES
68
69=over 4
70
71=item $sql_exec
72
73Since the C<sql_exec> family of functions return a statement handle there
74must eb another way to test the return value of the C<execute> call. This
75global variable contains the result of the most recent call to C<execute>
76done by this module.
77
78=item $PApp::SQL::DBH
79
80The default database handle used by this module if no C<$DBH> was
81specified as argument and no C<$DBH> is found in the current package. See
82C<sql_exec> for a discussion.
83
84=item $PApp::SQL::Database
85
86The current default C<PApp::SQL::Database>-object. Future versions might
87automatically fall back on this database and create database handles from
88it if neccessary. At the moment this is not used by this module but might
89be nice as a placeholder for the database object that corresponds to
90$PApp::SQL::DBH.
91
92=back
93
94=head2 FUNCTIONS
95
96=over 4
46 97
47=item $dbh = connect_cached $id, $dsn, $user, $pass, $flags, $connect 98=item $dbh = connect_cached $id, $dsn, $user, $pass, $flags, $connect
48 99
49(not exported by by default) 100(not exported by by default)
50 101
94 $dbcache{$id}; 145 $dbcache{$id};
95} 146}
96 147
97=item $sth = sql_exec [dbh,] [bind-vals...,] "sql-statement", [arguments...] 148=item $sth = sql_exec [dbh,] [bind-vals...,] "sql-statement", [arguments...]
98 149
150=item $sth = sql_uexec <see sql_exec>
151
99C<sql_exec> is the most important and most-used function in this module. 152C<sql_exec> is the most important and most-used function in this module.
100 153
101Runs the given sql command with the given parameters and returns the 154Runs the given sql command with the given parameters and returns the
102statement handle. The command and the statement handle will be cached 155statement handle. The command and the statement handle will be cached
103(with the database handle and the sql string as key), so prepare will be 156(with the database handle and the sql string as key), so prepare will be
114The actual return value from the C<$sth->execute> call is stored in the 167The actual return value from the C<$sth->execute> call is stored in the
115package-global (and exported) variable C<$sql_exec>. 168package-global (and exported) variable C<$sql_exec>.
116 169
117If any error occurs C<sql_exec> will throw an exception. 170If any error occurs C<sql_exec> will throw an exception.
118 171
172C<sql_uexec> is similar to C<sql_exec> but upgrades all input arguments to
173utf8 before calling the C<execute> method.
174
119Examples: 175Examples:
120 176
121 # easy one 177 # easy one
122 my $st = sql_exec "select name, id from table where id = ?", $id; 178 my $st = sql_exec "select name, id from table where id = ?", $id;
123 while (my ($name, $id) = $st->fetchrow_array) { ... }; 179 while (my ($name, $id) = $st->fetchrow_array) { ... };
132 sql_exec $dbh, "update file set name = ?", "oops.txt"; 188 sql_exec $dbh, "update file set name = ?", "oops.txt";
133 189
134 190
135=item sql_fetch <see sql_exec> 191=item sql_fetch <see sql_exec>
136 192
193=item sql_ufetch <see sql_uexec>
194
137Execute a sql-statement and fetch the first row of results. Depending on 195Execute an sql-statement and fetch the first row of results. Depending on
138the caller context the row will be returned as a list (array context), or 196the caller context the row will be returned as a list (array context), or
139just the first columns. In table form: 197just the first columns. In table form:
140 198
141 CONTEXT RESULT 199 CONTEXT RESULT
142 void () 200 void ()
153 211
154 my($name, $amount) = sql_fetch "select ...", args... 212 my($name, $amount) = sql_fetch "select ...", args...
155 213
156... and it's still quite fast unless you fetch large amounts of data. 214... and it's still quite fast unless you fetch large amounts of data.
157 215
216C<sql_ufetch> is similar to C<sql_fetch> but upgrades all input values to
217utf8 and forces all result values to utf8.
218
158=item sql_fetchall <see sql_exec> 219=item sql_fetchall <see sql_exec>
220
221=item sql_ufetchall <see sql_uexec>
159 222
160Similarly to C<sql_fetch>, but all result rows will be fetched (this is 223Similarly to C<sql_fetch>, but all result rows will be fetched (this is
161of course inefficient for large results!). The context is ignored (only 224of course inefficient for large results!). The context is ignored (only
162list context makes sense), but the result still depends on the number of 225list context makes sense), but the result still depends on the number of
163columns in the result: 226columns in the result:
175 238
176 for (sql_fetchall "select name, age, place from user") { 239 for (sql_fetchall "select name, age, place from user") {
177 my ($name, $age, $place) = @$_; 240 my ($name, $age, $place) = @$_;
178 } 241 }
179 242
243C<sql_ufetchall> is similar to C<sql_fetchall> but upgrades all input
244values to utf8 and forces all result values to utf8.
245
180=item sql_exists "<table> where ...", args... 246=item sql_exists "<table> where ...", args...
247
248=item sql_uexists <see sql_exists>
181 249
182Check wether the result of the sql-statement "select xxx from 250Check wether the result of the sql-statement "select xxx from
183$first_argument" would be empty or not (that is, imagine the string 251$first_argument" would be empty or not (that is, imagine the string
184"select from" were prepended to your statement (it isn't)). Should work 252"select * from" were prepended to your statement (it isn't)). Should work
185with every database but can be quite slow, except on mysql, where this 253with every database but can be quite slow, except on mysql, where this
186should be quite fast. 254should be quite fast.
255
256C<sql_uexists> is similar to C<sql_exists> but upgrades all parameters to
257utf8.
187 258
188Examples: 259Examples:
189 260
190 print "user 7 exists!\n" 261 print "user 7 exists!\n"
191 if sql_exists "user where id = ?", 7; 262 if sql_exists "user where id = ?", 7;
241 312
242=cut 313=cut
243 314
244=item reinitialize [not exported] 315=item reinitialize [not exported]
245 316
246Clears any internal caches (statement cache, database handle cache). 317Clears any internal caches (statement cache, database handle
318cache). Should be called after C<fork> and other accidents that invalidate
319database handles.
247 320
248=cut 321=cut
249 322
250sub reinitialize { 323sub reinitialize {
251 cachesize cachesize 0; 324 cachesize cachesize 0;
252 for (values %dbcache) { 325 for (values %dbcache) {
253 eval { $_->disconnect }; 326 eval { $_->{InactiveDestroy} = 1 };
254 } 327 }
255 undef %dbcache; 328 undef %dbcache;
256} 329}
257 330
258=back 331=back
263 336
264package PApp::SQL::Database; 337package PApp::SQL::Database;
265 338
266=head2 THE DATABASE CLASS 339=head2 THE DATABASE CLASS
267 340
268Again (sigh) the problem of persistency. What do you do when you have to serialize on object 341Again (sigh) the problem of persistency. What do you do when you have
269that contains (or should contain) a database handle? Short answer: you don't. Long answer: 342to serialize on object that contains (or should contain) a database
343handle? Short answer: you don't. Long answer: you can embed the necessary
270you can embed the necessary information to recreate the dbh when needed. 344information to recreate the dbh when needed.
271 345
272The C<PApp::SQL::Database> class does that, in a relatively efficient 346The C<PApp::SQL::Database> class does that, in a relatively efficient
273fashion: the overhead is currently a single method call per access (you 347fashion: the overhead is currently a single method call per access (you
274can cache the real dbh if you want). 348can cache the real dbh if you want).
275 349
315 389
316=item $db->dsn 390=item $db->dsn
317 391
318Return the DSN (L<DBI>) fo the database object (e.g. for error messages). 392Return the DSN (L<DBI>) fo the database object (e.g. for error messages).
319 393
394=item $db->login
395
396Return the login name.
397
398=item $db->password
399
400Return the password (emphasizing the fact that the apssword is stored plaintext ;)
401
320=cut 402=cut
321 403
322sub dsn($) { 404sub dsn($) {
323 my $self = shift; 405 my $self = shift;
324 $self->[1][1]; 406 (split /\x00/, $self->[0])[1];
407}
408
409sub login($) {
410 my $self = shift;
411 (split /\x00/, $self->[0])[2];
412}
413
414sub password($) {
415 my $self = shift;
416 (split /\x00/, $self->[0])[3];
325} 417}
326 418
327=back 419=back
328 420
329=cut 421=cut
330 422
3311; 4231;
332
333=head1 BUGS
334
335As of this writing, sql_fetch and sql_fetchall are not very well tested
336(they were just re-written in C).
337
338sql_exists could be faster (it is written very ugly to not change the
339current package).
340 424
341=head1 SEE ALSO 425=head1 SEE ALSO
342 426
343L<PApp>. 427L<PApp>.
344 428

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines