summaryrefslogtreecommitdiff
path: root/tests
diff options
context:
space:
mode:
authorunknown <konstantin@mysql.com>2004-10-13 19:27:07 +0400
committerunknown <konstantin@mysql.com>2004-10-13 19:27:07 +0400
commitba48e6f9aae98aea3128a7fd1695516424b53ad5 (patch)
treeff782b326a1cb9f03a582811d39722889598703a /tests
parent74c254182dad379fb81153fa227f5f8e84f67d39 (diff)
downloadmariadb-git-ba48e6f9aae98aea3128a7fd1695516424b53ad5.tar.gz
tests/client_test.c:
Make checks (asserts) performed in client_test.c work in non-debug builds. tests/client_test.c: Make checks (asserts) performed in client_test.c work in non-debug builds: all asserts/DBUG_ASSERTs replaced with if (!(expr)) abort();
Diffstat (limited to 'tests')
-rw-r--r--tests/client_test.c1078
1 files changed, 596 insertions, 482 deletions
diff --git a/tests/client_test.c b/tests/client_test.c
index ee8bc28165c..0b30cc3386d 100644
--- a/tests/client_test.c
+++ b/tests/client_test.c
@@ -26,7 +26,6 @@
#include <mysql.h>
#include <my_getopt.h>
#include <m_string.h>
-#include <assert.h>
#ifdef HAVE_SYS_PARAM_H
/* Include to get MAXPATHLEN */
#include <sys/param.h>
@@ -78,6 +77,28 @@ static void print_error(const char *msg);
static void print_st_error(MYSQL_STMT *stmt, const char *msg);
static void client_disconnect();
+
+/*
+ Abort unless given experssion is non-zero.
+
+ SYNOPSIS
+ DIE_UNLESS(expr)
+
+ DESCRIPTION
+ We can't use any kind of system assert as we need to
+ preserve tested invariants in release builds as well.
+*/
+
+#define DIE_UNLESS(expr) \
+ ((void) ((expr) ? 0 : (die(__FILE__, __LINE__, #expr), 0)))
+
+void die(const char *file, int line, const char *expr)
+{
+ fprintf(stderr, "%s:%d: check failed: '%s'\n", file, line, expr);
+ abort();
+}
+
+
#define myerror(msg) print_error(msg)
#define mysterror(stmt, msg) print_st_error(stmt, msg)
@@ -85,46 +106,46 @@ static void client_disconnect();
{ \
if (r) \
myerror(NULL); \
- assert(r == 0); \
+ DIE_UNLESS(r == 0); \
}
#define myquery_r(r) \
{ \
if (r) \
myerror(NULL); \
-assert(r != 0); \
+DIE_UNLESS(r != 0); \
}
#define check_execute(stmt, r) \
{ \
if (r) \
mysterror(stmt, NULL); \
-assert(r == 0);\
+DIE_UNLESS(r == 0);\
}
#define check_execute_r(stmt, r) \
{ \
if (r) \
mysterror(stmt, NULL); \
-assert(r != 0);\
+DIE_UNLESS(r != 0);\
}
#define check_stmt(stmt) \
{ \
if ( stmt == 0) \
myerror(NULL); \
-assert(stmt != 0); \
+DIE_UNLESS(stmt != 0); \
}
#define check_stmt_r(stmt) \
{ \
if (stmt == 0) \
myerror(NULL);\
-assert(stmt == 0);\
+DIE_UNLESS(stmt == 0);\
}
-#define mytest(x) if (!x) {myerror(NULL);assert(TRUE);}
-#define mytest_r(x) if (x) {myerror(NULL);assert(TRUE);}
+#define mytest(x) if (!x) {myerror(NULL);DIE_UNLESS(FALSE);}
+#define mytest_r(x) if (x) {myerror(NULL);DIE_UNLESS(FALSE);}
/* Print the error message */
@@ -413,10 +434,10 @@ int my_process_result(MYSQL *mysql)
#define MAX_RES_FIELDS 50
#define MAX_FIELD_DATA_SIZE 255
-uint my_process_stmt_result(MYSQL_STMT *stmt)
+int my_process_stmt_result(MYSQL_STMT *stmt)
{
int field_count;
- uint row_count= 0;
+ int row_count= 0;
MYSQL_BIND buffer[MAX_RES_FIELDS];
MYSQL_FIELD *field;
MYSQL_RES *result;
@@ -492,10 +513,10 @@ uint my_process_stmt_result(MYSQL_STMT *stmt)
/* Prepare statement, execute, and process result set for given query */
-uint my_stmt_result(const char *buff)
+int my_stmt_result(const char *buff)
{
MYSQL_STMT *stmt;
- uint row_count;
+ int row_count;
int rc;
fprintf(stdout, "\n\n %s", buff);
@@ -543,7 +564,7 @@ static void verify_col_data(const char *table, const char *col,
{
fprintf(stdout, "\n obtained: `%s` (expected: `%s`)",
row[field], exp_data);
- assert(0);
+ DIE_UNLESS(FALSE);
}
mysql_free_result(result);
}
@@ -581,15 +602,15 @@ static void verify_prepare_field(MYSQL_RES *result,
fprintf(stdout, "\n default :`%s`\t(expected: `%s`)",
field->def ? field->def : "(null)", def ? def: "(null)");
fprintf(stdout, "\n");
- assert(strcmp(field->name, name) == 0);
- assert(strcmp(field->org_name, org_name) == 0);
- assert(field->type == type);
- assert(strcmp(field->table, table) == 0);
- assert(strcmp(field->org_table, org_table) == 0);
- assert(strcmp(field->db, db) == 0);
- assert(field->length == length);
+ DIE_UNLESS(strcmp(field->name, name) == 0);
+ DIE_UNLESS(strcmp(field->org_name, org_name) == 0);
+ DIE_UNLESS(field->type == type);
+ DIE_UNLESS(strcmp(field->table, table) == 0);
+ DIE_UNLESS(strcmp(field->org_table, org_table) == 0);
+ DIE_UNLESS(strcmp(field->db, db) == 0);
+ DIE_UNLESS(field->length == length);
if (def)
- assert(strcmp(field->def, def) == 0);
+ DIE_UNLESS(strcmp(field->def, def) == 0);
}
@@ -600,7 +621,7 @@ static void verify_param_count(MYSQL_STMT *stmt, long exp_count)
long param_count= mysql_stmt_param_count(stmt);
fprintf(stdout, "\n total parameters in stmt: `%ld` (expected: `%ld`)",
param_count, exp_count);
- assert(param_count == exp_count);
+ DIE_UNLESS(param_count == exp_count);
}
@@ -611,7 +632,7 @@ static void verify_st_affected_rows(MYSQL_STMT *stmt, ulonglong exp_count)
ulonglong affected_rows= mysql_stmt_affected_rows(stmt);
fprintf(stdout, "\n total affected rows: `%lld` (expected: `%lld`)",
affected_rows, exp_count);
- assert(affected_rows == exp_count);
+ DIE_UNLESS(affected_rows == exp_count);
}
@@ -622,7 +643,7 @@ static void verify_affected_rows(ulonglong exp_count)
ulonglong affected_rows= mysql_affected_rows(mysql);
fprintf(stdout, "\n total affected rows: `%lld` (expected: `%lld`)",
affected_rows, exp_count);
- assert(affected_rows == exp_count);
+ DIE_UNLESS(affected_rows == exp_count);
}
@@ -633,7 +654,7 @@ static void verify_field_count(MYSQL_RES *result, uint exp_count)
uint field_count= mysql_num_fields(result);
fprintf(stdout, "\n total fields in the result set: `%d` (expected: `%d`)",
field_count, exp_count);
- assert(field_count == exp_count);
+ DIE_UNLESS(field_count == exp_count);
}
@@ -655,7 +676,7 @@ static void execute_prepare_query(const char *query, ulonglong exp_count)
fprintf(stdout, "\n total affected rows: `%lld` (expected: `%lld`)",
affected_rows, exp_count);
- assert(affected_rows == exp_count);
+ DIE_UNLESS(affected_rows == exp_count);
mysql_stmt_close(stmt);
}
@@ -676,7 +697,7 @@ static void client_store_result()
result= mysql_store_result(mysql);
mytest(result);
- my_process_result_set(result);
+ (void) my_process_result_set(result);
mysql_free_result(result);
}
@@ -696,7 +717,7 @@ static void client_use_result()
result= mysql_use_result(mysql);
mytest(result);
- my_process_result_set(result);
+ (void) my_process_result_set(result);
mysql_free_result(result);
}
@@ -767,7 +788,7 @@ static void test_debug_example()
result= mysql_use_result(mysql);
mytest(result);
- my_process_result_set(result);
+ (void) my_process_result_set(result);
mysql_free_result(result);
rc= mysql_query(mysql, "DROP TABLE test_debug_example");
@@ -827,7 +848,7 @@ static void test_tran_bdb()
result= mysql_store_result(mysql);
mytest(result);
- my_process_result_set(result);
+ (void) my_process_result_set(result);
mysql_free_result(result);
/* test the results now, only one row should exist */
@@ -900,7 +921,7 @@ static void test_tran_innodb()
result= mysql_store_result(mysql);
mytest(result);
- my_process_result_set(result);
+ (void) my_process_result_set(result);
mysql_free_result(result);
/* test the results now, only one row should exist */
@@ -1167,7 +1188,8 @@ static void test_prepare()
myquery(rc);
/* test the results now, only one row should exist */
- assert(tiny_data == (char) my_stmt_result("SELECT * FROM my_prepare"));
+ rc= my_stmt_result("SELECT * FROM my_prepare");
+ DIE_UNLESS(tiny_data == (char) rc);
stmt= mysql_simple_prepare(mysql, "SELECT * FROM my_prepare");
check_stmt(stmt);
@@ -1205,27 +1227,27 @@ static void test_prepare()
fprintf(stdout, "\n\t str : %s (%lu)", str_data, length[1]);
- assert(tiny_data == o_tiny_data);
- assert(is_null[0] == 0);
- assert(length[0] == 1);
+ DIE_UNLESS(tiny_data == o_tiny_data);
+ DIE_UNLESS(is_null[0] == 0);
+ DIE_UNLESS(length[0] == 1);
- assert(int_data == o_int_data);
- assert(length[2] == 4);
+ DIE_UNLESS(int_data == o_int_data);
+ DIE_UNLESS(length[2] == 4);
- assert(small_data == o_small_data);
- assert(length[3] == 2);
+ DIE_UNLESS(small_data == o_small_data);
+ DIE_UNLESS(length[3] == 2);
- assert(big_data == o_big_data);
- assert(length[4] == 8);
+ DIE_UNLESS(big_data == o_big_data);
+ DIE_UNLESS(length[4] == 8);
- assert(real_data == o_real_data);
- assert(length[5] == 4);
+ DIE_UNLESS(real_data == o_real_data);
+ DIE_UNLESS(length[5] == 4);
- assert(double_data == o_double_data);
- assert(length[6] == 8);
+ DIE_UNLESS(double_data == o_double_data);
+ DIE_UNLESS(length[6] == 8);
- assert(strcmp(data, str_data) == 0);
- assert(length[1] == len);
+ DIE_UNLESS(strcmp(data, str_data) == 0);
+ DIE_UNLESS(length[1] == len);
o_int_data += 25;
o_small_data += 10;
@@ -1235,7 +1257,7 @@ static void test_prepare()
}
rc= mysql_stmt_fetch(stmt);
- assert(rc == MYSQL_NO_DATA);
+ DIE_UNLESS(rc == MYSQL_NO_DATA);
mysql_stmt_close(stmt);
@@ -1320,7 +1342,8 @@ static void test_double_compare()
result= mysql_store_result(mysql);
mytest(result);
- assert((int)tiny_data == my_process_result_set(result));
+ rc= my_process_result_set(result);
+ DIE_UNLESS((int)tiny_data == rc);
mysql_free_result(result);
}
@@ -1393,7 +1416,8 @@ static void test_null()
myquery(rc);
nData*= 2;
- assert(nData == my_stmt_result("SELECT * FROM test_null"));
+ rc= my_stmt_result("SELECT * FROM test_null");;
+ DIE_UNLESS((int) nData == rc);
/* Fetch results */
bind[0].buffer_type= MYSQL_TYPE_LONG;
@@ -1416,12 +1440,12 @@ static void test_null()
is_null[0]= is_null[1]= 0;
while (mysql_stmt_fetch(stmt) != MYSQL_NO_DATA)
{
- assert(is_null[0]);
- assert(is_null[1]);
+ DIE_UNLESS(is_null[0]);
+ DIE_UNLESS(is_null[1]);
rc++;
is_null[0]= is_null[1]= 0;
}
- assert(rc == (int)nData);
+ DIE_UNLESS(rc == (int) nData);
mysql_stmt_close(stmt);
}
@@ -1491,10 +1515,10 @@ static void test_ps_null_param()
rc= mysql_stmt_execute(stmt);
check_execute(stmt, rc);
rc= mysql_stmt_fetch(stmt);
- assert(rc != MYSQL_NO_DATA);
- assert(out_is_null);
+ DIE_UNLESS(rc != MYSQL_NO_DATA);
+ DIE_UNLESS(out_is_null);
rc= mysql_stmt_fetch(stmt);
- assert(rc == MYSQL_NO_DATA);
+ DIE_UNLESS(rc == MYSQL_NO_DATA);
mysql_stmt_close(stmt);
}
}
@@ -1544,7 +1568,8 @@ static void test_fetch_null()
strmov((char *)query , "SELECT * FROM test_fetch_null");
- assert(3 == my_stmt_result(query));
+ rc= my_stmt_result(query);
+ DIE_UNLESS(rc == 3);
stmt= mysql_simple_prepare(mysql, query);
check_stmt(stmt);
@@ -1563,14 +1588,14 @@ static void test_fetch_null()
{
fprintf(stdout, "\n data[%d] : %s", i,
is_null[i] ? "NULL" : "NOT NULL");
- assert(is_null[i]);
+ DIE_UNLESS(is_null[i]);
}
fprintf(stdout, "\n data[%d]: %d", i, nData);
- assert(nData == 1000 || nData == 88 || nData == 389789);
- assert(is_null[i] == 0);
- assert(length[i] == 4);
+ DIE_UNLESS(nData == 1000 || nData == 88 || nData == 389789);
+ DIE_UNLESS(is_null[i] == 0);
+ DIE_UNLESS(length[i] == 4);
}
- assert(rc == 3);
+ DIE_UNLESS(rc == 3);
mysql_stmt_close(stmt);
}
@@ -1657,7 +1682,7 @@ static void test_select_direct()
result= mysql_store_result(mysql);
mytest(result);
- my_process_result_set(result);
+ (void) my_process_result_set(result);
mysql_free_result(result);
}
@@ -1693,7 +1718,8 @@ static void test_select_prepare()
rc= mysql_stmt_execute(stmt);
check_execute(stmt, rc);
- assert(1 == my_process_stmt_result(stmt));
+ rc= my_process_stmt_result(stmt);
+ DIE_UNLESS(rc == 1);
mysql_stmt_close(stmt);
rc= mysql_query(mysql, "DROP TABLE test_select");
@@ -1717,7 +1743,8 @@ static void test_select_prepare()
rc= mysql_stmt_execute(stmt);
check_execute(stmt, rc);
- assert(1 == my_process_stmt_result(stmt));
+ rc= my_process_stmt_result(stmt);
+ DIE_UNLESS(rc == 1);
mysql_stmt_close(stmt);
}
@@ -1782,7 +1809,8 @@ static void test_select()
rc= mysql_stmt_execute(stmt);
check_execute(stmt, rc);
- assert(my_process_stmt_result(stmt) == 1);
+ rc= my_process_stmt_result(stmt);
+ DIE_UNLESS(rc == 1);
mysql_stmt_close(stmt);
}
@@ -1841,7 +1869,8 @@ static void test_ps_conj_select()
rc= mysql_stmt_execute(stmt);
check_execute(stmt, rc);
- assert(my_process_stmt_result(stmt) == 3);
+ rc= my_process_stmt_result(stmt);
+ DIE_UNLESS(rc == 3);
mysql_stmt_close(stmt);
}
@@ -1914,7 +1943,8 @@ session_id char(9) NOT NULL, \
rc= mysql_stmt_execute(stmt);
check_execute(stmt, rc);
- assert(my_process_stmt_result(stmt) == 1);
+ rc= my_process_stmt_result(stmt);
+ DIE_UNLESS(rc == 1);
strmov(szData, (char *)"venu");
bind[0].buffer_type= MYSQL_TYPE_STRING;
@@ -1930,7 +1960,8 @@ session_id char(9) NOT NULL, \
rc= mysql_stmt_execute(stmt);
check_execute(stmt, rc);
- assert(my_process_stmt_result(stmt) == 0);
+ rc= my_process_stmt_result(stmt);
+ DIE_UNLESS(rc == 0);
strmov(szData, (char *)"abc");
bind[0].buffer_type= MYSQL_TYPE_STRING;
@@ -1946,7 +1977,8 @@ session_id char(9) NOT NULL, \
rc= mysql_stmt_execute(stmt);
check_execute(stmt, rc);
- assert(my_process_stmt_result(stmt) == 1);
+ rc= my_process_stmt_result(stmt);
+ DIE_UNLESS(rc == 1);
mysql_stmt_close(stmt);
}
@@ -1996,7 +2028,8 @@ static void test_bug1180()
rc= mysql_stmt_execute(stmt);
check_execute(stmt, rc);
- assert(my_process_stmt_result(stmt) == 0);
+ rc= my_process_stmt_result(stmt);
+ DIE_UNLESS(rc == 0);
strmov(szData, (char *)"1111");
bind[0].buffer_type= MYSQL_TYPE_STRING;
@@ -2012,7 +2045,8 @@ static void test_bug1180()
rc= mysql_stmt_execute(stmt);
check_execute(stmt, rc);
- assert(my_process_stmt_result(stmt) == 1);
+ rc= my_process_stmt_result(stmt);
+ DIE_UNLESS(rc == 1);
strmov(szData, (char *)"abc");
bind[0].buffer_type= MYSQL_TYPE_STRING;
@@ -2028,7 +2062,8 @@ static void test_bug1180()
rc= mysql_stmt_execute(stmt);
check_execute(stmt, rc);
- assert(my_process_stmt_result(stmt) == 0);
+ rc= my_process_stmt_result(stmt);
+ DIE_UNLESS(rc == 0);
mysql_stmt_close(stmt);
}
@@ -2111,7 +2146,8 @@ static void test_bug1644()
result= mysql_store_result(mysql);
mytest(result);
- assert(3 == my_process_result_set(result));
+ rc= my_process_result_set(result);
+ DIE_UNLESS(rc == 3);
mysql_data_seek(result, 0);
@@ -2119,19 +2155,19 @@ static void test_bug1644()
mytest(row);
for (i= 0 ; i < 4 ; i++)
{
- assert(strcmp(row[i], "22") == 0);
+ DIE_UNLESS(strcmp(row[i], "22") == 0);
}
row= mysql_fetch_row(result);
mytest(row);
for (i= 0 ; i < 4 ; i++)
{
- assert(row[i] == 0);
+ DIE_UNLESS(row[i] == 0);
}
row= mysql_fetch_row(result);
mytest(row);
for (i= 0 ; i < 4 ; i++)
{
- assert(strcmp(row[i], "88") == 0);
+ DIE_UNLESS(strcmp(row[i], "88") == 0);
}
row= mysql_fetch_row(result);
mytest_r(row);
@@ -2197,7 +2233,8 @@ static void test_select_show()
rc= mysql_stmt_execute(stmt);
check_execute(stmt, rc);
- assert(1 == my_process_stmt_result(stmt));
+ rc= my_process_stmt_result(stmt);
+ DIE_UNLESS(rc == 1);
mysql_stmt_close(stmt);
}
@@ -2275,7 +2312,8 @@ static void test_simple_update()
result= mysql_store_result(mysql);
mytest(result);
- assert(1 == my_process_result_set(result));
+ rc= my_process_result_set(result);
+ DIE_UNLESS(rc == 1);
mysql_free_result(result);
}
@@ -2351,7 +2389,8 @@ static void test_long_data()
result= mysql_store_result(mysql);
mytest(result);
- assert(1 == my_process_result_set(result));
+ rc= my_process_result_set(result);
+ DIE_UNLESS(rc == 1);
mysql_free_result(result);
verify_col_data("test_long_data", "col1", "999");
@@ -2435,7 +2474,8 @@ static void test_long_data_str()
result= mysql_store_result(mysql);
mytest(result);
- assert(1 == my_process_result_set(result));
+ rc= my_process_result_set(result);
+ DIE_UNLESS(rc == 1);
mysql_free_result(result);
my_sprintf(data, (data, "%d", i*5));
@@ -2530,7 +2570,8 @@ static void test_long_data_str1()
mytest(result);
- assert(1 == my_process_result_set(result));
+ rc= my_process_result_set(result);
+ DIE_UNLESS(rc == 1);
mysql_free_result(result);
my_sprintf(data, (data, "%ld", (long)i*length));
@@ -2554,7 +2595,7 @@ static void test_long_data_str1()
field= mysql_fetch_fields(result);
/* First test what happens if STMT_ATTR_UPDATE_MAX_LENGTH is not used */
- DBUG_ASSERT(field->max_length == 0);
+ DIE_UNLESS(field->max_length == 0);
mysql_free_result(result);
/* Enable updating of field->max_length */
@@ -2569,7 +2610,7 @@ static void test_long_data_str1()
result= mysql_stmt_result_metadata(stmt);
field= mysql_fetch_fields(result);
- DBUG_ASSERT(field->max_length == max_blob_length);
+ DIE_UNLESS(field->max_length == max_blob_length);
/* Fetch results into a data buffer that is smaller than data */
bzero((char*) bind, sizeof(*bind));
@@ -2580,9 +2621,10 @@ static void test_long_data_str1()
rc= mysql_stmt_bind_result(stmt, bind);
data[16]= 0;
- DBUG_ASSERT((mysql_stmt_fetch(stmt) == 0));
- DBUG_ASSERT(strlen(data) == 16);
- DBUG_ASSERT(blob_length == max_blob_length);
+ rc= mysql_stmt_fetch(stmt);
+ DIE_UNLESS(rc == 0);
+ DIE_UNLESS(strlen(data) == 16);
+ DIE_UNLESS(blob_length == max_blob_length);
/* Fetch all data */
bzero((char*) (bind+1), sizeof(*bind));
@@ -2592,7 +2634,7 @@ static void test_long_data_str1()
bind[1].length= &blob_length;
bzero(data, sizeof(data));
mysql_stmt_fetch_column(stmt, bind+1, 0, 0);
- DBUG_ASSERT(strlen(data) == max_blob_length);
+ DIE_UNLESS(strlen(data) == max_blob_length);
mysql_free_result(result);
mysql_stmt_close(stmt);
@@ -2674,7 +2716,8 @@ static void test_long_data_bin()
result= mysql_store_result(mysql);
mytest(result);
- assert(1 == my_process_result_set(result));
+ rc= my_process_result_set(result);
+ DIE_UNLESS(rc == 1);
mysql_free_result(result);
}
@@ -2754,7 +2797,8 @@ static void test_simple_delete()
result= mysql_store_result(mysql);
mytest(result);
- assert(0 == my_process_result_set(result));
+ rc= my_process_result_set(result);
+ DIE_UNLESS(rc == 0);
mysql_free_result(result);
}
@@ -2853,7 +2897,8 @@ static void test_update()
result= mysql_store_result(mysql);
mytest(result);
- assert(1 == my_process_result_set(result));
+ rc= my_process_result_set(result);
+ DIE_UNLESS(rc == 1);
mysql_free_result(result);
}
@@ -2899,7 +2944,8 @@ static void test_prepare_noparam()
result= mysql_store_result(mysql);
mytest(result);
- assert(1 == my_process_result_set(result));
+ rc= my_process_result_set(result);
+ DIE_UNLESS(rc == 1);
mysql_free_result(result);
}
@@ -2962,17 +3008,17 @@ static void test_bind_result()
check_execute(stmt, rc);
fprintf(stdout, "\n row 1: %d, %s(%lu)", nData, szData, length1);
- assert(nData == 10);
- assert(strcmp(szData, "venu") == 0);
- assert(length1 == 4);
+ DIE_UNLESS(nData == 10);
+ DIE_UNLESS(strcmp(szData, "venu") == 0);
+ DIE_UNLESS(length1 == 4);
rc= mysql_stmt_fetch(stmt);
check_execute(stmt, rc);
fprintf(stdout, "\n row 2: %d, %s(%lu)", nData, szData, length1);
- assert(nData == 20);
- assert(strcmp(szData, "MySQL") == 0);
- assert(length1 == 5);
+ DIE_UNLESS(nData == 20);
+ DIE_UNLESS(strcmp(szData, "MySQL") == 0);
+ DIE_UNLESS(length1 == 5);
length= 99;
rc= mysql_stmt_fetch(stmt);
@@ -2980,12 +3026,12 @@ static void test_bind_result()
if (is_null[0])
fprintf(stdout, "\n row 3: NULL, %s(%lu)", szData, length1);
- assert(is_null[0]);
- assert(strcmp(szData, "monty") == 0);
- assert(length1 == 5);
+ DIE_UNLESS(is_null[0]);
+ DIE_UNLESS(strcmp(szData, "monty") == 0);
+ DIE_UNLESS(length1 == 5);
rc= mysql_stmt_fetch(stmt);
- assert(rc == MYSQL_NO_DATA);
+ DIE_UNLESS(rc == MYSQL_NO_DATA);
mysql_stmt_close(stmt);
}
@@ -3090,19 +3136,19 @@ static void test_bind_result_ext()
fprintf(stdout, "\n data (bin) : %s(%lu)", bData, bLength);
- assert(t_data == 19);
- assert(s_data == 2999);
- assert(i_data == 3999);
- assert(b_data == 4999999);
- /*assert(f_data == 2345.60);*/
- /*assert(d_data == 5678.89563);*/
- assert(strcmp(szData, "venu") == 0);
- assert(strncmp(bData, "mysql", 5) == 0);
- assert(szLength == 4);
- assert(bLength == 5);
+ DIE_UNLESS(t_data == 19);
+ DIE_UNLESS(s_data == 2999);
+ DIE_UNLESS(i_data == 3999);
+ DIE_UNLESS(b_data == 4999999);
+ /*DIE_UNLESS(f_data == 2345.60);*/
+ /*DIE_UNLESS(d_data == 5678.89563);*/
+ DIE_UNLESS(strcmp(szData, "venu") == 0);
+ DIE_UNLESS(strncmp(bData, "mysql", 5) == 0);
+ DIE_UNLESS(szLength == 4);
+ DIE_UNLESS(bLength == 5);
rc= mysql_stmt_fetch(stmt);
- assert(rc == MYSQL_NO_DATA);
+ DIE_UNLESS(rc == MYSQL_NO_DATA);
mysql_stmt_close(stmt);
}
@@ -3207,23 +3253,23 @@ static void test_bind_result_ext1()
fprintf(stdout, "\n data (bin) : %ld(%lu)", bData, length[6]);
fprintf(stdout, "\n data (str) : %g(%lu)", szData, length[7]);
- assert(strcmp(t_data, "120") == 0);
- assert(i_data == 3999);
- assert(f_data == 2);
- assert(strcmp(d_data, "58.89") == 0);
- assert(b_data == 54);
-
- assert(length[0] == 3);
- assert(length[1] == 4);
- assert(length[2] == 2);
- assert(length[3] == 1);
- assert(length[4] == 4);
- assert(length[5] == 5);
- assert(length[6] == 4);
- assert(length[7] == 8);
+ DIE_UNLESS(strcmp(t_data, "120") == 0);
+ DIE_UNLESS(i_data == 3999);
+ DIE_UNLESS(f_data == 2);
+ DIE_UNLESS(strcmp(d_data, "58.89") == 0);
+ DIE_UNLESS(b_data == 54);
+
+ DIE_UNLESS(length[0] == 3);
+ DIE_UNLESS(length[1] == 4);
+ DIE_UNLESS(length[2] == 2);
+ DIE_UNLESS(length[3] == 1);
+ DIE_UNLESS(length[4] == 4);
+ DIE_UNLESS(length[5] == 5);
+ DIE_UNLESS(length[6] == 4);
+ DIE_UNLESS(length[7] == 8);
rc= mysql_stmt_fetch(stmt);
- assert(rc == MYSQL_NO_DATA);
+ DIE_UNLESS(rc == MYSQL_NO_DATA);
mysql_stmt_close(stmt);
}
@@ -3281,11 +3327,11 @@ static void bind_fetch(int row_count)
mysql_stmt_close(stmt);
- assert(row_count == (int)
- my_stmt_result("SELECT * FROM test_bind_fetch"));
+ rc= my_stmt_result("SELECT * FROM test_bind_fetch");
+ DIE_UNLESS(row_count == rc);
stmt= mysql_simple_prepare(mysql, "SELECT * FROM test_bind_fetch");
- myquery(rc);
+ check_stmt(stmt);
for (i= 0; i < (int) array_elements(bind); i++)
{
@@ -3342,45 +3388,45 @@ static void bind_fetch(int row_count)
rc= 10+row_count;
/* TINY */
- assert((int) i8_data == rc);
- assert(length[0] == 1);
+ DIE_UNLESS((int) i8_data == rc);
+ DIE_UNLESS(length[0] == 1);
rc+= 13;
/* SHORT */
- assert((int) i16_data == rc);
- assert(length[1] == 2);
+ DIE_UNLESS((int) i16_data == rc);
+ DIE_UNLESS(length[1] == 2);
rc+= 13;
/* LONG */
- assert((int) i32_data == rc);
- assert(length[2] == 4);
+ DIE_UNLESS((int) i32_data == rc);
+ DIE_UNLESS(length[2] == 4);
rc+= 13;
/* LONGLONG */
- assert((int) i64_data == rc);
- assert(length[3] == 8);
+ DIE_UNLESS((int) i64_data == rc);
+ DIE_UNLESS(length[3] == 8);
rc+= 13;
/* FLOAT */
- assert((int)f_data == rc);
- assert(length[4] == 4);
+ DIE_UNLESS((int)f_data == rc);
+ DIE_UNLESS(length[4] == 4);
rc+= 13;
/* DOUBLE */
- assert((int)d_data == rc);
- assert(length[5] == 8);
+ DIE_UNLESS((int)d_data == rc);
+ DIE_UNLESS(length[5] == 8);
rc+= 13;
/* CHAR */
{
char buff[20];
long len= my_sprintf(buff, (buff, "%d", rc));
- assert(strcmp(s_data, buff) == 0);
- assert(length[6] == (ulong) len);
+ DIE_UNLESS(strcmp(s_data, buff) == 0);
+ DIE_UNLESS(length[6] == (ulong) len);
}
}
rc= mysql_stmt_fetch(stmt);
- assert(rc == MYSQL_NO_DATA);
+ DIE_UNLESS(rc == MYSQL_NO_DATA);
mysql_stmt_close(stmt);
}
@@ -3464,7 +3510,8 @@ static void test_fetch_date()
bind[6].buffer_length= sizeof(ts_6);
bind[6].length= &ts6_length;
- assert(1 == my_stmt_result("SELECT * FROM test_bind_result"));
+ rc= my_stmt_result("SELECT * FROM test_bind_result");
+ DIE_UNLESS(rc == 1);
stmt= mysql_simple_prepare(mysql, "SELECT * FROM test_bind_result");
check_stmt(stmt);
@@ -3487,29 +3534,29 @@ static void test_fetch_date()
fprintf(stdout, "\n ts(4) : %s(%lu)", ts_4, ts4_length);
fprintf(stdout, "\n ts(6) : %s(%lu)", ts_6, ts6_length);
- assert(strcmp(date, "2002-01-02") == 0);
- assert(d_length == 10);
+ DIE_UNLESS(strcmp(date, "2002-01-02") == 0);
+ DIE_UNLESS(d_length == 10);
- assert(strcmp(time, "12:49:00") == 0);
- assert(t_length == 8);
+ DIE_UNLESS(strcmp(time, "12:49:00") == 0);
+ DIE_UNLESS(t_length == 8);
- assert(strcmp(ts, "2002-01-02 17:46:59") == 0);
- assert(ts_length == 19);
+ DIE_UNLESS(strcmp(ts, "2002-01-02 17:46:59") == 0);
+ DIE_UNLESS(ts_length == 19);
- assert(year == 2010);
- assert(y_length == 4);
+ DIE_UNLESS(year == 2010);
+ DIE_UNLESS(y_length == 4);
- assert(strcmp(dt, "2010-07-10 00:00:00") == 0);
- assert(dt_length == 19);
+ DIE_UNLESS(strcmp(dt, "2010-07-10 00:00:00") == 0);
+ DIE_UNLESS(dt_length == 19);
- assert(ts_4[0] == '\0');
- assert(ts4_length == 0);
+ DIE_UNLESS(ts_4[0] == '\0');
+ DIE_UNLESS(ts4_length == 0);
- assert(strcmp(ts_6, "1999-12-29 00:00:00") == 0);
- assert(ts6_length == 19);
+ DIE_UNLESS(strcmp(ts_6, "1999-12-29 00:00:00") == 0);
+ DIE_UNLESS(ts6_length == 19);
rc= mysql_stmt_fetch(stmt);
- assert(rc == MYSQL_NO_DATA);
+ DIE_UNLESS(rc == MYSQL_NO_DATA);
mysql_stmt_close(stmt);
}
@@ -3796,7 +3843,8 @@ static void test_prepare_ext()
rc= mysql_stmt_execute(stmt);
check_execute(stmt, rc);
- assert(nData == (int)my_process_stmt_result(stmt));
+ rc= my_process_stmt_result(stmt);
+ DIE_UNLESS(nData == rc);
mysql_stmt_close(stmt);
}
@@ -3831,7 +3879,8 @@ static void test_field_names()
result= mysql_use_result(mysql);
mytest(result);
- assert(0 == my_process_result_set(result));
+ rc= my_process_result_set(result);
+ DIE_UNLESS(rc == 0);
mysql_free_result(result);
/* with table name included with TRUE column name */
@@ -3841,7 +3890,8 @@ static void test_field_names()
result= mysql_use_result(mysql);
mytest(result);
- assert(0 == my_process_result_set(result));
+ rc= my_process_result_set(result);
+ DIE_UNLESS(rc == 0);
mysql_free_result(result);
}
@@ -3867,7 +3917,8 @@ static void test_warnings()
result= mysql_store_result(mysql);
mytest(result);
- assert(1 == my_process_result_set(result));
+ rc= my_process_result_set(result);
+ DIE_UNLESS(rc == 1);
mysql_free_result(result);
}
@@ -3892,7 +3943,7 @@ static void test_errors()
result= mysql_store_result(mysql);
mytest(result);
- my_process_result_set(result);
+ (void) my_process_result_set(result);
mysql_free_result(result);
}
@@ -3969,7 +4020,8 @@ static void test_insert()
result= mysql_store_result(mysql);
mytest(result);
- assert((int)tiny_data == my_process_result_set(result));
+ rc= my_process_result_set(result);
+ DIE_UNLESS((int) tiny_data == rc);
mysql_free_result(result);
}
@@ -4126,7 +4178,7 @@ static void test_stmt_close()
rc= mysql_stmt_close(stmt1);
fprintf(stdout, "\n mysql_close_stmt(1) returned: %d", rc);
- assert(rc == 0);
+ DIE_UNLESS(rc == 0);
/*
Originally we were going to close all statements automatically in
@@ -4160,7 +4212,7 @@ static void test_stmt_close()
rc= mysql_stmt_close(stmt_x);
fprintf(stdout, "\n mysql_close_stmt(x) returned: %d", rc);
- assert( rc == 0);
+ DIE_UNLESS( rc == 0);
rc= mysql_query(mysql, "SELECT id FROM test_stmt_close");
myquery(rc);
@@ -4168,7 +4220,8 @@ static void test_stmt_close()
result= mysql_store_result(mysql);
mytest(result);
- assert(1 == my_process_result_set(result));
+ rc= my_process_result_set(result);
+ DIE_UNLESS(rc == 1);
mysql_free_result(result);
}
@@ -4220,9 +4273,9 @@ static void test_set_variable()
fprintf(stdout, "\n max_error_count(default): %d", get_count);
def_count= get_count;
- assert(strcmp(var, "max_error_count") == 0);
+ DIE_UNLESS(strcmp(var, "max_error_count") == 0);
rc= mysql_stmt_fetch(stmt1);
- assert(rc == MYSQL_NO_DATA);
+ DIE_UNLESS(rc == MYSQL_NO_DATA);
stmt= mysql_simple_prepare(mysql, "set max_error_count= ?");
check_stmt(stmt);
@@ -4248,10 +4301,10 @@ static void test_set_variable()
check_execute(stmt1, rc);
fprintf(stdout, "\n max_error_count : %d", get_count);
- assert(get_count == set_count);
+ DIE_UNLESS(get_count == set_count);
rc= mysql_stmt_fetch(stmt1);
- assert(rc == MYSQL_NO_DATA);
+ DIE_UNLESS(rc == MYSQL_NO_DATA);
/* restore back to default */
set_count= def_count;
@@ -4265,10 +4318,10 @@ static void test_set_variable()
check_execute(stmt1, rc);
fprintf(stdout, "\n max_error_count(default): %d", get_count);
- assert(get_count == set_count);
+ DIE_UNLESS(get_count == set_count);
rc= mysql_stmt_fetch(stmt1);
- assert(rc == MYSQL_NO_DATA);
+ DIE_UNLESS(rc == MYSQL_NO_DATA);
mysql_stmt_close(stmt);
mysql_stmt_close(stmt1);
@@ -4323,12 +4376,12 @@ static void test_insert_meta()
field= mysql_fetch_field(result);
mytest(field);
fprintf(stdout, "\n obtained: `%s` (expected: `%s`)", field->name, "col1");
- assert(strcmp(field->name, "col1") == 0);
+ DIE_UNLESS(strcmp(field->name, "col1") == 0);
field= mysql_fetch_field(result);
mytest(field);
fprintf(stdout, "\n obtained: `%s` (expected: `%s`)", field->name, "col3");
- assert(strcmp(field->name, "col3") == 0);
+ DIE_UNLESS(strcmp(field->name, "col3") == 0);
field= mysql_fetch_field(result);
mytest_r(field);
@@ -4386,15 +4439,15 @@ static void test_update_meta()
mytest(field);
fprintf(stdout, "\n col obtained: `%s` (expected: `%s`)", field->name, "col1");
fprintf(stdout, "\n tab obtained: `%s` (expected: `%s`)", field->table, "test_prep_update");
- assert(strcmp(field->name, "col1") == 0);
- assert(strcmp(field->table, "test_prep_update") == 0);
+ DIE_UNLESS(strcmp(field->name, "col1") == 0);
+ DIE_UNLESS(strcmp(field->table, "test_prep_update") == 0);
field= mysql_fetch_field(result);
mytest(field);
fprintf(stdout, "\n col obtained: `%s` (expected: `%s`)", field->name, "col3");
fprintf(stdout, "\n tab obtained: `%s` (expected: `%s`)", field->table, "test_prep_update");
- assert(strcmp(field->name, "col3") == 0);
- assert(strcmp(field->table, "test_prep_update") == 0);
+ DIE_UNLESS(strcmp(field->name, "col3") == 0);
+ DIE_UNLESS(strcmp(field->table, "test_prep_update") == 0);
field= mysql_fetch_field(result);
mytest_r(field);
@@ -4450,15 +4503,15 @@ static void test_select_meta()
mytest(field);
fprintf(stdout, "\n col obtained: `%s` (expected: `%s`)", field->name, "col1");
fprintf(stdout, "\n tab obtained: `%s` (expected: `%s`)", field->table, "test_prep_select");
- assert(strcmp(field->name, "col1") == 0);
- assert(strcmp(field->table, "test_prep_select") == 0);
+ DIE_UNLESS(strcmp(field->name, "col1") == 0);
+ DIE_UNLESS(strcmp(field->table, "test_prep_select") == 0);
field= mysql_fetch_field(result);
mytest(field);
fprintf(stdout, "\n col obtained: `%s` (expected: `%s`)", field->name, "col2");
fprintf(stdout, "\n tab obtained: `%s` (expected: `%s`)", field->table, "test_prep_select");
- assert(strcmp(field->name, "col2") == 0);
- assert(strcmp(field->table, "test_prep_select") == 0);
+ DIE_UNLESS(strcmp(field->name, "col2") == 0);
+ DIE_UNLESS(strcmp(field->table, "test_prep_select") == 0);
field= mysql_fetch_field(result);
mytest_r(field);
@@ -4502,7 +4555,7 @@ static void test_func_fields()
mytest(field);
fprintf(stdout, "\n table name: `%s` (expected: `%s`)", field->table,
"test_dateformat");
- assert(strcmp(field->table, "test_dateformat") == 0);
+ DIE_UNLESS(strcmp(field->table, "test_dateformat") == 0);
field= mysql_fetch_field(result);
mytest_r(field); /* no more fields */
@@ -4519,7 +4572,7 @@ static void test_func_fields()
field= mysql_fetch_field(result);
mytest(field);
fprintf(stdout, "\n table name: `%s` (expected: `%s`)", field->table, "");
- assert(field->table[0] == '\0');
+ DIE_UNLESS(field->table[0] == '\0');
field= mysql_fetch_field(result);
mytest_r(field); /* no more fields */
@@ -4537,8 +4590,8 @@ static void test_func_fields()
mytest(field);
fprintf(stdout, "\n field name: `%s` (expected: `%s`)", field->name, "YEAR");
fprintf(stdout, "\n field org name: `%s` (expected: `%s`)", field->org_name, "");
- assert(strcmp(field->name, "YEAR") == 0);
- assert(field->org_name[0] == '\0');
+ DIE_UNLESS(strcmp(field->name, "YEAR") == 0);
+ DIE_UNLESS(field->org_name[0] == '\0');
field= mysql_fetch_field(result);
mytest_r(field); /* no more fields */
@@ -4615,11 +4668,11 @@ static void test_multi_stmt()
fprintf(stdout, "\n int_data: %lu(%lu)", (ulong) id, length[0]);
fprintf(stdout, "\n str_data: %s(%lu)", name, length[1]);
- assert(id == 10);
- assert(strcmp(name, "mysql") == 0);
+ DIE_UNLESS(id == 10);
+ DIE_UNLESS(strcmp(name, "mysql") == 0);
rc= mysql_stmt_fetch(stmt);
- assert(rc == MYSQL_NO_DATA);
+ DIE_UNLESS(rc == MYSQL_NO_DATA);
/* alter the table schema now */
stmt1= mysql_simple_prepare(mysql, "DELETE FROM test_multi_table "
@@ -4644,11 +4697,11 @@ static void test_multi_stmt()
fprintf(stdout, "\n int_data: %lu(%lu)", (ulong) id, length[0]);
fprintf(stdout, "\n str_data: %s(%lu)", name, length[1]);
- assert(id == 10);
- assert(strcmp(name, "updated") == 0);
+ DIE_UNLESS(id == 10);
+ DIE_UNLESS(strcmp(name, "updated") == 0);
rc= mysql_stmt_fetch(stmt);
- assert(rc == MYSQL_NO_DATA);
+ DIE_UNLESS(rc == MYSQL_NO_DATA);
rc= mysql_stmt_execute(stmt1);
check_execute(stmt1, rc);
@@ -4661,9 +4714,10 @@ static void test_multi_stmt()
check_execute(stmt, rc);
rc= mysql_stmt_fetch(stmt);
- assert(rc == MYSQL_NO_DATA);
+ DIE_UNLESS(rc == MYSQL_NO_DATA);
- assert(0 == my_stmt_result("SELECT * FROM test_multi_table"));
+ rc= my_stmt_result("SELECT * FROM test_multi_table");
+ DIE_UNLESS(rc == 0);
mysql_stmt_close(stmt);
mysql_stmt_close(stmt2);
@@ -4679,6 +4733,7 @@ static void test_manual_sample()
MYSQL_STMT *stmt;
short small_data;
int int_data;
+ int rc;
char str_data[50];
ulonglong affected_rows;
MYSQL_BIND bind[3];
@@ -4814,7 +4869,8 @@ static void test_manual_sample()
fprintf(stderr, "\n %s", mysql_stmt_error(stmt));
exit(1);
}
- assert(2 == my_stmt_result("SELECT * FROM test_table"));
+ rc= my_stmt_result("SELECT * FROM test_table");
+ DIE_UNLESS(rc == 2);
/* DROP THE TABLE */
if (mysql_query(mysql, "DROP TABLE test_table"))
@@ -4879,7 +4935,8 @@ static void test_prepare_alter()
rc= mysql_stmt_execute(stmt);
check_execute(stmt, rc);
- assert(4 == my_stmt_result("SELECT * FROM test_prep_alter"));
+ rc= my_stmt_result("SELECT * FROM test_prep_alter");
+ DIE_UNLESS(rc == 4);
mysql_stmt_close(stmt);
}
@@ -4919,8 +4976,10 @@ DROP TABLE IF EXISTS test_multi_tab";
rc= mysql_query(mysql, query); /* syntax error */
myquery_r(rc);
- assert(-1 == mysql_next_result(mysql));
- assert(0 == mysql_more_results(mysql));
+ rc= mysql_next_result(mysql);
+ DIE_UNLESS(rc == -1);
+ rc= mysql_more_results(mysql);
+ DIE_UNLESS(rc == 0);
if (!(mysql_local= mysql_init(NULL)))
{
@@ -4945,7 +5004,7 @@ DROP TABLE IF EXISTS test_multi_tab";
fprintf(stdout, "\n Query %d: ", count);
if ((result= mysql_store_result(mysql_local)))
{
- my_process_result_set(result);
+ (void) my_process_result_set(result);
mysql_free_result(result);
}
else
@@ -4978,8 +5037,10 @@ DROP TABLE IF EXISTS test_multi_tab";
}
else
{
- assert(mysql_more_results(mysql_local) == 0);
- assert(mysql_next_result(mysql_local) == -1);
+ rc= mysql_more_results(mysql_local);
+ DIE_UNLESS(rc == 0);
+ rc= mysql_next_result(mysql_local);
+ DIE_UNLESS(rc == -1);
}
}
@@ -4987,16 +5048,20 @@ DROP TABLE IF EXISTS test_multi_tab";
rc= mysql_query(mysql_local, "select 1+1+a;select 1+1");
myquery_r(rc);
- assert(mysql_more_results(mysql_local) == 0);
- assert(mysql_next_result(mysql_local) == -1);
+ rc= mysql_more_results(mysql_local);
+ DIE_UNLESS(rc == 0);
+ rc= mysql_next_result(mysql_local);
+ DIE_UNLESS(rc == -1);
rc= mysql_query(mysql_local, "select 1+1;select 1+1+a;select 1");
myquery(rc);
result= mysql_store_result(mysql_local);
mytest(result);
mysql_free_result(result);
- assert(mysql_more_results(mysql_local) == 1);
- assert(mysql_next_result(mysql_local) > 0);
+ rc= mysql_more_results(mysql_local);
+ DIE_UNLESS(rc == 1);
+ rc= mysql_next_result(mysql_local);
+ DIE_UNLESS(rc > 0);
/*
Ensure that we can now do a simple query (this checks that the server is
@@ -5006,7 +5071,7 @@ DROP TABLE IF EXISTS test_multi_tab";
myquery(rc);
result= mysql_store_result(mysql_local);
mytest(result);
- my_process_result_set(result);
+ (void) my_process_result_set(result);
mysql_free_result(result);
mysql_close(mysql_local);
@@ -5103,17 +5168,17 @@ static void test_store_result()
check_execute(stmt, rc);
fprintf(stdout, "\n row 1: %ld, %s(%lu)", (long) nData, szData, length1);
- assert(nData == 10);
- assert(strcmp(szData, "venu") == 0);
- assert(length1 == 4);
+ DIE_UNLESS(nData == 10);
+ DIE_UNLESS(strcmp(szData, "venu") == 0);
+ DIE_UNLESS(length1 == 4);
rc= mysql_stmt_fetch(stmt);
check_execute(stmt, rc);
fprintf(stdout, "\n row 2: %ld, %s(%lu)", (long) nData, szData, length1);
- assert(nData == 20);
- assert(strcmp(szData, "mysql") == 0);
- assert(length1 == 5);
+ DIE_UNLESS(nData == 20);
+ DIE_UNLESS(strcmp(szData, "mysql") == 0);
+ DIE_UNLESS(length1 == 5);
length= 99;
rc= mysql_stmt_fetch(stmt);
@@ -5121,12 +5186,12 @@ static void test_store_result()
if (is_null[0])
fprintf(stdout, "\n row 3: NULL, %s(%lu)", szData, length1);
- assert(is_null[0]);
- assert(strcmp(szData, "monty") == 0);
- assert(length1 == 5);
+ DIE_UNLESS(is_null[0]);
+ DIE_UNLESS(strcmp(szData, "monty") == 0);
+ DIE_UNLESS(length1 == 5);
rc= mysql_stmt_fetch(stmt);
- assert(rc == MYSQL_NO_DATA);
+ DIE_UNLESS(rc == MYSQL_NO_DATA);
rc= mysql_stmt_execute(stmt);
check_execute(stmt, rc);
@@ -5138,17 +5203,17 @@ static void test_store_result()
check_execute(stmt, rc);
fprintf(stdout, "\n row 1: %ld, %s(%lu)", (long) nData, szData, length1);
- assert(nData == 10);
- assert(strcmp(szData, "venu") == 0);
- assert(length1 == 4);
+ DIE_UNLESS(nData == 10);
+ DIE_UNLESS(strcmp(szData, "venu") == 0);
+ DIE_UNLESS(length1 == 4);
rc= mysql_stmt_fetch(stmt);
check_execute(stmt, rc);
fprintf(stdout, "\n row 2: %ld, %s(%lu)", (long) nData, szData, length1);
- assert(nData == 20);
- assert(strcmp(szData, "mysql") == 0);
- assert(length1 == 5);
+ DIE_UNLESS(nData == 20);
+ DIE_UNLESS(strcmp(szData, "mysql") == 0);
+ DIE_UNLESS(length1 == 5);
length= 99;
rc= mysql_stmt_fetch(stmt);
@@ -5156,12 +5221,12 @@ static void test_store_result()
if (is_null[0])
fprintf(stdout, "\n row 3: NULL, %s(%lu)", szData, length1);
- assert(is_null[0]);
- assert(strcmp(szData, "monty") == 0);
- assert(length1 == 5);
+ DIE_UNLESS(is_null[0]);
+ DIE_UNLESS(strcmp(szData, "monty") == 0);
+ DIE_UNLESS(length1 == 5);
rc= mysql_stmt_fetch(stmt);
- assert(rc == MYSQL_NO_DATA);
+ DIE_UNLESS(rc == MYSQL_NO_DATA);
mysql_stmt_close(stmt);
}
@@ -5204,7 +5269,7 @@ static void test_store_result1()
while (mysql_stmt_fetch(stmt) != MYSQL_NO_DATA)
rc++;
fprintf(stdout, "\n total rows: %d", rc);
- assert(rc == 3);
+ DIE_UNLESS(rc == 3);
rc= mysql_stmt_execute(stmt);
check_execute(stmt, rc);
@@ -5216,7 +5281,7 @@ static void test_store_result1()
while (mysql_stmt_fetch(stmt) != MYSQL_NO_DATA)
rc++;
fprintf(stdout, "\n total rows: %d", rc);
- assert(rc == 3);
+ DIE_UNLESS(rc == 3);
mysql_stmt_close(stmt);
}
@@ -5282,10 +5347,10 @@ static void test_store_result2()
check_execute(stmt, rc);
fprintf(stdout, "\n row 1: %d", nData);
- assert(nData == 10);
+ DIE_UNLESS(nData == 10);
rc= mysql_stmt_fetch(stmt);
- assert(rc == MYSQL_NO_DATA);
+ DIE_UNLESS(rc == MYSQL_NO_DATA);
nData= 20;
rc= mysql_stmt_execute(stmt);
@@ -5299,10 +5364,10 @@ static void test_store_result2()
check_execute(stmt, rc);
fprintf(stdout, "\n row 1: %d", nData);
- assert(nData == 20);
+ DIE_UNLESS(nData == 20);
rc= mysql_stmt_fetch(stmt);
- assert(rc == MYSQL_NO_DATA);
+ DIE_UNLESS(rc == MYSQL_NO_DATA);
mysql_stmt_close(stmt);
}
@@ -5374,13 +5439,18 @@ static void test_subselect()
mysql_stmt_close(stmt);
- assert(3 == my_stmt_result("SELECT * FROM test_sub2"));
+ rc= my_stmt_result("SELECT * FROM test_sub2");
+ DIE_UNLESS(rc == 3);
- strmov((char *)query , "SELECT ROW(1, 7) IN (select id, id1 from test_sub2 WHERE id1= ?)");
- assert(1 == my_stmt_result("SELECT ROW(1, 7) IN (select id, id1 from test_sub2 WHERE id1= 8)"));
- assert(1 == my_stmt_result("SELECT ROW(1, 7) IN (select id, id1 from test_sub2 WHERE id1= 7)"));
+ rc= my_stmt_result("SELECT ROW(1, 7) IN (select id, id1 "
+ "from test_sub2 WHERE id1= 8)");
+ DIE_UNLESS(rc == 1);
+ rc= my_stmt_result("SELECT ROW(1, 7) IN (select id, id1 "
+ "from test_sub2 WHERE id1= 7)");
+ DIE_UNLESS(rc == 1);
- stmt= mysql_simple_prepare(mysql, query);
+ stmt= mysql_simple_prepare(mysql, ("SELECT ROW(1, 7) IN (select id, id1 "
+ "from test_sub2 WHERE id1= ?)"));
check_stmt(stmt);
rc= mysql_stmt_bind_param(stmt, bind);
@@ -5397,10 +5467,10 @@ static void test_subselect()
check_execute(stmt, rc);
fprintf(stdout, "\n row 1: %d", id);
- assert(id == 1);
+ DIE_UNLESS(id == 1);
rc= mysql_stmt_fetch(stmt);
- assert(rc == MYSQL_NO_DATA);
+ DIE_UNLESS(rc == MYSQL_NO_DATA);
id= 8;
rc= mysql_stmt_execute(stmt);
@@ -5410,10 +5480,10 @@ static void test_subselect()
check_execute(stmt, rc);
fprintf(stdout, "\n row 1: %d", id);
- assert(id == 0);
+ DIE_UNLESS(id == 0);
rc= mysql_stmt_fetch(stmt);
- assert(rc == MYSQL_NO_DATA);
+ DIE_UNLESS(rc == MYSQL_NO_DATA);
mysql_stmt_close(stmt);
}
@@ -5505,10 +5575,11 @@ static void test_bind_date_conv(uint row_count)
mysql_stmt_close(stmt);
- assert(row_count == my_stmt_result("SELECT * FROM test_date"));
+ rc= my_stmt_result("SELECT * FROM test_date");
+ DIE_UNLESS(row_count == rc);
stmt= mysql_simple_prepare(mysql, "SELECT * FROM test_date");
- myquery(rc);
+ check_stmt(stmt);
rc= mysql_stmt_bind_result(stmt, bind);
check_execute(stmt, rc);
@@ -5533,23 +5604,25 @@ static void test_bind_date_conv(uint row_count)
tm[i].hour, tm[i].minute, tm[i].second,
tm[i].second_part);
- assert(tm[i].year == 0 || tm[i].year == year+count);
- assert(tm[i].month == 0 || tm[i].month == month+count);
- assert(tm[i].day == 0 || tm[i].day == day+count);
+ DIE_UNLESS(tm[i].year == 0 || tm[i].year == year+count);
+ DIE_UNLESS(tm[i].month == 0 || tm[i].month == month+count);
+ DIE_UNLESS(tm[i].day == 0 || tm[i].day == day+count);
- assert(tm[i].hour == 0 || tm[i].hour == hour+count);
+ DIE_UNLESS(tm[i].hour == 0 || tm[i].hour == hour+count);
+#if 0
/*
- minute causes problems from date<->time, don't assert, instead
- validate separatly in another routine
- */
- /*assert(tm[i].minute == 0 || tm[i].minute == minute+count);
- assert(tm[i].second == 0 || tm[i].second == sec+count);*/
-
- assert(tm[i].second_part == 0 || tm[i].second_part == second_part+count);
+ minute causes problems from date<->time, don't assert, instead
+ validate separatly in another routine
+ */
+ DIE_UNLESS(tm[i].minute == 0 || tm[i].minute == minute+count);
+ DIE_UNLESS(tm[i].second == 0 || tm[i].second == sec+count);
+#endif
+ DIE_UNLESS(tm[i].second_part == 0 ||
+ tm[i].second_part == second_part+count);
}
}
rc= mysql_stmt_fetch(stmt);
- assert(rc == MYSQL_NO_DATA);
+ DIE_UNLESS(rc == MYSQL_NO_DATA);
mysql_stmt_close(stmt);
}
@@ -5792,9 +5865,9 @@ static void test_buffers()
rc= mysql_stmt_fetch(stmt);
check_execute(stmt, rc);
fprintf(stdout, "\n data: %s (%lu)", buffer, length);
- assert(buffer[0] == 'M');
- assert(buffer[1] == 'X');
- assert(length == 5);
+ DIE_UNLESS(buffer[0] == 'M');
+ DIE_UNLESS(buffer[1] == 'X');
+ DIE_UNLESS(length == 5);
bind[0].buffer_length= 8;
rc= mysql_stmt_bind_result(stmt, bind);/* re-bind */
@@ -5803,8 +5876,8 @@ static void test_buffers()
rc= mysql_stmt_fetch(stmt);
check_execute(stmt, rc);
fprintf(stdout, "\n data: %s (%lu)", buffer, length);
- assert(strncmp(buffer, "Database", 8) == 0);
- assert(length == 8);
+ DIE_UNLESS(strncmp(buffer, "Database", 8) == 0);
+ DIE_UNLESS(length == 8);
bind[0].buffer_length= 12;
rc= mysql_stmt_bind_result(stmt, bind);/* re-bind */
@@ -5813,8 +5886,8 @@ static void test_buffers()
rc= mysql_stmt_fetch(stmt);
check_execute(stmt, rc);
fprintf(stdout, "\n data: %s (%lu)", buffer, length);
- assert(strcmp(buffer, "Open-Source") == 0);
- assert(length == 11);
+ DIE_UNLESS(strcmp(buffer, "Open-Source") == 0);
+ DIE_UNLESS(length == 11);
bind[0].buffer_length= 6;
rc= mysql_stmt_bind_result(stmt, bind);/* re-bind */
@@ -5823,8 +5896,8 @@ static void test_buffers()
rc= mysql_stmt_fetch(stmt);
check_execute(stmt, rc);
fprintf(stdout, "\n data: %s (%lu)", buffer, length);
- assert(strncmp(buffer, "Popula", 6) == 0);
- assert(length == 7);
+ DIE_UNLESS(strncmp(buffer, "Popula", 6) == 0);
+ DIE_UNLESS(length == 7);
mysql_stmt_close(stmt);
}
@@ -5855,7 +5928,8 @@ static void test_open_direct()
result= mysql_store_result(mysql);
mytest(result);
- assert(0 == my_process_result_set(result));
+ rc= my_process_result_set(result);
+ DIE_UNLESS(rc == 0);
mysql_free_result(result);
rc= mysql_stmt_execute(stmt);
@@ -5869,7 +5943,8 @@ static void test_open_direct()
result= mysql_store_result(mysql);
mytest(result);
- assert(1 == my_process_result_set(result));
+ rc= my_process_result_set(result);
+ DIE_UNLESS(rc == 1);
mysql_free_result(result);
rc= mysql_stmt_execute(stmt);
@@ -5883,7 +5958,8 @@ static void test_open_direct()
result= mysql_store_result(mysql);
mytest(result);
- assert(2 == my_process_result_set(result));
+ rc= my_process_result_set(result);
+ DIE_UNLESS(rc == 2);
mysql_free_result(result);
mysql_stmt_close(stmt);
@@ -5951,7 +6027,7 @@ static void test_fetch_nobuffs()
rc++;
fprintf(stdout, "\n total rows : %d", rc);
- assert(rc == 1);
+ DIE_UNLESS(rc == 1);
bind[0].buffer_type= MYSQL_TYPE_STRING;
bind[0].buffer= (void *)str[0];
@@ -5979,7 +6055,7 @@ static void test_fetch_nobuffs()
fprintf(stdout, "\n CURRENT_TIME() : %s", str[3]);
}
fprintf(stdout, "\n total rows : %d", rc);
- assert(rc == 1);
+ DIE_UNLESS(rc == 1);
mysql_stmt_close(stmt);
}
@@ -6050,20 +6126,20 @@ static void test_ushort_bug()
fprintf(stdout, "\n longlong : %lld (%ld)", longlong_value, ll_length);
fprintf(stdout, "\n tinyint : %d (%ld)", tiny_value, t_length);
- assert(short_value == 35999);
- assert(s_length == 2);
+ DIE_UNLESS(short_value == 35999);
+ DIE_UNLESS(s_length == 2);
- assert(long_value == 35999);
- assert(l_length == 4);
+ DIE_UNLESS(long_value == 35999);
+ DIE_UNLESS(l_length == 4);
- assert(longlong_value == 35999);
- assert(ll_length == 8);
+ DIE_UNLESS(longlong_value == 35999);
+ DIE_UNLESS(ll_length == 8);
- assert(tiny_value == 200);
- assert(t_length == 1);
+ DIE_UNLESS(tiny_value == 200);
+ DIE_UNLESS(t_length == 1);
rc= mysql_stmt_fetch(stmt);
- assert(rc == MYSQL_NO_DATA);
+ DIE_UNLESS(rc == MYSQL_NO_DATA);
mysql_stmt_close(stmt);
}
@@ -6134,20 +6210,20 @@ static void test_sshort_bug()
fprintf(stdout, "\n longlong : %lld (%ld)", longlong_value, ll_length);
fprintf(stdout, "\n tinyint : %d (%ld)", tiny_value, t_length);
- assert(short_value == -5999);
- assert(s_length == 2);
+ DIE_UNLESS(short_value == -5999);
+ DIE_UNLESS(s_length == 2);
- assert(long_value == -5999);
- assert(l_length == 4);
+ DIE_UNLESS(long_value == -5999);
+ DIE_UNLESS(l_length == 4);
- assert(longlong_value == 35999);
- assert(ll_length == 8);
+ DIE_UNLESS(longlong_value == 35999);
+ DIE_UNLESS(ll_length == 8);
- assert(tiny_value == 200);
- assert(t_length == 1);
+ DIE_UNLESS(tiny_value == 200);
+ DIE_UNLESS(t_length == 1);
rc= mysql_stmt_fetch(stmt);
- assert(rc == MYSQL_NO_DATA);
+ DIE_UNLESS(rc == MYSQL_NO_DATA);
mysql_stmt_close(stmt);
}
@@ -6218,20 +6294,20 @@ static void test_stiny_bug()
fprintf(stdout, "\n longlong : %lld (%ld)", longlong_value, ll_length);
fprintf(stdout, "\n tinyint : %d (%ld)", tiny_value, t_length);
- assert(short_value == -128);
- assert(s_length == 2);
+ DIE_UNLESS(short_value == -128);
+ DIE_UNLESS(s_length == 2);
- assert(long_value == -127);
- assert(l_length == 4);
+ DIE_UNLESS(long_value == -127);
+ DIE_UNLESS(l_length == 4);
- assert(longlong_value == 255);
- assert(ll_length == 8);
+ DIE_UNLESS(longlong_value == 255);
+ DIE_UNLESS(ll_length == 8);
- assert(tiny_value == 0);
- assert(t_length == 1);
+ DIE_UNLESS(tiny_value == 0);
+ DIE_UNLESS(t_length == 1);
rc= mysql_stmt_fetch(stmt);
- assert(rc == MYSQL_NO_DATA);
+ DIE_UNLESS(rc == MYSQL_NO_DATA);
mysql_stmt_close(stmt);
}
@@ -6256,13 +6332,14 @@ static void test_field_misc()
result= mysql_store_result(mysql);
mytest(result);
- assert(1 == my_process_result_set(result));
+ rc= my_process_result_set(result);
+ DIE_UNLESS(rc == 1);
verify_prepare_field(result, 0,
- "@@autocommit", "", /* field and its org name */
+ "@@autocommit", "", /* field and its org name */
MYSQL_TYPE_LONGLONG, /* field type */
"", "", /* table and its org name */
- "", 1, 0); /* db name, length(its bool flag)*/
+ "", 1, 0); /* db name, length(its bool flag)*/
mysql_free_result(result);
@@ -6275,13 +6352,14 @@ static void test_field_misc()
result= mysql_stmt_result_metadata(stmt);
mytest(result);
- assert(1 == my_process_stmt_result(stmt));
+ rc= my_process_stmt_result(stmt);
+ DIE_UNLESS(rc == 1);
verify_prepare_field(result, 0,
- "@@autocommit", "", /* field and its org name */
+ "@@autocommit", "", /* field and its org name */
MYSQL_TYPE_LONGLONG, /* field type */
"", "", /* table and its org name */
- "", 1, 0); /* db name, length(its bool flag)*/
+ "", 1, 0); /* db name, length(its bool flag)*/
mysql_free_result(result);
mysql_stmt_close(stmt);
@@ -6306,7 +6384,7 @@ static void test_field_misc()
fprintf(stdout, "\n default table type: %s(%ld)", table_type, type_length);
rc= mysql_stmt_fetch(stmt);
- assert(rc == MYSQL_NO_DATA);
+ DIE_UNLESS(rc == MYSQL_NO_DATA);
mysql_stmt_close(stmt);
@@ -6315,12 +6393,12 @@ static void test_field_misc()
result= mysql_stmt_result_metadata(stmt);
mytest(result);
- assert(mysql_stmt_field_count(stmt) == mysql_num_fields(result));
+ DIE_UNLESS(mysql_stmt_field_count(stmt) == mysql_num_fields(result));
rc= mysql_stmt_execute(stmt);
check_execute(stmt, rc);
- assert(1 == my_process_stmt_result(stmt));
+ DIE_UNLESS(1 == my_process_stmt_result(stmt));
verify_prepare_field(result, 0,
"@@table_type", "", /* field and its org name */
@@ -6340,7 +6418,8 @@ static void test_field_misc()
rc= mysql_stmt_execute(stmt);
check_execute(stmt, rc);
- assert(1 == my_process_stmt_result(stmt));
+ rc= my_process_stmt_result(stmt);
+ DIE_UNLESS(rc == 1);
verify_prepare_field(result, 0,
"@@max_error_count", "", /* field and its org name */
@@ -6360,7 +6439,7 @@ static void test_field_misc()
rc= mysql_stmt_execute(stmt);
check_execute(stmt, rc);
- assert(1 == my_process_stmt_result(stmt));
+ DIE_UNLESS(1 == my_process_stmt_result(stmt));
verify_prepare_field(result, 0,
"@@max_allowed_packet", "", /* field and its org name */
@@ -6380,13 +6459,14 @@ static void test_field_misc()
rc= mysql_stmt_execute(stmt);
check_execute(stmt, rc);
- assert(1 == my_process_stmt_result(stmt));
+ rc= my_process_stmt_result(stmt);
+ DIE_UNLESS(rc == 1);
verify_prepare_field(result, 0,
- "@@sql_warnings", "", /* field and its org name */
+ "@@sql_warnings", "", /* field and its org name */
MYSQL_TYPE_LONGLONG, /* field type */
"", "", /* table and its org name */
- "", 1, 0); /* db name, length */
+ "", 1, 0); /* db name, length */
mysql_free_result(result);
mysql_stmt_close(stmt);
@@ -6428,7 +6508,8 @@ static void test_set_option()
result= mysql_store_result(mysql);
mytest(result);
- assert(2 == my_process_result_set(result));
+ rc= my_process_result_set(result);
+ DIE_UNLESS(rc == 2);
mysql_free_result(result);
@@ -6439,7 +6520,8 @@ static void test_set_option()
rc= mysql_stmt_execute(stmt);
check_execute(stmt, rc);
- assert(2 == my_process_stmt_result(stmt));
+ rc= my_process_stmt_result(stmt);
+ DIE_UNLESS(rc == 2);
mysql_stmt_close(stmt);
@@ -6454,7 +6536,8 @@ static void test_set_option()
rc= mysql_stmt_execute(stmt);
check_execute(stmt, rc);
- assert(4 == my_process_stmt_result(stmt));
+ rc= my_process_stmt_result(stmt);
+ DIE_UNLESS(rc == 4);
mysql_stmt_close(stmt);
}
@@ -6527,7 +6610,8 @@ static void test_prepare_grant()
execute_prepare_query("INSERT INTO test_grant(a) VALUES(NULL)", 1);
execute_prepare_query("INSERT INTO test_grant VALUES(NULL)", 1);
execute_prepare_query("UPDATE test_grant SET a=9 WHERE a=1", 1);
- assert(4 == my_stmt_result("SELECT a FROM test_grant"));
+ rc= my_stmt_result("SELECT a FROM test_grant");
+ DIE_UNLESS(rc == 4);
/* Both DELETE expected to fail as user does not have DELETE privs */
@@ -6537,18 +6621,19 @@ static void test_prepare_grant()
stmt= mysql_simple_prepare(mysql, "DELETE FROM test_grant");
check_stmt_r(stmt);
- assert(4 == my_stmt_result("SELECT * FROM test_grant"));
+ rc= my_stmt_result("SELECT * FROM test_grant");
+ DIE_UNLESS(rc == 4);
mysql_close(lmysql);
mysql= org_mysql;
rc= mysql_query(mysql, "delete from mysql.user where User='test_grant'");
myquery(rc);
- assert(1 == mysql_affected_rows(mysql));
+ DIE_UNLESS(1 == mysql_affected_rows(mysql));
rc= mysql_query(mysql, "delete from mysql.tables_priv where User='test_grant'");
myquery(rc);
- assert(1 == mysql_affected_rows(mysql));
+ DIE_UNLESS(1 == mysql_affected_rows(mysql));
}
}
@@ -6603,7 +6688,7 @@ static void test_frm_bug()
fprintf(stdout, "\n data directory: %s", data_dir);
rc= mysql_stmt_fetch(stmt);
- assert(rc == MYSQL_NO_DATA);
+ DIE_UNLESS(rc == MYSQL_NO_DATA);
strxmov(test_frm, data_dir, "/", current_db, "/", "test_frm_bug.frm", NullS);
@@ -6623,7 +6708,8 @@ static void test_frm_bug()
result= mysql_store_result(mysql);
mytest(result);/* It can't be NULL */
- assert(1 == my_process_result_set(result));
+ rc= my_process_result_set(result);
+ DIE_UNLESS(rc == 1);
mysql_data_seek(result, 0);
@@ -6631,7 +6717,7 @@ static void test_frm_bug()
mytest(row);
fprintf(stdout, "\n Comment: %s", row[17]);
- assert(row[17] != 0);
+ DIE_UNLESS(row[17] != 0);
mysql_free_result(result);
mysql_stmt_close(stmt);
@@ -6694,10 +6780,10 @@ static void test_decimal_bug()
check_execute(stmt, rc);
fprintf(stdout, "\n data: %s", data);
- assert(strcmp(data, "8.00") == 0);
+ DIE_UNLESS(strcmp(data, "8.00") == 0);
rc= mysql_stmt_fetch(stmt);
- assert(rc == MYSQL_NO_DATA);
+ DIE_UNLESS(rc == MYSQL_NO_DATA);
strcpy(data, "5.61");
rc= mysql_stmt_execute(stmt);
@@ -6711,17 +6797,17 @@ static void test_decimal_bug()
check_execute(stmt, rc);
fprintf(stdout, "\n data: %s", data);
- assert(strcmp(data, "5.61") == 0);
+ DIE_UNLESS(strcmp(data, "5.61") == 0);
rc= mysql_stmt_fetch(stmt);
- assert(rc == MYSQL_NO_DATA);
+ DIE_UNLESS(rc == MYSQL_NO_DATA);
is_null= 1;
rc= mysql_stmt_execute(stmt);
check_execute(stmt, rc);
rc= mysql_stmt_fetch(stmt);
- assert(rc == MYSQL_NO_DATA);
+ DIE_UNLESS(rc == MYSQL_NO_DATA);
strcpy(data, "10.22"); is_null= 0;
rc= mysql_stmt_execute(stmt);
@@ -6735,10 +6821,10 @@ static void test_decimal_bug()
check_execute(stmt, rc);
fprintf(stdout, "\n data: %s", data);
- assert(strcmp(data, "10.22") == 0);
+ DIE_UNLESS(strcmp(data, "10.22") == 0);
rc= mysql_stmt_fetch(stmt);
- assert(rc == MYSQL_NO_DATA);
+ DIE_UNLESS(rc == MYSQL_NO_DATA);
mysql_stmt_close(stmt);
}
@@ -6768,14 +6854,15 @@ static void test_explain_bug()
rc= mysql_stmt_execute(stmt);
check_execute(stmt, rc);
- assert( 2 == my_process_stmt_result(stmt));
+ rc= my_process_stmt_result(stmt);
+ DIE_UNLESS(rc == 2);
result= mysql_stmt_result_metadata(stmt);
mytest(result);
fprintf(stdout, "\n total fields in the result: %d",
mysql_num_fields(result));
- assert(6 == mysql_num_fields(result));
+ DIE_UNLESS(6 == mysql_num_fields(result));
verify_prepare_field(result, 0, "Field", "", MYSQL_TYPE_VAR_STRING,
"", "", "", NAME_LEN, 0);
@@ -6804,14 +6891,15 @@ static void test_explain_bug()
rc= mysql_stmt_execute(stmt);
check_execute(stmt, rc);
- assert( 1 == my_process_stmt_result(stmt));
+ rc= my_process_stmt_result(stmt);
+ DIE_UNLESS(rc == 1);
result= mysql_stmt_result_metadata(stmt);
mytest(result);
fprintf(stdout, "\n total fields in the result: %d",
mysql_num_fields(result));
- assert(10 == mysql_num_fields(result));
+ DIE_UNLESS(10 == mysql_num_fields(result));
verify_prepare_field(result, 0, "id", "", MYSQL_TYPE_LONGLONG,
"", "", "", 3, 0);
@@ -6863,7 +6951,7 @@ static void check_errcode(const unsigned int err)
else
fprintf(stdout, "\n [MySQL]");
fprintf(stdout, "[%d] %s\n", mysql_errno(mysql), mysql_error(mysql));
- assert(mysql_errno(mysql) == err);
+ DIE_UNLESS(mysql_errno(mysql) == err);
}
@@ -6959,16 +7047,16 @@ static void test_drop_temp()
rc= mysql_query(mysql, "drop database test_drop_temp_db");
myquery(rc);
- assert(1 == mysql_affected_rows(mysql));
+ DIE_UNLESS(1 == mysql_affected_rows(mysql));
rc= mysql_query(mysql, "delete from mysql.user where User='test_temp'");
myquery(rc);
- assert(1 == mysql_affected_rows(mysql));
+ DIE_UNLESS(1 == mysql_affected_rows(mysql));
rc= mysql_query(mysql, "delete from mysql.tables_priv where User='test_temp'");
myquery(rc);
- assert(1 == mysql_affected_rows(mysql));
+ DIE_UNLESS(1 == mysql_affected_rows(mysql));
}
}
#endif
@@ -6997,14 +7085,14 @@ static void test_cuted_rows()
count= mysql_warning_count(mysql);
fprintf(stdout, "\n total warnings: %d", count);
- assert(count == 0);
+ DIE_UNLESS(count == 0);
rc= mysql_query(mysql, "INSERT INTO t2 SELECT * FROM t1");
myquery(rc);
count= mysql_warning_count(mysql);
fprintf(stdout, "\n total warnings: %d", count);
- assert(count == 2);
+ DIE_UNLESS(count == 2);
rc= mysql_query(mysql, "SHOW WARNINGS");
myquery(rc);
@@ -7012,7 +7100,8 @@ static void test_cuted_rows()
result= mysql_store_result(mysql);
mytest(result);
- assert(2 == my_process_result_set(result));
+ rc= my_process_result_set(result);
+ DIE_UNLESS(rc == 2);
mysql_free_result(result);
rc= mysql_query(mysql, "INSERT INTO t1 VALUES('junk'), (876789)");
@@ -7020,7 +7109,7 @@ static void test_cuted_rows()
count= mysql_warning_count(mysql);
fprintf(stdout, "\n total warnings: %d", count);
- assert(count == 2);
+ DIE_UNLESS(count == 2);
rc= mysql_query(mysql, "SHOW WARNINGS");
myquery(rc);
@@ -7028,7 +7117,8 @@ static void test_cuted_rows()
result= mysql_store_result(mysql);
mytest(result);
- assert(2 == my_process_result_set(result));
+ rc= my_process_result_set(result);
+ DIE_UNLESS(rc == 2);
mysql_free_result(result);
}
@@ -7134,44 +7224,44 @@ static void test_logs()
fprintf(stdout, "\n id : %d", id);
fprintf(stdout, "\n name : %s(%ld)", data, length);
- assert(id == 9876);
- assert(length == 19); /* Due to VARCHAR(20) */
- assert(strcmp(data, "MySQL - Open Source") == 0);
+ DIE_UNLESS(id == 9876);
+ DIE_UNLESS(length == 19); /* Due to VARCHAR(20) */
+ DIE_UNLESS(strcmp(data, "MySQL - Open Source") == 0);
rc= mysql_stmt_fetch(stmt);
check_execute(stmt, rc);
fprintf(stdout, "\n name : %s(%ld)", data, length);
- assert(length == 1);
- assert(strcmp(data, "'") == 0);
+ DIE_UNLESS(length == 1);
+ DIE_UNLESS(strcmp(data, "'") == 0);
rc= mysql_stmt_fetch(stmt);
check_execute(stmt, rc);
fprintf(stdout, "\n name : %s(%ld)", data, length);
- assert(length == 1);
- assert(strcmp(data, "\"") == 0);
+ DIE_UNLESS(length == 1);
+ DIE_UNLESS(strcmp(data, "\"") == 0);
rc= mysql_stmt_fetch(stmt);
check_execute(stmt, rc);
fprintf(stdout, "\n name : %s(%ld)", data, length);
- assert(length == 7);
- assert(strcmp(data, "my\'sql\'") == 0);
+ DIE_UNLESS(length == 7);
+ DIE_UNLESS(strcmp(data, "my\'sql\'") == 0);
rc= mysql_stmt_fetch(stmt);
check_execute(stmt, rc);
fprintf(stdout, "\n name : %s(%ld)", data, length);
- assert(length == 7);
- /*assert(strcmp(data, "my\"sql\"") == 0); */
+ DIE_UNLESS(length == 7);
+ /*DIE_UNLESS(strcmp(data, "my\"sql\"") == 0); */
rc= mysql_stmt_fetch(stmt);
- assert(rc == MYSQL_NO_DATA);
+ DIE_UNLESS(rc == MYSQL_NO_DATA);
mysql_stmt_close(stmt);
@@ -7239,10 +7329,10 @@ static void test_nstmts()
rc= mysql_stmt_fetch(stmt);
check_execute(stmt, rc);
fprintf(stdout, "\n total rows: %d", i);
- assert( i == total_stmts);
+ DIE_UNLESS( i == total_stmts);
rc= mysql_stmt_fetch(stmt);
- assert(rc == MYSQL_NO_DATA);
+ DIE_UNLESS(rc == MYSQL_NO_DATA);
mysql_stmt_close(stmt);
@@ -7339,7 +7429,7 @@ static void test_fetch_seek()
check_execute(stmt, rc);
rc= mysql_stmt_fetch(stmt);
- assert(rc == MYSQL_NO_DATA);
+ DIE_UNLESS(rc == MYSQL_NO_DATA);
mysql_stmt_close(stmt);
}
@@ -7396,17 +7486,17 @@ static void test_fetch_offset()
rc= mysql_stmt_fetch_column(stmt, bind, 0, 0);
check_execute(stmt, rc);
fprintf(stdout, "\n col 1: %s (%ld)", data, length);
- assert(strncmp(data, "abcd", 4) == 0 && length == 10);
+ DIE_UNLESS(strncmp(data, "abcd", 4) == 0 && length == 10);
rc= mysql_stmt_fetch_column(stmt, bind, 0, 5);
check_execute(stmt, rc);
fprintf(stdout, "\n col 1: %s (%ld)", data, length);
- assert(strncmp(data, "fg", 2) == 0 && length == 10);
+ DIE_UNLESS(strncmp(data, "fg", 2) == 0 && length == 10);
rc= mysql_stmt_fetch_column(stmt, bind, 0, 9);
check_execute(stmt, rc);
fprintf(stdout, "\n col 0: %s (%ld)", data, length);
- assert(strncmp(data, "j", 1) == 0 && length == 10);
+ DIE_UNLESS(strncmp(data, "j", 1) == 0 && length == 10);
rc= mysql_stmt_fetch(stmt);
check_execute(stmt, rc);
@@ -7416,10 +7506,10 @@ static void test_fetch_offset()
rc= mysql_stmt_fetch_column(stmt, bind, 0, 0);
check_execute(stmt, rc);
- assert(is_null == 1);
+ DIE_UNLESS(is_null == 1);
rc= mysql_stmt_fetch(stmt);
- assert(rc == MYSQL_NO_DATA);
+ DIE_UNLESS(rc == MYSQL_NO_DATA);
rc= mysql_stmt_fetch_column(stmt, bind, 1, 0);
check_execute_r(stmt, rc);
@@ -7490,13 +7580,13 @@ static void test_fetch_column()
rc= mysql_stmt_fetch_column(stmt, bind, 1, 0);
check_execute(stmt, rc);
fprintf(stdout, "\n col 1: %s(%ld)", c2, l2);
- assert(strncmp(c2, "venu", 4) == 0 && l2 == 4);
+ DIE_UNLESS(strncmp(c2, "venu", 4) == 0 && l2 == 4);
c2[0]= '\0'; l2= 0;
rc= mysql_stmt_fetch_column(stmt, bind, 1, 0);
check_execute(stmt, rc);
fprintf(stdout, "\n col 1: %s(%ld)", c2, l2);
- assert(strcmp(c2, "venu") == 0 && l2 == 4);
+ DIE_UNLESS(strcmp(c2, "venu") == 0 && l2 == 4);
c1= 0;
bind[0].buffer_type= MYSQL_TYPE_LONG;
@@ -7508,7 +7598,7 @@ static void test_fetch_column()
rc= mysql_stmt_fetch_column(stmt, bind, 0, 0);
check_execute(stmt, rc);
fprintf(stdout, "\n col 0: %d(%ld)", c1, l1);
- assert(c1 == 1 && l1 == 4);
+ DIE_UNLESS(c1 == 1 && l1 == 4);
rc= mysql_stmt_fetch(stmt);
check_execute(stmt, rc);
@@ -7525,13 +7615,13 @@ static void test_fetch_column()
rc= mysql_stmt_fetch_column(stmt, bind, 1, 0);
check_execute(stmt, rc);
fprintf(stdout, "\n col 1: %s(%ld)", c2, l2);
- assert(strncmp(c2, "mysq", 4) == 0 && l2 == 5);
+ DIE_UNLESS(strncmp(c2, "mysq", 4) == 0 && l2 == 5);
c2[0]= '\0'; l2= 0;
rc= mysql_stmt_fetch_column(stmt, bind, 1, 0);
check_execute(stmt, rc);
fprintf(stdout, "\n col 1: %si(%ld)", c2, l2);
- assert(strcmp(c2, "mysql") == 0 && l2 == 5);
+ DIE_UNLESS(strcmp(c2, "mysql") == 0 && l2 == 5);
c1= 0;
bind[0].buffer_type= MYSQL_TYPE_LONG;
@@ -7543,10 +7633,10 @@ static void test_fetch_column()
rc= mysql_stmt_fetch_column(stmt, bind, 0, 0);
check_execute(stmt, rc);
fprintf(stdout, "\n col 0: %d(%ld)", c1, l1);
- assert(c1 == 2 && l1 == 4);
+ DIE_UNLESS(c1 == 2 && l1 == 4);
rc= mysql_stmt_fetch(stmt);
- assert(rc == MYSQL_NO_DATA);
+ DIE_UNLESS(rc == MYSQL_NO_DATA);
rc= mysql_stmt_fetch_column(stmt, bind, 1, 0);
check_execute_r(stmt, rc);
@@ -7572,13 +7662,16 @@ static void test_list_fields()
result= mysql_list_fields(mysql, "test_list_fields", NULL);
mytest(result);
- assert( 0 == my_process_result_set(result));
+ rc= my_process_result_set(result);
+ DIE_UNLESS(rc == 0);
verify_prepare_field(result, 0, "c1", "c1", MYSQL_TYPE_LONG,
- "test_list_fields", "test_list_fields", current_db, 11, "0");
+ "test_list_fields", "test_list_fields",
+ current_db, 11, "0");
verify_prepare_field(result, 1, "c2", "c2", MYSQL_TYPE_STRING,
- "test_list_fields", "test_list_fields", current_db, 10, "mysql");
+ "test_list_fields", "test_list_fields",
+ current_db, 10, "mysql");
mysql_free_result(result);
}
@@ -7631,7 +7724,8 @@ static void test_mem_overun()
rc= mysql_query(mysql, "select * from t_mem_overun");
myquery(rc);
- assert(1 == my_process_result(mysql));
+ rc= my_process_result(mysql);
+ DIE_UNLESS(rc == 1);
stmt= mysql_simple_prepare(mysql, "select * from t_mem_overun");
check_stmt(stmt);
@@ -7643,7 +7737,7 @@ static void test_mem_overun()
mytest(field_res);
fprintf(stdout, "\n total fields : %d", mysql_num_fields(field_res));
- assert( 1000 == mysql_num_fields(field_res));
+ DIE_UNLESS( 1000 == mysql_num_fields(field_res));
rc= mysql_stmt_store_result(stmt);
check_execute(stmt, rc);
@@ -7652,7 +7746,7 @@ static void test_mem_overun()
check_execute(stmt, rc);
rc= mysql_stmt_fetch(stmt);
- assert(rc == MYSQL_NO_DATA);
+ DIE_UNLESS(rc == MYSQL_NO_DATA);
mysql_free_result(field_res);
@@ -7710,7 +7804,7 @@ static void test_free_result()
rc= mysql_stmt_fetch_column(stmt, bind, 0, 0);
check_execute(stmt, rc);
fprintf(stdout, "\n col 0: %s(%ld)", c2, l2);
- assert(strncmp(c2, "1", 1) == 0 && l2 == 1);
+ DIE_UNLESS(strncmp(c2, "1", 1) == 0 && l2 == 1);
rc= mysql_stmt_fetch(stmt);
check_execute(stmt, rc);
@@ -7725,7 +7819,7 @@ static void test_free_result()
rc= mysql_stmt_fetch_column(stmt, bind, 0, 0);
check_execute(stmt, rc);
fprintf(stdout, "\n col 0: %d(%ld)", c1, l2);
- assert(c1 == 2 && l2 == 4);
+ DIE_UNLESS(c1 == 2 && l2 == 4);
rc= mysql_query(mysql, "drop table test_free_result");
myquery_r(rc); /* error should be, COMMANDS OUT OF SYNC */
@@ -7792,7 +7886,7 @@ static void test_free_store_result()
rc= mysql_stmt_fetch_column(stmt, bind, 0, 0);
check_execute(stmt, rc);
fprintf(stdout, "\n col 1: %s(%ld)", c2, l2);
- assert(strncmp(c2, "1", 1) == 0 && l2 == 1);
+ DIE_UNLESS(strncmp(c2, "1", 1) == 0 && l2 == 1);
rc= mysql_stmt_fetch(stmt);
check_execute(stmt, rc);
@@ -7807,7 +7901,7 @@ static void test_free_store_result()
rc= mysql_stmt_fetch_column(stmt, bind, 0, 0);
check_execute(stmt, rc);
fprintf(stdout, "\n col 0: %d(%ld)", c1, l2);
- assert(c1 == 2 && l2 == 4);
+ DIE_UNLESS(c1 == 2 && l2 == 4);
rc= mysql_stmt_free_result(stmt);
check_execute(stmt, rc);
@@ -7916,7 +8010,7 @@ static void test_sqlmode()
check_execute(stmt, rc);
rc= mysql_stmt_fetch(stmt);
- assert(rc == MYSQL_NO_DATA);
+ DIE_UNLESS(rc == MYSQL_NO_DATA);
fprintf(stdout, "\n returned 1 row\n");
mysql_stmt_close(stmt);
@@ -7939,7 +8033,7 @@ static void test_sqlmode()
check_execute(stmt, rc);
rc= mysql_stmt_fetch(stmt);
- assert(rc == MYSQL_NO_DATA);
+ DIE_UNLESS(rc == MYSQL_NO_DATA);
fprintf(stdout, "\n returned 1 row");
mysql_stmt_close(stmt);
@@ -8019,7 +8113,8 @@ static void test_ts()
rc= mysql_stmt_execute(stmt);
check_execute(stmt, rc);
- assert(2 == my_process_stmt_result(stmt));
+ rc= my_process_stmt_result(stmt);
+ DIE_UNLESS(rc == 2);
field_count= mysql_num_fields(prep_res);
mysql_free_result(prep_res);
@@ -8045,7 +8140,7 @@ static void test_ts()
row_count++;
fprintf(stdout, "\n returned '%d' rows", row_count);
- assert(row_count == 2);
+ DIE_UNLESS(row_count == 2);
mysql_stmt_close(stmt);
}
}
@@ -8097,7 +8192,8 @@ static void test_bug1500()
rc= mysql_stmt_execute(stmt);
check_execute(stmt, rc);
- assert(1 == my_process_stmt_result(stmt));
+ rc= my_process_stmt_result(stmt);
+ DIE_UNLESS(rc == 1);
mysql_stmt_close(stmt);
@@ -8133,7 +8229,8 @@ static void test_bug1500()
rc= mysql_stmt_execute(stmt);
check_execute(stmt, rc);
- assert(1 == my_process_stmt_result(stmt));
+ rc= my_process_stmt_result(stmt);
+ DIE_UNLESS(rc == 1);
/*
FIXME If we comment out next string server will crash too :(
@@ -8159,7 +8256,8 @@ static void test_bug1500()
rc= mysql_stmt_execute(stmt);
check_execute(stmt, rc);
- assert(1 == my_process_stmt_result(stmt));
+ rc= my_process_stmt_result(stmt);
+ DIE_UNLESS(rc == 1);
mysql_stmt_close(stmt);
}
@@ -8182,7 +8280,7 @@ static void test_bug1946()
stmt= mysql_simple_prepare(mysql, query);
check_stmt(stmt);
rc= mysql_real_query(mysql, query, strlen(query));
- assert(rc != 0);
+ DIE_UNLESS(rc != 0);
fprintf(stdout, "Got error (as expected):\n");
myerror(NULL);
@@ -8200,18 +8298,19 @@ static void test_parse_error_and_bad_length()
myheader("test_parse_error_and_bad_length");
rc= mysql_query(mysql, "SHOW DATABAAAA");
- assert(rc);
+ DIE_UNLESS(rc);
fprintf(stdout, "Got error (as expected): '%s'\n", mysql_error(mysql));
rc= mysql_real_query(mysql, "SHOW DATABASES", 100);
- assert(rc);
+ DIE_UNLESS(rc);
fprintf(stdout, "Got error (as expected): '%s'\n", mysql_error(mysql));
stmt= mysql_simple_prepare(mysql, "SHOW DATABAAAA");
- assert(!stmt);
+ DIE_UNLESS(!stmt);
fprintf(stdout, "Got error (as expected): '%s'\n", mysql_error(mysql));
stmt= mysql_stmt_init(mysql);
- assert(stmt);
- assert(mysql_stmt_prepare(stmt, "SHOW DATABASES", 100) != 0);
+ DIE_UNLESS(stmt);
+ rc= mysql_stmt_prepare(stmt, "SHOW DATABASES", 100);
+ DIE_UNLESS(rc != 0);
fprintf(stdout, "Got error (as expected): '%s'\n", mysql_stmt_error(stmt));
mysql_stmt_close(stmt);
}
@@ -8250,7 +8349,7 @@ static void test_bug2247()
check_execute(stmt, rc);
}
exp_count= mysql_stmt_affected_rows(stmt);
- assert(exp_count == 1);
+ DIE_UNLESS(exp_count == 1);
rc= mysql_query(mysql, select);
myquery(rc);
@@ -8262,13 +8361,13 @@ static void test_bug2247()
res= mysql_store_result(mysql);
mytest(res);
- assert(mysql_affected_rows(mysql) == NUM_ROWS);
- assert(exp_count == mysql_stmt_affected_rows(stmt));
+ DIE_UNLESS(mysql_affected_rows(mysql) == NUM_ROWS);
+ DIE_UNLESS(exp_count == mysql_stmt_affected_rows(stmt));
rc= mysql_query(mysql, update);
myquery(rc);
- assert(mysql_affected_rows(mysql) == NUM_ROWS);
- assert(exp_count == mysql_stmt_affected_rows(stmt));
+ DIE_UNLESS(mysql_affected_rows(mysql) == NUM_ROWS);
+ DIE_UNLESS(exp_count == mysql_stmt_affected_rows(stmt));
mysql_free_result(res);
mysql_stmt_close(stmt);
@@ -8282,12 +8381,12 @@ static void test_bug2247()
rc= mysql_stmt_store_result(stmt);
check_execute(stmt, rc);
exp_count= mysql_stmt_affected_rows(stmt);
- assert(exp_count == NUM_ROWS);
+ DIE_UNLESS(exp_count == NUM_ROWS);
rc= mysql_query(mysql, insert);
myquery(rc);
- assert(mysql_affected_rows(mysql) == 1);
- assert(mysql_stmt_affected_rows(stmt) == exp_count);
+ DIE_UNLESS(mysql_affected_rows(mysql) == 1);
+ DIE_UNLESS(mysql_stmt_affected_rows(stmt) == exp_count);
mysql_stmt_close(stmt);
fprintf(stdout, "OK");
@@ -8321,7 +8420,8 @@ static void test_subqueries()
{
rc= mysql_stmt_execute(stmt);
check_execute(stmt, rc);
- assert(5 == my_process_stmt_result(stmt));
+ rc= my_process_stmt_result(stmt);
+ DIE_UNLESS(rc == 5);
}
mysql_stmt_close(stmt);
@@ -8338,7 +8438,7 @@ static void test_bad_union()
myheader("test_bad_union");
stmt= mysql_simple_prepare(mysql, query);
- assert(stmt == 0);
+ DIE_UNLESS(stmt == 0);
myerror(NULL);
}
@@ -8369,7 +8469,8 @@ static void test_distinct()
check_stmt(stmt);
rc= mysql_stmt_execute(stmt);
check_execute(stmt, rc);
- assert(5 == my_process_stmt_result(stmt));
+ rc= my_process_stmt_result(stmt);
+ DIE_UNLESS(rc == 5);
mysql_stmt_close(stmt);
}
@@ -8418,7 +8519,7 @@ static void test_bug2248()
/* This too should not hang but should return proper error */
rc= mysql_stmt_fetch(stmt);
- assert(rc == MYSQL_NO_DATA);
+ DIE_UNLESS(rc == MYSQL_NO_DATA);
/* This too should not hang but should not bark */
rc= mysql_stmt_store_result(stmt);
@@ -8427,7 +8528,7 @@ static void test_bug2248()
/* This should return proper error */
rc= mysql_stmt_fetch(stmt);
check_execute_r(stmt, rc);
- assert(rc == MYSQL_NO_DATA);
+ DIE_UNLESS(rc == MYSQL_NO_DATA);
mysql_stmt_close(stmt);
@@ -8460,7 +8561,8 @@ static void test_subqueries_ref()
{
rc= mysql_stmt_execute(stmt);
check_execute(stmt, rc);
- assert(1 == my_process_stmt_result(stmt));
+ rc= my_process_stmt_result(stmt);
+ DIE_UNLESS(rc == 1);
}
mysql_stmt_close(stmt);
@@ -8513,7 +8615,8 @@ static void test_union()
rc= mysql_stmt_execute(stmt);
check_execute(stmt, rc);
- assert(20 == my_process_stmt_result(stmt));
+ rc= my_process_stmt_result(stmt);
+ DIE_UNLESS(rc == 20);
mysql_stmt_close(stmt);
rc= mysql_query(mysql, "DROP TABLE t1, t2");
@@ -8563,7 +8666,7 @@ static void test_bug3117()
rc= mysql_stmt_fetch(stmt);
check_execute(stmt, rc);
- assert(is_null == 0 && lii == 1);
+ DIE_UNLESS(is_null == 0 && lii == 1);
fprintf(stdout, "\n\tLAST_INSERT_ID()= 1 ok\n");
rc= mysql_query(mysql, "INSERT INTO t1 VALUES (NULL)");
@@ -8575,7 +8678,7 @@ static void test_bug3117()
rc= mysql_stmt_fetch(stmt);
check_execute(stmt, rc);
- assert(is_null == 0 && lii == 2);
+ DIE_UNLESS(is_null == 0 && lii == 2);
fprintf(stdout, "\tLAST_INSERT_ID()= 2 ok\n");
mysql_stmt_close(stmt);
@@ -8626,7 +8729,8 @@ static void test_join()
{
rc= mysql_stmt_execute(stmt);
check_execute(stmt, rc);
- assert(5 == my_process_stmt_result(stmt));
+ rc= my_process_stmt_result(stmt);
+ DIE_UNLESS(rc == 5);
}
mysql_stmt_close(stmt);
}
@@ -8673,7 +8777,8 @@ static void test_selecttmp()
{
rc= mysql_stmt_execute(stmt);
check_execute(stmt, rc);
- assert(3 == my_process_stmt_result(stmt));
+ rc= my_process_stmt_result(stmt);
+ DIE_UNLESS(rc == 3);
}
mysql_stmt_close(stmt);
@@ -8728,7 +8833,8 @@ static void test_create_drop()
rc= mysql_stmt_execute(stmt_select);
check_execute(stmt_select, rc);
- assert(0 == my_process_stmt_result(stmt_select));
+ rc= my_process_stmt_result(stmt_select);
+ DIE_UNLESS(rc == 0);
rc= mysql_stmt_execute(stmt_drop);
check_execute(stmt_drop, rc);
@@ -8740,7 +8846,8 @@ static void test_create_drop()
rc= mysql_stmt_execute(stmt_select);
check_execute(stmt_select, rc);
- assert(3 == my_process_stmt_result(stmt_select));
+ rc= my_process_stmt_result(stmt_select);
+ DIE_UNLESS(rc == 3);
rc= mysql_stmt_execute(stmt_drop);
check_execute(stmt_drop, rc);
@@ -8904,11 +9011,13 @@ static void test_multi()
rc= mysql_stmt_execute(stmt_select1);
check_execute(stmt_select1, rc);
- assert((uint)(3-param) == my_process_stmt_result(stmt_select1));
+ rc= my_process_stmt_result(stmt_select1);
+ DIE_UNLESS(rc == 3-param);
rc= mysql_stmt_execute(stmt_select2);
check_execute(stmt_select2, rc);
- assert((uint)(3-param) == my_process_stmt_result(stmt_select2));
+ rc= my_process_stmt_result(stmt_select2);
+ DIE_UNLESS(rc == 3-param);
param++;
}
@@ -8958,7 +9067,8 @@ static void test_insert_select()
rc= mysql_stmt_execute(stmt_select);
check_execute(stmt_select, rc);
- assert((i+1) == my_process_stmt_result(stmt_select));
+ rc= my_process_stmt_result(stmt_select);
+ DIE_UNLESS(rc == (int)(i+1));
}
mysql_stmt_close(stmt_insert);
@@ -9056,7 +9166,8 @@ TYPE=InnoDB DEFAULT CHARSET=utf8");
{
rc= mysql_stmt_execute(stmt);
check_execute(stmt, rc);
- assert(1 == my_process_stmt_result(stmt));
+ rc= my_process_stmt_result(stmt);
+ DIE_UNLESS(rc == 1);
}
mysql_stmt_close(stmt);
@@ -9108,7 +9219,8 @@ static void test_xjoin()
{
rc= mysql_stmt_execute(stmt);
check_execute(stmt, rc);
- assert(1 == my_process_stmt_result(stmt));
+ rc= my_process_stmt_result(stmt);
+ DIE_UNLESS(rc == 1);
}
mysql_stmt_close(stmt);
@@ -9265,37 +9377,37 @@ static void test_bug3035()
rc= mysql_stmt_fetch(stmt);
check_execute(stmt, rc);
- assert(int8_val == int8_min);
- assert(uint8_val == uint8_min);
- assert(int16_val == int16_min);
- assert(uint16_val == uint16_min);
- assert(int32_val == int32_min);
- assert(uint32_val == uint32_min);
- assert(int64_val == int64_min);
- assert(uint64_val == uint64_min);
- assert(double_val == (longlong) uint64_min);
- assert(udouble_val == ulonglong2double(uint64_val));
- assert(!strcmp(longlong_as_string, "0"));
- assert(!strcmp(ulonglong_as_string, "0"));
+ DIE_UNLESS(int8_val == int8_min);
+ DIE_UNLESS(uint8_val == uint8_min);
+ DIE_UNLESS(int16_val == int16_min);
+ DIE_UNLESS(uint16_val == uint16_min);
+ DIE_UNLESS(int32_val == int32_min);
+ DIE_UNLESS(uint32_val == uint32_min);
+ DIE_UNLESS(int64_val == int64_min);
+ DIE_UNLESS(uint64_val == uint64_min);
+ DIE_UNLESS(double_val == (longlong) uint64_min);
+ DIE_UNLESS(udouble_val == ulonglong2double(uint64_val));
+ DIE_UNLESS(!strcmp(longlong_as_string, "0"));
+ DIE_UNLESS(!strcmp(ulonglong_as_string, "0"));
rc= mysql_stmt_fetch(stmt);
check_execute(stmt, rc);
- assert(int8_val == int8_max);
- assert(uint8_val == uint8_max);
- assert(int16_val == int16_max);
- assert(uint16_val == uint16_max);
- assert(int32_val == int32_max);
- assert(uint32_val == uint32_max);
- assert(int64_val == int64_max);
- assert(uint64_val == uint64_max);
- assert(double_val == (longlong) uint64_val);
- assert(udouble_val == ulonglong2double(uint64_val));
- assert(!strcmp(longlong_as_string, "-1"));
- assert(!strcmp(ulonglong_as_string, "18446744073709551615"));
+ DIE_UNLESS(int8_val == int8_max);
+ DIE_UNLESS(uint8_val == uint8_max);
+ DIE_UNLESS(int16_val == int16_max);
+ DIE_UNLESS(uint16_val == uint16_max);
+ DIE_UNLESS(int32_val == int32_max);
+ DIE_UNLESS(uint32_val == uint32_max);
+ DIE_UNLESS(int64_val == int64_max);
+ DIE_UNLESS(uint64_val == uint64_max);
+ DIE_UNLESS(double_val == (longlong) uint64_val);
+ DIE_UNLESS(udouble_val == ulonglong2double(uint64_val));
+ DIE_UNLESS(!strcmp(longlong_as_string, "-1"));
+ DIE_UNLESS(!strcmp(ulonglong_as_string, "18446744073709551615"));
rc= mysql_stmt_fetch(stmt);
- assert(rc == MYSQL_NO_DATA);
+ DIE_UNLESS(rc == MYSQL_NO_DATA);
mysql_stmt_close(stmt);
@@ -9329,7 +9441,8 @@ static void test_union2()
{
rc= mysql_stmt_execute(stmt);
check_execute(stmt, rc);
- assert(0 == my_process_stmt_result(stmt));
+ rc= my_process_stmt_result(stmt);
+ DIE_UNLESS(rc == 0);
}
mysql_stmt_close(stmt);
@@ -9562,7 +9675,8 @@ static void test_union_param()
{
rc= mysql_stmt_execute(stmt);
check_execute(stmt, rc);
- assert(1 == my_process_stmt_result(stmt));
+ rc= my_process_stmt_result(stmt);
+ DIE_UNLESS(rc == 1);
}
mysql_stmt_close(stmt);
@@ -9653,13 +9767,13 @@ static void test_ps_i18n()
rc= mysql_stmt_fetch(stmt);
check_execute(stmt, rc);
- assert(buf1_len == strlen(cp1251));
- assert(buf2_len == strlen(cp1251));
- assert(!memcmp(buf1, cp1251, buf1_len));
- assert(!memcmp(buf2, cp1251, buf1_len));
+ DIE_UNLESS(buf1_len == strlen(cp1251));
+ DIE_UNLESS(buf2_len == strlen(cp1251));
+ DIE_UNLESS(!memcmp(buf1, cp1251, buf1_len));
+ DIE_UNLESS(!memcmp(buf2, cp1251, buf1_len));
rc= mysql_stmt_fetch(stmt);
- assert(rc == MYSQL_NO_DATA);
+ DIE_UNLESS(rc == MYSQL_NO_DATA);
stmt_text= "DROP TABLE IF EXISTS t1";
rc= mysql_real_query(mysql, stmt_text, strlen(stmt_text));
@@ -9738,12 +9852,12 @@ static void test_ps_i18n()
while ((rc= mysql_stmt_fetch(stmt)) == 0)
{
- assert(buf1_len == strlen(koi8));
- assert(buf2_len == strlen(koi8));
- assert(!memcmp(buf1, koi8, buf1_len));
- assert(!memcmp(buf2, koi8, buf1_len));
+ DIE_UNLESS(buf1_len == strlen(koi8));
+ DIE_UNLESS(buf2_len == strlen(koi8));
+ DIE_UNLESS(!memcmp(buf1, koi8, buf1_len));
+ DIE_UNLESS(!memcmp(buf2, koi8, buf1_len));
}
- assert(rc == MYSQL_NO_DATA);
+ DIE_UNLESS(rc == MYSQL_NO_DATA);
mysql_stmt_close(stmt);
stmt_text= "DROP TABLE t1";
@@ -9813,18 +9927,18 @@ static void test_bug3796()
check_execute(stmt, rc);
strcpy(canonical_buff, concat_arg0);
strcat(canonical_buff, "ONE");
- assert(strlen(canonical_buff) == out_length &&
+ DIE_UNLESS(strlen(canonical_buff) == out_length &&
strncmp(out_buff, canonical_buff, out_length) == 0);
rc= mysql_stmt_fetch(stmt);
check_execute(stmt, rc);
strcpy(canonical_buff + strlen(concat_arg0), "TWO");
- assert(strlen(canonical_buff) == out_length &&
+ DIE_UNLESS(strlen(canonical_buff) == out_length &&
strncmp(out_buff, canonical_buff, out_length) == 0);
printf("Concat result: '%s'\n", out_buff);
rc= mysql_stmt_fetch(stmt);
- assert(rc == MYSQL_NO_DATA);
+ DIE_UNLESS(rc == MYSQL_NO_DATA);
mysql_stmt_close(stmt);
@@ -9871,7 +9985,7 @@ static void test_bug4026()
time_in.second= 59;
time_in.second_part= 123456;
/*
- This is not necessary, just to make assert below work: this field
+ This is not necessary, just to make DIE_UNLESS below work: this field
is filled in when time is received from server
*/
time_in.time_type= MYSQL_TIMESTAMP_TIME;
@@ -9894,15 +10008,15 @@ static void test_bug4026()
mysql_stmt_bind_result(stmt, bind);
rc= mysql_stmt_fetch(stmt);
- assert(rc == 0);
+ DIE_UNLESS(rc == 0);
printf("%d:%d:%d.%lu\n", time_out.hour, time_out.minute, time_out.second,
time_out.second_part);
printf("%d-%d-%d %d:%d:%d.%lu\n", datetime_out.year, datetime_out.month,
datetime_out.day, datetime_out.hour,
datetime_out.minute, datetime_out.second,
datetime_out.second_part);
- assert(memcmp(&time_in, &time_out, sizeof(time_in)) == 0);
- assert(memcmp(&datetime_in, &datetime_out, sizeof(datetime_in)) == 0);
+ DIE_UNLESS(memcmp(&time_in, &time_out, sizeof(time_in)) == 0);
+ DIE_UNLESS(memcmp(&datetime_in, &datetime_out, sizeof(datetime_in)) == 0);
mysql_stmt_close(stmt);
}
@@ -9942,7 +10056,7 @@ static void test_bug4079()
mysql_stmt_bind_result(stmt, bind);
rc= mysql_stmt_fetch(stmt);
- assert(rc != 0 && rc != MYSQL_NO_DATA);
+ DIE_UNLESS(rc != 0 && rc != MYSQL_NO_DATA);
printf("Got error from mysql_stmt_fetch (as expected):\n%s\n",
mysql_stmt_error(stmt));
/* buggy version of libmysql hanged up here */
@@ -9970,7 +10084,7 @@ static void test_bug4236()
backup.stmt_id= stmt->stmt_id;
stmt->stmt_id= 0;
rc= mysql_stmt_execute(stmt);
- assert(rc);
+ DIE_UNLESS(rc);
/* Restore original statement id to be able to reprepare it */
stmt->stmt_id= backup.stmt_id;
@@ -10037,7 +10151,7 @@ static void test_bug4030()
mysql_stmt_bind_result(stmt, bind);
rc= mysql_stmt_fetch(stmt);
- assert(rc == 0);
+ DIE_UNLESS(rc == 0);
printf("%d:%d:%d.%lu\n", time_out.hour, time_out.minute, time_out.second,
time_out.second_part);
printf("%d-%d-%d\n", date_out.year, date_out.month, date_out.day);
@@ -10045,9 +10159,9 @@ static void test_bug4030()
datetime_out.day, datetime_out.hour,
datetime_out.minute, datetime_out.second,
datetime_out.second_part);
- assert(memcmp(&time_canonical, &time_out, sizeof(time_out)) == 0);
- assert(memcmp(&date_canonical, &date_out, sizeof(date_out)) == 0);
- assert(memcmp(&datetime_canonical, &datetime_out, sizeof(datetime_out)) == 0);
+ DIE_UNLESS(memcmp(&time_canonical, &time_out, sizeof(time_out)) == 0);
+ DIE_UNLESS(memcmp(&date_canonical, &date_out, sizeof(date_out)) == 0);
+ DIE_UNLESS(memcmp(&datetime_canonical, &datetime_out, sizeof(datetime_out)) == 0);
mysql_stmt_close(stmt);
}
@@ -10092,8 +10206,8 @@ static void test_bug5126()
mysql_stmt_bind_result(stmt, bind);
rc= mysql_stmt_fetch(stmt);
- assert(rc == 0);
- assert(c1 == 8386608 && c2 == 1);
+ DIE_UNLESS(rc == 0);
+ DIE_UNLESS(c1 == 8386608 && c2 == 1);
printf("%ld, %ld\n", (long) c1, (long) c2);
mysql_stmt_close(stmt);
}
@@ -10156,14 +10270,14 @@ static void test_bug4231()
rc= mysql_stmt_fetch(stmt);
/* binds are unequal, no rows should be returned */
- DBUG_ASSERT(rc == MYSQL_NO_DATA);
+ DIE_UNLESS(rc == MYSQL_NO_DATA);
/* Set one of the dates to zero */
tm[0].year= tm[0].month= tm[0].day= 0;
tm[1]= tm[0];
mysql_stmt_execute(stmt);
rc= mysql_stmt_fetch(stmt);
- DBUG_ASSERT(rc == 0);
+ DIE_UNLESS(rc == 0);
mysql_stmt_close(stmt);
stmt_text= "DROP TABLE t1";
@@ -10208,8 +10322,8 @@ static void test_bug5399()
rc= mysql_stmt_store_result(stmt[i]);
check_execute(stmt[i], rc);
rc= mysql_stmt_fetch(stmt[i]);
- assert(rc == 0);
- assert((int32) i == no);
+ DIE_UNLESS(rc == 0);
+ DIE_UNLESS((int32) i == no);
}
for (i= 0; i < NUM_OF_USED_STMT; ++i)
@@ -10410,19 +10524,19 @@ static void test_bug5315()
stmt_text= "SELECT 1";
stmt= mysql_stmt_init(mysql);
rc= mysql_stmt_prepare(stmt, stmt_text, strlen(stmt_text));
- DBUG_ASSERT(rc == 0);
+ DIE_UNLESS(rc == 0);
mysql_change_user(mysql, opt_user, opt_password, current_db);
rc= mysql_stmt_execute(stmt);
- DBUG_ASSERT(rc != 0);
+ DIE_UNLESS(rc != 0);
if (rc)
printf("Got error (as expected):\n%s", mysql_stmt_error(stmt));
/* check that connection is OK */
mysql_stmt_close(stmt);
stmt= mysql_stmt_init(mysql);
rc= mysql_stmt_prepare(stmt, stmt_text, strlen(stmt_text));
- DBUG_ASSERT(rc == 0);
+ DIE_UNLESS(rc == 0);
rc= mysql_stmt_execute(stmt);
- DBUG_ASSERT(rc == 0);
+ DIE_UNLESS(rc == 0);
mysql_stmt_close(stmt);
}