comparison: dbutils/db.c
dbutils/db.c
- changeset 51
- e3163dc41a80
- parent 49
- 34c723ed7190
equal
deleted
inserted
replaced
| 50:c160700751ec | 51:e3163dc41a80 |
|---|---|
| 27 */ | 27 */ |
| 28 | 28 |
| 29 #include "db.h" | 29 #include "db.h" |
| 30 #include "dbutils/db.h" | 30 #include "dbutils/db.h" |
| 31 | 31 |
| 32 int dbuConnectionExec(DBUConnection *conn, const char *sql) { | |
| 33 DBUQuery *q = conn->createQuery(conn, NULL); | |
| 34 int err = 1; | |
| 35 if(!dbuQuerySetSQL(q, sql)) { | |
| 36 err = dbuQueryExec(q); | |
| 37 } | |
| 38 dbuQueryFree(q); | |
| 39 return err; | |
| 40 } | |
| 41 | |
| 42 int dbuConnectionIsActive(DBUConnection *conn) { | 32 int dbuConnectionIsActive(DBUConnection *conn) { |
| 43 return conn->isActive ? conn->isActive(conn) : 1; | 33 return conn->isActive ? conn->isActive(conn) : 1; |
| 44 } | 34 } |
| 45 | 35 |
| 46 void dbuConnectionFree(DBUConnection *conn) { | 36 void dbuConnectionFree(DBUConnection *conn) { |
| 282 DBUResult *r = dbuQueryGetResult(q); | 272 DBUResult *r = dbuQueryGetResult(q); |
| 283 dbuQueryFree(q); | 273 dbuQueryFree(q); |
| 284 return r; | 274 return r; |
| 285 } | 275 } |
| 286 | 276 |
| 287 DBUResult* dbuSqlExecQueryParamUInt64(DBUConnection *conn, const CxAllocator *a, const char *sql, uint32_t param) { | 277 DBUResult* dbuSqlExecQueryParamUInt64(DBUConnection *conn, const CxAllocator *a, const char *sql, uint64_t param) { |
| 288 DBUQuery *q = execInt64ParamQuery(conn, sql, param); | 278 DBUQuery *q = execInt64ParamQuery(conn, sql, param); |
| 289 if(!q) return NULL; | 279 if(!q) return NULL; |
| 290 DBUResult *r = dbuQueryGetResult(q); | 280 DBUResult *r = dbuQueryGetResult(q); |
| 291 dbuQueryFree(q); | 281 dbuQueryFree(q); |
| 292 return r; | 282 return r; |
| 394 if(!result) { | 384 if(!result) { |
| 395 return 1; | 385 return 1; |
| 396 } | 386 } |
| 397 int ret = dbuResultIsOk(result); | 387 int ret = dbuResultIsOk(result); |
| 398 dbuResultFree(result); | 388 dbuResultFree(result); |
| 399 return ret; | 389 return !ret; |
| 400 } | 390 } |
| 401 | 391 |
| 402 int dbuSqlExecParamInt64(DBUConnection *conn, const char *sql, int64_t param) { | 392 int dbuSqlExecParamInt64(DBUConnection *conn, const char *sql, int64_t param) { |
| 403 DBUResult *result = dbuSqlExecQueryParam(conn, NULL, sql, param); | 393 DBUResult *result = dbuSqlExecQueryParam(conn, NULL, sql, param); |
| 404 if(!result) { | 394 if(!result) { |
| 405 return 1; | 395 return 1; |
| 406 } | 396 } |
| 407 int ret = dbuResultIsOk(result); | 397 int ret = dbuResultIsOk(result); |
| 408 dbuResultFree(result); | 398 dbuResultFree(result); |
| 409 return ret; | 399 return !ret; |
| 410 } | 400 } |
| 411 | 401 |
| 412 int dbuSqlExecParamUInt32(DBUConnection *conn, const char *sql, uint32_t param) { | 402 int dbuSqlExecParamUInt32(DBUConnection *conn, const char *sql, uint32_t param) { |
| 413 DBUResult *result = dbuSqlExecQueryParam(conn, NULL, sql, param); | 403 DBUResult *result = dbuSqlExecQueryParam(conn, NULL, sql, param); |
| 414 if(!result) { | 404 if(!result) { |
| 415 return 1; | 405 return 1; |
| 416 } | 406 } |
| 417 int ret = dbuResultIsOk(result); | 407 int ret = dbuResultIsOk(result); |
| 418 dbuResultFree(result); | 408 dbuResultFree(result); |
| 419 return ret; | 409 return !ret; |
| 420 } | 410 } |
| 421 | 411 |
| 422 int dbuSqlExecParamUInt64(DBUConnection *conn, const char *sql, uint32_t param) { | 412 int dbuSqlExecParamUInt64(DBUConnection *conn, const char *sql, uint64_t param) { |
| 423 DBUResult *result = dbuSqlExecQueryParam(conn, NULL, sql, param); | 413 DBUResult *result = dbuSqlExecQueryParam(conn, NULL, sql, param); |
| 424 if(!result) { | 414 if(!result) { |
| 425 return 1; | 415 return 1; |
| 426 } | 416 } |
| 427 int ret = dbuResultIsOk(result); | 417 int ret = dbuResultIsOk(result); |
| 428 dbuResultFree(result); | 418 dbuResultFree(result); |
| 429 return ret; | 419 return !ret; |
| 430 } | 420 } |
| 431 | 421 |
| 432 int dbuSqlExecParamString(DBUConnection *conn, const char *sql, const char *param) { | 422 int dbuSqlExecParamString(DBUConnection *conn, const char *sql, const char *param) { |
| 433 DBUResult *result = dbuSqlExecQueryParam(conn, NULL, sql, param); | 423 DBUResult *result = dbuSqlExecQueryParam(conn, NULL, sql, param); |
| 434 if(!result) { | 424 if(!result) { |
| 435 return 1; | 425 return 1; |
| 436 } | 426 } |
| 437 int ret = dbuResultIsOk(result); | 427 int ret = dbuResultIsOk(result); |
| 438 dbuResultFree(result); | 428 dbuResultFree(result); |
| 439 return ret; | 429 return !ret; |
| 440 } | 430 } |
| 441 | 431 |
| 442 int dbuSqlExecParamCxString(DBUConnection *conn, const char *sql, cxstring param) { | 432 int dbuSqlExecParamCxString(DBUConnection *conn, const char *sql, cxstring param) { |
| 443 DBUResult *result = dbuSqlExecQueryParam(conn, NULL, sql, param); | 433 DBUResult *result = dbuSqlExecQueryParam(conn, NULL, sql, param); |
| 444 if(!result) { | 434 if(!result) { |
| 445 return 1; | 435 return 1; |
| 446 } | 436 } |
| 447 int ret = dbuResultIsOk(result); | 437 int ret = dbuResultIsOk(result); |
| 448 dbuResultFree(result); | 438 dbuResultFree(result); |
| 449 return ret; | 439 return !ret; |
| 450 } | 440 } |
| 451 | 441 |
| 452 int dbuSqlExecParamCxMutStr(DBUConnection *conn, const char *sql, cxmutstr param) { | 442 int dbuSqlExecParamCxMutStr(DBUConnection *conn, const char *sql, cxmutstr param) { |
| 453 DBUResult *result = dbuSqlExecQueryParam(conn, NULL, sql, param); | 443 DBUResult *result = dbuSqlExecQueryParam(conn, NULL, sql, param); |
| 454 if(!result) { | 444 if(!result) { |
| 455 return 1; | 445 return 1; |
| 456 } | 446 } |
| 457 int ret = dbuResultIsOk(result); | 447 int ret = dbuResultIsOk(result); |
| 458 dbuResultFree(result); | 448 dbuResultFree(result); |
| 459 return ret; | 449 return !ret; |
| 460 } | 450 } |
