Lines Matching defs:sql
231 static int dbd_mysql_select(apr_pool_t *pool, apr_dbd_t *sql,
237 if (sql->trans && sql->trans->errnum) {
238 return sql->trans->errnum;
240 ret = mysql_query(sql->conn, query);
242 if (sz = mysql_field_count(sql->conn), sz > 0) {
250 (*results)->res = mysql_store_result(sql->conn);
253 (*results)->res = mysql_use_result(sql->conn);
259 ret = mysql_errno(sql->conn);
262 if (TXN_NOTICE_ERRORS(sql->trans)) {
263 sql->trans->errnum = ret;
541 static const char *dbd_mysql_error(apr_dbd_t *sql, int n)
543 return mysql_error(sql->conn);
546 static int dbd_mysql_query(apr_dbd_t *sql, int *nrows, const char *query)
549 if (sql->trans && sql->trans->errnum) {
550 return sql->trans->errnum;
552 ret = mysql_query(sql->conn, query);
554 ret = mysql_errno(sql->conn);
556 *nrows = (int) mysql_affected_rows(sql->conn);
557 if (TXN_NOTICE_ERRORS(sql->trans)) {
558 sql->trans->errnum = ret;
564 apr_dbd_t *sql)
568 mysql_real_escape_string(sql->conn, ret, arg, len);
578 static int dbd_mysql_prepare(apr_pool_t *pool, apr_dbd_t *sql,
589 (*statement)->stmt = mysql_stmt_init(sql->conn);
646 static int dbd_mysql_pquery_internal(apr_pool_t *pool, apr_dbd_t *sql,
668 static int dbd_mysql_pquery(apr_pool_t *pool, apr_dbd_t *sql,
675 if (sql->trans && sql->trans->errnum) {
676 return sql->trans->errnum;
683 ret = dbd_mysql_pquery_internal(pool, sql, nrows, statement, bind);
685 if (TXN_NOTICE_ERRORS(sql->trans)) {
686 sql->trans->errnum = ret;
691 static int dbd_mysql_pvquery(apr_pool_t *pool, apr_dbd_t *sql, int *nrows,
697 if (sql->trans && sql->trans->errnum) {
698 return sql->trans->errnum;
707 return dbd_mysql_pquery(pool, sql, nrows, statement, values);
710 static int dbd_mysql_pselect_internal(apr_pool_t *pool, apr_dbd_t *sql,
745 maxlen = ((*res)->res->fields[i].length < sql->fldsz ?
746 (*res)->res->fields[i].length : sql->fldsz) + 1;
775 static int dbd_mysql_pselect(apr_pool_t *pool, apr_dbd_t *sql,
783 if (sql->trans && sql->trans->errnum) {
784 return sql->trans->errnum;
791 ret = dbd_mysql_pselect_internal(pool, sql, res, statement, random, bind);
793 if (TXN_NOTICE_ERRORS(sql->trans)) {
794 sql->trans->errnum = ret;
799 static int dbd_mysql_pvselect(apr_pool_t *pool, apr_dbd_t *sql,
807 if (sql->trans && sql->trans->errnum) {
808 return sql->trans->errnum;
817 return dbd_mysql_pselect(pool, sql, res, statement, random, values);
954 static int dbd_mysql_pbquery(apr_pool_t *pool, apr_dbd_t *sql,
961 if (sql->trans && sql->trans->errnum) {
962 return sql->trans->errnum;
969 ret = dbd_mysql_pquery_internal(pool, sql, nrows, statement, bind);
971 if (TXN_NOTICE_ERRORS(sql->trans)) {
972 sql->trans->errnum = ret;
977 static int dbd_mysql_pvbquery(apr_pool_t *pool, apr_dbd_t *sql, int *nrows,
983 if (sql->trans && sql->trans->errnum) {
984 return sql->trans->errnum;
993 return dbd_mysql_pbquery(pool, sql, nrows, statement, values);
996 static int dbd_mysql_pbselect(apr_pool_t *pool, apr_dbd_t *sql,
1004 if (sql->trans && sql->trans->errnum) {
1005 return sql->trans->errnum;
1012 ret = dbd_mysql_pselect_internal(pool, sql, res, statement, random, bind);
1014 if (TXN_NOTICE_ERRORS(sql->trans)) {
1015 sql->trans->errnum = ret;
1020 static int dbd_mysql_pvbselect(apr_pool_t *pool, apr_dbd_t *sql,
1028 if (sql->trans && sql->trans->errnum) {
1029 return sql->trans->errnum;
1038 return dbd_mysql_pbselect(pool, sql, res, statement, random, values);
1129 apr_dbd_t *sql = apr_pcalloc(pool, sizeof(apr_dbd_t));
1130 sql->fldsz = FIELDSIZE;
1131 sql->conn = mysql_init(sql->conn);
1132 if ( sql->conn == NULL ) {
1172 sql->fldsz = atol(fields[7].value);
1175 mysql_options(sql->conn, MYSQL_READ_DEFAULT_GROUP, fields[8].value);
1185 mysql_options(sql->conn, MYSQL_OPT_RECONNECT, &do_reconnect);
1188 real_conn = mysql_real_connect(sql->conn, fields[0].value,
1195 *error = apr_pstrdup(pool, mysql_error(sql->conn));
1197 mysql_close(sql->conn);
1203 mysql_options(sql->conn, MYSQL_OPT_RECONNECT, &do_reconnect);
1206 return sql;