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.14 by root, Sun Mar 11 14:54:21 2001 UTC vs.
Revision 1.23 by root, Sun Apr 7 16:23: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.122; 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
153called only once for each distinct sql call (please keep in mind that the 165called only once for each distinct sql call (please keep in mind that the
154returned statement will always be the same, so, if you call C<sql_exec> 166returned statement will always be the same, so, if you call C<sql_exec>
155with the same dbh and sql-statement twice (e.g. in a subroutine you 167with the same dbh and sql-statement twice (e.g. in a subroutine you
156called), the statement handle for the first call mustn't be used. 168called), the statement handle for the first call mustn't not be in use
169anymore, as the subsequent call will re-use the handle.
157 170
158The database handle (the first argument) is optional. If it is missing, 171The database handle (the first argument) is optional. If it is missing,
159C<sql_exec> first tries to use the variable C<$DBH> in the current (= 172C<sql_exec> first tries to use the variable C<$DBH> in the current (=
160calling) package and, if that fails, it tries to use database handle in 173calling) package and, if that fails, it tries to use database handle in
161C<$PApp::SQL::DBH>, which you can set before calling these functions. 174C<$PApp::SQL::DBH>, which you can set before calling these functions.
162 175
163The actual return value from the C<$sth->execute> call is stored in the 176The actual return value from the C<$sth->execute> call is stored in the
164package-global (and exported) variable C<$sql_exec>. 177package-global (and exported) variable C<$sql_exec>.
165 178
166If any error occurs C<sql_exec> will throw an exception. 179If any error occurs C<sql_exec> will throw an exception.
180
181C<sql_uexec> is similar to C<sql_exec> but upgrades all input arguments to
182utf8 before calling the C<execute> method.
167 183
168Examples: 184Examples:
169 185
170 # easy one 186 # easy one
171 my $st = sql_exec "select name, id from table where id = ?", $id; 187 my $st = sql_exec "select name, id from table where id = ?", $id;
181 sql_exec $dbh, "update file set name = ?", "oops.txt"; 197 sql_exec $dbh, "update file set name = ?", "oops.txt";
182 198
183 199
184=item sql_fetch <see sql_exec> 200=item sql_fetch <see sql_exec>
185 201
202=item sql_ufetch <see sql_uexec>
203
186Execute a sql-statement and fetch the first row of results. Depending on 204Execute 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 205the caller context the row will be returned as a list (array context), or
188just the first columns. In table form: 206just the first columns. In table form:
189 207
190 CONTEXT RESULT 208 CONTEXT RESULT
191 void () 209 void ()
202 220
203 my($name, $amount) = sql_fetch "select ...", args... 221 my($name, $amount) = sql_fetch "select ...", args...
204 222
205... and it's still quite fast unless you fetch large amounts of data. 223... and it's still quite fast unless you fetch large amounts of data.
206 224
225C<sql_ufetch> is similar to C<sql_fetch> but upgrades all input values to
226utf8 and forces all result values to utf8 (this does I<not> include result
227parameters, only return values. Using bind variables in cinjunction with
228sql_u* functions results in undefined behaviour).
229
207=item sql_fetchall <see sql_exec> 230=item sql_fetchall <see sql_exec>
231
232=item sql_ufetchall <see sql_uexec>
208 233
209Similarly to C<sql_fetch>, but all result rows will be fetched (this is 234Similarly to C<sql_fetch>, but all result rows will be fetched (this is
210of course inefficient for large results!). The context is ignored (only 235of course inefficient for large results!). The context is ignored (only
211list context makes sense), but the result still depends on the number of 236list context makes sense), but the result still depends on the number of
212columns in the result: 237columns in the result:
224 249
225 for (sql_fetchall "select name, age, place from user") { 250 for (sql_fetchall "select name, age, place from user") {
226 my ($name, $age, $place) = @$_; 251 my ($name, $age, $place) = @$_;
227 } 252 }
228 253
254C<sql_ufetchall> is similar to C<sql_fetchall> but upgrades all input
255values to utf8 and forces all result values to utf8 (see the caveats in
256the description of C<sql_ufetch>, though).
257
229=item sql_exists "<table> where ...", args... 258=item sql_exists "<table_references> where <where_condition>...", args...
259
260=item sql_uexists <see sql_exists>
230 261
231Check wether the result of the sql-statement "select xxx from 262Check wether the result of the sql-statement "select xxx from
232$first_argument" would be empty or not (that is, imagine the string 263$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 264"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 265with every database but can be quite slow, except on mysql, where this
235should be quite fast. 266should be quite fast.
267
268C<sql_uexists> is similar to C<sql_exists> but upgrades all parameters to
269utf8.
236 270
237Examples: 271Examples:
238 272
239 print "user 7 exists!\n" 273 print "user 7 exists!\n"
240 if sql_exists "user where id = ?", 7; 274 if sql_exists "user where id = ?", 7;
314 348
315package PApp::SQL::Database; 349package PApp::SQL::Database;
316 350
317=head2 THE DATABASE CLASS 351=head2 THE DATABASE CLASS
318 352
319Again (sigh) the problem of persistency. What do you do when you have to serialize on object 353Again (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: 354to serialize on object that contains (or should contain) a database
355handle? Short answer: you don't. Long answer: you can embed the necessary
321you can embed the necessary information to recreate the dbh when needed. 356information to recreate the dbh when needed.
322 357
323The C<PApp::SQL::Database> class does that, in a relatively efficient 358The C<PApp::SQL::Database> class does that, in a relatively efficient
324fashion: the overhead is currently a single method call per access (you 359fashion: the overhead is currently a single method call per access (you
325can cache the real dbh if you want). 360can cache the real dbh if you want).
326 361

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines