File Coverage

/usr/local/lib/perl5/site_perl/5.26.1/x86_64-linux/auto/DBI/Driver_xst.h
Criterion Covered Total %
statement 40 57 70.1
branch 27 60 45.0
condition n/a
subroutine n/a
pod n/a
total 67 117 57.2


line stmt bran cond sub pod time code
1             /*
2             # $Id$
3             # Copyright (c) 2002 Tim Bunce Ireland
4             #
5             # You may distribute under the terms of either the GNU General Public
6             # License or the Artistic License, as specified in the Perl README file.
7             */
8              
9              
10             /* This is really just a workaround for SUPER:: not working right for XS code.
11             * It would be better if we setup perl's context so SUPER:: did the right thing
12             * (borrowing the relevant magic from pp_entersub in perl pp_hot.c).
13             * Then we could just use call_method("SUPER::foo") instead.
14             * XXX remember to call SPAGAIN in the calling code after calling this!
15             */
16             static SV *
17 720           dbixst_bounce_method(char *methname, int params)
18             {
19             dTHX;
20             /* XXX this 'magic' undoes the dMARK embedded in the dXSARGS of our caller */
21             /* so that the dXSARGS below can set things up as they were for our caller */
22 720           void *xxx = PL_markstack_ptr++;
23 720           dXSARGS; /* declares sp, ax, mark, items */
24             int i;
25             SV *sv;
26 720           int debug = 0;
27 720           D_imp_xxh(ST(0));
28 720 50         if (debug >= 3) {
29 0           PerlIO_printf(DBIc_LOGPIO(imp_xxh),
30             " -> %s (trampoline call with %d (%ld) params)\n", methname, params, (long)items);
31             PERL_UNUSED_VAR(xxx);
32             }
33 720 50         EXTEND(SP, params);
    50          
34 720 50         PUSHMARK(SP);
35 2880 100         for (i=0; i < params; ++i) {
36 2160 100         sv = (i >= items) ? &PL_sv_undef : ST(i);
37 2160           PUSHs(sv);
38             }
39 720           PUTBACK;
40 720           i = call_method(methname, G_SCALAR);
41 720           SPAGAIN;
42 720 50         sv = (i) ? POPs : &PL_sv_undef;
43 720           PUTBACK;
44 720 50         if (debug >= 3)
45 0           PerlIO_printf(DBIc_LOGPIO(imp_xxh),
46 0           " <- %s= %s (trampoline call return)\n", methname, neatsvpv(sv,0));
47 720           return sv;
48             }
49              
50              
51             static int
52 599           dbdxst_bind_params(SV *sth, imp_sth_t *imp_sth, I32 items, I32 ax)
53             {
54             /* Handle binding supplied values to placeholders. */
55             /* items = one greater than the number of params */
56             /* ax = ax from calling sub, maybe adjusted to match items */
57             dTHX;
58             int i;
59             SV *idx;
60 599 50         if (items-1 != DBIc_NUM_PARAMS(imp_sth)
61 0 0         && DBIc_NUM_PARAMS(imp_sth) != DBIc_NUM_PARAMS_AT_EXECUTE
62             ) {
63             char errmsg[99];
64             /* clear any previous ParamValues before error is generated */
65 0           SV **svp = hv_fetch((HV*)DBIc_MY_H(imp_sth),"ParamValues",11,FALSE);
66 0 0         if (svp && SvROK(*svp) && SvTYPE(SvRV(*svp)) == SVt_PVHV) {
    0          
    0          
67 0           HV *hv = (HV*)SvRV(*svp);
68 0           hv_clear(hv);
69             }
70 0           sprintf(errmsg,"called with %d bind variables when %d are needed",
71             (int)items-1, DBIc_NUM_PARAMS(imp_sth));
72 0           DBIh_SET_ERR_CHAR(sth, (imp_xxh_t*)imp_sth, "-1", -1, errmsg, Nullch, Nullch);
73 0           return 0;
74             }
75 599           idx = sv_2mortal(newSViv(0));
76 1495 100         for(i=1; i < items ; ++i) {
77 896           SV* value = ST(i);
78 896 50         if (SvGMAGICAL(value))
79 0           mg_get(value); /* trigger magic to FETCH the value */
80 896           sv_setiv(idx, i);
81 896 50         if (!dbd_bind_ph(sth, imp_sth, idx, value, 0, Nullsv, FALSE, 0)) {
82 0           return 0; /* dbd_bind_ph already registered error */
83             }
84             }
85 599           return 1;
86             }
87              
88             #ifndef dbd_fetchall_arrayref
89             static SV *
90 310           dbdxst_fetchall_arrayref(SV *sth, SV *slice, SV *batch_row_count)
91             {
92             dTHX;
93 310           D_imp_sth(sth);
94             SV *rows_rvav;
95 310 50         if (SvOK(slice)) { /* should never get here */
    50          
    50          
96             char errmsg[99];
97 0           sprintf(errmsg,"slice param not supported by XS version of fetchall_arrayref");
98 0           DBIh_SET_ERR_CHAR(sth, (imp_xxh_t*)imp_sth, "-1", -1, errmsg, Nullch, Nullch);
99 0           return &PL_sv_undef;
100             }
101             else {
102 310 50         IV maxrows = SvOK(batch_row_count) ? SvIV(batch_row_count) : -1;
    50          
    50          
    0          
103             AV *fetched_av;
104 310           AV *rows_av = newAV();
105 310 50         if ( !DBIc_ACTIVE(imp_sth) && maxrows>0 ) {
    0          
106             /* to simplify application logic we return undef without an error */
107             /* if we've fetched all the rows and called with a batch_row_count */
108 0           return &PL_sv_undef;
109             }
110 310 50         av_extend(rows_av, (maxrows>0) ? maxrows : 31);
111 688 50         while ( (maxrows < 0 || maxrows-- > 0)
    0          
112 688 100         && (fetched_av = dbd_st_fetch(sth, imp_sth))
113             ) {
114 378 50         AV *copy_row_av = av_make(AvFILL(fetched_av)+1, AvARRAY(fetched_av));
115 378           av_push(rows_av, newRV_noinc((SV*)copy_row_av));
116             }
117 310           rows_rvav = sv_2mortal(newRV_noinc((SV *)rows_av));
118             }
119 310           return rows_rvav;
120             }
121             #endif
122