apr-util/dbd/apr_dbd_oracle.c

92                               apr_dbd_prepared_t **statement);
96                               apr_dbd_prepared_t *statement,
99                              int *nrows, apr_dbd_prepared_t *statement,
120     apr_dbd_prepared_t *statement;
253     define_arg *val = &res->statement->out[col];
678     define_arg *val = &res->statement->out[n];
680     if ((n < 0) || (n >= res->statement->nout)) {
711         sql->status = OCIStmtFetch2(res->statement->stmt, res->handle->err, 1,
715         sql->status = OCIStmtFetch2(res->statement->stmt, res->handle->err, 1,
770 static apr_status_t freeStatement(void *statement)
773     OCIStmt *stmt = ((apr_dbd_prepared_t*)statement)->stmt;
802     apr_dbd_prepared_t *statement = NULL;
804     ret = dbd_oracle_prepare(pool, sql, query, NULL, 0, 0, NULL, &statement);
809     ret = dbd_oracle_pselect(pool, sql, results, statement, seek, NULL);
821     apr_dbd_prepared_t *statement = NULL;
833     ret = dbd_oracle_prepare(pool, sql, query, NULL, 0, 0, NULL, &statement);
835         ret = dbd_oracle_pquery(pool, sql, nrows, statement, NULL);
837             sql->status = OCIAttrGet(statement->stmt, OCI_HTYPE_STMT,
857                               apr_dbd_prepared_t **statement)
863     if (*statement == NULL) {
864         *statement = apr_pcalloc(pool, sizeof(apr_dbd_prepared_t));
866     stmt = *statement;
896     /* Perl gets statement type here */
919 static void dbd_oracle_bind(apr_dbd_prepared_t *statement, const char **values)
921     OCIStmt *stmt = statement->stmt;
922     apr_dbd_t *sql = statement->handle;
926     for (i = 0, j = 0; i < statement->nargs; i++, j++) {
928             sql->status = OCIBindByPos(stmt, &statement->args[i].bind,
936             switch (statement->args[i].type) {
945                 sql->status = OCIBindByPos(stmt, &statement->args[i].bind,
948                                            &statement->args[i].ind,
962                 sql->status = OCIBindByPos(stmt, &statement->args[i].bind,
965                                            &statement->args[i].ind,
972                 sql->status = OCIBindByPos(stmt, &statement->args[i].bind,
977                                            &statement->args[i].ind,
1014         printf("Describing prepared statement: %s\n", sql->buf);
1143                              int *nrows, apr_dbd_prepared_t *statement,
1176     dbd_oracle_bind(statement, values);
1178     sql->status = OCIStmtExecute(sql->svc, statement->stmt, sql->err, 1, 0,
1197     sql->status = OCIAttrGet(statement->stmt, OCI_HTYPE_STMT, nrows, 0,
1203                               int *nrows, apr_dbd_prepared_t *statement,
1213     values = apr_palloc(pool, sizeof(*values) * statement->nvals);
1215     for (i = 0; i < statement->nvals; i++) {
1219     return dbd_oracle_pquery(pool, sql, nrows, statement, values);
1224                               apr_dbd_prepared_t *statement,
1253     dbd_oracle_bind(statement, values);
1255     sql->status = OCIStmtExecute(sql->svc, statement->stmt, sql->err, 0, 0,
1264         printf("Executing prepared statement: %s\n", sql->buf);
1278     (*results)->statement = statement;
1288                                apr_dbd_prepared_t *statement,
1298     values = apr_palloc(pool, sizeof(*values) * statement->nvals);
1300     for (i = 0; i < statement->nvals; i++) {
1304     return dbd_oracle_pselect(pool, sql, results, statement, seek, values);
1307 static void dbd_oracle_bbind(apr_dbd_prepared_t * statement,
1310     OCIStmt *stmt = statement->stmt;
1311     apr_dbd_t *sql = statement->handle;
1316     for (i = 0, j = 0; i < statement->nargs; i++, j++) {
1318                                   : statement->args[i].type);
1322             statement->args[i].value.ival = *(char*)values[j];
1323             sql->status = OCIBindByPos(stmt, &statement->args[i].bind,
1325                                        &statement->args[i].value.ival,
1326                                        sizeof(statement->args[i].value.ival),
1328                                        &statement->args[i].ind, NULL,
1333             statement->args[i].value.uval = *(unsigned char*)values[j];
1334             sql->status = OCIBindByPos(stmt, &statement->args[i].bind,
1336                                        &statement->args[i].value.uval,
1337                                        sizeof(statement->args[i].value.uval),
1339                                        &statement->args[i].ind, NULL,
1344             statement->args[i].value.ival = *(short*)values[j];
1345             sql->status = OCIBindByPos(stmt, &statement->args[i].bind,
1347                                        &statement->args[i].value.ival,
1348                                        sizeof(statement->args[i].value.ival),
1350                                        &statement->args[i].ind, NULL,
1355             statement->args[i].value.uval = *(unsigned short*)values[j];
1356             sql->status = OCIBindByPos(stmt, &statement->args[i].bind,
1358                                        &statement->args[i].value.uval,
1359                                        sizeof(statement->args[i].value.uval),
1361                                        &statement->args[i].ind, NULL,
1366             statement->args[i].value.ival = *(int*)values[j];
1367             sql->status = OCIBindByPos(stmt, &statement->args[i].bind,
1369                                        &statement->args[i].value.ival,
1370                                        sizeof(statement->args[i].value.ival),
1372                                        &statement->args[i].ind, NULL,
1377             statement->args[i].value.uval = *(unsigned int*)values[j];
1378             sql->status = OCIBindByPos(stmt, &statement->args[i].bind,
1380                                        &statement->args[i].value.uval,
1381                                        sizeof(statement->args[i].value.uval),
1383                                        &statement->args[i].ind, NULL,
1388             statement->args[i].value.sval =
1389                 apr_psprintf(statement->pool, "%ld", *(long*)values[j]);
1390             sql->status = OCIBindByPos(stmt, &statement->args[i].bind,
1392                                        statement->args[i].value.sval,
1393                                        strlen(statement->args[i].value.sval)+1,
1395                                        &statement->args[i].ind, NULL,
1400             statement->args[i].value.sval =
1401                 apr_psprintf(statement->pool, "%lu",
1403             sql->status = OCIBindByPos(stmt, &statement->args[i].bind,
1405                                        statement->args[i].value.sval,
1406                                        strlen(statement->args[i].value.sval)+1,
1408                                        &statement->args[i].ind, NULL,
1413             statement->args[i].value.sval =
1414                 apr_psprintf(statement->pool, "%" APR_INT64_T_FMT,
1416             sql->status = OCIBindByPos(stmt, &statement->args[i].bind,
1418                                        statement->args[i].value.sval,
1419                                        strlen(statement->args[i].value.sval)+1,
1421                                        &statement->args[i].ind, NULL,
1426             statement->args[i].value.sval =
1427                 apr_psprintf(statement->pool, "%" APR_UINT64_T_FMT,
1429             sql->status = OCIBindByPos(stmt, &statement->args[i].bind,
1431                                        statement->args[i].value.sval,
1432                                        strlen(statement->args[i].value.sval)+1,
1434                                        &statement->args[i].ind, NULL,
1439             statement->args[i].value.fval = *(float*)values[j];
1440             sql->status = OCIBindByPos(stmt, &statement->args[i].bind,
1442                                        &statement->args[i].value.fval,
1443                                        sizeof(statement->args[i].value.fval),
1445                                        &statement->args[i].ind, NULL,
1450             statement->args[i].value.fval = *(double*)values[j];
1451             sql->status = OCIBindByPos(stmt, &statement->args[i].bind,
1453                                        &statement->args[i].value.fval,
1454                                        sizeof(statement->args[i].value.fval),
1456                                        &statement->args[i].ind, NULL,
1467             sql->status = OCIBindByPos(stmt, &statement->args[i].bind,
1472                                        &statement->args[i].ind, NULL,
1484             sql->status = OCIBindByPos(stmt, &statement->args[i].bind,
1487                                        &statement->args[i].ind,
1501             sql->status = OCIBindByPos(stmt, &statement->args[i].bind,
1504                                        &statement->args[i].ind,
1512             sql->status = OCIBindByPos(stmt, &statement->args[i].bind,
1530                               int *nrows, apr_dbd_prepared_t * statement,
1563     dbd_oracle_bbind(statement, values);
1565     sql->status = OCIStmtExecute(sql->svc, statement->stmt, sql->err, 1, 0,
1584     sql->status = OCIAttrGet(statement->stmt, OCI_HTYPE_STMT, nrows, 0,
1590                                int *nrows, apr_dbd_prepared_t * statement,
1600     values = apr_palloc(pool, sizeof(*values) * statement->nvals);
1602     for (i = 0; i < statement->nvals; i++) {
1606     return dbd_oracle_pbquery(pool, sql, nrows, statement, values);
1611                                apr_dbd_prepared_t * statement,
1640     dbd_oracle_bbind(statement, values);
1642     sql->status = OCIStmtExecute(sql->svc, statement->stmt, sql->err, 0, 0,
1651         printf("Executing prepared statement: %s\n", sql->buf);
1665     (*results)->statement = statement;
1675                                 apr_dbd_prepared_t * statement, int seek,
1685     values = apr_palloc(pool, sizeof(*values) * statement->nvals);
1687     for (i = 0; i < statement->nvals; i++) {
1691     return dbd_oracle_pbselect(pool, sql, results, statement, seek, values);
1820     define_arg *val = &row->res->statement->out[n];
1824     if ((n < 0) || (n >= row->res->statement->nout) || (val->ind == -1)) {
1935     define_arg *val = &row->res->statement->out[n];
1938     if ((n < 0) || (n >= row->res->statement->nout)) {
2170     return res->statement->nout;
2181     res->handle->status = OCIAttrGet(res->statement->stmt, OCI_HTYPE_STMT,