| … | |
… | |
| 9 | #endif |
9 | #endif |
| 10 | |
10 | |
| 11 | #if (PERL_VERSION > 5) || ((PERL_VERSION == 5) && (PERL_SUBVERSION >= 6)) |
11 | #if (PERL_VERSION > 5) || ((PERL_VERSION == 5) && (PERL_SUBVERSION >= 6)) |
| 12 | # define CAN_UTF8 1 |
12 | # define CAN_UTF8 1 |
| 13 | #endif |
13 | #endif |
|
|
14 | |
|
|
15 | #define MAX_CACHED_STATEMENT_SIZE 8192 |
| 14 | |
16 | |
| 15 | static SV * |
17 | static SV * |
| 16 | sql_upgrade_utf8 (SV *sv) |
18 | sql_upgrade_utf8 (SV *sv) |
| 17 | { |
19 | { |
| 18 | #if CAN_UTF8 |
20 | #if CAN_UTF8 |
| … | |
… | |
| 60 | #define lru_init lru_list.next = &lru_list; lru_list.prev = &lru_list /* other fields are zero */ |
62 | #define lru_init lru_list.next = &lru_list; lru_list.prev = &lru_list /* other fields are zero */ |
| 61 | |
63 | |
| 62 | /* this is primitive, yet effective */ |
64 | /* this is primitive, yet effective */ |
| 63 | /* the returned value must never be zero (or bad things will happen) */ |
65 | /* the returned value must never be zero (or bad things will happen) */ |
| 64 | #define lru_hash do { \ |
66 | #define lru_hash do { \ |
| 65 | hash = (((U32)dbh)>>2); \ |
67 | hash = (((U32)(long)dbh)>>2); \ |
| 66 | hash += *statement;\ |
68 | hash += *statement;\ |
| 67 | hash += len; \ |
69 | hash += len; \ |
| 68 | } while (0) |
70 | } while (0) |
| 69 | |
71 | |
| 70 | /* fetch and "use" */ |
72 | /* fetch and "use" */ |
| … | |
… | |
| 290 | SvPV (sql, dc), |
292 | SvPV (sql, dc), |
| 291 | SvPV (get_sv ("DBI::errstr", TRUE), dd)); |
293 | SvPV (get_sv ("DBI::errstr", TRUE), dd)); |
| 292 | |
294 | |
| 293 | sth = POPs; |
295 | sth = POPs; |
| 294 | |
296 | |
|
|
297 | if (SvLEN (sql) < MAX_CACHED_STATEMENT_SIZE) |
| 295 | lru_store (dbh, sql, sth); |
298 | lru_store (dbh, sql, sth); |
| 296 | } |
299 | } |
| 297 | |
300 | |
| 298 | PUSHMARK (SP); |
301 | PUSHMARK (SP); |
| 299 | EXTEND (SP, items - arg + 1); |
302 | EXTEND (SP, items - arg + 1); |
| 300 | PUSHs (sth); |
303 | PUSHs (sth); |
| 301 | while (items > arg) |
304 | while (items > arg) |
| 302 | { |
305 | { |
|
|
306 | SV *sv = ST(arg); |
|
|
307 | /* we sv_mortalcopy magical values since DBI seems to have a memory |
|
|
308 | * leak when magical values are passed into execute(). |
|
|
309 | */ |
| 303 | PUSHs (maybe_upgrade_utf8 (ix & 1, ST(arg))); |
310 | PUSHs (maybe_upgrade_utf8 (ix & 1, SvMAGICAL(sv) ? sv_mortalcopy(sv) : sv)); |
| 304 | arg++; |
311 | arg++; |
| 305 | } |
312 | } |
| 306 | |
313 | |
| 307 | PUTBACK; |
314 | PUTBACK; |
| 308 | /* { static GV *execute; |
315 | /* { static GV *execute; |
| … | |
… | |
| 330 | { |
337 | { |
| 331 | PUSHMARK (SP); |
338 | PUSHMARK (SP); |
| 332 | EXTEND (SP, bind_last - bind_first + 2); |
339 | EXTEND (SP, bind_last - bind_first + 2); |
| 333 | PUSHs (sth); |
340 | PUSHs (sth); |
| 334 | do { |
341 | do { |
|
|
342 | #if CAN_UTF8 |
|
|
343 | if (ix & 1) |
|
|
344 | SvUTF8_on (SvRV(ST(bind_first))); |
|
|
345 | #endif |
| 335 | PUSHs (ST(bind_first)); |
346 | PUSHs (ST(bind_first)); |
| 336 | bind_first++; |
347 | bind_first++; |
| 337 | } while (bind_first != bind_last); |
348 | } while (bind_first != bind_last); |
| 338 | |
349 | |
| 339 | PUTBACK; |
350 | PUTBACK; |
