diff options
Diffstat (limited to '')
-rw-r--r-- | src/sledjchisl/sledjchisl.c | 64 |
1 files changed, 33 insertions, 31 deletions
diff --git a/src/sledjchisl/sledjchisl.c b/src/sledjchisl/sledjchisl.c index 00575c0..95724df 100644 --- a/src/sledjchisl/sledjchisl.c +++ b/src/sledjchisl/sledjchisl.c | |||
@@ -1179,7 +1179,7 @@ d("New SQL statement - %s", req->sql); | |||
1179 | goto freeIt; | 1179 | goto freeIt; |
1180 | } | 1180 | } |
1181 | req->inBind = xzalloc(i * sizeof(MYSQL_BIND)); | 1181 | req->inBind = xzalloc(i * sizeof(MYSQL_BIND)); |
1182 | W("Allocated %d %d inBinds for %s", i, req->inCount, req->sql); | 1182 | //W("Allocated %d %d inBinds for %s", i, req->inCount, req->sql); |
1183 | for (i = 0; i < req->inCount; i++) | 1183 | for (i = 0; i < req->inCount; i++) |
1184 | { | 1184 | { |
1185 | dbField *fld = req->flds->get(req->flds, req->inParams[i], NULL, false); | 1185 | dbField *fld = req->flds->get(req->flds, req->inParams[i], NULL, false); |
@@ -1201,53 +1201,53 @@ W("Allocated %d %d inBinds for %s", i, req->inCount, req->sql); | |||
1201 | { | 1201 | { |
1202 | case MYSQL_TYPE_TINY: | 1202 | case MYSQL_TYPE_TINY: |
1203 | { | 1203 | { |
1204 | d("TINY %d %s %d", i, fld->name, req->inBind[i].buffer_length); | 1204 | //d("TINY %d %s %d", i, fld->name, req->inBind[i].buffer_length); |
1205 | break; | 1205 | break; |
1206 | } | 1206 | } |
1207 | 1207 | ||
1208 | case MYSQL_TYPE_SHORT: | 1208 | case MYSQL_TYPE_SHORT: |
1209 | { | 1209 | { |
1210 | req->inBind[i].is_unsigned = FALSE; | 1210 | req->inBind[i].is_unsigned = FALSE; |
1211 | d("SHORT %d %s %d", i, fld->name, req->inBind[i].buffer_length); | 1211 | //d("SHORT %d %s %d", i, fld->name, req->inBind[i].buffer_length); |
1212 | break; | 1212 | break; |
1213 | } | 1213 | } |
1214 | 1214 | ||
1215 | case MYSQL_TYPE_INT24: | 1215 | case MYSQL_TYPE_INT24: |
1216 | { | 1216 | { |
1217 | req->inBind[i].is_unsigned = FALSE; | 1217 | req->inBind[i].is_unsigned = FALSE; |
1218 | d("INT24 %d %s %d", i, fld->name, req->inBind[i].buffer_length); | 1218 | //d("INT24 %d %s %d", i, fld->name, req->inBind[i].buffer_length); |
1219 | break; | 1219 | break; |
1220 | } | 1220 | } |
1221 | 1221 | ||
1222 | case MYSQL_TYPE_LONG: | 1222 | case MYSQL_TYPE_LONG: |
1223 | { | 1223 | { |
1224 | req->inBind[i].is_unsigned = FALSE; | 1224 | req->inBind[i].is_unsigned = FALSE; |
1225 | d("LONG %d %s %d", i, fld->name, req->inBind[i].buffer_length); | 1225 | //d("LONG %d %s %d", i, fld->name, req->inBind[i].buffer_length); |
1226 | break; | 1226 | break; |
1227 | } | 1227 | } |
1228 | 1228 | ||
1229 | case MYSQL_TYPE_LONGLONG: | 1229 | case MYSQL_TYPE_LONGLONG: |
1230 | { | 1230 | { |
1231 | req->inBind[i].is_unsigned = FALSE; | 1231 | req->inBind[i].is_unsigned = FALSE; |
1232 | d("LONGLONG %d %s %d", i, fld->name, req->inBind[i].buffer_length); | 1232 | //d("LONGLONG %d %s %d", i, fld->name, req->inBind[i].buffer_length); |
1233 | break; | 1233 | break; |
1234 | } | 1234 | } |
1235 | 1235 | ||
1236 | case MYSQL_TYPE_FLOAT: | 1236 | case MYSQL_TYPE_FLOAT: |
1237 | { | 1237 | { |
1238 | d("FLOAT %d %s %d", i, fld->name, req->inBind[i].buffer_length); | 1238 | //d("FLOAT %d %s %d", i, fld->name, req->inBind[i].buffer_length); |
1239 | break; | 1239 | break; |
1240 | } | 1240 | } |
1241 | 1241 | ||
1242 | case MYSQL_TYPE_DOUBLE: | 1242 | case MYSQL_TYPE_DOUBLE: |
1243 | { | 1243 | { |
1244 | d("DOUBLE %d %s %d", i, fld->name, req->inBind[i].buffer_length); | 1244 | //d("DOUBLE %d %s %d", i, fld->name, req->inBind[i].buffer_length); |
1245 | break; | 1245 | break; |
1246 | } | 1246 | } |
1247 | 1247 | ||
1248 | case MYSQL_TYPE_NEWDECIMAL: | 1248 | case MYSQL_TYPE_NEWDECIMAL: |
1249 | { | 1249 | { |
1250 | d("NEWDECIMAL %d %s %d", i, fld->name, req->inBind[i].buffer_length); | 1250 | //d("NEWDECIMAL %d %s %d", i, fld->name, req->inBind[i].buffer_length); |
1251 | break; | 1251 | break; |
1252 | } | 1252 | } |
1253 | 1253 | ||
@@ -1256,14 +1256,14 @@ d("NEWDECIMAL %d %s %d", i, fld->name, req->inBind[i].buffer_length); | |||
1256 | case MYSQL_TYPE_DATETIME: | 1256 | case MYSQL_TYPE_DATETIME: |
1257 | case MYSQL_TYPE_TIMESTAMP: | 1257 | case MYSQL_TYPE_TIMESTAMP: |
1258 | { | 1258 | { |
1259 | d("DATE / TIME ish %d %s %d", i, fld->name, req->inBind[i].buffer_length); | 1259 | //d("DATE / TIME ish %d %s %d", i, fld->name, req->inBind[i].buffer_length); |
1260 | break; | 1260 | break; |
1261 | } | 1261 | } |
1262 | 1262 | ||
1263 | case MYSQL_TYPE_STRING: | 1263 | case MYSQL_TYPE_STRING: |
1264 | case MYSQL_TYPE_VAR_STRING: | 1264 | case MYSQL_TYPE_VAR_STRING: |
1265 | { | 1265 | { |
1266 | d("STRING / VARSTRING %d %s %d", i, fld->name, req->inBind[i].buffer_length); | 1266 | //d("STRING / VARSTRING %d %s %d", i, fld->name, req->inBind[i].buffer_length); |
1267 | req->inBind[i].is_null = xzalloc(sizeof(my_bool)); | 1267 | req->inBind[i].is_null = xzalloc(sizeof(my_bool)); |
1268 | req->inBind[i].length = xzalloc(sizeof(unsigned long)); | 1268 | req->inBind[i].length = xzalloc(sizeof(unsigned long)); |
1269 | break; | 1269 | break; |
@@ -1274,7 +1274,7 @@ d("STRING / VARSTRING %d %s %d", i, fld->name, req->inBind[i].buffer_length); | |||
1274 | case MYSQL_TYPE_MEDIUM_BLOB: | 1274 | case MYSQL_TYPE_MEDIUM_BLOB: |
1275 | case MYSQL_TYPE_LONG_BLOB: | 1275 | case MYSQL_TYPE_LONG_BLOB: |
1276 | { | 1276 | { |
1277 | d("BLOBs %d %s %d", i, fld->name, req->inBind[i].buffer_length); | 1277 | //d("BLOBs %d %s %d", i, fld->name, req->inBind[i].buffer_length); |
1278 | req->inBind[i].is_null = xzalloc(sizeof(my_bool)); | 1278 | req->inBind[i].is_null = xzalloc(sizeof(my_bool)); |
1279 | break; | 1279 | break; |
1280 | } | 1280 | } |
@@ -1282,13 +1282,13 @@ d("BLOBs %d %s %d", i, fld->name, req->inBind[i].buffer_length); | |||
1282 | case MYSQL_TYPE_BIT: | 1282 | case MYSQL_TYPE_BIT: |
1283 | { | 1283 | { |
1284 | req->inBind[i].is_null = xzalloc(sizeof(my_bool)); | 1284 | req->inBind[i].is_null = xzalloc(sizeof(my_bool)); |
1285 | d("BIT %d %s %d", i, fld->name, req->inBind[i].buffer_length); | 1285 | //d("BIT %d %s %d", i, fld->name, req->inBind[i].buffer_length); |
1286 | break; | 1286 | break; |
1287 | } | 1287 | } |
1288 | 1288 | ||
1289 | case MYSQL_TYPE_NULL: | 1289 | case MYSQL_TYPE_NULL: |
1290 | { | 1290 | { |
1291 | d("NULL %d %s %d", i, fld->name, req->inBind[i].buffer_length); | 1291 | //d("NULL %d %s %d", i, fld->name, req->inBind[i].buffer_length); |
1292 | break; | 1292 | break; |
1293 | } | 1293 | } |
1294 | } | 1294 | } |
@@ -1340,7 +1340,7 @@ I("count!!!!!!!!!!!!!!!!"); | |||
1340 | goto freeIt; | 1340 | goto freeIt; |
1341 | } | 1341 | } |
1342 | req->outBind = xzalloc(i * sizeof(MYSQL_BIND)); | 1342 | req->outBind = xzalloc(i * sizeof(MYSQL_BIND)); |
1343 | W("Allocated %d %d outBinds for %s", i, req->outCount, req->sql); | 1343 | //W("Allocated %d %d outBinds for %s", i, req->outCount, req->sql); |
1344 | for (i = 0; i < req->outCount; i++) | 1344 | for (i = 0; i < req->outCount; i++) |
1345 | { | 1345 | { |
1346 | dbField *fld = req->flds->get(req->flds, req->outParams[i], NULL, false); | 1346 | dbField *fld = req->flds->get(req->flds, req->outParams[i], NULL, false); |
@@ -1464,7 +1464,7 @@ W("Allocated %d %d outBinds for %s", i, req->outCount, req->sql); | |||
1464 | } | 1464 | } |
1465 | 1465 | ||
1466 | 1466 | ||
1467 | d("input bind for %s", req->sql); | 1467 | //d("input bind for %s", req->sql); |
1468 | for (i = 0; i < req->inCount; i++) | 1468 | for (i = 0; i < req->inCount; i++) |
1469 | { | 1469 | { |
1470 | dbField *fld = req->flds->get(req->flds, req->inParams[i], NULL, false); | 1470 | dbField *fld = req->flds->get(req->flds, req->inParams[i], NULL, false); |
@@ -1485,7 +1485,7 @@ d("input bind for %s", req->sql); | |||
1485 | signed char d = (signed char) c; | 1485 | signed char d = (signed char) c; |
1486 | 1486 | ||
1487 | memcpy(req->inBind[i].buffer, &d, (size_t) fld->length); | 1487 | memcpy(req->inBind[i].buffer, &d, (size_t) fld->length); |
1488 | T("TINY %d %s %d", i, fld->name, req->inBind[i].buffer_length); | 1488 | //T("TINY %d %s %d", i, fld->name, req->inBind[i].buffer_length); |
1489 | break; | 1489 | break; |
1490 | } | 1490 | } |
1491 | 1491 | ||
@@ -1495,7 +1495,7 @@ T("TINY %d %s %d", i, fld->name, req->inBind[i].buffer_length); | |||
1495 | short int d = (short int) c; | 1495 | short int d = (short int) c; |
1496 | 1496 | ||
1497 | memcpy(req->inBind[i].buffer, &d, (size_t) fld->length); | 1497 | memcpy(req->inBind[i].buffer, &d, (size_t) fld->length); |
1498 | T("SHORT %d %s %d = %d", i, fld->name, req->inBind[i].buffer_length, c); | 1498 | //T("SHORT %d %s %d = %d", i, fld->name, req->inBind[i].buffer_length, c); |
1499 | break; | 1499 | break; |
1500 | } | 1500 | } |
1501 | 1501 | ||
@@ -1504,7 +1504,7 @@ T("SHORT %d %s %d = %d", i, fld->name, req->inBind[i].buffer_length, c); | |||
1504 | int d = va_arg(ap, int); | 1504 | int d = va_arg(ap, int); |
1505 | 1505 | ||
1506 | memcpy(req->inBind[i].buffer, &d, (size_t) fld->length); | 1506 | memcpy(req->inBind[i].buffer, &d, (size_t) fld->length); |
1507 | T("INT24 %d %s %d - %d", i, fld->name, req->inBind[i].buffer_length, d); | 1507 | //T("INT24 %d %s %d - %d", i, fld->name, req->inBind[i].buffer_length, d); |
1508 | break; | 1508 | break; |
1509 | } | 1509 | } |
1510 | 1510 | ||
@@ -1513,7 +1513,7 @@ T("INT24 %d %s %d - %d", i, fld->name, req->inBind[i].buffer_length, d); | |||
1513 | long d = va_arg(ap, long); | 1513 | long d = va_arg(ap, long); |
1514 | 1514 | ||
1515 | memcpy(req->inBind[i].buffer, &d, (size_t) fld->length); | 1515 | memcpy(req->inBind[i].buffer, &d, (size_t) fld->length); |
1516 | T("LONG %d %s %d = %ld", i, fld->name, req->inBind[i].buffer_length, d); | 1516 | //T("LONG %d %s %d = %ld", i, fld->name, req->inBind[i].buffer_length, d); |
1517 | break; | 1517 | break; |
1518 | } | 1518 | } |
1519 | 1519 | ||
@@ -1522,7 +1522,7 @@ T("LONG %d %s %d = %ld", i, fld->name, req->inBind[i].buffer_length, d); | |||
1522 | long long int d = va_arg(ap, long long int); | 1522 | long long int d = va_arg(ap, long long int); |
1523 | 1523 | ||
1524 | memcpy(req->inBind[i].buffer, &d, (size_t) fld->length); | 1524 | memcpy(req->inBind[i].buffer, &d, (size_t) fld->length); |
1525 | T("LONGLONG %d %s %d = %lld", i, fld->name, req->inBind[i].buffer_length, d); | 1525 | //T("LONGLONG %d %s %d = %lld", i, fld->name, req->inBind[i].buffer_length, d); |
1526 | break; | 1526 | break; |
1527 | } | 1527 | } |
1528 | 1528 | ||
@@ -1532,7 +1532,7 @@ T("LONGLONG %d %s %d = %lld", i, fld->name, req->inBind[i].buffer_length, d); | |||
1532 | float d = (float) c; | 1532 | float d = (float) c; |
1533 | 1533 | ||
1534 | memcpy(req->inBind[i].buffer, &d, (size_t) fld->length); | 1534 | memcpy(req->inBind[i].buffer, &d, (size_t) fld->length); |
1535 | T("FLOAT %d %s %d = %f", i, fld->name, req->inBind[i].buffer_length, d); | 1535 | //T("FLOAT %d %s %d = %f", i, fld->name, req->inBind[i].buffer_length, d); |
1536 | break; | 1536 | break; |
1537 | } | 1537 | } |
1538 | 1538 | ||
@@ -1541,13 +1541,13 @@ T("FLOAT %d %s %d = %f", i, fld->name, req->inBind[i].buffer_length, d); | |||
1541 | double d = va_arg(ap, double); | 1541 | double d = va_arg(ap, double); |
1542 | 1542 | ||
1543 | memcpy(req->inBind[i].buffer, &d, (size_t) fld->length); | 1543 | memcpy(req->inBind[i].buffer, &d, (size_t) fld->length); |
1544 | T("DOUBLE %d %s %d = %f", i, fld->name, req->inBind[i].buffer_length, d); | 1544 | //T("DOUBLE %d %s %d = %f", i, fld->name, req->inBind[i].buffer_length, d); |
1545 | break; | 1545 | break; |
1546 | } | 1546 | } |
1547 | 1547 | ||
1548 | case MYSQL_TYPE_NEWDECIMAL: | 1548 | case MYSQL_TYPE_NEWDECIMAL: |
1549 | { | 1549 | { |
1550 | T("NEWDECIMAL %d %s %d", i, fld->name, req->inBind[i].buffer_length); | 1550 | //T("NEWDECIMAL %d %s %d", i, fld->name, req->inBind[i].buffer_length); |
1551 | break; | 1551 | break; |
1552 | } | 1552 | } |
1553 | 1553 | ||
@@ -1559,7 +1559,7 @@ T("NEWDECIMAL %d %s %d", i, fld->name, req->inBind[i].buffer_length); | |||
1559 | MYSQL_TIME d = va_arg(ap, MYSQL_TIME); | 1559 | MYSQL_TIME d = va_arg(ap, MYSQL_TIME); |
1560 | 1560 | ||
1561 | memcpy(req->inBind[i].buffer, &d, (size_t) fld->length); | 1561 | memcpy(req->inBind[i].buffer, &d, (size_t) fld->length); |
1562 | T("DATE / TIME ish %d %s %d", i, fld->name, req->inBind[i].buffer_length); | 1562 | //T("DATE / TIME ish %d %s %d", i, fld->name, req->inBind[i].buffer_length); |
1563 | break; | 1563 | break; |
1564 | } | 1564 | } |
1565 | 1565 | ||
@@ -1574,7 +1574,7 @@ T("DATE / TIME ish %d %s %d", i, fld->name, req->inBind[i].buffer_length); | |||
1574 | *(req->inBind[i].length) = l; | 1574 | *(req->inBind[i].length) = l; |
1575 | strncpy(req->inBind[i].buffer, d, (size_t) l); | 1575 | strncpy(req->inBind[i].buffer, d, (size_t) l); |
1576 | ((char *) req->inBind[i].buffer)[l] = '\0'; | 1576 | ((char *) req->inBind[i].buffer)[l] = '\0'; |
1577 | T("STRING / VARSTRING %d %s %d = %s", i, fld->name, req->inBind[i].buffer_length, d); | 1577 | //T("STRING / VARSTRING %d %s %d = %s", i, fld->name, req->inBind[i].buffer_length, d); |
1578 | break; | 1578 | break; |
1579 | } | 1579 | } |
1580 | 1580 | ||
@@ -1583,20 +1583,20 @@ T("STRING / VARSTRING %d %s %d = %s", i, fld->name, req->inBind[i].buffer_length | |||
1583 | case MYSQL_TYPE_MEDIUM_BLOB: | 1583 | case MYSQL_TYPE_MEDIUM_BLOB: |
1584 | case MYSQL_TYPE_LONG_BLOB: | 1584 | case MYSQL_TYPE_LONG_BLOB: |
1585 | { | 1585 | { |
1586 | // TODO - should write this, we will likely need it. Main problem is - how long is this blob? Probably should add alongth param before the blob. | 1586 | // TODO - should write this, we will likely need it. Main problem is - how long is this blob? Probably should add a length param before the blob. |
1587 | T("BLOBs %d %s %d", i, fld->name, req->inBind[i].buffer_length); | 1587 | //T("BLOBs %d %s %d", i, fld->name, req->inBind[i].buffer_length); |
1588 | break; | 1588 | break; |
1589 | } | 1589 | } |
1590 | 1590 | ||
1591 | case MYSQL_TYPE_BIT: | 1591 | case MYSQL_TYPE_BIT: |
1592 | { | 1592 | { |
1593 | T("BIT %d %s %d", i, fld->name, req->inBind[i].buffer_length); | 1593 | //T("BIT %d %s %d", i, fld->name, req->inBind[i].buffer_length); |
1594 | break; | 1594 | break; |
1595 | } | 1595 | } |
1596 | 1596 | ||
1597 | case MYSQL_TYPE_NULL: | 1597 | case MYSQL_TYPE_NULL: |
1598 | { | 1598 | { |
1599 | T("NULL %d %s %d", i, fld->name, req->inBind[i].buffer_length); | 1599 | //T("NULL %d %s %d", i, fld->name, req->inBind[i].buffer_length); |
1600 | break; | 1600 | break; |
1601 | } | 1601 | } |
1602 | } | 1602 | } |
@@ -1610,7 +1610,7 @@ T("NULL %d %s %d", i, fld->name, req->inBind[i].buffer_length); | |||
1610 | } | 1610 | } |
1611 | 1611 | ||
1612 | 1612 | ||
1613 | d("Execute %s", req->sql); | 1613 | //d("Execute %s", req->sql); |
1614 | 1614 | ||
1615 | // do the prepared statement req->prep. | 1615 | // do the prepared statement req->prep. |
1616 | if (mysql_stmt_execute(req->prep)) | 1616 | if (mysql_stmt_execute(req->prep)) |
@@ -1772,6 +1772,7 @@ end: | |||
1772 | double n = (now.tv_sec * 1000000000.0) + now.tv_nsec; | 1772 | double n = (now.tv_sec * 1000000000.0) + now.tv_nsec; |
1773 | double t = (then.tv_sec * 1000000000.0) + then.tv_nsec; | 1773 | double t = (then.tv_sec * 1000000000.0) + then.tv_nsec; |
1774 | T("dbDoSomething(%s) took %lf seconds", req->sql, (n - t) / 1000000000.0); | 1774 | T("dbDoSomething(%s) took %lf seconds", req->sql, (n - t) / 1000000000.0); |
1775 | /* | ||
1775 | if (NULL != req->prep) | 1776 | if (NULL != req->prep) |
1776 | I("The prepared statement itself is NOT NULL."); | 1777 | I("The prepared statement itself is NOT NULL."); |
1777 | else | 1778 | else |
@@ -1781,6 +1782,7 @@ end: | |||
1781 | I("The prepared0 statement itself is NOT NULL."); | 1782 | I("The prepared0 statement itself is NOT NULL."); |
1782 | else | 1783 | else |
1783 | W("The prepared0 statement itself is NULL!"); | 1784 | W("The prepared0 statement itself is NULL!"); |
1785 | */ | ||
1784 | 1786 | ||
1785 | return ret; | 1787 | return ret; |
1786 | } | 1788 | } |