| List: | Commits | « Previous MessageNext Message » | |
| From: | jwinstead | Date: | April 6 2007 8:21pm |
| Subject: | Connector/ODBC 3.51 commit: r298 - trunk/test | ||
| View as plain text | |||
Added: trunk/test/my_info.c trunk/test/my_types.c Removed: trunk/test/mytest3.c Modified: trunk/test/ trunk/test/Makefile.am trunk/test/my_basics.c trunk/test/my_blob.c trunk/test/my_catalog.c trunk/test/my_cursor.c trunk/test/my_datetime.c trunk/test/my_error.c trunk/test/my_prepare.c trunk/test/my_relative.c trunk/test/my_result.c Log: Break up mytest3, putting tests into some old tests and a couple of new ones Property changes on: trunk/test ___________________________________________________________________ Name: svn:ignore - .deps .libs Makefile Makefile.in my_basics my_blob my_bulk my_catalog my_col_length my_curext my_cursor my_datetime my_dyn_cursor my_error my_keys my_param my_position my_prepare my_relative my_result my_scroll mytest mytest3 my_tran my_unixodbc my_use_result odbc.ini odbcinst.ini + .deps .libs Makefile Makefile.in my_basics my_blob my_bulk my_catalog my_col_length my_curext my_cursor my_datetime my_dyn_cursor my_error my_info my_keys my_param my_position my_prepare my_relative my_result my_scroll mytest my_tran my_types my_unixodbc my_use_result odbc.ini odbcinst.ini Modified: trunk/test/Makefile.am =================================================================== --- trunk/test/Makefile.am 2007-04-06 17:01:21 UTC (rev 297) +++ trunk/test/Makefile.am 2007-04-06 18:21:39 UTC (rev 298) @@ -48,6 +48,7 @@ my_datetime \ my_dyn_cursor \ my_error \ +my_info \ my_keys \ my_param \ my_position \ @@ -56,10 +57,10 @@ my_result \ my_scroll \ my_tran \ +my_types \ my_unixodbc \ my_use_result \ -mytest \ -mytest3 +mytest noinst_PROGRAMS= $(tap_tests) Modified: trunk/test/my_basics.c =================================================================== --- trunk/test/my_basics.c 2007-04-06 17:01:21 UTC (rev 297) +++ trunk/test/my_basics.c 2007-04-06 18:21:39 UTC (rev 298) @@ -118,8 +118,68 @@ } +DECLARE_TEST(t_max_select) +{ + SQLRETURN rc; + SQLCHAR szData[255]; + SQLINTEGER i; + + tmysql_exec(hstmt,"drop table t_max_select"); + + rc = SQLTransact(NULL,hdbc,SQL_COMMIT); + mycon(hdbc,rc); + + rc = tmysql_exec(hstmt,"create table t_max_select(col1 int ,col2 varchar(30))"); + mystmt(hstmt,rc); + + rc = SQLPrepare(hstmt,"insert into t_max_select values(?,?)",SQL_NTS); + mystmt(hstmt,rc); + + rc = SQLBindParameter(hstmt,1,SQL_PARAM_INPUT,SQL_C_LONG, + SQL_INTEGER,0,0,&i,0,NULL); + mystmt(hstmt,rc); + + rc = SQLBindParameter(hstmt,2,SQL_PARAM_INPUT,SQL_C_CHAR, + SQL_CHAR,0,0,szData,sizeof(szData),NULL); + mystmt(hstmt,rc); + + fprintf(stdout," inserting 1000 rows, it will take some time\n"); + for(i = 1; i <= 1000; i++) + { + fprintf(stdout," \r %d", i); + sprintf((char *)szData,"MySQL%d",i); + rc = SQLExecute(hstmt); + mystmt(hstmt,rc); + } + fprintf(stdout,"\n"); + + rc = SQLFreeStmt(hstmt,SQL_RESET_PARAMS); + mystmt(hstmt,rc); + + rc = SQLFreeStmt(hstmt,SQL_CLOSE); + mystmt(hstmt,rc); + + rc = SQLTransact(NULL,hdbc,SQL_COMMIT); + mycon(hdbc,rc); + + rc = tmysql_exec(hstmt,"select * from t_max_select"); + mystmt(hstmt,rc); + + my_assert( 1000 == myrowcount(hstmt)); + + rc = SQLFreeStmt(hstmt,SQL_UNBIND); + mystmt(hstmt,rc); + + rc = SQLFreeStmt(hstmt,SQL_CLOSE); + mystmt(hstmt,rc); + + return OK; +} + + BEGIN_TESTS ADD_TEST(my_basics) + ADD_TEST(t_max_select) END_TESTS Modified: trunk/test/my_blob.c =================================================================== --- trunk/test/my_blob.c 2007-04-06 17:01:21 UTC (rev 297) +++ trunk/test/my_blob.c 2007-04-06 18:21:39 UTC (rev 298) @@ -199,9 +199,527 @@ } +/* Test for a simple SQLPutData and SQLParamData handling for longtext */ +DECLARE_TEST(t_putdata) +{ + SQLRETURN rc; + SQLLEN pcbLength; + SQLINTEGER c1; + SQLCHAR data[255]; + SQLPOINTER token; + + SQLExecDirect(hstmt,"drop table t_putdata",SQL_NTS); + rc = SQLExecDirect(hstmt,"create table t_putdata(c1 int, c2 long varchar)",SQL_NTS); + mystmt(hstmt,rc); + + rc = SQLPrepare(hstmt,"insert into t_putdata values(?,?)",SQL_NTS); + mystmt(hstmt,rc); + + rc = SQLBindParameter(hstmt,1,SQL_PARAM_INPUT,SQL_C_LONG, + SQL_INTEGER,0,0,&c1,0,NULL); + + rc = SQLBindParameter(hstmt,2,SQL_PARAM_INPUT,SQL_C_CHAR, + SQL_LONGVARCHAR,0,0, + (SQLPOINTER)1,0,&pcbLength); + + pcbLength = SQL_LEN_DATA_AT_EXEC(0); + + c1 = 10; + rc = SQLExecute(hstmt); + myassert(rc == SQL_NEED_DATA); + + rc = SQLParamData(hstmt, &token); + myassert(rc == SQL_NEED_DATA); + + strcpy(data,"mysql ab"); + rc = SQLPutData(hstmt,data,6); + mystmt(hstmt,rc); + + strcpy(data,"- the open source database company"); + rc = SQLPutData(hstmt,data,strlen(data)); + mystmt(hstmt,rc); + + rc = SQLParamData(hstmt, &token); + mystmt(hstmt,rc); + + SQLFreeStmt(hstmt, SQL_RESET_PARAMS); + SQLFreeStmt(hstmt, SQL_CLOSE); + + rc = SQLExecDirect(hstmt,"select c2 from t_putdata where c1= 10",SQL_NTS); + mystmt(hstmt,rc); + + rc = SQLFetch(hstmt); + mystmt(hstmt,rc); + + pcbLength= 0; + rc = SQLGetData(hstmt, 1, SQL_C_CHAR, data, sizeof(data), &pcbLength); + mystmt(hstmt,rc); + fprintf(stdout,"data: %s(%d)\n", data, pcbLength); + myassert(strcmp(data,"mysql - the open source database company")==0); + myassert(pcbLength == 40); + + SQLFreeStmt(hstmt, SQL_UNBIND); + SQLFreeStmt(hstmt, SQL_CLOSE); + + return OK; +} + +/* Test for a simple SQLPutData and SQLParamData handling for longtext */ +DECLARE_TEST(t_putdata1) +{ + SQLRETURN rc; + SQLLEN pcbLength; + SQLINTEGER c1; + SQLCHAR data[255]; + SQLPOINTER token; + + SQLExecDirect(hstmt,"drop table t_putdata",SQL_NTS); + rc = SQLExecDirect(hstmt,"create table t_putdata(c1 int, c2 long varchar)",SQL_NTS); + mystmt(hstmt,rc); + + rc = SQLExecDirect(hstmt,"insert into t_putdata values(10,'venu')",SQL_NTS); + mystmt(hstmt,rc); + + rc = SQLPrepare(hstmt,"update t_putdata set c2= ? where c1 = ?",SQL_NTS); + mystmt(hstmt,rc); + + rc = SQLBindParameter(hstmt,1,SQL_PARAM_INPUT,SQL_C_CHAR, + SQL_LONGVARCHAR,0,0, + (SQLPOINTER)1,0,&pcbLength); + + rc = SQLBindParameter(hstmt,2,SQL_PARAM_INPUT,SQL_C_LONG, + SQL_INTEGER,0,0,&c1,0,NULL); + + pcbLength = SQL_LEN_DATA_AT_EXEC(0); + + c1 = 10; + rc = SQLExecute(hstmt); + myassert(rc == SQL_NEED_DATA); + + rc = SQLParamData(hstmt, &token); + myassert(rc == SQL_NEED_DATA); + + strcpy(data,"mysql ab"); + rc = SQLPutData(hstmt,data,6); + mystmt(hstmt,rc); + + strcpy(data,"- the open source database company"); + rc = SQLPutData(hstmt,data,strlen(data)); + mystmt(hstmt,rc); + + rc = SQLParamData(hstmt, &token); + mystmt(hstmt,rc); + + SQLFreeStmt(hstmt, SQL_RESET_PARAMS); + SQLFreeStmt(hstmt, SQL_CLOSE); + + rc = SQLExecDirect(hstmt,"select c2 from t_putdata where c1= 10",SQL_NTS); + mystmt(hstmt,rc); + + rc = SQLFetch(hstmt); + mystmt(hstmt,rc); + + pcbLength= 0; + rc = SQLGetData(hstmt, 1, SQL_C_CHAR, data, sizeof(data), &pcbLength); + mystmt(hstmt,rc); + fprintf(stdout,"data: %s(%d)\n", data, pcbLength); + myassert(strcmp(data,"mysql - the open source database company")==0); + myassert(pcbLength == 40); + + SQLFreeStmt(hstmt, SQL_UNBIND); + SQLFreeStmt(hstmt, SQL_CLOSE); + + return OK; +} + + +/* Test for a simple SQLPutData and SQLParamData handling for longtext */ +DECLARE_TEST(t_putdata2) +{ + SQLRETURN rc; + SQLLEN pcbLength; + SQLINTEGER c1; + SQLCHAR data[255]; + SQLPOINTER token; + + SQLExecDirect(hstmt,"drop table t_putdata",SQL_NTS); + rc = SQLExecDirect(hstmt,"create table t_putdata(c1 int, c2 long varchar, c3 long varchar)",SQL_NTS); + mystmt(hstmt,rc); + + rc = SQLPrepare(hstmt,"insert into t_putdata values(?,?,?)",SQL_NTS); + mystmt(hstmt,rc); + + rc = SQLBindParameter(hstmt,1,SQL_PARAM_INPUT,SQL_C_LONG, + SQL_INTEGER,0,0,&c1,0,NULL); + + rc = SQLBindParameter(hstmt,2,SQL_PARAM_INPUT,SQL_C_CHAR, + SQL_LONGVARCHAR,0,0, + (SQLPOINTER)1,0,&pcbLength); + + rc = SQLBindParameter(hstmt,3,SQL_PARAM_INPUT,SQL_C_CHAR, + SQL_LONGVARCHAR,0,0, + (SQLPOINTER)1,0,&pcbLength); + + pcbLength = SQL_LEN_DATA_AT_EXEC(0); + + c1 = 10; + rc = SQLExecute(hstmt); + myassert(rc == SQL_NEED_DATA); + + rc = SQLParamData(hstmt, &token); + myassert(rc == SQL_NEED_DATA); + + strcpy(data,"mysql ab"); + rc = SQLPutData(hstmt,data,6); + mystmt(hstmt,rc); + + strcpy(data,"- the open source database company"); + rc = SQLPutData(hstmt,data,strlen(data)); + mystmt(hstmt,rc); + + rc = SQLParamData(hstmt, &token); + myassert(rc == SQL_NEED_DATA); + + strcpy(data,"MySQL AB"); + rc = SQLPutData(hstmt,data, 8); + mystmt(hstmt,rc); + + rc = SQLParamData(hstmt, &token); + mystmt(hstmt,rc); + + SQLFreeStmt(hstmt, SQL_RESET_PARAMS); + SQLFreeStmt(hstmt, SQL_CLOSE); + + rc = SQLExecDirect(hstmt,"select c2,c3 from t_putdata where c1= 10",SQL_NTS); + mystmt(hstmt,rc); + + rc = SQLFetch(hstmt); + mystmt(hstmt,rc); + + pcbLength= 0; + rc = SQLGetData(hstmt, 1, SQL_C_CHAR, data, sizeof(data), &pcbLength); + mystmt(hstmt,rc); + fprintf(stdout,"data: %s(%d)\n", data, pcbLength); + myassert(strcmp(data,"mysql - the open source database company")==0); + myassert(pcbLength == 40); + + pcbLength= 0; + rc = SQLGetData(hstmt, 2, SQL_C_CHAR, data, sizeof(data), &pcbLength); + mystmt(hstmt,rc); + fprintf(stdout,"data: %s(%d)\n", data, pcbLength); + myassert(strcmp(data,"MySQL AB")==0); + myassert(pcbLength == 8); + + SQLFreeStmt(hstmt, SQL_RESET_PARAMS); + SQLFreeStmt(hstmt, SQL_UNBIND); + SQLFreeStmt(hstmt, SQL_CLOSE); + + return OK; +} + + +/* Test for a simple SQLPutData and SQLParamData handling bug #1316 */ +DECLARE_TEST(t_putdata3) +{ + char buffer[]= "MySQL - The worlds's most popular open source database"; + SQLRETURN rc; + const int MAX_PART_SIZE = 5; + + char *pdata= 0, data[50]; + int dynData; + int commonLen= 20; + + SQLINTEGER id, id1, id2, id3, resId; + SQLINTEGER resUTimeSec; + SQLINTEGER resUTimeMSec; + SQLINTEGER resDataLen; + SQLLEN resData; + + SQLExecDirect(hstmt,"drop table t_putdata3",SQL_NTS); + rc = SQLExecDirect(hstmt,"CREATE TABLE t_putdata3 ( id INT, id1 INT, \ + id2 INT, id3 INT, pdata blob);",SQL_NTS); + mystmt(hstmt,rc); + + dynData = 1; + + rc = SQLPrepare(hstmt, "INSERT INTO t_putdata3 VALUES ( ?, ?, ?, ?, ? )", SQL_NTS); + mystmt(hstmt,rc); + + id= 1, id1= 2, id2= 3, id3= 4; + resId = 0; + resUTimeSec = 0; + resUTimeMSec = 0; + resDataLen = 0; + resData = SQL_LEN_DATA_AT_EXEC(0); + + rc = SQLBindParameter(hstmt, 1, SQL_PARAM_INPUT, SQL_C_SLONG, + SQL_INTEGER, 0, 0, &id, 0, &resId); + mystmt(hstmt,rc); + + rc = SQLBindParameter(hstmt, 2, SQL_PARAM_INPUT, SQL_C_SLONG, + SQL_INTEGER, 0, 0, &id1, 0, &resUTimeSec); + mystmt(hstmt,rc); + + rc = SQLBindParameter(hstmt, 3, SQL_PARAM_INPUT, SQL_C_SLONG, + SQL_INTEGER, 0, 0, &id2, 0, &resUTimeMSec); + mystmt(hstmt,rc); + + rc = SQLBindParameter(hstmt, 4, SQL_PARAM_INPUT, SQL_C_SLONG, + SQL_INTEGER, 0, 0, &id3, 0, + &resDataLen); + mystmt(hstmt,rc); + + rc = SQLBindParameter(hstmt, 5, SQL_PARAM_INPUT, + SQL_C_BINARY, SQL_LONGVARBINARY, 10, 10, + dynData ? (SQLPOINTER)5 : + pdata, 0, &resData); + mystmt(hstmt,rc); + + rc = SQLExecute(hstmt); + if (rc == SQL_NEED_DATA) + { + int parameter; + if (SQLParamData(hstmt,(void**)¶meter) == SQL_NEED_DATA && parameter == 5) + { + int len = 0; + int partsize; + + /* storing long data by parts */ + while (len < commonLen) + { + partsize = commonLen - len; + if (partsize > MAX_PART_SIZE) + partsize = MAX_PART_SIZE; + + rc = SQLPutData(hstmt, buffer+len, partsize); + mystmt(hstmt,rc); + len += partsize; + } + if (SQLParamData(hstmt,(void**)¶meter) == SQL_ERROR) + { + + } + } + } /* end if (rc == SQL_NEED_DATA) */ + + SQLFreeStmt(hstmt, SQL_UNBIND); + SQLFreeStmt(hstmt, SQL_CLOSE); + + if (mysql_min_version(hdbc, "4.0", 3)) + { + rc = tmysql_exec(hstmt,"select id, id1, id2, id3, convert(pdata,char) from t_putdata3"); + mystmt(hstmt,rc); + + rc = SQLFetch(hstmt); + + my_assert(1 == my_fetch_int(hstmt,1)); + my_assert(2 == my_fetch_int(hstmt,2)); + my_assert(3 == my_fetch_int(hstmt,3)); + my_assert(4 == my_fetch_int(hstmt,4)); + + my_assert(strncmp(buffer, my_fetch_str(hstmt,data,5), commonLen) == 0); + } + else + { + rc = tmysql_exec(hstmt,"select id, id1, id2, id3, pdata from t_putdata3"); + mystmt(hstmt,rc); + + rc = SQLFetch(hstmt); + + my_assert(1 == my_fetch_int(hstmt,1)); + my_assert(2 == my_fetch_int(hstmt,2)); + my_assert(3 == my_fetch_int(hstmt,3)); + my_assert(4 == my_fetch_int(hstmt,4)); + my_assert(strncmp("4D7953514C202D2054686520776F726C64732773", + my_fetch_str(hstmt,data,5), commonLen) == 0); + } + + rc = SQLFreeStmt(hstmt,SQL_CLOSE); + mystmt(hstmt,rc); + + /* + output: + + ###################################### + t_putdata3 + ###################################### + my_fetch_int: 1 + my_fetch_int: 2 + my_fetch_int: 3 + my_fetch_int: 4 + my_fetch_str: MySQL - The worlds's(20) + */ + + return OK; +} + + +/* Test the bug when blob size > 8k */ +DECLARE_TEST(t_blob_bug) +{ + SQLRETURN rc; + SQLCHAR *data; + SQLINTEGER i; + SQLLEN length; + const SQLINTEGER max_blob_size=1024*100; + + SQLExecDirect(hstmt,"drop table t_blob",SQL_NTS); + rc = SQLExecDirect(hstmt,"create table t_blob(blb long varbinary)",SQL_NTS); + mystmt(hstmt,rc); + + rc = SQLPrepare(hstmt,"insert into t_blob values(?)",SQL_NTS); + mystmt(hstmt,rc); + + if (!(data = (SQLCHAR *)calloc(max_blob_size,sizeof(SQLCHAR)))) + { + SQLFreeStmt(hstmt,SQL_RESET_PARAMS); + SQLFreeStmt(hstmt,SQL_CLOSE); + return; + } + + rc = SQLBindParameter(hstmt,1,SQL_PARAM_INPUT,SQL_C_CHAR,SQL_VARBINARY, + 0,0,data,0,&length); + mystmt(hstmt,rc); + + memset(data,'X',max_blob_size); + + fprintf(stdout,"inserting %d rows\n\n", max_blob_size / 1024); + for (length=1024; length <= max_blob_size; length+= 1024) + { + fprintf(stdout,"\r %d", length/1024); + rc = SQLExecute(hstmt); + mystmt(hstmt,rc); + } + + SQLFreeStmt(hstmt,SQL_RESET_PARAMS); + SQLFreeStmt(hstmt,SQL_CLOSE); + + rc = SQLExecDirect(hstmt,"SELECT length(blb) FROM t_blob",SQL_NTS); + mystmt(hstmt,rc); + + rc = SQLBindCol(hstmt,1,SQL_C_LONG,&length,0,NULL); + mystmt(hstmt,rc); + + for (i= 1; i <= max_blob_size/1024; i++) + { + rc = SQLFetch(hstmt); + mystmt(hstmt,rc); + + fprintf(stdout,"row %d length: %d\n", i, length); + myassert(length == i * 1024); + } + rc = SQLFetch(hstmt); + myassert(rc == SQL_NO_DATA); + + free(data); + + SQLFreeStmt(hstmt,SQL_UNBIND); + SQLFreeStmt(hstmt,SQL_CLOSE); + + return OK; +} + + +#define TEST_ODBC_TEXT_LEN 3000 +DECLARE_TEST(t_text_fetch) +{ + SQLRETURN rc; + SQLINTEGER i; + SQLLEN row_count, length; + SQLCHAR data[TEST_ODBC_TEXT_LEN+1]; + + SQLExecDirect(hstmt,"drop table t_text_fetch",SQL_NTS); + rc = SQLExecDirect(hstmt,"create table t_text_fetch(t1 tinytext, \ + t2 text, \ + t3 mediumtext, \ + t4 longtext)",SQL_NTS); + mystmt(hstmt,rc); + + rc = SQLPrepare(hstmt,"insert into t_text_fetch values(?,?,?,?)",SQL_NTS); + mystmt(hstmt,rc); + + rc = SQLBindParameter(hstmt, 1, SQL_PARAM_INPUT, SQL_C_CHAR, SQL_CHAR, + 0,0,(char *)data, TEST_ODBC_TEXT_LEN/3, NULL); + mystmt(hstmt,rc); + + rc = SQLBindParameter(hstmt, 2, SQL_PARAM_INPUT, SQL_C_CHAR, SQL_CHAR, + 0,0,(char *)data, TEST_ODBC_TEXT_LEN/2, NULL); + mystmt(hstmt,rc); + + rc = SQLBindParameter(hstmt, 3, SQL_PARAM_INPUT, SQL_C_CHAR, SQL_CHAR, + 0,0,(char *)data, + (SQLINTEGER)(TEST_ODBC_TEXT_LEN/1.5), NULL); + mystmt(hstmt,rc); + + rc = SQLBindParameter(hstmt, 4, SQL_PARAM_INPUT, SQL_C_CHAR, SQL_CHAR, + 0,0,(char *)data, TEST_ODBC_TEXT_LEN-1, NULL); + mystmt(hstmt,rc); + + memset(data,'A',TEST_ODBC_TEXT_LEN); + data[TEST_ODBC_TEXT_LEN]='\0'; + + for (i=0; i < 10; i++) + { + rc = SQLExecute(hstmt); + mystmt(hstmt,rc); + } + + SQLFreeStmt(hstmt, SQL_RESET_PARAMS); + SQLFreeStmt(hstmt, SQL_CLOSE); + + rc = SQLExecDirect(hstmt,"SELECT * FROM t_text_fetch",SQL_NTS); + mystmt(hstmt,rc); + + row_count= 0; + rc = SQLFetch(hstmt); + while (rc == SQL_SUCCESS || rc == SQL_SUCCESS_WITH_INFO) + { + fprintf(stdout,"row '%d' (lengths: \n", row_count); + rc = SQLGetData(hstmt,1,SQL_C_CHAR,(char *)data,TEST_ODBC_TEXT_LEN,&length); + mystmt(hstmt,rc); + fprintf(stdout,"%d", length); + myassert(length == 255); + + rc = SQLGetData(hstmt,2,SQL_C_CHAR,(char *)data,TEST_ODBC_TEXT_LEN,&length); + mystmt(hstmt,rc); + fprintf(stdout,",%d", length); + myassert(length == TEST_ODBC_TEXT_LEN/2); + + rc = SQLGetData(hstmt,3,SQL_C_CHAR,(char *)data,TEST_ODBC_TEXT_LEN,&length); + mystmt(hstmt,rc); + fprintf(stdout,",%d", length); + myassert(length == (SQLINTEGER)(TEST_ODBC_TEXT_LEN/1.5)); + + rc = SQLGetData(hstmt,4,SQL_C_CHAR,(char *)data,TEST_ODBC_TEXT_LEN,&length); + mystmt(hstmt,rc); + fprintf(stdout,",%d)", length); + myassert(length == TEST_ODBC_TEXT_LEN-1); + row_count++; + + rc = SQLFetch(hstmt); + } + fprintf(stdout,"total rows: %d\n", row_count); + myassert(row_count == i); + + SQLFreeStmt(hstmt, SQL_UNBIND); + SQLFreeStmt(hstmt, SQL_CLOSE); + + rc = SQLExecDirect(hstmt,"DROP TABLE t_text_fetch",SQL_NTS); + mystmt(hstmt,rc); + + return OK; +} + + BEGIN_TESTS ADD_TEST(t_blob) ADD_TEST(t_1piecewrite2) + ADD_TEST(t_putdata) + ADD_TEST(t_putdata1) + ADD_TEST(t_putdata2) + ADD_TEST(t_putdata3) + ADD_TEST(t_blob_bug) + ADD_TEST(t_text_fetch) END_TESTS Modified: trunk/test/my_catalog.c =================================================================== --- trunk/test/my_catalog.c 2007-04-06 17:01:21 UTC (rev 297) +++ trunk/test/my_catalog.c 2007-04-06 18:21:39 UTC (rev 298) @@ -815,6 +815,302 @@ } +DECLARE_TEST(tmysql_specialcols) +{ + SQLRETURN rc; + + tmysql_exec(hstmt,"drop table tmysql_specialcols"); + rc = tmysql_exec(hstmt,"create table tmysql_specialcols(col1 int primary key, col2 varchar(30), col3 int)"); + mystmt(hstmt,rc); + + rc = tmysql_exec(hstmt,"create index tmysql_ind1 on tmysql_specialcols(col1)"); + mystmt(hstmt,rc); + + rc = tmysql_exec(hstmt,"insert into tmysql_specialcols values(100,'venu',1)"); + mystmt(hstmt,rc); + + rc = tmysql_exec(hstmt,"insert into tmysql_specialcols values(200,'MySQL',2)"); + mystmt(hstmt,rc); + + rc = SQLTransact(NULL,hdbc,SQL_COMMIT); + mycon(hdbc,rc); + + rc = SQLFreeStmt(hstmt,SQL_CLOSE); + mystmt(hstmt,rc); + + rc = tmysql_exec(hstmt,"select * from tmysql_specialcols"); + mystmt(hstmt,rc); + + myresult(hstmt); + + rc = SQLFreeStmt(hstmt,SQL_CLOSE); + mystmt(hstmt,rc); + + rc = SQLSpecialColumns(hstmt, + SQL_BEST_ROWID, + NULL,0, + NULL,0, + "tmysql_specialcols",SQL_NTS, + SQL_SCOPE_SESSION, + SQL_NULLABLE); + mystmt(hstmt,rc); + + myresult(hstmt); + + rc = SQLFreeStmt(hstmt,SQL_CLOSE); + mystmt(hstmt,rc); + + rc = tmysql_exec(hstmt,"drop table tmysql_specialcols"); + mystmt(hstmt,rc); + + rc = SQLTransact(NULL,hdbc,SQL_COMMIT); + mycon(hdbc,rc); + + return OK; +} + + +/* To test SQLColumns misc case */ +DECLARE_TEST(t_columns) +{ + SQLSMALLINT NumPrecRadix, DataType, Nullable, DecimalDigits; + SQLLEN cbColumnSize, cbDecimalDigits, cbNumPrecRadix, + cbDatabaseName, cbDataType, cbNullable; + SQLRETURN rc; + SQLUINTEGER ColumnSize, i; + SQLUINTEGER ColumnCount= 7; + SQLCHAR ColumnName[MAX_NAME_LEN], DatabaseName[MAX_NAME_LEN]; + SQLINTEGER Values[7][5][2]= + { + { {5,2}, {6,4}, {0,2}, {10,2}, {1,2}}, + { {1,2}, {5,4}, {0,-1}, {10,-1}, {1,2}}, + { {12,2}, {20,4}, {0,-1}, {10,-1}, {0,2}}, + { {3,2}, {10,4}, {2,2}, {10,2}, {1,2}}, + { {-6,2}, {4,4}, {0,2}, {10,2}, {0,2}}, + { {4,2}, {11,4}, {0,2}, {10,2}, {0,2}}, + { {-6,2}, {4,4}, {0,2}, {10,2}, {0,2}} + }; + + SQLFreeStmt(hstmt, SQL_CLOSE); + SQLExecDirect(hstmt,"DROP TABLE test_column",SQL_NTS); + + rc = SQLExecDirect(hstmt,"CREATE TABLE test_column(col0 smallint, \ + col1 char(5),\ + col2 varchar(20) not null,\ + col3 decimal(10,2),\ + col4 tinyint not null,\ + col5 integer primary key,\ + col6 tinyint not null unique auto_increment)",SQL_NTS); + mystmt(hstmt,rc); + + mystmt(hstmt,rc); + + rc= SQLSetStmtAttr(hstmt, SQL_ATTR_METADATA_ID, + (SQLPOINTER)SQL_FALSE, SQL_IS_UINTEGER); + mystmt(hstmt,rc); + + SQLSetStmtAttr(hstmt, SQL_ATTR_CURSOR_TYPE, (SQLPOINTER) SQL_CURSOR_STATIC, 0); + + rc= SQLGetConnectAttr(hdbc, SQL_ATTR_CURRENT_CATALOG,(SQLCHAR *)DatabaseName, + MAX_NAME_LEN, &cbDatabaseName);/* Current Catalog */ + mycon(hdbc,rc); + + for (i=0; i< ColumnCount; i++) + { + sprintf(ColumnName,"col%d",i); + + rc= SQLColumns(hstmt, + (SQLCHAR *)DatabaseName, (SQLUSMALLINT)cbDatabaseName, + SQL_NULL_HANDLE, 0, + (SQLCHAR *)"test_column", SQL_NTS, + (SQLCHAR *)ColumnName, SQL_NTS); + mystmt(hstmt,rc); + + /* 5 -- Data type */ + rc= SQLBindCol(hstmt, 5, SQL_C_SSHORT, &DataType, 0, &cbDataType); + mystmt(hstmt,rc); + + /* 7 -- Column Size */ + rc= SQLBindCol(hstmt, 7, SQL_C_ULONG, &ColumnSize, 0, &cbColumnSize); + mystmt(hstmt,rc); + + /* 9 -- Decimal Digits */ + rc= SQLBindCol(hstmt, 9, SQL_C_SSHORT, &DecimalDigits, 0, &cbDecimalDigits); + mystmt(hstmt,rc); + + /* 10 -- Num Prec Radix */ + rc= SQLBindCol(hstmt, 10, SQL_C_SSHORT, &NumPrecRadix, 0, &cbNumPrecRadix); + mystmt(hstmt,rc); + + /* 11 -- Nullable */ + rc= SQLBindCol(hstmt, 11, SQL_C_SSHORT, &Nullable, 0, &cbNullable); + mystmt(hstmt,rc); + + rc= SQLFetch(hstmt); + mystmt(hstmt,rc); + + fprintf(stdout,"Column %s:\n", ColumnName); + fprintf(stdout,"\t DataType = %d(%d)\n", DataType, cbDataType); + fprintf(stdout,"\t ColumnSize = %d(%d)\n", ColumnSize, cbColumnSize); + fprintf(stdout,"\t DecimalDigits= %d(%d)\n", DecimalDigits, cbDecimalDigits); + fprintf(stdout,"\t NumPrecRadix = %d(%d)\n", NumPrecRadix, cbNumPrecRadix); + fprintf(stdout,"\t Nullable = %s(%d)\n\n", + Nullable == SQL_NO_NULLS ? "NO": "YES", cbNullable); + + myassert(DataType == Values[i][0][0]); + myassert(cbDataType == Values[i][0][1]); + + myassert(ColumnSize == Values[i][1][0]); + myassert(cbColumnSize == Values[i][1][1]); + + myassert(DecimalDigits == Values[i][2][0]); + myassert(cbDecimalDigits == Values[i][2][1]); + + myassert(NumPrecRadix == Values[i][3][0]); + myassert(cbNumPrecRadix == Values[i][3][1]); + + myassert(Nullable == Values[i][4][0]); + myassert(cbNullable == Values[i][4][1]); + + rc= SQLFetch(hstmt); + myassert(rc == SQL_NO_DATA); + + SQLFreeStmt(hstmt,SQL_UNBIND); + SQLFreeStmt(hstmt,SQL_CLOSE); + } + + SQLFreeStmt(hstmt,SQL_UNBIND); + SQLFreeStmt(hstmt,SQL_CLOSE); + + rc = SQLExecDirect(hstmt,"DROP TABLE test_column",SQL_NTS); + mystmt(hstmt,rc); + SQLFreeStmt(hstmt,SQL_CLOSE); + + return OK; +} + + +/* Test the bug SQLTables */ +typedef struct t_table_bug +{ + SQLCHAR szColName[MAX_NAME_LEN]; + SQLSMALLINT pcbColName; + SQLSMALLINT pfSqlType; + SQLUINTEGER pcbColDef; + SQLSMALLINT pibScale; + SQLSMALLINT pfNullable; +} t_describe_col; + + +t_describe_col t_tables_bug_data[5] = +{ + {"TABLE_CAT", 9, SQL_VARCHAR, MYSQL_NAME_LEN, 0, SQL_NULLABLE}, + {"TABLE_SCHEM",11, SQL_VARCHAR, MYSQL_NAME_LEN, 0, SQL_NULLABLE}, + {"TABLE_NAME", 10, SQL_VARCHAR, MYSQL_NAME_LEN, 0, SQL_NULLABLE}, + {"TABLE_TYPE", 10, SQL_VARCHAR, MYSQL_NAME_LEN, 0, SQL_NULLABLE}, + {"REMARKS", 7, SQL_VARCHAR, MYSQL_NAME_LEN, 0, SQL_NULLABLE}, +}; + + +DECLARE_TEST(t_tables_bug) +{ + SQLRETURN rc; + SQLSMALLINT i, ColumnCount, pcbColName, pfSqlType, pibScale, pfNullable; + SQLUINTEGER pcbColDef; + SQLCHAR szColName[MAX_NAME_LEN]; + + SQLFreeStmt(hstmt, SQL_CLOSE); + + rc = SQLTables(hstmt,NULL,0,NULL,0,NULL,0,"'TABLE'",SQL_NTS); + mystmt(hstmt,rc); + + rc = SQLNumResultCols(hstmt,&ColumnCount); + mystmt(hstmt,rc); + + fprintf(stdout, "total columns in SQLTables: %d\n", ColumnCount); + myassert(ColumnCount == 5); + + for (i= 1; i <= ColumnCount; i++) + { + rc = SQLDescribeCol(hstmt, (SQLUSMALLINT)i, + szColName,MAX_NAME_LEN,&pcbColName, + &pfSqlType,&pcbColDef,&pibScale,&pfNullable); + mystmt(hstmt,rc); + + fprintf(stdout, "Column Number'%d':\n", i); + fprintf(stdout, "\t Column Name : %s\n", szColName); + fprintf(stdout, "\t NameLengh : %d\n", pcbColName); + fprintf(stdout, "\t DataType : %d\n", pfSqlType); + fprintf(stdout, "\t ColumnSize : %d\n", pcbColDef); + fprintf(stdout, "\t DecimalDigits : %d\n", pibScale); + fprintf(stdout, "\t Nullable : %d\n", pfNullable); + + myassert(strcmp(t_tables_bug_data[i-1].szColName,szColName) == 0); + myassert(t_tables_bug_data[i-1].pcbColName == pcbColName); + myassert(t_tables_bug_data[i-1].pfSqlType == pfSqlType); + myassert(t_tables_bug_data[i-1].pcbColDef == pcbColDef); + myassert(t_tables_bug_data[i-1].pibScale == pibScale); + myassert(t_tables_bug_data[i-1].pfNullable == pfNullable); + } + SQLFreeStmt(hstmt,SQL_CLOSE); + + return OK; +} + + +DECLARE_TEST(t_current_catalog) +{ + SQLCHAR cur_db[255], db[255]; + SQLRETURN rc; + SQLUINTEGER len; + + rc = SQLFreeStmt(hstmt,SQL_CLOSE); + mystmt(hstmt,rc); + + rc = SQLGetConnectAttr(hdbc, SQL_ATTR_CURRENT_CATALOG, (char *)db, 255, &len); + mycon(hdbc,rc); + fprintf(stdout,"current_catalog: %s (%ld)\n", db, len); + myassert(strcmp(db, "test") == 0 || strlen("test") == len); + + rc = SQLSetConnectAttr(hdbc, SQL_ATTR_CURRENT_CATALOG, (char *)db, SQL_NTS); + mycon(hdbc,rc); + + SQLExecDirect(hstmt, "DROP DATABASE IF EXISTS test_odbc_current", SQL_NTS); + + strcpy(cur_db, "test_odbc_current"); + rc = SQLSetConnectAttr(hdbc, SQL_ATTR_CURRENT_CATALOG, (char *)cur_db, SQL_NTS); + mycon_r(hdbc,rc); + + rc = SQLExecDirect(hstmt, "CREATE DATABASE test_odbc_current", SQL_NTS); + mystmt(hstmt,rc); + + strcpy(cur_db, "test_odbc_current"); + rc = SQLSetConnectAttr(hdbc, SQL_ATTR_CURRENT_CATALOG, (char *)cur_db, SQL_NTS); + mycon(hdbc,rc); + + rc = SQLGetConnectAttr(hdbc, SQL_ATTR_CURRENT_CATALOG, (char *)db, 255, &len); + mycon(hdbc,rc); + fprintf(stdout,"current_catalog: %s (%ld)\n", db, len); + myassert(strcmp(cur_db, db) == 0 || strlen(cur_db) == len); + + strcpy(cur_db, "test_odbc_current_12455"); + rc = SQLSetConnectAttr(hdbc, SQL_ATTR_CURRENT_CATALOG, (char *)cur_db, SQL_NTS); + mycon_r(hdbc,rc); + + rc = SQLSetConnectAttr(hdbc, SQL_ATTR_CURRENT_CATALOG, (char *)cur_db, len); + mycon(hdbc,rc); + + /* reset for further tests */ + rc = SQLSetConnectAttr(hdbc, SQL_ATTR_CURRENT_CATALOG, (char *)test_db, SQL_NTS); + mycon(hdbc,rc); + + rc = SQLExecDirect(hstmt, "DROP DATABASE test_odbc_current", SQL_NTS); + mycon(hstmt,rc); + + return OK; +} + + BEGIN_TESTS ADD_TEST(my_columns_null) ADD_TEST(my_drop_table) @@ -826,6 +1122,10 @@ ADD_TEST(my_colpriv) ADD_TEST(t_sqlprocedures) ADD_TEST(t_catalog) + ADD_TEST(tmysql_specialcols) + ADD_TEST(t_columns) + ADD_TEST(t_tables_bug) + ADD_TEST(t_current_catalog) END_TESTS Modified: trunk/test/my_cursor.c =================================================================== --- trunk/test/my_cursor.c 2007-04-06 17:01:21 UTC (rev 297) +++ trunk/test/my_cursor.c 2007-04-06 18:21:39 UTC (rev 298) @@ -187,8 +187,6 @@ long id; char name[50]; - printMessage("\nmy_setpos_cursor:\n"); - /* Open the resultset of table 'my_demo_cursor' */ rc = SQLExecDirect(hstmt,"SELECT * FROM my_demo_cursor",SQL_NTS); mystmt(hstmt,rc); @@ -356,11 +354,872 @@ } +DECLARE_TEST(t_setpos_del_all) +{ + SQLRETURN rc; + SQLINTEGER nData[4]; + SQLLEN nlen; + SQLCHAR szData[4][10]; + + tmysql_exec(hstmt,"drop table t_sp_del_all"); + rc = tmysql_exec(hstmt,"create table t_sp_del_all(col1 int not null primary key,\ + col2 varchar(20))"); + mystmt(hstmt,rc); + + rc = tmysql_exec(hstmt,"insert into t_sp_del_all values(100,'MySQL1')"); + mystmt(hstmt,rc); + rc = tmysql_exec(hstmt,"insert into t_sp_del_all values(200,'MySQL2')"); + mystmt(hstmt,rc); + rc = tmysql_exec(hstmt,"insert into t_sp_del_all values(300,'MySQL3')"); + mystmt(hstmt,rc); + rc = tmysql_exec(hstmt,"insert into t_sp_del_all values(400,'MySQL4')"); + mystmt(hstmt,rc); + + rc = SQLTransact(NULL,hdbc,SQL_COMMIT); + mycon(hdbc,rc); + + rc = SQLFreeStmt(hstmt,SQL_CLOSE); + mystmt(hstmt,rc); + + rc = SQLSetCursorName(hstmt,"venu",SQL_NTS); + mystmt(hstmt,rc); + + rc = SQLSetStmtOption(hstmt, SQL_ROWSET_SIZE, 4); + mystmt(hstmt,rc); + + rc = tmysql_exec(hstmt,"select * from t_sp_del_all order by col1 asc"); + mystmt(hstmt,rc); + + rc = SQLBindCol(hstmt,1,SQL_C_LONG,&nData,100,NULL); + mystmt(hstmt,rc); + + rc = SQLBindCol(hstmt,2,SQL_C_CHAR,&szData[0],sizeof(szData[0]),NULL); + mystmt(hstmt,rc); + + rc = SQLExtendedFetch(hstmt,SQL_FETCH_FIRST,1,NULL,NULL); + mystmt(hstmt,rc); + + fprintf(stdout," row1 : %d, %s\n",nData[0],szData[0]); + fprintf(stdout," row2 : %d, %s\n",nData[1],szData[1]); + fprintf(stdout," row3 : %d, %s\n",nData[2],szData[2]); + fprintf(stdout," row4 : %d, %s\n",nData[3],szData[3]); + + rc = SQLSetPos(hstmt,1,SQL_POSITION,SQL_LOCK_NO_CHANGE); + mystmt(hstmt,rc); + + rc = SQLSetPos(hstmt,0,SQL_DELETE,SQL_LOCK_NO_CHANGE); + mystmt(hstmt,rc); + + rc = SQLRowCount(hstmt,&nlen); + mystmt(hstmt,rc); + + fprintf(stdout," total rows deleted: %d\n",nlen); + myassert(nlen == 4); + + rc = SQLFreeStmt(hstmt,SQL_UNBIND); + mystmt(hstmt,rc); + + rc = SQLFreeStmt(hstmt,SQL_CLOSE); + mystmt(hstmt,rc); + + rc = tmysql_exec(hstmt,"select * from t_sp_del_all"); + mystmt(hstmt,rc); + + my_assert(0 == myresult(hstmt)); + + rc = SQLFreeStmt(hstmt,SQL_CLOSE); + mystmt(hstmt,rc); + + rc = SQLSetStmtOption(hstmt, SQL_ROWSET_SIZE, 1); + mystmt(hstmt,rc); + + return OK; +} + + +DECLARE_TEST(t_setpos_upd_decimal) +{ + SQLRETURN rc; + SQLINTEGER rec; + + tmysql_exec(hstmt,"drop table t_setpos_upd_decimal"); + rc = tmysql_exec(hstmt,"create table t_setpos_upd_decimal(record decimal(3,0),\ + num1 float, num2 decimal(6,0),num3 decimal(10,3))"); + mystmt(hstmt,rc); + + rc = tmysql_exec(hstmt,"insert into t_setpos_upd_decimal values(001,12.3,134,0.100)"); + mystmt(hstmt,rc); + + rc = SQLTransact(NULL,hdbc,SQL_COMMIT); + mycon(hdbc,rc); + + rc = SQLFreeStmt(hstmt,SQL_CLOSE); + mystmt(hstmt,rc); + + /* MS SQL Server to work...*/ + SQLSetStmtAttr(hstmt, SQL_ATTR_CONCURRENCY, (SQLPOINTER) SQL_CONCUR_ROWVER, 0); + SQLSetStmtAttr(hstmt, SQL_ATTR_CURSOR_TYPE, (SQLPOINTER) SQL_CURSOR_DYNAMIC, 0); + SQLSetStmtOption(hstmt,SQL_SIMULATE_CURSOR,SQL_SC_NON_UNIQUE); + + rc = tmysql_exec(hstmt,"select record from t_setpos_upd_decimal"); + mystmt(hstmt,rc); + + rc = SQLBindCol(hstmt,1,SQL_C_LONG,&rec,100,NULL); + mystmt(hstmt,rc); + + rc = SQLExtendedFetch(hstmt,SQL_FETCH_NEXT,1,NULL,NULL); + mystmt(hstmt,rc); + fprintf(stdout," row1: %d",rec); + + rc = SQLSetPos(hstmt,1,SQL_POSITION,SQL_LOCK_NO_CHANGE); + mystmt(hstmt,rc); + + rec = 100; + + rc = SQLSetPos(hstmt,1,SQL_UPDATE,SQL_LOCK_NO_CHANGE); + mystmt_r(hstmt,rc); + + rc = SQLFreeStmt(hstmt,SQL_UNBIND); + mystmt(hstmt,rc); + + rc = SQLFreeStmt(hstmt,SQL_CLOSE); + mystmt(hstmt,rc); + + rc = tmysql_exec(hstmt,"select * from t_setpos_upd_decimal"); + mystmt(hstmt,rc); + + myresult(hstmt); + + rc = SQLFreeStmt(hstmt,SQL_CLOSE); + mystmt(hstmt,rc); + + return OK; +} + + +DECLARE_TEST(t_setpos_position) +{ + SQLRETURN rc; + SQLINTEGER nData= 500; + SQLLEN nlen; + SQLCHAR szData[255]={0}; + SQLUINTEGER pcrow; + + tmysql_exec(hstmt,"drop table t_setpos_position"); + rc = tmysql_exec(hstmt,"create table t_setpos_position(col1 int, col2 varchar(30))"); + mystmt(hstmt,rc); + + rc = tmysql_exec(hstmt,"insert into t_setpos_position values(100,'MySQL1')"); + mystmt(hstmt,rc); + rc = tmysql_exec(hstmt,"insert into t_setpos_position values(200,'MySQL2')"); + mystmt(hstmt,rc); + rc = tmysql_exec(hstmt,"insert into t_setpos_position values(300,'MySQL3')"); + mystmt(hstmt,rc); + + rc = SQLTransact(NULL,hdbc,SQL_COMMIT); + mycon(hdbc,rc); + + rc = SQLFreeStmt(hstmt,SQL_CLOSE); + mystmt(hstmt,rc); + + rc = SQLSetCursorName(hstmt,"venu",SQL_NTS); + mystmt(hstmt,rc); + + SQLSetStmtAttr(hstmt, SQL_ATTR_CONCURRENCY, (SQLPOINTER) SQL_CONCUR_ROWVER, 0); + SQLSetStmtAttr(hstmt, SQL_ATTR_CURSOR_TYPE, (SQLPOINTER) SQL_CURSOR_DYNAMIC, 0); + SQLSetStmtOption(hstmt,SQL_SIMULATE_CURSOR,SQL_SC_NON_UNIQUE); + + rc = tmysql_exec(hstmt,"select * from t_setpos_position"); + mystmt(hstmt,rc); + + rc = SQLBindCol(hstmt,1,SQL_C_LONG,&nData,100,NULL); + mystmt(hstmt,rc); + + rc = SQLBindCol(hstmt,2,SQL_C_CHAR,szData,100,NULL); + mystmt(hstmt,rc); + + rc = SQLExtendedFetch(hstmt,SQL_FETCH_NEXT,1,&pcrow,NULL); + mystmt(hstmt,rc); + + rc = SQLExtendedFetch(hstmt,SQL_FETCH_NEXT,1,&pcrow,NULL); + mystmt(hstmt,rc); + + fprintf(stdout," pcrow:%d\n",pcrow); + fprintf(stdout," row1:%d,%s\n",nData,szData); + + rc = SQLSetPos(hstmt,1,SQL_POSITION,SQL_LOCK_NO_CHANGE); + mystmt(hstmt,rc); + + nData = 1000; + strcpy((char *)szData , "updated"); + + rc = SQLSetPos(hstmt,3,SQL_UPDATE,SQL_LOCK_NO_CHANGE); + mystmt_err(hstmt,rc == SQL_ERROR,rc); + + rc = SQLSetPos(hstmt,2,SQL_UPDATE,SQL_LOCK_NO_CHANGE); + mystmt_err(hstmt,rc == SQL_ERROR,rc); + + rc = SQLSetPos(hstmt,1,SQL_UPDATE,SQL_LOCK_NO_CHANGE); + mystmt(hstmt,rc); + + rc = SQLRowCount(hstmt,&nlen); + mystmt(hstmt,rc); + + fprintf(stdout," rows affected:%d\n",nlen); + + rc = SQLFreeStmt(hstmt,SQL_UNBIND); + mystmt(hstmt,rc); + + rc = SQLFreeStmt(hstmt,SQL_CLOSE); + mystmt(hstmt,rc); + + rc = tmysql_exec(hstmt,"select * from t_setpos_position"); + mystmt(hstmt,rc); + + myresult(hstmt); + + rc = SQLFreeStmt(hstmt,SQL_CLOSE); + mystmt(hstmt,rc); + + rc = SQLExecDirect(hstmt,"DELETE FROM t_setpos_position WHERE col2 = 'updated'",SQL_NTS); + mystmt(hstmt,rc); + + rc = SQLRowCount(hstmt,&nlen); + mystmt(hstmt,rc); + fprintf(stdout,"total rows affceted:%d\n",nlen); + my_assert(nlen == 1); + + rc = SQLFreeStmt(hstmt,SQL_CLOSE); + mystmt(hstmt,rc); + + rc = SQLTransact(NULL,hdbc,SQL_COMMIT); + mycon(hdbc,rc); + + rc = tmysql_exec(hstmt,"select * from t_setpos_position"); + mystmt(hstmt,rc); + + my_assert(2 == myresult(hstmt)); + + rc = SQLFreeStmt(hstmt,SQL_CLOSE); + mystmt(hstmt,rc); + + return OK; +} + + +DECLARE_TEST(t_pos_column_ignore) +{ + SQLRETURN rc; + SQLHSTMT hstmt1; + SQLCHAR szData[]="updated"; + SQLINTEGER nData; + SQLLEN pcbValue, nlen, pcrow; + + rc = SQLAllocStmt(hdbc,&hstmt1); + mycon(hdbc,rc); + + tmysql_exec(hstmt,"drop table t_pos_column_ignore"); + rc = tmysql_exec(hstmt,"create table t_pos_column_ignore(col1 int NOT NULL primary key, col2 varchar(30))"); + mystmt(hstmt,rc); + + rc = tmysql_exec(hstmt,"insert into t_pos_column_ignore values(10,'venu')"); + mystmt(hstmt,rc); + + rc = tmysql_exec(hstmt,"insert into t_pos_column_ignore values(100,'MySQL')"); + mystmt(hstmt,rc); + + rc = SQLTransact(NULL,hdbc,SQL_COMMIT); + mycon(hdbc,rc); + + rc = SQLFreeStmt(hstmt,SQL_CLOSE); + mystmt(hstmt,rc); + + SQLSetStmtAttr(hstmt, SQL_ATTR_CONCURRENCY, (SQLPOINTER) SQL_CONCUR_ROWVER, 0); + SQLSetStmtAttr(hstmt, SQL_ATTR_CURSOR_TYPE, (SQLPOINTER) SQL_CURSOR_KEYSET_DRIVEN, 0); + + /* ignore all columns */ + rc = tmysql_exec(hstmt,"select * from t_pos_column_ignore order by col1 asc"); + mystmt(hstmt,rc); + + rc = SQLBindCol(hstmt,1,SQL_C_LONG,&nData,100,&pcbValue); + mystmt(hstmt,rc); + + rc = SQLBindCol(hstmt,2,SQL_C_CHAR,szData,100,&pcbValue); + mystmt(hstmt,rc); + + rc = SQLExtendedFetch(hstmt,SQL_FETCH_NEXT,1,&pcrow,NULL); + mystmt(hstmt,rc); + + rc = SQLSetPos(hstmt,1,SQL_POSITION,SQL_LOCK_NO_CHANGE); + mystmt(hstmt,rc); + + nData = 99; + strcpy((char *)szData , "updated"); + + pcbValue = SQL_COLUMN_IGNORE; + rc = SQLSetPos(hstmt,1,SQL_UPDATE,SQL_LOCK_NO_CHANGE); + mystmt(hstmt,rc); + + rc = SQLRowCount(hstmt,&nlen); + mystmt(hstmt,rc); + + fprintf(stdout," rows affected:%d\n",nlen); + myassert(nlen == 0); + + rc = SQLFreeStmt(hstmt,SQL_UNBIND); + mystmt(hstmt,rc); + + SQLFreeStmt(hstmt1,SQL_CLOSE); + SQLFreeStmt(hstmt,SQL_CLOSE); + + rc = SQLTransact(NULL,hdbc,SQL_COMMIT); + mycon(hdbc,rc); + + rc = tmysql_exec(hstmt,"select * from t_pos_column_ignore order by col1 asc"); + mystmt(hstmt,rc); + + rc = SQLFetch(hstmt); + mystmt(hstmt,rc); + { + SQLCHAR szData[20]; + my_assert(10 == my_fetch_int(hstmt,1)); + my_assert(!strcmp("venu",my_fetch_str(hstmt,szData,2))); + } + + rc = SQLFreeStmt(hstmt,SQL_CLOSE); + mystmt(hstmt,rc); + + /* ignore only one column */ + + rc = tmysql_exec(hstmt,"select * from t_pos_column_ignore order by col1 asc"); + mystmt(hstmt,rc); + + rc = SQLBindCol(hstmt,1,SQL_C_LONG,&nData,100,NULL); + mystmt(hstmt,rc); + + rc = SQLBindCol(hstmt,2,SQL_C_CHAR,szData,100,&pcbValue); + mystmt(hstmt,rc); + + rc = SQLExtendedFetch(hstmt,SQL_FETCH_NEXT,1,&pcrow,NULL); + mystmt(hstmt,rc); + + rc = SQLSetPos(hstmt,1,SQL_POSITION,SQL_LOCK_NO_CHANGE); + mystmt(hstmt,rc); + + nData = 99; + strcpy((char *)szData , "updated"); + + pcbValue = SQL_COLUMN_IGNORE; + rc = SQLSetPos(hstmt,1,SQL_UPDATE,SQL_LOCK_NO_CHANGE); + mystmt(hstmt,rc); + + rc = SQLRowCount(hstmt,&nlen); + mystmt(hstmt,rc); + + fprintf(stdout," rows affected:%d\n",nlen); + + rc = SQLFreeStmt(hstmt,SQL_UNBIND); + mystmt(hstmt,rc); + + SQLFreeStmt(hstmt1,SQL_CLOSE); + SQLFreeStmt(hstmt,SQL_CLOSE); + + rc = SQLTransact(NULL,hdbc,SQL_COMMIT); + mycon(hdbc,rc); + + rc = tmysql_exec(hstmt,"select * from t_pos_column_ignore order by col1 asc"); + mystmt(hstmt,rc); + + rc = SQLFetch(hstmt); + mystmt(hstmt,rc); + { + SQLCHAR szData[20]; + my_assert(99 == my_fetch_int(hstmt,1)); + my_assert(!strcmp("venu",my_fetch_str(hstmt,szData,2))); + } + + rc = SQLFreeStmt(hstmt,SQL_CLOSE); + mystmt(hstmt,rc); + + rc = SQLFreeStmt(hstmt1,SQL_DROP); + mystmt(hstmt1,rc); + + return OK; +} + + +static void verify_col_data(SQLHSTMT hstmt, const char *table, + const char *col, const char *exp_data) +{ + SQLCHAR data[255], query[255]; + SQLRETURN rc; + + if (table && col) + { + sprintf(query,"SELECT %s FROM %s",col,table); + fprintf(stdout,"\n %s", query); + + rc = SQLExecDirect(hstmt, query, SQL_NTS); + mystmt(hstmt,rc); + } + + rc = SQLFetch(hstmt); + if (rc == SQL_NO_DATA) + myassert(strcmp(exp_data,"SQL_NO_DATA") ==0 ); + + rc = SQLGetData(hstmt, 1, SQL_C_CHAR, &data, 255, NULL); + if (rc == SQL_ERROR) + { + fprintf(stdout,"\n *** ERROR: FAILED TO GET THE RESULT ***"); + exit(1); + } + fprintf(stdout,"\n obtained: `%s` (expected: `%s`)\n", data, exp_data); + myassert(strcmp(data,exp_data) == 0); + + SQLFreeStmt(hstmt, SQL_UNBIND); + SQLFreeStmt(hstmt, SQL_CLOSE); +} + + +DECLARE_TEST(t_pos_datetime_delete) +{ + SQLRETURN rc; + SQLHSTMT hstmt1; + SQLINTEGER int_data; + SQLLEN row_count, cur_type; + + rc = SQLAllocStmt(hdbc,&hstmt1); + mycon(hdbc,rc); + + tmysql_exec(hstmt,"drop table t_pos_delete"); + rc = tmysql_exec(hstmt,"create table t_pos_delete(id int not null default '0',\ + name varchar(20) NOT NULL default '',\ + created datetime NOT NULL default '2000-01-01')"); + mystmt(hstmt,rc); + + rc = tmysql_exec(hstmt,"insert into t_pos_delete values(1,'venu','2003-02-10 14:45:39')"); + mystmt(hstmt,rc); + + rc = tmysql_exec(hstmt,"insert into t_pos_delete(name) values('')"); + mystmt(hstmt,rc); + + rc = tmysql_exec(hstmt,"insert into t_pos_delete(id) values(2)"); + mystmt(hstmt,rc); + + rc = SQLTransact(NULL,hdbc,SQL_COMMIT); + mycon(hdbc,rc); + + rc = SQLFreeStmt(hstmt,SQL_CLOSE); + mystmt(hstmt,rc); + + rc = tmysql_exec(hstmt,"select * from t_pos_delete"); + mystmt(hstmt,rc); + + my_assert(3 == myresult(hstmt)); + + rc = SQLFreeStmt(hstmt,SQL_CLOSE); + mystmt(hstmt,rc); + + SQLSetStmtAttr(hstmt, SQL_ATTR_CONCURRENCY, (SQLPOINTER) SQL_CONCUR_ROWVER, 0); + SQLSetStmtAttr(hstmt, SQL_ATTR_CURSOR_TYPE, (SQLPOINTER) SQL_CURSOR_DYNAMIC, 0); + SQLSetStmtOption(hstmt,SQL_SIMULATE_CURSOR,SQL_SC_TRY_UNIQUE); + + SQLSetStmtAttr(hstmt1, SQL_ATTR_CONCURRENCY, (SQLPOINTER) SQL_CONCUR_ROWVER, 0); + SQLSetStmtAttr(hstmt1, SQL_ATTR_CURSOR_TYPE, (SQLPOINTER) SQL_CURSOR_DYNAMIC, 0); + SQLSetStmtOption(hstmt1,SQL_SIMULATE_CURSOR,SQL_SC_TRY_UNIQUE); + + rc = SQLSetCursorName(hstmt,"venu_cur",8); + mystmt(hstmt,rc); + + rc = SQLGetStmtAttr(hstmt, SQL_ATTR_CURSOR_TYPE, &cur_type, 0, NULL); + mystmt(hstmt,rc); + + rc = tmysql_exec(hstmt,"select * from t_pos_delete"); + mystmt(hstmt,rc); + + rc = SQLBindCol(hstmt,1,SQL_C_LONG,&int_data,0,NULL); + mystmt(hstmt,rc); + + rc = SQLExtendedFetch(hstmt,SQL_FETCH_NEXT,1,NULL,NULL); + mystmt(hstmt,rc); + fprintf(stdout,"current_row: %d\n", int_data); + myassert(int_data == 1); + + rc = SQLSetPos(hstmt,1,SQL_POSITION,SQL_LOCK_NO_CHANGE); + mystmt(hstmt,rc); + + rc = SQLExecDirect(hstmt1,"DELETE FROM t_pos_delete WHERE CURRENT OF venu_cur",SQL_NTS); + mystmt(hstmt1,rc); + + rc = SQLRowCount(hstmt1,&row_count); + mystmt(hstmt1,rc); + fprintf(stdout, "rows affected: %d\n", row_count); + myassert(row_count == 1); + + rc = SQLExtendedFetch(hstmt,SQL_FETCH_NEXT,1,NULL,NULL); + mystmt(hstmt,rc); + fprintf(stdout,"current_row: %d\n", int_data); + if (cur_type == SQL_CURSOR_DYNAMIC) + myassert(int_data == 2); + else + myassert(int_data == 0); + + /*rc = SQLExtendedFetch(hstmt,SQL_FETCH_NEXT,1,NULL,NULL); + mystmt(hstmt,rc);*/ + + rc = SQLSetPos(hstmt,1,SQL_POSITION,SQL_LOCK_NO_CHANGE); + mystmt(hstmt,rc); + + rc = SQLExecDirect(hstmt1,"DELETE FROM t_pos_delete WHERE CURRENT OF venu_cur",SQL_NTS); + mystmt(hstmt1,rc); + + rc = SQLRowCount(hstmt1,&row_count); + mystmt(hstmt1,rc); + fprintf(stdout, "rows affected: %d\n", row_count); + myassert(row_count == 1); + + SQLFreeStmt(hstmt,SQL_UNBIND); + SQLFreeStmt(hstmt,SQL_CLOSE); + SQLFreeStmt(hstmt1,SQL_CLOSE); + + rc = SQLTransact(NULL,hdbc,SQL_COMMIT); + mycon(hdbc,rc); + + rc = tmysql_exec(hstmt,"select * from t_pos_delete"); + mystmt(hstmt,rc); + + my_assert(1 == myresult(hstmt)); + + rc = SQLFreeStmt(hstmt,SQL_CLOSE); + mystmt(hstmt,rc); + + if (cur_type == SQL_CURSOR_DYNAMIC) + verify_col_data(hstmt,"t_pos_delete","id","0"); + else + verify_col_data(hstmt,"t_pos_delete","id","2"); + + rc = SQLFreeStmt(hstmt1,SQL_DROP); + mystmt(hstmt1,rc); + + return OK; +} + + +DECLARE_TEST(t_pos_datetime_delete1) +{ + SQLRETURN rc; + SQLHSTMT hstmt1; + SQLINTEGER int_data; + SQLLEN row_count, cur_type; + + rc = SQLAllocStmt(hdbc,&hstmt1); + mycon(hdbc,rc); + + tmysql_exec(hstmt,"drop table t_pos_delete"); + rc = tmysql_exec(hstmt,"create table t_pos_delete(id int not null default '0',\ + name varchar(20) NOT NULL default '',\ + created datetime NOT NULL default '2000-01-01')"); + mystmt(hstmt,rc); + + rc = tmysql_exec(hstmt,"insert into t_pos_delete values(1,'venu','2003-02-10 14:45:39')"); + mystmt(hstmt,rc); + + rc = tmysql_exec(hstmt,"insert into t_pos_delete(name) values('')"); + mystmt(hstmt,rc); + + rc = tmysql_exec(hstmt,"insert into t_pos_delete(id) values(2)"); + mystmt(hstmt,rc); + + rc = tmysql_exec(hstmt,"insert into t_pos_delete(id) values(3)"); + mystmt(hstmt,rc); + + rc = tmysql_exec(hstmt,"insert into t_pos_delete(id) values(4)"); + mystmt(hstmt,rc); + + rc = tmysql_exec(hstmt,"insert into t_pos_delete(id) values(5)"); + mystmt(hstmt,rc); + + rc = SQLTransact(NULL,hdbc,SQL_COMMIT); + mycon(hdbc,rc); + + rc = SQLFreeStmt(hstmt,SQL_CLOSE); + mystmt(hstmt,rc); + + rc = tmysql_exec(hstmt,"select * from t_pos_delete"); + mystmt(hstmt,rc); + + my_assert(6 == myresult(hstmt)); + + rc = SQLFreeStmt(hstmt,SQL_CLOSE); + mystmt(hstmt,rc); + + SQLSetStmtAttr(hstmt, SQL_ATTR_CONCURRENCY, (SQLPOINTER) SQL_CONCUR_ROWVER, 0); + SQLSetStmtAttr(hstmt, SQL_ATTR_CURSOR_TYPE, (SQLPOINTER) SQL_CURSOR_DYNAMIC, 0); + SQLSetStmtOption(hstmt,SQL_SIMULATE_CURSOR,SQL_SC_NON_UNIQUE); + + SQLSetStmtAttr(hstmt1, SQL_ATTR_CONCURRENCY, (SQLPOINTER) SQL_CONCUR_ROWVER, 0); + SQLSetStmtAttr(hstmt1, SQL_ATTR_CURSOR_TYPE, (SQLPOINTER) SQL_CURSOR_DYNAMIC, 0); + SQLSetStmtOption(hstmt1,SQL_SIMULATE_CURSOR,SQL_SC_NON_UNIQUE); + + rc = SQLSetCursorName(hstmt,"venu_cur",8); + mystmt(hstmt,rc); + + rc = SQLGetStmtAttr(hstmt, SQL_ATTR_CURSOR_TYPE, &cur_type, 0, NULL); + mystmt(hstmt,rc); + + rc = tmysql_exec(hstmt,"select * from t_pos_delete"); + mystmt(hstmt,rc); + + rc = SQLBindCol(hstmt,1,SQL_C_LONG,&int_data,0,NULL); + mystmt(hstmt,rc); + + rc = SQLExtendedFetch(hstmt,SQL_FETCH_ABSOLUTE,3,NULL,NULL); + mystmt(hstmt,rc); + fprintf(stdout,"current_row: %d\n", int_data); + myassert(int_data == 2); + + rc = SQLSetPos(hstmt,1,SQL_POSITION,SQL_LOCK_NO_CHANGE); + mystmt(hstmt,rc); + + rc = SQLExecDirect(hstmt1,"DELETE FROM t_pos_delete WHERE CURRENT OF venu_cur",SQL_NTS); + mystmt(hstmt1,rc); + + rc = SQLRowCount(hstmt1,&row_count); + mystmt(hstmt1,rc); + fprintf(stdout, "rows affected: %d\n", row_count); + myassert(row_count == 1); + + rc = SQLExtendedFetch(hstmt,SQL_FETCH_NEXT,1,NULL,NULL); + mystmt(hstmt,rc); + fprintf(stdout,"current_row: %d\n", int_data); + + rc = SQLExtendedFetch(hstmt,SQL_FETCH_NEXT,1,NULL,NULL); + mystmt(hstmt,rc); + fprintf(stdout,"current_row: %d\n", int_data); + + /*rc = SQLExtendedFetch(hstmt,SQL_FETCH_NEXT,1,NULL,NULL); + mystmt(hstmt,rc);*/ + + rc = SQLSetPos(hstmt,1,SQL_POSITION,SQL_LOCK_NO_CHANGE); + mystmt(hstmt,rc); + + rc = SQLExecDirect(hstmt1,"DELETE FROM t_pos_delete WHERE CURRENT OF venu_cur",SQL_NTS); + mystmt(hstmt1,rc); + + rc = SQLRowCount(hstmt1,&row_count); + mystmt(hstmt1,rc); + fprintf(stdout, "rows affected: %d\n", row_count); + myassert(row_count == 1); + + SQLFreeStmt(hstmt,SQL_UNBIND); + SQLFreeStmt(hstmt,SQL_CLOSE); + SQLFreeStmt(hstmt1,SQL_CLOSE); + + rc = SQLTransact(NULL,hdbc,SQL_COMMIT); + mycon(hdbc,rc); + + rc = tmysql_exec(hstmt,"select * from t_pos_delete"); + mystmt(hstmt,rc); + + my_assert(4 == myresult(hstmt)); + + rc = SQLFreeStmt(hstmt,SQL_CLOSE); + mystmt(hstmt,rc); + + rc = SQLFreeStmt(hstmt1,SQL_DROP); + mystmt(hstmt1,rc); + + return OK; +} + + +DECLARE_TEST(t_getcursor) +{ + SQLRETURN rc; + SQLHSTMT hstmt1,hstmt2,hstmt3; + SQLCHAR curname[50]; + SQLSMALLINT nlen; + + rc = SQLAllocHandle(SQL_HANDLE_STMT,hdbc,&hstmt1); + mycon(hdbc, rc); + rc = SQLAllocHandle(SQL_HANDLE_STMT,hdbc,&hstmt2); + mycon(hdbc, rc); + rc = SQLAllocHandle(SQL_HANDLE_STMT,hdbc,&hstmt3); + mycon(hdbc, rc); + + rc = SQLGetCursorName(hstmt1,curname,50,&nlen); + if (rc == SQL_SUCCESS || rc == SQL_SUCCESS_WITH_INFO) + { + fprintf(stdout,"default cursor name : %s(%d)\n",curname,nlen); + myassert(nlen == 8); + myassert(!strcmp(curname,"SQL_CUR0")); + + rc = SQLGetCursorName(hstmt3,curname,50,&nlen); + mystmt(hstmt1,rc); + fprintf(stdout,"default cursor name : %s(%d)\n",curname,nlen); + + rc = SQLGetCursorName(hstmt1,curname,4,&nlen); + mystmt_err(hstmt1,rc == SQL_SUCCESS_WITH_INFO, rc); + fprintf(stdout,"truncated cursor name: %s(%d)\n",curname,nlen); + myassert(nlen == 8); + myassert(!strcmp(curname,"SQL")); + + rc = SQLGetCursorName(hstmt1,curname,0,&nlen); + mystmt_err(hstmt1,rc == SQL_SUCCESS_WITH_INFO, rc); + fprintf(stdout,"untouched cursor name: %s(%d)\n",curname,nlen); + myassert(nlen == 8); + + rc = SQLGetCursorName(hstmt1,curname,8,&nlen); + mystmt_err(hstmt1,rc == SQL_SUCCESS_WITH_INFO, rc); + fprintf(stdout,"truncated cursor name: %s(%d)\n",curname,nlen); + myassert(nlen == 8); + myassert(!strcmp(curname,"SQL_CUR")); + + rc = SQLGetCursorName(hstmt1,curname,9,&nlen); + mystmt(hstmt1,rc); + fprintf(stdout,"full cursor name : %s(%d)\n",curname,nlen); + myassert(nlen == 8); + myassert(!strcmp(curname,"SQL_CUR0")); + } + + rc = SQLSetCursorName(hstmt1,"venucur123",7); + mystmt(hstmt1,rc); + + rc = SQLGetCursorName(hstmt1,curname,8,&nlen); + mystmt(hstmt1,rc); + fprintf(stdout,"full setcursor name : %s(%d)\n",curname,nlen); + myassert(nlen == 7); + myassert(!strcmp(curname,"venucur")); + + rc = SQLFreeHandle(SQL_HANDLE_STMT,hstmt1); + mystmt(hstmt1,rc); + + return OK; +} + + +DECLARE_TEST(t_getcursor1) +{ + SQLRETURN rc; + SQLHSTMT hstmt1; + SQLCHAR curname[50]; + SQLSMALLINT nlen,index;; + + for(index=0; index < 100; index++) + { + rc = SQLAllocHandle(SQL_HANDLE_STMT,hdbc,&hstmt1); + mycon(hdbc, rc); + + rc = SQLGetCursorName(hstmt1,curname,50,&nlen); + if (rc != SQL_SUCCESS) + break; + fprintf(stdout,"%s(%d) \n",curname,nlen); + + rc = SQLFreeHandle(SQL_HANDLE_STMT,hstmt1); + mystmt(hstmt1,rc); + } + + return OK; +} + + +DECLARE_TEST(t_acc_crash) +{ + SQLRETURN rc; + SQLINTEGER id; + SQLCHAR name[20], data[30]; + SQL_TIMESTAMP_STRUCT ts; + + tmysql_exec(hstmt,"drop table if exists t_acc_crash"); + rc = tmysql_exec(hstmt,"create table t_acc_crash(id int(11) not null auto_increment,\ + name char(20),\ + ts date,\ + primary key(id))"); + mystmt(hstmt,rc); + + rc = tmysql_exec(hstmt,"insert into t_acc_crash(id,name) values(1,'venu')"); + mystmt(hstmt,rc); + + rc = tmysql_exec(hstmt,"insert into t_acc_crash(name) values('monty')"); + mystmt(hstmt,rc); + + rc = tmysql_exec(hstmt,"insert into t_acc_crash(name) values('mysql')"); + mystmt(hstmt,rc); + + rc = SQLTransact(NULL,hdbc,SQL_COMMIT); + mycon(hdbc,rc); + + rc = SQLFreeStmt(hstmt,SQL_CLOSE); + mystmt(hstmt,rc); + + rc = SQLSetStmtOption(hstmt, SQL_ROWSET_SIZE, 1); + mystmt(hstmt,rc); + + rc = tmysql_exec(hstmt,"select * from t_acc_crash order by id asc"); + mystmt(hstmt,rc); + + rc = SQLBindCol(hstmt,1,SQL_C_LONG,&id,0,NULL); + mystmt(hstmt,rc); + + rc = SQLBindCol(hstmt,2,SQL_C_CHAR,(SQLCHAR *)&name,20,NULL); + mystmt(hstmt,rc); + + rc = SQLBindCol(hstmt,3,SQL_C_DATE,&ts,30,NULL); + mystmt(hstmt,rc); + + rc = SQLFetchScroll(hstmt,SQL_FETCH_FIRST,1); + mystmt(hstmt,rc); + + id = 9; + strcpy(name,"updated"); + ts.year=2010;ts.month=9;ts.day=25; + + rc = SQLSetPos(hstmt,1,SQL_POSITION,SQL_LOCK_NO_CHANGE); + mystmt(hstmt,rc); + + rc = SQLSetPos(hstmt,1,SQL_UPDATE,SQL_LOCK_NO_CHANGE); + mystmt(hstmt,rc); + + SQLFreeStmt(hstmt,SQL_UNBIND); + SQLFreeStmt(hstmt,SQL_CLOSE); + + rc = SQLTransact(NULL,hdbc,SQL_COMMIT); + mycon(hdbc,rc); + + rc = tmysql_exec(hstmt,"select * from t_acc_crash order by id desc"); + mystmt(hstmt,rc); + + rc = SQLFetch(hstmt); + mystmt(hstmt,rc); + + my_assert(9 == my_fetch_int(hstmt,1)); + my_assert(!strcmp("updated", my_fetch_str(hstmt,data,2))); + my_assert(!strcmp("2010-09-25", my_fetch_str(hstmt,data,3))); + + rc = SQLFreeStmt(hstmt,SQL_UNBIND); + mystmt(hstmt,rc); + + rc = SQLFreeStmt(hstmt,SQL_CLOSE); + mystmt(hstmt,rc); + + return OK; +} + + BEGIN_TESTS ADD_TEST(my_init_table) ADD_TEST(my_positioned_cursor) ADD_TEST(my_setpos_cursor) ADD_TEST(t_bug5853) + ADD_TEST(t_setpos_del_all) + ADD_TEST(t_setpos_upd_decimal) + ADD_TEST(t_setpos_position) + ADD_TEST(t_pos_column_ignore) + ADD_TEST(t_pos_datetime_delete) + ADD_TEST(t_pos_datetime_delete1) + ADD_TEST(t_getcursor) + ADD_TEST(t_getcursor1) + ADD_TEST(t_acc_crash) END_TESTS Modified: trunk/test/my_datetime.c =================================================================== --- trunk/test/my_datetime.c 2007-04-06 17:01:21 UTC (rev 297) +++ trunk/test/my_datetime.c 2007-04-06 18:21:39 UTC (rev 298) @@ -326,11 +326,346 @@ } +DECLARE_TEST(t_time) +{ + SQLRETURN rc; + SQL_TIME_STRUCT tm; + SQLCHAR str[20]; + + tmysql_exec(hstmt,"drop table t_time"); + rc = tmysql_exec(hstmt,"create table t_time(tm time, ts timestamp(14))"); + mystmt(hstmt,rc); + + rc = SQLTransact(NULL,hdbc,SQL_COMMIT); + mycon(hdbc,rc); + + rc = SQLPrepare(hstmt,"insert into t_time values (?,?)",SQL_NTS); + mystmt(hstmt,rc); + + rc = SQLBindParameter( hstmt, 1, SQL_PARAM_INPUT, SQL_C_TIME, + SQL_TIME, 0, 0, &tm, 0, NULL ); + mystmt(hstmt,rc); + + rc = SQLBindParameter( hstmt, 2, SQL_PARAM_INPUT, SQL_C_TIME, + SQL_TIMESTAMP, 0, 0, &tm, 15, NULL ); + mystmt(hstmt,rc); + + tm.hour = 20; + tm.minute = 59; + tm.second = 45; + + rc = SQLExecute(hstmt); + mystmt(hstmt,rc); + + rc = SQLFreeStmt(hstmt,SQL_RESET_PARAMS); + mystmt(hstmt,rc); + + rc = SQLFreeStmt(hstmt,SQL_CLOSE); + mystmt(hstmt,rc); + + rc = SQLTransact(NULL,hdbc,SQL_COMMIT); + mycon(hdbc,rc); + + rc = SQLExecDirect(hstmt,"select tm from t_time",SQL_NTS); + mystmt(hstmt,rc); + + rc = SQLFetch(hstmt); + mystmt(hstmt,rc); + + rc = SQLGetData(hstmt,1,SQL_C_CHAR,&str,100,NULL); + mystmt(hstmt,rc); + fprintf(stdout,"time:%s\n",str); + my_assert(strcmp(str,"20:59:45")==0); + + rc = SQLFetch(hstmt); + my_assert(rc == SQL_NO_DATA_FOUND); + + rc = SQLFreeStmt(hstmt,SQL_UNBIND); + mystmt(hstmt,rc); + + rc = SQLFreeStmt(hstmt,SQL_CLOSE); + mystmt(hstmt,rc); + + return OK; +} + + +/* Test for a simple time struct */ +DECLARE_TEST(t_time1) +{ + SQLRETURN rc; + SQL_TIME_STRUCT tt; + SQLCHAR data[30]; + SQLLEN length; + + SQLExecDirect(hstmt,"drop table t_time",SQL_NTS); + rc = SQLExecDirect(hstmt,"create table t_time(t time, t1 timestamp, t2 datetime, t3 date)",SQL_NTS); + mystmt(hstmt,rc); + + rc = SQLPrepare(hstmt,"insert into t_time(t) values(?)",SQL_NTS); + mystmt(hstmt,rc); + + rc = SQLBindParameter(hstmt,1,SQL_PARAM_INPUT,SQL_C_TYPE_TIME, + SQL_TIME,0,0,&tt,0,NULL); + + + tt.hour= 00; + tt.minute= 00; + tt.second= 03; + + rc = SQLExecute(hstmt); + mystmt(hstmt, rc); + + tt.hour= 01; + tt.minute= 00; + tt.second= 00; + + rc = SQLExecute(hstmt); + mystmt(hstmt, rc); + + tt.hour= 19; + tt.minute= 00; + tt.second= 00; + + rc = SQLExecute(hstmt); + mystmt(hstmt, rc); + + tt.hour= 01; + tt.minute= 01; + tt.second= 00; + + rc = SQLExecute(hstmt); + mystmt(hstmt, rc); + + tt.hour= 01; + tt.minute= 00; + tt.second= 01; + + rc = SQLExecute(hstmt); + mystmt(hstmt, rc); + + tt.hour= 00; + tt.minute= 01; + tt.second= 00; + + rc = SQLExecute(hstmt); + mystmt(hstmt, rc); + + tt.hour= 00; + tt.minute= 11; + tt.second= 12; + + rc = SQLExecute(hstmt); + mystmt(hstmt, rc); + + tt.hour= 01; + tt.minute= 01; + tt.second= 01; + + rc = SQLExecute(hstmt); + mystmt(hstmt, rc); + + tt.hour= 00; + tt.minute= 00; + tt.second= 00; + + rc = SQLExecute(hstmt); + mystmt(hstmt, rc); + + tt.hour= 10; + tt.minute= 11; + tt.second= 12; + + rc = SQLExecute(hstmt); + mystmt(hstmt, rc); + + SQLFreeStmt(hstmt, SQL_RESET_PARAMS); + SQLFreeStmt(hstmt, SQL_CLOSE); + + rc = SQLExecDirect(hstmt,"select t from t_time",SQL_NTS); + mystmt(hstmt,rc); + + rc = SQLFetch(hstmt); + mystmt(hstmt,rc); + + rc = SQLGetData(hstmt, 1, SQL_C_CHAR, data, sizeof(data), &length); + mystmt(hstmt,rc); + fprintf(stdout,"time: %s(%d)\n", data, length); + myassert(strcmp(data,"00:00:03")==0); + myassert(length == 8); + + rc = SQLFetch(hstmt); + mystmt(hstmt,rc); + + rc = SQLGetData(hstmt, 1, SQL_C_CHAR, data, sizeof(data), &length); + mystmt(hstmt,rc); + fprintf(stdout,"time: %s(%d)\n", data, length); + myassert(strcmp(data,"01:00:00")==0); + myassert(length == 8); + + rc = SQLFetch(hstmt); + mystmt(hstmt,rc); + + rc = SQLGetData(hstmt, 1, SQL_C_CHAR, data, sizeof(data), &length); + mystmt(hstmt,rc); + fprintf(stdout,"time: %s(%d)\n", data, length); + myassert(strcmp(data,"19:00:00")==0); + myassert(length == 8); + + rc = SQLFetch(hstmt); + mystmt(hstmt,rc); + + rc = SQLGetData(hstmt, 1, SQL_C_CHAR, data, sizeof(data), &length); + mystmt(hstmt,rc); + fprintf(stdout,"time: %s(%d)\n", data, length); + myassert(strcmp(data,"01:01:00")==0); + myassert(length == 8); + + rc = SQLFetch(hstmt); + mystmt(hstmt,rc); + + rc = SQLGetData(hstmt, 1, SQL_C_CHAR, data, sizeof(data), &length); + mystmt(hstmt,rc); + fprintf(stdout,"time: %s(%d)\n", data, length); + myassert(strcmp(data,"01:00:01")==0); + myassert(length == 8); + + rc = SQLFetch(hstmt); + mystmt(hstmt,rc); + + rc = SQLGetData(hstmt, 1, SQL_C_CHAR, data, sizeof(data), &length); + mystmt(hstmt,rc); + fprintf(stdout,"time: %s(%d)\n", data, length); + myassert(strcmp(data,"00:01:00")==0); + myassert(length == 8); + + rc = SQLFetch(hstmt); + mystmt(hstmt,rc); + + rc = SQLGetData(hstmt, 1, SQL_C_CHAR, data, sizeof(data), &length); + mystmt(hstmt,rc); + fprintf(stdout,"time: %s(%d)\n", data, length); + myassert(strcmp(data,"00:11:12")==0); + myassert(length == 8); + + rc = SQLFetch(hstmt); + mystmt(hstmt,rc); + + rc = SQLGetData(hstmt, 1, SQL_C_CHAR, data, sizeof(data), &length); + mystmt(hstmt,rc); + fprintf(stdout,"time: %s(%d)\n", data, length); + myassert(strcmp(data,"01:01:01")==0); + myassert(length == 8); + + rc = SQLFetch(hstmt); + mystmt(hstmt,rc); + + rc = SQLGetData(hstmt, 1, SQL_C_CHAR, data, sizeof(data), &length); + mystmt(hstmt,rc); + fprintf(stdout,"time: %s(%d)\n", data, length); + + myassert(strcmp(data,"00:00:00")==0); + myassert(length == 8); + + rc = SQLFetch(hstmt); + mystmt(hstmt,rc); + + rc = SQLGetData(hstmt, 1, SQL_C_CHAR, data, sizeof(data), &length); + mystmt(hstmt,rc); + fprintf(stdout,"time: %s(%d)\n", data, length); + myassert(strcmp(data,"10:11:12")==0); + myassert(length == 8); + + rc = SQLFetch(hstmt); + myassert(rc == SQL_NO_DATA); + + SQLFreeStmt(hstmt, SQL_UNBIND); + SQLFreeStmt(hstmt, SQL_CLOSE); + + rc = SQLExecDirect(hstmt,"delete from t_time",SQL_NTS); + mystmt(hstmt,rc); + + rc = SQLExecDirect(hstmt,"insert into t_time(t1) values('2003-05-12 10:11:12')",SQL_NTS); + mystmt(hstmt,rc); + + rc = SQLExecDirect(hstmt,"select t1 from t_time", SQL_NTS); + mystmt(hstmt,rc); + + rc = SQLFetch(hstmt); + mystmt(hstmt,rc); + + rc = SQLGetData(hstmt, 1, SQL_C_TIME, &tt, sizeof(tt), &length); + mystmt(hstmt,rc); + fprintf(stdout,"time: %d:%d:%d(%d)\n", tt.hour, tt.minute, tt.second, length); + + myassert(tt.hour == 10 && tt.minute == 11 && tt.second == 12); + myassert(length == sizeof(SQL_TIME_STRUCT)); + + rc = SQLFetch(hstmt); + myassert(rc == SQL_NO_DATA); + + SQLFreeStmt(hstmt, SQL_UNBIND); + SQLFreeStmt(hstmt, SQL_CLOSE); + + rc = SQLExecDirect(hstmt,"delete from t_time",SQL_NTS); + mystmt(hstmt,rc); + + rc = SQLExecDirect(hstmt,"insert into t_time(t2) values('03-12-28 05:59:59')",SQL_NTS); + mystmt(hstmt,rc); + + rc = SQLExecDirect(hstmt,"select t2 from t_time", SQL_NTS); + mystmt(hstmt,rc); + + rc = SQLFetch(hstmt); + mystmt(hstmt,rc); + + rc = SQLGetData(hstmt, 1, SQL_C_TIME, &tt, sizeof(tt), &length); + mystmt(hstmt,rc); + fprintf(stdout,"time: %d:%d:%d(%d)\n", tt.hour, tt.minute, tt.second, length); + myassert(tt.hour == 05 && tt.minute == 59 && tt.second == 59); + myassert(length == sizeof(SQL_TIME_STRUCT)); + + rc = SQLFetch(hstmt); + myassert(rc == SQL_NO_DATA); + + SQLFreeStmt(hstmt, SQL_UNBIND); + SQLFreeStmt(hstmt, SQL_CLOSE); + + rc = SQLExecDirect(hstmt,"delete from t_time",SQL_NTS); + mystmt(hstmt,rc); + + rc = SQLExecDirect(hstmt,"insert into t_time(t3) values('2003-05-12 10:11:12')",SQL_NTS); + mystmt(hstmt,rc); + + rc = SQLExecDirect(hstmt,"select t3 from t_time", SQL_NTS); + mystmt(hstmt,rc); + + rc = SQLFetch(hstmt); + mystmt(hstmt,rc); + + rc = SQLGetData(hstmt, 1, SQL_C_TIME, &tt, sizeof(tt), &length); + mystmt(hstmt,rc); + fprintf(stdout,"time: %d:%d:%d(%d)\n", tt.hour, tt.minute, tt.second, length); + myassert(tt.hour == 00 || tt.minute == 00 || tt.second == 00); + myassert(length == sizeof(SQL_TIME_STRUCT)); + + rc = SQLFetch(hstmt); + myassert(rc == SQL_NO_DATA); + + SQLFreeStmt(hstmt, SQL_UNBIND); + SQLFreeStmt(hstmt, SQL_CLOSE); + + return OK; +} + + BEGIN_TESTS ADD_TEST(my_ts) ADD_TEST(t_tstotime) ADD_TEST(t_tstotime1) ADD_TEST(t_bug25846) + ADD_TEST(t_time) + ADD_TEST(t_time1) END_TESTS Modified: trunk/test/my_error.c =================================================================== --- trunk/test/my_error.c 2007-04-06 17:01:21 UTC (rev 297) +++ trunk/test/my_error.c 2007-04-06 18:21:39 UTC (rev 298) @@ -180,11 +180,106 @@ return OK; } +static void test_diagrec(SQLSMALLINT HandleType,SQLHANDLE Handle, + SQLSMALLINT RecNumber, SQLSMALLINT BufferLength, + SQLRETURN return_value_expected) +{ + SQLRETURN rc; + SQLCHAR sqlstate[6]={0}; + SQLCHAR message[255]={0}; + SQLINTEGER native_err=0; + SQLSMALLINT msglen=0; + + rc = SQLGetDiagRec(HandleType,Handle,RecNumber, + (char *)&sqlstate,&native_err, + (char *)&message,BufferLength,&msglen); + + fprintf(stdout,"%d@%s(%d)\n",rc,message,msglen); + myassert(return_value_expected == rc); +} + + +DECLARE_TEST(t_diagrec) +{ + SQLRETURN rc; + + fprintf(stdout," ** SQL_HANDLE_STMT ** \n"); + + rc = SQLExecDirect(hstmt,"DROP TABLE ODBC3_NON_EXISTANTi_TAB",SQL_NTS); + myassert(rc == SQL_ERROR); + + test_diagrec(SQL_HANDLE_STMT,hstmt,2,0,SQL_NO_DATA_FOUND); + test_diagrec(SQL_HANDLE_STMT,hstmt,1,255,SQL_SUCCESS); + test_diagrec(SQL_HANDLE_STMT,hstmt,1,0,SQL_SUCCESS_WITH_INFO); + test_diagrec(SQL_HANDLE_STMT,hstmt,1,10,SQL_SUCCESS_WITH_INFO); + test_diagrec(SQL_HANDLE_STMT,hstmt,1,-1,SQL_ERROR); + + return OK; +} + + +DECLARE_TEST(t_warning) +{ + SQLRETURN rc; + SQLCHAR szData[20]; + SQLINTEGER pcbValue; + + tmysql_exec(hstmt,"drop table t_warning"); + rc = tmysql_exec(hstmt,"create table t_warning(col2 char(20))"); + mystmt(hstmt,rc); + + rc = tmysql_exec(hstmt,"insert into t_warning values('venu anuganti')"); + mystmt(hstmt,rc); + + rc = SQLTransact(NULL,hdbc,SQL_COMMIT); + mycon(hdbc,rc); + + rc = SQLFreeStmt(hstmt,SQL_CLOSE); + mystmt(hstmt,rc); + + SQLSetStmtAttr(hstmt, SQL_ATTR_CONCURRENCY, (SQLPOINTER) SQL_CONCUR_ROWVER, 0); + SQLSetStmtAttr(hstmt, SQL_ATTR_CURSOR_TYPE, (SQLPOINTER) SQL_CURSOR_KEYSET_DRIVEN, 0); + + /* ignore all columns */ + rc = tmysql_exec(hstmt,"select * from t_warning"); + mystmt(hstmt,rc); + + rc = SQLFetch(hstmt); + mystmt(hstmt, rc); + + rc = SQLGetData(hstmt,1,SQL_C_CHAR,szData,4,&pcbValue); + mystmt_err(hstmt, rc == SQL_SUCCESS_WITH_INFO, rc); + fprintf(stdout,"data: %s(%d)\n",szData,pcbValue); + + rc = SQLGetData(hstmt,1,SQL_C_CHAR,szData,4,&pcbValue); + mystmt_err(hstmt, rc == SQL_SUCCESS_WITH_INFO, rc); + fprintf(stdout,"data: %s(%d)\n",szData,pcbValue); + + rc = SQLGetData(hstmt,1,SQL_C_CHAR,szData,4,&pcbValue); + mystmt_err(hstmt, rc == SQL_SUCCESS_WITH_INFO, rc); + fprintf(stdout,"data: %s(%d)\n",szData,pcbValue); + + rc = SQLGetData(hstmt,1,SQL_C_CHAR,szData,4,&pcbValue); + mystmt(hstmt,rc); + fprintf(stdout,"data: %s(%d)\n",szData,pcbValue); + + rc = SQLFetch(hstmt); + mystmt_err(hstmt, rc == SQL_NO_DATA_FOUND, rc); + + SQLFreeStmt(hstmt,SQL_UNBIND); + SQLFreeStmt(hstmt,SQL_CLOSE); + + return OK; +} + + BEGIN_TESTS ADD_TEST(t_odbc2_error) ADD_TEST(t_odbc3_error) /* Run twice to test the driver's handling of switching */ ADD_TEST(t_odbc2_error) + ADD_TEST(t_diagrec) + ADD_TEST(t_warning) END_TESTS RUN_TESTS Added: trunk/test/my_info.c =================================================================== --- trunk/test/my_info.c 2007-04-06 17:01:21 UTC (rev 297) +++ trunk/test/my_info.c 2007-04-06 18:21:39 UTC (rev 298) @@ -0,0 +1,168 @@ +/* + Copyright (C) 1995-2007 MySQL AB + + This program is free software; you can redistribute it and/or modify + it under the terms of version 2 of the GNU General Public License as + published by the Free Software Foundation. + + There are special exceptions to the terms and conditions of the GPL + as it is applied to this software. View the full text of the exception + in file LICENSE.exceptions in the top-level directory of this software + distribution. + + This program is distributed in the hope that it will be useful, + but WITHOUT ANY WARRANTY; without even the implied warranty of + MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + GNU General Public License for more details. + + You should have received a copy of the GNU General Public License + along with this program; if not, write to the Free Software + Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA +*/ + +#include "odbctap.h" + + +DECLARE_TEST(t_gettypeinfo) +{ + SQLRETURN rc; + SQLSMALLINT pccol; + + rc = SQLFreeStmt(hstmt,SQL_CLOSE); + mystmt(hstmt,rc); + + rc = SQLGetTypeInfo(hstmt,SQL_ALL_TYPES); + mystmt(hstmt,rc); + + rc = SQLNumResultCols(hstmt,&pccol); + mystmt(hstmt,rc); + fprintf(stdout,"total columns: %d\n",pccol); + myassert(pccol == 19); + myresult(hstmt); + + rc = SQLFreeStmt(hstmt,SQL_RESET_PARAMS); + mystmt(hstmt,rc); + + rc = SQLFreeStmt(hstmt,SQL_CLOSE); + mystmt(hstmt,rc); + + return OK; +} + + +DECLARE_TEST(t_getinfo) +{ + SQLRETURN rc; + SQLCHAR rgbValue[100]; + SQLSMALLINT pcbInfo; + + rc = SQLGetInfo(hdbc,SQL_DRIVER_ODBC_VER,rgbValue,100,&pcbInfo); + mycon(hdbc,rc); + fprintf(stdout,"SQL_DRIVER_ODBC_VER: %s(%d)\n",rgbValue,pcbInfo); + + return OK; +} + + +DECLARE_TEST(t_stmt_attr_status) +{ + SQLRETURN rc; + SQLUSMALLINT rowStatusPtr[3]; + SQLUINTEGER rowsFetchedPtr; + + tmysql_exec(hstmt,"drop table t_stmtstatus"); + + rc = SQLTransact(NULL,hdbc,SQL_COMMIT); + mycon(hdbc,rc); + + rc = tmysql_exec(hstmt,"create table t_stmtstatus(id int, name char(20))"); + mystmt(hstmt,rc); + + rc = SQLTransact(NULL,hdbc,SQL_COMMIT); + mycon(hdbc,rc); + + rc = tmysql_exec(hstmt,"insert into t_stmtstatus values(10,'data1')"); + mystmt(hstmt,rc); + rc = tmysql_exec(hstmt,"insert into t_stmtstatus values(20,'data2')"); + mystmt(hstmt,rc); + + rc = SQLTransact(NULL,hdbc,SQL_COMMIT); + mycon(hdbc,rc); + + rc = SQLFreeStmt(hstmt,SQL_CLOSE); + mystmt(hstmt,rc); + + rc = SQLSetStmtAttr(hstmt,SQL_ATTR_CURSOR_SCROLLABLE,(SQLPOINTER)SQL_NONSCROLLABLE,0); + mystmt(hstmt,rc); + + rc = tmysql_exec(hstmt,"select * from t_stmtstatus"); + mystmt(hstmt,rc); + + rc = SQLSetStmtAttr(hstmt,SQL_ATTR_ROWS_FETCHED_PTR,&rowsFetchedPtr,0); + mystmt(hstmt,rc); + + rc = SQLSetStmtAttr(hstmt,SQL_ATTR_ROW_STATUS_PTR,&rowStatusPtr,0); + mystmt(hstmt,rc); + + rc = SQLFetchScroll(hstmt,SQL_FETCH_ABSOLUTE,2); + mystmt_err(hstmt,rc == SQL_ERROR,rc); + + rc = SQLFreeStmt(hstmt,SQL_CLOSE); + mystmt(hstmt,rc); + + rc = SQLSetStmtAttr(hstmt,SQL_ATTR_CURSOR_SCROLLABLE,(SQLPOINTER)SQL_SCROLLABLE,0); + mystmt(hstmt,rc); + + rc = tmysql_exec(hstmt,"select * from t_stmtstatus"); + mystmt(hstmt,rc); + + rc = SQLFetchScroll(hstmt,SQL_FETCH_ABSOLUTE,2); + mystmt(hstmt,rc); + + printMessage("total rows fetched: %d\n",rowsFetchedPtr); + printMessage("row 0 status : %d\n",rowStatusPtr[0]); + printMessage("row 1 status : %d\n",rowStatusPtr[1]); + printMessage("row 2 status : %d\n",rowStatusPtr[2]); + myassert(rowsFetchedPtr == 1); + myassert(rowStatusPtr[0] == 0); + + rc = SQLFreeStmt(hstmt,SQL_CLOSE); + mystmt(hstmt,rc); + + rc = SQLSetStmtAttr(hstmt,SQL_ATTR_ROWS_FETCHED_PTR,(SQLPOINTER)0,0); + mystmt(hstmt,rc); + + rc = SQLSetStmtAttr(hstmt,SQL_ATTR_ROW_STATUS_PTR,(SQLPOINTER)0,0); + mystmt(hstmt,rc); + + return OK; +} + + +DECLARE_TEST(t_msdev_bug) +{ + SQLRETURN rc; + SQLCHAR catalog[30]; + SQLLEN len; + + rc = SQLGetConnectOption(hdbc,SQL_CURRENT_QUALIFIER,&catalog); + mycon(hdbc,rc); + fprintf(stdout," SQL_CURRENT_QUALIFIER:%s\n",catalog); + + rc = SQLGetConnectAttr(hdbc,SQL_ATTR_CURRENT_CATALOG,&catalog,30,&len); + mycon(hdbc,rc); + fprintf(stdout," SQL_ATTR_CURRENT_CATRALOG:%s(%d)\n",catalog,len); + + return OK; +} + + +BEGIN_TESTS + ADD_TEST(t_gettypeinfo) + ADD_TEST(t_getinfo) + ADD_TEST(t_stmt_attr_status) + ADD_TEST(t_msdev_bug) +END_TESTS + + +RUN_TESTS Modified: trunk/test/my_prepare.c =================================================================== --- trunk/test/my_prepare.c 2007-04-06 17:01:21 UTC (rev 297) +++ trunk/test/my_prepare.c 2007-04-06 18:21:39 UTC (rev 298) @@ -722,6 +722,126 @@ } +DECLARE_TEST(t_prepare) +{ + SQLRETURN rc; + SQLINTEGER nidata= 200, nodata; + SQLLEN nlen; + char szodata[20],szidata[20]="MySQL"; + short pccol; + + SQLFreeStmt(hstmt,SQL_CLOSE); + + tmysql_exec(hstmt,"drop table t_prepare"); + + rc = tmysql_exec(hstmt,"create table t_prepare(col1 int primary key, col2 varchar(30), col3 set(\"one\", \"two\"))"); + mystmt(hstmt,rc); + + rc = tmysql_exec(hstmt,"insert into t_prepare values(100,'venu','one')"); + mystmt(hstmt,rc); + + rc = tmysql_exec(hstmt,"insert into t_prepare values(200,'MySQL','two')"); + mystmt(hstmt,rc); + + rc = SQLPrepare(hstmt,"select * from t_prepare where col2 = ? AND col1 = ?",SQL_NTS); + mystmt(hstmt,rc); + + rc = SQLNumResultCols(hstmt,&pccol); + mystmt(hstmt,rc); + + rc = SQLBindCol(hstmt,1,SQL_C_LONG,&nodata,0,&nlen); + mystmt(hstmt,rc); + + rc = SQLBindCol(hstmt,2,SQL_C_CHAR,szodata,200,&nlen); + mystmt(hstmt,rc); + + rc = SQLBindParameter(hstmt,1,SQL_PARAM_INPUT, SQL_C_CHAR,SQL_VARCHAR, + 0,0,szidata,20,&nlen); + mystmt(hstmt,rc); + + rc = SQLBindParameter(hstmt,2,SQL_PARAM_INPUT, SQL_C_LONG,SQL_INTEGER, + 0,0,&nidata,20,NULL); + mystmt(hstmt,rc); + + nlen= strlen(szidata); + rc = SQLExecute(hstmt); + mystmt(hstmt,rc); + + rc = SQLFetch(hstmt); + mystmt(hstmt,rc); + + fprintf(stdout," outdata: %d, %s(%d)\n", nodata,szodata,nlen); + my_assert(nodata == 200); + + rc = SQLFetch(hstmt); + my_assert(rc == SQL_NO_DATA_FOUND); + + rc = SQLFreeStmt(hstmt,SQL_CLOSE); + mystmt(hstmt,rc); + + rc = SQLFreeStmt(hstmt,SQL_UNBIND); + mystmt(hstmt,rc); + + rc = SQLFreeStmt(hstmt,SQL_RESET_PARAMS); + mystmt(hstmt,rc); + + return OK; +} + + +DECLARE_TEST(t_prepare1) +{ + SQLRETURN rc; + SQLINTEGER nidata= 1000; + + tmysql_exec(hstmt,"drop table t_prepare1"); + + rc = tmysql_exec(hstmt,"create table t_prepare1(col1 int primary key, col2 varchar(30))"); + mystmt(hstmt,rc); + + rc = tmysql_exec(hstmt,"insert into t_prepare1 values(100,'venu')"); + mystmt(hstmt,rc); + + rc = tmysql_exec(hstmt,"insert into t_prepare1 values(200,'MySQL')"); + mystmt(hstmt,rc); + + rc = SQLTransact(NULL,hdbc,SQL_COMMIT); + mycon(hdbc,rc); + + rc = SQLFreeStmt(hstmt,SQL_CLOSE); + mystmt(hstmt,rc); + + rc = tmysql_prepare(hstmt,"insert into t_prepare1(col1) values(?)"); + mystmt(hstmt,rc); + + rc = SQLBindParameter(hstmt,1,SQL_PARAM_INPUT, SQL_C_LONG,SQL_INTEGER, + 0,0,&nidata,0,NULL); + mystmt(hstmt,rc); + + rc = SQLExecute(hstmt); + mystmt(hstmt,rc); + + rc = SQLTransact(NULL,hdbc,SQL_COMMIT); + mycon(hdbc,rc); + + rc = SQLFreeStmt(hstmt,SQL_CLOSE); + mystmt(hstmt,rc); + + rc = SQLFreeStmt(hstmt,SQL_RESET_PARAMS); + mystmt(hstmt,rc); + + rc = SQLExecDirect(hstmt,"SELECT * FROM t_prepare1",SQL_NTS); + mystmt(hstmt,rc); + + myassert(3 == myresult(hstmt));/* unless prepare is supported..*/ + + rc = SQLFreeStmt(hstmt,SQL_CLOSE); + mystmt(hstmt,rc); + + return OK; +} + + BEGIN_TESTS ADD_TEST(t_prep_basic) ADD_TEST(t_prep_buffer_length) @@ -731,6 +851,8 @@ ADD_TEST(t_prep_getdata1) ADD_TEST(t_prep_catalog) ADD_TEST(t_sps) + ADD_TEST(t_prepare) + ADD_TEST(t_prepare1) END_TESTS Modified: trunk/test/my_relative.c =================================================================== --- trunk/test/my_relative.c 2007-04-06 17:01:21 UTC (rev 297) +++ trunk/test/my_relative.c 2007-04-06 18:21:39 UTC (rev 298) @@ -745,11 +745,144 @@ } +DECLARE_TEST(t_rows_fetched_ptr1) +{ + SQLRETURN rc; + SQLLEN rowsFetched, rowsSize; + SQLINTEGER i; + + SQLExecDirect(hstmt,"drop table t_rows_fetched_ptr",SQL_NTS); + + rc = SQLExecDirect(hstmt,"create table t_rows_fetched_ptr(a int)",SQL_NTS); + mystmt(hstmt,rc); + + rc = SQLExecDirect(hstmt,"insert into t_rows_fetched_ptr values(0)",SQL_NTS); + mystmt(hstmt,rc); + + rc = SQLExecDirect(hstmt,"insert into t_rows_fetched_ptr values(1)",SQL_NTS); + mystmt(hstmt,rc); + + rc = SQLExecDirect(hstmt,"insert into t_rows_fetched_ptr values(2)",SQL_NTS); + mystmt(hstmt,rc); + + rc = SQLExecDirect(hstmt,"insert into t_rows_fetched_ptr values(3)",SQL_NTS); + mystmt(hstmt,rc); + + rc = SQLExecDirect(hstmt,"insert into t_rows_fetched_ptr values(4)",SQL_NTS); + mystmt(hstmt,rc); + + rc = SQLExecDirect(hstmt,"insert into t_rows_fetched_ptr values(5)",SQL_NTS); + mystmt(hstmt,rc); + + rowsSize= 1; + rc = SQLSetStmtAttr(hstmt, SQL_ATTR_ROW_ARRAY_SIZE, (SQLPOINTER)rowsSize, 0); + mystmt(hstmt,rc); + + rc = SQLSetStmtAttr(hstmt, SQL_ATTR_ROWS_FETCHED_PTR, &rowsFetched, 0); + mystmt(hstmt,rc); + + rc = SQLExecDirect(hstmt, "SELECT * FROM t_rows_fetched_ptr",SQL_NTS); + mystmt(hstmt,rc); + + i= 0; + rc = SQLFetchScroll(hstmt,SQL_FETCH_NEXT,0); + while (rc == SQL_SUCCESS || rc == SQL_SUCCESS_WITH_INFO) + { + fprintf(stdout,"total rows fetched: %ld\n", rowsFetched); + myassert(rowsFetched == rowsSize); + i++; rowsFetched= 0; + rc = SQLFetchScroll(hstmt, SQL_FETCH_NEXT, 0); + } + myassert( i == 6); + SQLFreeStmt(hstmt, SQL_CLOSE); + + rowsSize= 2; + rc = SQLSetStmtAttr(hstmt, SQL_ATTR_ROW_ARRAY_SIZE, (SQLPOINTER)rowsSize, 0); + mystmt(hstmt,rc); + + rc = SQLSetStmtAttr(hstmt, SQL_ATTR_ROWS_FETCHED_PTR, &rowsFetched, 0); + mystmt(hstmt,rc); + + rc = SQLExecDirect(hstmt, "SELECT * FROM t_rows_fetched_ptr",SQL_NTS); + mystmt(hstmt,rc); + + i= 0; + rc = SQLFetchScroll(hstmt,SQL_FETCH_NEXT,0); + while (rc == SQL_SUCCESS || rc == SQL_SUCCESS_WITH_INFO) + { + fprintf(stdout,"total rows fetched: %ld\n", rowsFetched); + myassert(rowsFetched == rowsSize); + i++;rowsFetched= 0; + rc = SQLFetchScroll(hstmt,SQL_FETCH_NEXT,0); + } + myassert( i == 3); + SQLFreeStmt(hstmt, SQL_CLOSE); + + rowsSize= 3; + rc = SQLSetStmtAttr(hstmt, SQL_ATTR_ROW_ARRAY_SIZE, (SQLPOINTER)rowsSize, 0); + mystmt(hstmt,rc); + + rc = SQLSetStmtAttr(hstmt, SQL_ATTR_ROWS_FETCHED_PTR, &rowsFetched, 0); + mystmt(hstmt,rc); + + rc = SQLExecDirect(hstmt, "SELECT * FROM t_rows_fetched_ptr",SQL_NTS); + mystmt(hstmt,rc); + + i= 0; + rc = SQLFetchScroll(hstmt,SQL_FETCH_NEXT,0); + while (rc == SQL_SUCCESS || rc == SQL_SUCCESS_WITH_INFO) + { + printMessage("total rows fetched: %ld\n", rowsFetched); + myassert(rowsFetched == rowsSize); + i++;rowsFetched= 0; + rc = SQLFetchScroll(hstmt, SQL_FETCH_NEXT, 0); + } + myassert( i == 2); + SQLFreeStmt(hstmt, SQL_CLOSE); + + rowsSize= 4; + rc = SQLSetStmtAttr(hstmt, SQL_ATTR_ROW_ARRAY_SIZE, (SQLPOINTER)rowsSize, 0); + mystmt(hstmt,rc); + + rc = SQLSetStmtAttr(hstmt, SQL_ATTR_ROWS_FETCHED_PTR, &rowsFetched, 0); + mystmt(hstmt,rc); + + rc = SQLExecDirect(hstmt, "SELECT * FROM t_rows_fetched_ptr",SQL_NTS); + mystmt(hstmt,rc); + + rc = SQLFetch(hstmt); + mystmt(hstmt,rc); + + printMessage("total rows fetched: %ld\n", rowsFetched); + myassert(rowsFetched == rowsSize); + + rc = SQLFetch(hstmt); + mystmt(hstmt,rc); + + printMessage("total rows fetched: %ld\n", rowsFetched); + myassert(rowsFetched == 2); + + rc = SQLFetch(hstmt); + myassert(rc == SQL_NO_DATA); + + SQLFreeStmt(hstmt, SQL_CLOSE); + + rc = SQLSetStmtAttr(hstmt, SQL_ATTR_ROW_ARRAY_SIZE, (SQLPOINTER)1, 0);/* reset */ + mystmt(hstmt,rc); + + rc = SQLSetStmtAttr(hstmt, SQL_ATTR_ROWS_FETCHED_PTR, NULL, 0); + mystmt(hstmt,rc); + + return OK; +} + + BEGIN_TESTS ADD_TEST(t_relative) ADD_TEST(t_relative1) ADD_TEST(t_relative2) ADD_TEST(t_rows_fetched_ptr) + ADD_TEST(t_rows_fetched_ptr1) END_TESTS Modified: trunk/test/my_result.c =================================================================== --- trunk/test/my_result.c 2007-04-06 17:01:21 UTC (rev 297) +++ trunk/test/my_result.c 2007-04-06 18:21:39 UTC (rev 298) @@ -128,8 +128,952 @@ } +/* To test a convertion type */ +DECLARE_TEST(t_convert_type) +{ + SQLRETURN rc; + SQLSMALLINT SqlType, DateType; + SQLCHAR ColName[MAX_NAME_LEN]; + SQLCHAR DbVersion[MAX_NAME_LEN]; + SQLINTEGER OdbcVersion; + + SQLFreeStmt(hstmt, SQL_CLOSE); + + rc = SQLGetEnvAttr(henv,SQL_ATTR_ODBC_VERSION,&OdbcVersion,0,NULL); + myenv(henv,rc); + + fprintf(stdout,"odbc version:\n"); + if (OdbcVersion == SQL_OV_ODBC2) + { + fprintf(stdout," SQL_OV_ODBC2"); + DateType= SQL_DATE; + } + else + { + fprintf(stdout," SQL_OV_ODBC3"); + DateType= SQL_TYPE_DATE; + } + + rc = SQLGetInfo(hdbc,SQL_DBMS_VER,(SQLCHAR *)&DbVersion,MAX_NAME_LEN,NULL); + mycon(hdbc,rc); + + SQLExecDirect(hstmt,"DROP TABLE t_convert",SQL_NTS); + + rc = SQLExecDirect(hstmt,"CREATE TABLE t_convert(col0 integer, \ + col1 date,\ + col2 char(10))",SQL_NTS); + mystmt(hstmt,rc); + + rc = SQLExecDirect(hstmt,"INSERT INTO t_convert VALUES(10,'2002-10-24','venu')",SQL_NTS); + mystmt(hstmt,rc); + + rc = SQLExecDirect(hstmt,"INSERT INTO t_convert VALUES(20,'2002-10-23','venu1')",SQL_NTS); + mystmt(hstmt,rc); + + rc = SQLExecDirect(hstmt,"INSERT INTO t_convert VALUES(30,'2002-10-25','venu2')",SQL_NTS); + mystmt(hstmt,rc); + + rc = SQLExecDirect(hstmt,"INSERT INTO t_convert VALUES(40,'2002-10-24','venu3')",SQL_NTS); + mystmt(hstmt,rc); + + rc = SQLExecDirect(hstmt,"SELECT MAX(col0) FROM t_convert",SQL_NTS); + mystmt(hstmt,rc); + + rc = SQLDescribeCol(hstmt,1,(SQLCHAR *)&ColName,MAX_NAME_LEN,NULL,&SqlType,NULL,NULL,NULL); + mystmt(hstmt,rc); + + fprintf(stdout,"MAX(col0): %d\n", SqlType); + myassert(SqlType == SQL_INTEGER); + + SQLFreeStmt(hstmt,SQL_CLOSE); + + rc = SQLExecDirect(hstmt,"SELECT MAX(col1) FROM t_convert",SQL_NTS); + mystmt(hstmt,rc); + + rc = SQLDescribeCol(hstmt,1,(SQLCHAR *)&ColName,MAX_NAME_LEN,NULL,&SqlType,NULL,NULL,NULL); + mystmt(hstmt,rc); + + fprintf(stdout,"MAX(col1): %d\n", SqlType); + myassert(SqlType == DateType); + + SQLFreeStmt(hstmt,SQL_CLOSE); + + rc = SQLExecDirect(hstmt,"SELECT MAX(col2) FROM t_convert",SQL_NTS); + mystmt(hstmt,rc); + + rc = SQLDescribeCol(hstmt,1,(SQLCHAR *)&ColName,MAX_NAME_LEN,NULL,&SqlType,NULL,NULL,NULL); + mystmt(hstmt,rc); + + fprintf(stdout,"MAX(col0): %d\n", SqlType); + + SQLFreeStmt(hstmt,SQL_CLOSE); + + if (strncmp(DbVersion,"4.",2) >= 0) + { + rc = SQLExecDirect(hstmt,"SELECT CAST(MAX(col1) AS DATE) AS col1 FROM t_convert",SQL_NTS); + mystmt(hstmt,rc); + + rc = SQLDescribeCol(hstmt,1,(SQLCHAR *)&ColName,MAX_NAME_LEN,NULL,&SqlType,NULL,NULL,NULL); + mystmt(hstmt,rc); + + fprintf(stdout,"CAST(MAX(col1) AS DATE): %d\n", SqlType); + myassert(SqlType == DateType); + + SQLFreeStmt(hstmt,SQL_CLOSE); + + rc = SQLExecDirect(hstmt,"SELECT CONVERT(MAX(col1),DATE) AS col1 FROM t_convert",SQL_NTS); + mystmt(hstmt,rc); + + rc = SQLDescribeCol(hstmt,1,(SQLCHAR *)&ColName,MAX_NAME_LEN,NULL,&SqlType,NULL,NULL,NULL); + mystmt(hstmt,rc); + + fprintf(stdout,"CONVERT(MAX(col1),DATE): %d\n", SqlType); + myassert(SqlType == DateType); + + SQLFreeStmt(hstmt,SQL_CLOSE); + + rc = SQLExecDirect(hstmt,"SELECT CAST(MAX(col1) AS CHAR) AS col1 FROM t_convert",SQL_NTS); + mystmt(hstmt,rc); + + rc = SQLDescribeCol(hstmt,1,(SQLCHAR *)&ColName,MAX_NAME_LEN,NULL,&SqlType,NULL,NULL,NULL); + mystmt(hstmt,rc); + + fprintf(stdout,"CAST(MAX(col1) AS CHAR): %d\n", SqlType); + myassert(SqlType == SQL_VARCHAR || SqlType == SQL_LONGVARCHAR); + + SQLFreeStmt(hstmt,SQL_CLOSE); + } + + rc = SQLExecDirect(hstmt,"DROP TABLE t_convert",SQL_NTS); + mystmt(hstmt,rc); + + SQLFreeStmt(hstmt,SQL_CLOSE); + + return OK; +} + + +static void desc_col_check(SQLHSTMT hstmt, + SQLUSMALLINT icol, + const char *name, + SQLSMALLINT sql_type, + SQLUINTEGER col_def, + SQLUINTEGER col_def1, + SQLSMALLINT scale, + SQLSMALLINT nullable) +{ + SQLRETURN rc; + SQLSMALLINT pcbColName, pfSqlType, pibScale, pfNullable; + SQLUINTEGER pcbColDef; + SQLCHAR szColName[MAX_NAME_LEN]; + + rc = SQLDescribeCol(hstmt, icol, + szColName,MAX_NAME_LEN,&pcbColName, + &pfSqlType,&pcbColDef,&pibScale,&pfNullable); + mystmt(hstmt,rc); + + fprintf(stdout, "\n\n Column Number'%d':", icol); + + fprintf(stdout, "\t Column Name : %s\n", szColName); + fprintf(stdout, "\t NameLengh : %d\n", pcbColName); + fprintf(stdout, "\t DataType : %d\n", pfSqlType); + fprintf(stdout, "\t ColumnSize : %d\n", pcbColDef); + fprintf(stdout, "\t DecimalDigits : %d\n", pibScale); + fprintf(stdout, "\t Nullable : %d\n", pfNullable); + + myassert(strcmp(name,szColName) == 0); + myassert(sql_type == pfSqlType); + myassert(col_def == pcbColDef || col_def1 == pcbColDef); + myassert(scale == pibScale); + myassert(nullable == pfNullable); +} + + +/* To test SQLDescribeCol */ +DECLARE_TEST(t_desc_col) +{ + SQLRETURN rc; + SQLSMALLINT ColumnCount; + + SQLFreeStmt(hstmt, SQL_CLOSE); + + SQLExecDirect(hstmt,"DROP TABLE t_desc_col",SQL_NTS); + + rc = SQLExecDirect(hstmt,"CREATE TABLE t_desc_col(c1 integer, \ + c2 binary(2) NOT NULL,\ + c3 char(1), \ + c4 varchar(5),\ + c5 decimal(10,3) NOT NULL,\ + c6 tinyint,\ + c7 smallint,\ + c8 numeric(4,2),\ + c9 real,\ + c10 float(5),\ + c11 bigint NOT NULL,\ + c12 varbinary(12),\ + c13 char(20) NOT NULL,\ + c14 float(10,3),\ + c15 tinytext,\ + c16 text,\ + c17 mediumtext,\ + c18 longtext,\ + c19 tinyblob,\ + c20 blob,\ + c21 mediumblob,\ + c22 longblob,\ + c23 tinyblob)",SQL_NTS); + mystmt(hstmt,rc); + + rc = SQLExecDirect(hstmt,"SELECT * FROM t_desc_col",SQL_NTS); + mystmt(hstmt,rc); + + rc = SQLNumResultCols(hstmt, &ColumnCount); + mystmt(hstmt,rc); + + fprintf(stdout,"total columns: %d\n", ColumnCount); + my_assert(ColumnCount == 23); + + desc_col_check(hstmt, 1, "c1", SQL_INTEGER, 10, 11, 0, SQL_NULLABLE); + desc_col_check(hstmt, 2, "c2", SQL_BINARY, 2, 2, 0, SQL_NO_NULLS); + desc_col_check(hstmt, 3, "c3", SQL_CHAR, 1, 1, 0, SQL_NULLABLE); + desc_col_check(hstmt, 4, "c4", SQL_VARCHAR, 5, 5, 0, SQL_NULLABLE); + desc_col_check(hstmt, 5, "c5", SQL_DECIMAL, 10, 10, 3, SQL_NO_NULLS); + desc_col_check(hstmt, 6, "c6", SQL_TINYINT, 3, 4, 0, SQL_NULLABLE); + desc_col_check(hstmt, 7, "c7", SQL_SMALLINT, 5, 6, 0, SQL_NULLABLE); + desc_col_check(hstmt, 8, "c8", SQL_DECIMAL, 4, 4, 2, SQL_NULLABLE); + desc_col_check(hstmt, 9, "c9", SQL_DOUBLE, 22, 24, 31, SQL_NULLABLE); + desc_col_check(hstmt, 10, "c10", SQL_REAL, 12, 24, 31, SQL_NULLABLE); + desc_col_check(hstmt, 11, "c11", SQL_BIGINT, 19, 19, 0, SQL_NO_NULLS); + desc_col_check(hstmt, 12, "c12", SQL_VARBINARY, 12, 12, 0, SQL_NULLABLE); + desc_col_check(hstmt, 13, "c13", SQL_CHAR, 20, 20, 0, SQL_NO_NULLS); + desc_col_check(hstmt, 14, "c14", SQL_REAL, 10, 24, 3, SQL_NULLABLE); + desc_col_check(hstmt, 15, "c15", SQL_LONGVARCHAR, 255, 255, 0, SQL_NULLABLE); + desc_col_check(hstmt, 16, "c16", SQL_LONGVARCHAR, 65535, 65535, 0, SQL_NULLABLE); + desc_col_check(hstmt, 17, "c17", SQL_LONGVARCHAR, 16777215, 16777215, 0, SQL_NULLABLE); + desc_col_check(hstmt, 18, "c18", SQL_LONGVARCHAR, 4294967295 , 16777215 , 0, SQL_NULLABLE); + desc_col_check(hstmt, 19, "c19", SQL_LONGVARBINARY, 255, 255, 0, SQL_NULLABLE); + desc_col_check(hstmt, 20, "c20", SQL_LONGVARBINARY, 65535, 65535, 0, SQL_NULLABLE); + desc_col_check(hstmt, 21, "c21", SQL_LONGVARBINARY, 16777215, 16777215, 0, SQL_NULLABLE); + desc_col_check(hstmt, 22, "c22", SQL_LONGVARBINARY, 4294967295 , 16777215 , 0, SQL_NULLABLE); + desc_col_check(hstmt, 23, "c23", SQL_LONGVARBINARY, 255, 5, 0, SQL_NULLABLE); + + SQLFreeStmt(hstmt,SQL_CLOSE); +} + + +/* Test for misc CONVERT bug #1082 */ +DECLARE_TEST(t_convert) +{ + SQLRETURN rc; + SQLLEN data_len; + SQLCHAR data[50]; + + tmysql_exec(hstmt,"drop table t_convert"); + + rc = SQLTransact(NULL,hdbc,SQL_COMMIT); + mycon(hdbc,rc); + + rc = tmysql_exec(hstmt,"CREATE TABLE t_convert(testing tinytext)"); + mystmt(hstmt,rc); + + rc = tmysql_exec(hstmt,"INSERT INTO t_convert VALUES('record1')"); + mystmt(hstmt,rc); + + rc = tmysql_exec(hstmt,"INSERT INTO t_convert VALUES('record2')"); + mystmt(hstmt,rc); + + rc = SQLTransact(NULL,hdbc,SQL_COMMIT); + mycon(hdbc,rc); + + rc = SQLFreeStmt(hstmt,SQL_CLOSE); + mystmt(hstmt,rc); + + rc = tmysql_exec(hstmt,"SELECT CONCAT(testing, '-must be string') FROM t_convert ORDER BY RAND()"); + mystmt(hstmt,rc); + + rc = SQLBindCol(hstmt,1,SQL_C_CHAR, &data, 100, &data_len); + mystmt(hstmt,rc); + + rc = SQLFetch(hstmt); + mystmt(hstmt,rc); + myassert(strcmp(data,"record1-must be string") == 0 || + strcmp(data,"record2-must be string") == 0); + + rc = SQLFetch(hstmt); + mystmt(hstmt,rc); + myassert(strcmp(data,"record1-must be string") == 0 || + strcmp(data,"record2-must be string") == 0); + + rc = SQLFetch(hstmt); + myassert( rc == SQL_NO_DATA); + + rc = SQLFreeStmt(hstmt,SQL_UNBIND); + mystmt(hstmt,rc); + + rc = SQLFreeStmt(hstmt,SQL_CLOSE); + mystmt(hstmt,rc); + + return OK; +} + + +DECLARE_TEST(t_max_rows) +{ + SQLRETURN rc; + SQLUINTEGER i; + + tmysql_exec(hstmt,"drop table t_max_rows"); + + rc = SQLTransact(NULL,hdbc,SQL_COMMIT); + mycon(hdbc,rc); + + rc = tmysql_exec(hstmt,"create table t_max_rows(id int)"); + mystmt(hstmt,rc); + + rc = SQLTransact(NULL,hdbc,SQL_COMMIT); + mycon(hdbc,rc); + + rc = SQLPrepare(hstmt,"insert into t_max_rows values(?)",SQL_NTS); + mystmt(hstmt,rc); + + rc = SQLBindParameter(hstmt,1,SQL_PARAM_INPUT,SQL_C_ULONG,SQL_INTEGER,0,0,&i,0,NULL); + mystmt(hstmt,rc); + + for(i=0; i < 10; i++) + { + rc = SQLExecute(hstmt); + mystmt(hstmt,rc); + } + + SQLFreeStmt(hstmt,SQL_RESET_PARAMS); + SQLFreeStmt(hstmt,SQL_CLOSE); + + rc = SQLTransact(NULL,hdbc,SQL_COMMIT); + mycon(hdbc,rc); + + rc = SQLSetStmtAttr(hstmt,SQL_ATTR_MAX_ROWS,(SQLPOINTER)0,0); + mystmt(hstmt,rc); + + rc = tmysql_exec(hstmt,"select count(*) from t_max_rows"); + mystmt(hstmt,rc); + myassert( 1 == myresult(hstmt) ); + SQLFreeStmt(hstmt,SQL_CLOSE); + + rc = tmysql_exec(hstmt,"select * from t_max_rows"); + mystmt(hstmt,rc); + myassert( 10 == myresult(hstmt) ); + SQLFreeStmt(hstmt,SQL_CLOSE); + + /* MAX rows through connection attribute */ + rc = SQLSetStmtAttr(hstmt,SQL_ATTR_MAX_ROWS,(SQLPOINTER)5,0); + mystmt(hstmt,rc); + + /* + This query includes leading spaces to act as a regression test + for Bug #6609: SQL_ATTR_MAX_ROWS and leading spaces in query result in + truncating end of query. + */ + rc = tmysql_exec(hstmt," select * from t_max_rows"); + mystmt(hstmt,rc); + myassert( 5 == myrowcount(hstmt)); + + SQLFreeStmt(hstmt,SQL_CLOSE); + + rc = SQLSetStmtAttr(hstmt,SQL_ATTR_MAX_ROWS,(SQLPOINTER)15,0); + mystmt(hstmt,rc); + + rc = tmysql_exec(hstmt,"select * from t_max_rows"); + mystmt(hstmt,rc); + myassert( 10 == myrowcount(hstmt)); + + SQLFreeStmt(hstmt,SQL_CLOSE); + + rc = SQLSetStmtAttr(hstmt,SQL_ATTR_MAX_ROWS,(SQLPOINTER)0,0); + mystmt(hstmt,rc); + + rc = tmysql_exec(hstmt,"select * from t_max_rows"); + mystmt(hstmt,rc); + myassert( 10 == myrowcount(hstmt)); + + SQLFreeStmt(hstmt,SQL_CLOSE); + + SQLFreeStmt(hstmt,SQL_CLOSE); + + rc = SQLFreeStmt(hstmt,SQL_CLOSE); + mystmt(hstmt,rc); + + return OK; +} + + +DECLARE_TEST(t_multistep) +{ + SQLRETURN rc; + SQLCHAR szData[150]; + SQLLEN pcbValue; + SQLINTEGER id; + + tmysql_exec(hstmt,"drop table t_multistep"); + rc = tmysql_exec(hstmt,"create table t_multistep(col1 int,col2 varchar(200))"); + mystmt(hstmt,rc); + + rc = tmysql_exec(hstmt,"insert into t_multistep values(10,'MySQL - Open Source Database')"); + mystmt(hstmt,rc); + + rc = SQLTransact(NULL,hdbc,SQL_COMMIT); + mycon(hdbc,rc); + + rc = SQLFreeStmt(hstmt,SQL_CLOSE); + mystmt(hstmt,rc); + + SQLSetStmtAttr(hstmt, SQL_ATTR_CONCURRENCY, (SQLPOINTER) SQL_CONCUR_ROWVER, 0); + SQLSetStmtAttr(hstmt, SQL_ATTR_CURSOR_TYPE, (SQLPOINTER) SQL_CURSOR_KEYSET_DRIVEN, 0); + + rc = SQLBindCol(hstmt,1,SQL_C_LONG,&id,0,NULL); + mystmt(hstmt,rc); + + rc = tmysql_exec(hstmt,"select * from t_multistep"); + mystmt(hstmt,rc); + + rc = SQLFetch(hstmt); + mystmt(hstmt,rc); + fprintf(stdout,"id: %ld\n",id); + myassert(id == 10); + + rc = SQLGetData(hstmt,2,SQL_C_CHAR,szData,0,&pcbValue); + myassert(rc == SQL_SUCCESS_WITH_INFO); + fprintf(stdout,"length: %ld\n", pcbValue); + myassert(pcbValue == 28); + + rc = SQLGetData(hstmt,2,SQL_C_CHAR,szData,0,&pcbValue); + myassert(rc == SQL_SUCCESS_WITH_INFO); + fprintf(stdout,"length: %ld\n", pcbValue); + myassert(pcbValue == 28); + + rc = SQLGetData(hstmt,2,SQL_C_BINARY,szData,0,&pcbValue); + myassert(rc == SQL_SUCCESS_WITH_INFO); + fprintf(stdout,"length: %ld\n", pcbValue); + myassert(pcbValue == 28); + + rc = SQLGetData(hstmt,2,SQL_C_BINARY,szData,0,&pcbValue); + myassert(rc == SQL_SUCCESS_WITH_INFO); + fprintf(stdout,"length: %ld\n", pcbValue); + myassert(pcbValue == 28); + + rc = SQLGetData(hstmt,2,SQL_C_CHAR,szData,0,&pcbValue); + myassert(rc == SQL_SUCCESS_WITH_INFO); + fprintf(stdout,"length: %ld\n", pcbValue); + myassert(pcbValue == 28); + + rc = SQLGetData(hstmt,2,SQL_C_CHAR,szData,10,&pcbValue); + myassert(rc == SQL_SUCCESS_WITH_INFO); + fprintf(stdout,"data : %s (%ld)\n",szData,pcbValue); + myassert(pcbValue == 28); + myassert(strcmp(szData,"MySQL - O") == 0); + + pcbValue= 0; + rc = SQLGetData(hstmt,2,SQL_C_CHAR,szData,5,&pcbValue); + myassert(rc == SQL_SUCCESS_WITH_INFO); + fprintf(stdout,"data : %s (%ld)\n",szData,pcbValue); + myassert(pcbValue == 19); + myassert(strcmp(szData,"pen ") == 0); + + pcbValue= 0; + szData[0]='A'; + rc = SQLGetData(hstmt,2,SQL_C_CHAR,szData,0,&pcbValue); + myassert(rc == SQL_SUCCESS_WITH_INFO); + fprintf(stdout,"data : %s (%ld)\n",szData,pcbValue); + myassert(pcbValue == 15); + myassert(szData[0] == 'A'); + + rc = SQLGetData(hstmt,2,SQL_C_CHAR,szData,pcbValue+1,&pcbValue); + mystmt(hstmt,rc); + fprintf(stdout,"data : %s (%ld)\n",szData,pcbValue); + myassert(pcbValue == 15); + myassert(strcmp(szData,"Source Database") == 0); + + pcbValue= 99; + szData[0]='A'; + rc = SQLGetData(hstmt,2,SQL_C_CHAR,szData,0,&pcbValue); + myassert(rc == SQL_SUCCESS_WITH_INFO); + fprintf(stdout,"data : %s (%ld)\n",szData,pcbValue); + myassert(pcbValue == 0); + myassert(szData[0] == 'A'); + + + rc = SQLFetch(hstmt); + myassert(rc == SQL_NO_DATA_FOUND); + + SQLFreeStmt(hstmt,SQL_UNBIND); + SQLFreeStmt(hstmt,SQL_CLOSE); +} + + +DECLARE_TEST(t_zerolength) +{ + SQLRETURN rc; + SQLCHAR szData[100], bData[100], bData1[100]; + SQLLEN pcbValue,pcbValue1,pcbValue2; + + tmysql_exec(hstmt,"drop table t_zerolength"); + rc = tmysql_exec(hstmt,"create table t_zerolength(str varchar(20), bin varbinary(20), blb blob)"); + mystmt(hstmt,rc); + + rc = tmysql_exec(hstmt,"insert into t_zerolength values('','','')"); + mystmt(hstmt,rc); + + rc = tmysql_exec(hstmt,"insert into t_zerolength values('venu','mysql','monty')"); + mystmt(hstmt,rc); + + rc = SQLTransact(NULL,hdbc,SQL_COMMIT); + mycon(hdbc,rc); + + rc = SQLFreeStmt(hstmt,SQL_CLOSE); + mystmt(hstmt,rc); + + SQLSetStmtAttr(hstmt, SQL_ATTR_CONCURRENCY, (SQLPOINTER) SQL_CONCUR_ROWVER, 0); + SQLSetStmtAttr(hstmt, SQL_ATTR_CURSOR_TYPE, (SQLPOINTER) SQL_CURSOR_KEYSET_DRIVEN, 0); + + rc = tmysql_exec(hstmt,"select * from t_zerolength"); + mystmt(hstmt,rc); + + rc = SQLFetch(hstmt); + mystmt(hstmt,rc); + + pcbValue= pcbValue1= 99; + rc = SQLGetData(hstmt,1,SQL_C_CHAR,szData,0,&pcbValue); + mystmt_err(hstmt,rc == SQL_SUCCESS_WITH_INFO,rc); + fprintf(stdout,"length: %d\n", pcbValue); + myassert(pcbValue == 0); + + bData[0]=bData[1]='z'; + rc = SQLGetData(hstmt,2,SQL_C_BINARY,bData,0,&pcbValue1); + mystmt_err(hstmt,rc == SQL_SUCCESS_WITH_INFO,rc); + fprintf(stdout,"length: %d\n", pcbValue1); + myassert(pcbValue1 == 0); + myassert(bData[0] == 'z'); + myassert(bData[1] == 'z'); + + bData1[0]=bData1[1]='z'; + rc = SQLGetData(hstmt,3,SQL_C_BINARY,bData1,0,&pcbValue2); + mystmt_err(hstmt,rc == SQL_SUCCESS_WITH_INFO,rc); + fprintf(stdout,"length: %d\n", pcbValue2); + myassert(pcbValue2 == 0); + myassert(bData1[0] == 'z'); + myassert(bData1[1] == 'z'); + + pcbValue= pcbValue1= 99; + rc = SQLGetData(hstmt,1,SQL_C_CHAR,szData,1,&pcbValue); + mystmt(hstmt,rc); + fprintf(stdout,"data: %s, length: %d\n", szData, pcbValue); + myassert(pcbValue == 0); + myassert(szData[0] == '\0'); + + bData[0]=bData[1]='z'; + rc = SQLGetData(hstmt,2,SQL_C_BINARY,bData,1,&pcbValue1); + mystmt(hstmt,rc); + fprintf(stdout,"data: %s, length: %d\n", bData, pcbValue1); + myassert(pcbValue1 == 0); + myassert(bData[0]== '\0'); + + bData1[0]=bData1[1]='z'; + rc = SQLGetData(hstmt,3,SQL_C_CHAR,bData1,1,&pcbValue2); + mystmt(hstmt,rc); + fprintf(stdout,"data: %s, length: %d\n", bData1, pcbValue2); + myassert(pcbValue2 == 0); + myassert(bData1[0] == '\0'); + myassert(bData1[1] == 'z'); + + rc = SQLFetch(hstmt); + mystmt(hstmt,rc); + + pcbValue= pcbValue1= 99; + szData[0]= bData[0]= 'z'; + rc = SQLGetData(hstmt,1,SQL_C_CHAR,szData,0,&pcbValue); + mystmt_err(hstmt,rc == SQL_SUCCESS_WITH_INFO,rc); + fprintf(stdout,"length: %d\n", pcbValue); + myassert(pcbValue == 4); + myassert(szData[0] == 'z'); + + rc = SQLGetData(hstmt,2,SQL_C_BINARY,bData,0,&pcbValue1); + mystmt_err(hstmt,rc == SQL_SUCCESS_WITH_INFO,rc); + fprintf(stdout,"length: %d\n", pcbValue1); + myassert(pcbValue1 == 5); + myassert(bData[0] == 'z'); + + bData[0]=bData1[1]='z'; + rc = SQLGetData(hstmt,3,SQL_C_BINARY,bData1,0,&pcbValue2); + mystmt_err(hstmt,rc == SQL_SUCCESS_WITH_INFO,rc); + fprintf(stdout,"length: %d\n", pcbValue2); + myassert(pcbValue2 == 5); + + pcbValue= pcbValue1= 99; + szData[0]= szData[1]= bData[0]= bData[1]= 'z'; + rc = SQLGetData(hstmt,1,SQL_C_CHAR,szData,1,&pcbValue); + mystmt_err(hstmt,rc == SQL_SUCCESS_WITH_INFO,rc); + fprintf(stdout,"data: %s, length: %d\n", szData,pcbValue); + myassert(pcbValue == 4); + myassert(szData[0] == '\0'); + + rc = SQLGetData(hstmt,2,SQL_C_BINARY,bData,1,&pcbValue1); + mystmt_err(hstmt,rc == SQL_SUCCESS_WITH_INFO,rc); + fprintf(stdout,"data; %s, length: %d\n", bData, pcbValue1); + myassert(pcbValue1 == 5); + myassert(bData[0] == 'm'); + + bData[0]=bData1[1]='z'; + rc = SQLGetData(hstmt,3,SQL_C_BINARY,bData1,1,&pcbValue2); + mystmt_err(hstmt,rc == SQL_SUCCESS_WITH_INFO,rc); + fprintf(stdout,"length: %d\n", pcbValue2); + myassert(pcbValue2 == 5); + myassert(bData1[0] == 'm'); + myassert(bData1[1] == 'z'); + + pcbValue= pcbValue1= 99; + rc = SQLGetData(hstmt,1,SQL_C_CHAR,szData,4,&pcbValue); + mystmt_err(hstmt,rc == SQL_SUCCESS_WITH_INFO,rc); + fprintf(stdout,"data: %s, length: %d\n", szData, pcbValue); + myassert(pcbValue == 4); + myassert(strcmp(szData,"ven")==0); + + rc = SQLGetData(hstmt,2,SQL_C_BINARY,bData,4,&pcbValue1); + mystmt_err(hstmt,rc == SQL_SUCCESS_WITH_INFO,rc); + fprintf(stdout,"data: %s, length: %d\n", bData, pcbValue1); + myassert(pcbValue1 == 5); + myassert(strncmp(bData,"mysq",4)==0); + + pcbValue= pcbValue1= 99; + rc = SQLGetData(hstmt,1,SQL_C_CHAR,szData,5,&pcbValue); + mystmt(hstmt,rc); + fprintf(stdout,"data: %s, length: %d\n", szData, pcbValue); + myassert(pcbValue == 4); + myassert(strcmp(szData,"venu")==0); + + rc = SQLGetData(hstmt,2,SQL_C_BINARY,bData,5,&pcbValue1); + mystmt(hstmt,rc); + fprintf(stdout,"data: %s, length: %d\n", bData, pcbValue1); + myassert(pcbValue1 == 5); + myassert(strncmp(bData,"mysql",5)==0); + + szData[0]= 'z'; + rc = SQLGetData(hstmt,3,SQL_C_CHAR,szData,0,&pcbValue); + mystmt_err(hstmt,rc == SQL_SUCCESS_WITH_INFO,rc); + fprintf(stdout,"data: %s, length: %d\n", szData, pcbValue); + myassert(pcbValue == 5 || pcbValue == 10); + myassert(szData[0] == 'z'); + +#if TO_BE_FIXED_IN_DRIVER + szData[0]=szData[1]='z'; + rc = SQLGetData(hstmt,3,SQL_C_CHAR,szData,1,&pcbValue); + mystmt_err(hstmt,rc == SQL_SUCCESS_WITH_INFO,rc); + fprintf(stdout,"data: %s, length: %d\n", szData, pcbValue); + myassert(pcbValue == 10); + myassert(szData[0] == 'm'); + myassert(szData[1] == 'z'); + + rc = SQLGetData(hstmt,3,SQL_C_CHAR,szData,4,&pcbValue); + mystmt_err(hstmt,rc == SQL_SUCCESS_WITH_INFO,rc); + fprintf(stdout,"data: %s, length: %d\n", szData, pcbValue); + myassert(pcbValue == 10); + myassert(strncmp(szData,"mont",4) == 0); + + rc = SQLGetData(hstmt,3,SQL_C_CHAR,szData,5,&pcbValue); + mystmt(hstmt,rc); + fprintf(stdout,"data: %s, length: %d\n", szData, pcbValue); + myassert(pcbValue == 10); + myassert(strncmp(szData,"monty",5) == 0); +#endif + + rc = SQLFetch(hstmt); + myassert(rc == SQL_NO_DATA_FOUND); + + SQLFreeStmt(hstmt,SQL_UNBIND); + SQLFreeStmt(hstmt,SQL_CLOSE); + + return OK; +} + + +/* Test the bug when two stmts are used with the don't cache results */ +DECLARE_TEST(t_cache_bug) +{ + SQLRETURN rc; + SQLHENV henv1; + SQLHDBC hdbc1; + SQLHSTMT hstmt11, hstmt12; + SQLCHAR conn[MAX_NAME_LEN]; + + sprintf(conn,"DSN=%s;USER=%s;PASSWORD=%s;OPTION=1048579", + mydsn,myuid,mypwd); + if (mysock != NULL) + { + strcat(conn, ";SOCKET="); + strcat(conn, mysock); + } + mydrvconnect(&henv1,&hdbc1,&hstmt11,conn); + + tmysql_exec(hstmt11,"drop table t_cache"); + rc = tmysql_exec(hstmt11,"create table t_cache(id int)"); + mystmt(hstmt11,rc); + + rc = tmysql_exec(hstmt11,"insert into t_cache values(1)"); + mystmt(hstmt11,rc); + + rc = tmysql_exec(hstmt11,"insert into t_cache values(2)"); + mystmt(hstmt11,rc); + + rc = tmysql_exec(hstmt11,"insert into t_cache values(3)"); + mystmt(hstmt11,rc); + + rc = tmysql_exec(hstmt11,"insert into t_cache values(4)"); + mystmt(hstmt11,rc); + + rc = tmysql_exec(hstmt11,"insert into t_cache values(5)"); + mystmt(hstmt11,rc); + + rc = SQLExecDirect(hstmt11,"select * from t_cache",SQL_NTS); + mystmt(hstmt11,rc); + + rc = SQLFetch(hstmt11); + mystmt(hstmt11,rc); + + rc = SQLFetch(hstmt11); + mystmt(hstmt11,rc); + + rc = SQLAllocHandle(SQL_HANDLE_STMT,hdbc1,&hstmt12); + mycon(hdbc1,rc); + + rc = SQLColumns(hstmt12,test_db,SQL_NTS, + NULL,0,"t_cache",SQL_NTS, + NULL,0); + mystmt(hstmt12,rc); + + rc = SQLFetch(hstmt12); + mystmt(hstmt12,rc); + + rc = SQLFetch(hstmt11); + mystmt(hstmt11,rc); + + rc = SQLFetch(hstmt12); + myassert(rc == SQL_NO_DATA); + + rc = SQLFetch(hstmt11); + mystmt(hstmt12,rc); + + rc = SQLFreeHandle(SQL_HANDLE_STMT,hstmt12); + mystmt(hstmt12,rc); + + rc = SQLFetch(hstmt11); + mystmt(hstmt12,rc); + + rc = SQLFetch(hstmt11); + myassert(rc == SQL_NO_DATA); + + rc = SQLFreeStmt(hstmt11, SQL_DROP); + mystmt(hstmt11,rc); + + rc = SQLDisconnect(hdbc1); + mycon(hdbc1,rc); + + rc = SQLFreeConnect(hdbc1); + mycon(hdbc1,rc); + + rc = SQLFreeEnv(henv1); + myenv(henv1,rc); + + return OK; +} + + +/* Test the bug when two stmts are used with the don't cache results */ +DECLARE_TEST(t_non_cache_bug) +{ + SQLRETURN rc; + SQLHENV henv1; + SQLHDBC hdbc1; + SQLHSTMT hstmt11, hstmt12; + SQLCHAR conn[MAX_NAME_LEN]; + + sprintf(conn,"DSN=%s;USER=%s;PASSWORD=%s;OPTION=3", + mydsn,myuid,mypwd); + if (mysock != NULL) + { + strcat(conn, ";SOCKET="); + strcat(conn, mysock); + } + mydrvconnect(&henv1,&hdbc1,&hstmt11,conn); + + tmysql_exec(hstmt11,"drop table t_cache"); + rc = tmysql_exec(hstmt11,"create table t_cache(id int)"); + mystmt(hstmt11,rc); + + rc = tmysql_exec(hstmt11,"insert into t_cache values(1)"); + mystmt(hstmt11,rc); + + rc = tmysql_exec(hstmt11,"insert into t_cache values(2)"); + mystmt(hstmt11,rc); + + rc = tmysql_exec(hstmt11,"insert into t_cache values(3)"); + mystmt(hstmt11,rc); + + rc = tmysql_exec(hstmt11,"insert into t_cache values(4)"); + mystmt(hstmt11,rc); + + rc = tmysql_exec(hstmt11,"insert into t_cache values(5)"); + mystmt(hstmt11,rc); + + rc = SQLExecDirect(hstmt11,"select * from t_cache",SQL_NTS); + mystmt(hstmt11,rc); + + rc = SQLFetch(hstmt11); + mystmt(hstmt11,rc); + + rc = SQLFetch(hstmt11); + mystmt(hstmt11,rc); + + rc = SQLAllocHandle(SQL_HANDLE_STMT,hdbc1,&hstmt12); + mycon(hdbc1,rc); + + rc = SQLColumns(hstmt12,test_db,SQL_NTS, + NULL,0,"t_cache",SQL_NTS, + NULL,0); + mystmt(hstmt12,rc); + + rc = SQLFetch(hstmt12); + mystmt(hstmt12,rc); + + rc = SQLFetch(hstmt11); + mystmt(hstmt11,rc); + + rc = SQLFetch(hstmt12); + myassert(rc == SQL_NO_DATA); + + rc = SQLFetch(hstmt11); + mystmt(hstmt12,rc); + + rc = SQLFreeHandle(SQL_HANDLE_STMT,hstmt12); + mystmt(hstmt12,rc); + + rc = SQLFetch(hstmt11); + mystmt(hstmt12,rc); + + rc = SQLFetch(hstmt11); + myassert(rc == SQL_NO_DATA); + + rc = SQLFreeStmt(hstmt11, SQL_DROP); + mystmt(hstmt11,rc); + + rc = SQLDisconnect(hdbc1); + mycon(hdbc1,rc); + + rc = SQLFreeConnect(hdbc1); + mycon(hdbc1,rc); + + rc = SQLFreeEnv(henv1); + myenv(henv1,rc); + + return OK; +} + + +DECLARE_TEST(t_empty_str_bug) +{ + SQLRETURN rc; + SQLINTEGER id; + SQLLEN name_len, desc_len; + SQLCHAR name[20], desc[20]; + + tmysql_exec(hstmt,"drop table t_empty_str_bug"); + + rc = SQLTransact(NULL,hdbc,SQL_COMMIT); + mycon(hdbc,rc); + + rc = tmysql_exec(hstmt,"CREATE TABLE t_empty_str_bug(Id int NOT NULL,\ + Name varchar(10) default NULL, \ + Description varchar(10) default NULL, \ + PRIMARY KEY (Id))"); + mystmt(hstmt,rc); + + rc = SQLTransact(NULL,hdbc,SQL_COMMIT); + mycon(hdbc,rc); + + rc = SQLFreeStmt(hstmt,SQL_CLOSE); + mystmt(hstmt,rc); + + rc = SQLSetCursorName(hstmt,"venu",SQL_NTS); + mystmt(hstmt,rc); + + rc = tmysql_exec(hstmt,"select * from t_empty_str_bug"); + mystmt(hstmt,rc); + + rc = SQLBindCol(hstmt,1,SQL_C_LONG,&id,0,NULL); + mystmt(hstmt,rc); + + rc = SQLBindCol(hstmt,2,SQL_C_CHAR,&name,100,&name_len); + mystmt(hstmt,rc); + + rc = SQLBindCol(hstmt,3,SQL_C_CHAR,&desc,100,&desc_len); + mystmt(hstmt,rc); + + rc = SQLExtendedFetch(hstmt,SQL_FETCH_NEXT,1,NULL,NULL); + myassert(rc == SQL_NO_DATA_FOUND); + + id= 10; + strcpy(name,"MySQL AB");name_len= SQL_NTS; + strcpy(desc,"");desc_len= SQL_COLUMN_IGNORE; + + rc = SQLSetPos(hstmt,1,SQL_ADD,SQL_LOCK_NO_CHANGE); + mystmt(hstmt,rc); + + rc = SQLRowCount(hstmt,&name_len); + mystmt(hstmt,rc); + + fprintf(stdout," rows affected:%d\n",name_len); + myassert(name_len == 1); + + rc = SQLFreeStmt(hstmt,SQL_UNBIND); + mystmt(hstmt,rc); + + rc = SQLFreeStmt(hstmt,SQL_CLOSE); + mystmt(hstmt,rc); + + rc = tmysql_exec(hstmt,"select * from t_empty_str_bug"); + mystmt(hstmt,rc); + + my_assert( 1 == myresult(hstmt)); + + rc = SQLFreeStmt(hstmt,SQL_CLOSE); + mystmt(hstmt,rc); + + rc = tmysql_exec(hstmt,"select * from t_empty_str_bug"); + mystmt(hstmt,rc); + + rc = SQLExtendedFetch(hstmt,SQL_FETCH_ABSOLUTE,1,NULL,NULL); + mystmt(hstmt,rc); + + name[0]='\0'; + my_assert(10 == my_fetch_int(hstmt,1)); + my_assert(!strcmp((const char *)"MySQL AB",my_fetch_str(hstmt,name,2))); + my_assert(!strcmp((const char *)"MySQL AB",my_fetch_str(hstmt,name,3))); /* NULL */ + + rc = SQLFreeStmt(hstmt,SQL_CLOSE); + mystmt(hstmt,rc); + + return OK; +} + + BEGIN_TESTS ADD_TEST(my_resultset) + ADD_TEST(t_convert_type) + ADD_TEST(t_desc_col) + ADD_TEST(t_convert) + ADD_TEST(t_max_rows) + ADD_TEST(t_multistep) + ADD_TEST(t_zerolength) + ADD_TEST(t_cache_bug) + ADD_TEST(t_non_cache_bug) + ADD_TEST(t_empty_str_bug) END_TESTS Added: trunk/test/my_types.c =================================================================== --- trunk/test/my_types.c 2007-04-06 17:01:21 UTC (rev 297) +++ trunk/test/my_types.c 2007-04-06 18:21:39 UTC (rev 298) @@ -0,0 +1,243 @@ +/* + Copyright (C) 1995-2007 MySQL AB + + This program is free software; you can redistribute it and/or modify + it under the terms of version 2 of the GNU General Public License as + published by the Free Software Foundation. + + There are special exceptions to the terms and conditions of the GPL + as it is applied to this software. View the full text of the exception + in file LICENSE.exceptions in the top-level directory of this software + distribution. + + This program is distributed in the hope that it will be useful, + but WITHOUT ANY WARRANTY; without even the implied warranty of + MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + GNU General Public License for more details. + + You should have received a copy of the GNU General Public License + along with this program; if not, write to the Free Software + Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA +*/ + +#include "odbctap.h" + + +DECLARE_TEST(t_longlong1) +{ + SQLRETURN rc; + SQLINTEGER session_id, ctn; + + tmysql_exec(hstmt,"drop table t_longlong"); + rc = tmysql_exec(hstmt,"create table t_longlong (\ + session_id bigint not null,\ + ctn bigint not null)"); + mystmt(hstmt,rc); + + rc = SQLTransact(NULL,hdbc,SQL_COMMIT); + mycon(hdbc,rc); + + SQLSetStmtAttr(hstmt, SQL_ATTR_CONCURRENCY, (SQLPOINTER) SQL_CONCUR_ROWVER, 0); + SQLSetStmtAttr(hstmt, SQL_ATTR_CURSOR_TYPE, (SQLPOINTER) SQL_CURSOR_STATIC, 0); + + rc = SQLPrepare(hstmt,"insert into t_longlong values (?,?)",SQL_NTS); + mystmt(hstmt,rc); + + rc = SQLBindParameter( hstmt, 1, SQL_PARAM_INPUT, SQL_C_UBIGINT, + SQL_BIGINT, 20, 0, &session_id, 20, NULL ); + + rc = SQLBindParameter( hstmt, 2, SQL_PARAM_INPUT, SQL_C_UBIGINT, + SQL_BIGINT, 20, 0, &ctn, 20, NULL ); + + for (session_id=50; session_id < 100; session_id++) + { + ctn += session_id; + rc = SQLExecute(hstmt); + mystmt(hstmt,rc); + } + + rc = SQLFreeStmt(hstmt,SQL_RESET_PARAMS); + mystmt(hstmt,rc); + + rc = SQLFreeStmt(hstmt,SQL_CLOSE); + mystmt(hstmt,rc); + + rc = SQLTransact(NULL,hdbc,SQL_COMMIT); + mycon(hdbc,rc); + + rc = tmysql_exec(hstmt,"select * from t_longlong"); + mystmt(hstmt,rc); + + my_assert( 50 == myresult(hstmt)); + + rc = SQLFreeStmt(hstmt,SQL_UNBIND); + mystmt(hstmt,rc); + + rc = SQLFreeStmt(hstmt,SQL_CLOSE); + mystmt(hstmt,rc); + + return OK; +} + + +DECLARE_TEST(t_numeric) +{ + SQLRETURN rc; + SQL_NUMERIC_STRUCT num; + + tmysql_exec(hstmt,"drop table t_decimal"); + rc = tmysql_exec(hstmt,"create table t_decimal(d1 decimal(10,6))"); + mystmt(hstmt,rc); + rc = tmysql_exec(hstmt,"insert into t_decimal values(10.2)"); + mystmt(hstmt,rc); + + rc = SQLTransact(NULL,hdbc,SQL_COMMIT); + mycon(hdbc,rc); + + rc = SQLPrepare(hstmt,"insert into t_decimal values (?)",SQL_NTS); + mystmt(hstmt,rc); + + rc = SQLBindParameter( hstmt, 1, SQL_PARAM_INPUT, SQL_C_NUMERIC, + SQL_DECIMAL, 10, 4, &num, 0, NULL ); + mystmt_r(hstmt,rc); + + SQLFreeStmt(hstmt, SQL_CLOSE); + + rc = SQLPrepare(hstmt,"insert into t_decimal values (?),(?)",SQL_NTS); + mystmt(hstmt,rc); + + rc = SQLBindParameter( hstmt, 1, SQL_PARAM_INPUT, SQL_C_LONG, + SQL_DECIMAL, 10, 4, &rc, 0, NULL ); + mystmt(hstmt,rc); + + rc = SQLBindParameter( hstmt, 2, SQL_PARAM_INPUT, SQL_C_NUMERIC, + SQL_DECIMAL, 10, 4, &num, 0, NULL ); + mystmt_r(hstmt,rc); + + SQLFreeStmt(hstmt, SQL_CLOSE); + SQLFreeStmt(hstmt, SQL_RESET_PARAMS); + + rc = SQLBindCol( hstmt, 1, SQL_C_NUMERIC, &num, 0, NULL ); + mystmt_r(hstmt,rc); + + SQLFreeStmt(hstmt, SQL_CLOSE); + SQLFreeStmt(hstmt, SQL_UNBIND); + + rc = SQLExecDirect(hstmt, "select * from t_decimal",SQL_NTS); + mystmt(hstmt,rc); + + rc = SQLFetch(hstmt); + mystmt(hstmt,rc); + + rc = SQLGetData( hstmt, 1, SQL_C_NUMERIC, &num, 0, NULL ); + mystmt_r(hstmt,rc); + + SQLFreeStmt(hstmt, SQL_UNBIND); + SQLFreeStmt(hstmt, SQL_RESET_PARAMS); + SQLFreeStmt(hstmt, SQL_CLOSE); + + return OK; +} + + +DECLARE_TEST(t_decimal) +{ + SQLCHAR str[20],s_data[]="189.4567"; + SQLDOUBLE d_data=189.4567; + SQLINTEGER i_data=189, l_data=-23; + SQLRETURN rc; + + tmysql_exec(hstmt,"drop table t_decimal"); + rc = tmysql_exec(hstmt,"create table t_decimal(d1 decimal(10,6))"); + mystmt(hstmt,rc); + + rc = SQLTransact(NULL,hdbc,SQL_COMMIT); + mycon(hdbc,rc); + + rc = SQLPrepare(hstmt,"insert into t_decimal values (?),(?),(?),(?)",SQL_NTS); + mystmt(hstmt,rc); + + rc = SQLBindParameter( hstmt, 1, SQL_PARAM_INPUT, SQL_C_DOUBLE, + SQL_DECIMAL, 10, 4, &d_data, 0, NULL ); + mystmt(hstmt,rc); + + rc = SQLBindParameter( hstmt, 2, SQL_PARAM_INPUT, SQL_C_LONG, + SQL_DECIMAL, 10, 4, &i_data, 0, NULL ); + mystmt(hstmt,rc); + + rc = SQLBindParameter( hstmt, 3, SQL_PARAM_INPUT, SQL_C_CHAR, + SQL_DECIMAL, 10, 4, &s_data, 9, NULL ); + mystmt(hstmt,rc); + + rc = SQLBindParameter( hstmt, 4, SQL_PARAM_INPUT, SQL_C_LONG, + SQL_DECIMAL, 10, 4, &l_data, 0, NULL ); + mystmt(hstmt,rc); + + rc = SQLExecute(hstmt); + mystmt(hstmt,rc); + + rc = SQLFreeStmt(hstmt,SQL_RESET_PARAMS); + mystmt(hstmt,rc); + + rc = SQLFreeStmt(hstmt,SQL_CLOSE); + mystmt(hstmt,rc); + + rc = SQLTransact(NULL,hdbc,SQL_COMMIT); + mycon(hdbc,rc); + + rc = SQLExecDirect(hstmt,"select d1 from t_decimal",SQL_NTS); + mystmt(hstmt,rc); + + rc = SQLFetch(hstmt); + mystmt(hstmt,rc); + + rc = SQLGetData(hstmt,1,SQL_C_CHAR,&str,19,NULL); + mystmt(hstmt,rc); + fprintf(stdout,"decimal(SQL_C_DOUBLE) : %s\n",str); + my_assert(strncmp(str,"189.4567",8)==0); + + rc = SQLFetch(hstmt); + mystmt(hstmt,rc); + + rc = SQLGetData(hstmt,1,SQL_C_CHAR,&str,19,NULL); + mystmt(hstmt,rc); + fprintf(stdout,"decimal(SQL_C_INTEGER): %s\n",str); + my_assert(strncmp(str,"189.0000",5)==0); + + rc = SQLFetch(hstmt); + mystmt(hstmt,rc); + + rc = SQLGetData(hstmt,1,SQL_C_CHAR,&str,19,NULL); + mystmt(hstmt,rc); + fprintf(stdout,"decimal(SQL_C_CHAR) : %s\n",str); + my_assert(strncmp(str,"189.4567",8)==0); + + rc = SQLFetch(hstmt); + mystmt(hstmt,rc); + + rc = SQLGetData(hstmt,1,SQL_C_CHAR,&str,19,NULL); + mystmt(hstmt,rc); + fprintf(stdout,"decimal(SQL_C_LONG) : %s\n",str); + my_assert(strncmp(str,"-23.00",6)==0); + + rc = SQLFetch(hstmt); + my_assert(rc == SQL_NO_DATA_FOUND); + + rc = SQLFreeStmt(hstmt,SQL_UNBIND); + mystmt(hstmt,rc); + + rc = SQLFreeStmt(hstmt,SQL_CLOSE); + mystmt(hstmt,rc); + + return OK; +} + + +BEGIN_TESTS + ADD_TEST(t_longlong1) + ADD_TEST(t_numeric) + ADD_TEST(t_decimal) +END_TESTS + + +RUN_TESTS Deleted: trunk/test/mytest3.c =================================================================== --- trunk/test/mytest3.c 2007-04-06 17:01:21 UTC (rev 297) +++ trunk/test/mytest3.c 2007-04-06 18:21:39 UTC (rev 298) @@ -1,3844 +0,0 @@ -/* - Copyright (C) 2003-2007 MySQL AB - - This program is free software; you can redistribute it and/or modify - it under the terms of version 2 of the GNU General Public License as - published by the Free Software Foundation. - - There are special exceptions to the terms and conditions of the GPL - as it is applied to this software. View the full text of the exception - in file LICENSE.exceptions in the top-level directory of this software - distribution. - - This program is distributed in the hope that it will be useful, - but WITHOUT ANY WARRANTY; without even the implied warranty of - MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the - GNU General Public License for more details. - - You should have received a copy of the GNU General Public License - along with this program; if not, write to the Free Software - Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA -*/ - -#include "odbctap.h" - -/* Utility function to verify a particular column data */ -static void verify_col_data(SQLHSTMT hstmt, const char *table, - const char *col, const char *exp_data) -{ - SQLCHAR data[255], query[255]; - SQLRETURN rc; - - if (table && col) - { - sprintf(query,"SELECT %s FROM %s",col,table); - fprintf(stdout,"%s\n", query); - - rc = SQLExecDirect(hstmt, query, SQL_NTS); - mystmt(hstmt,rc); - } - - rc = SQLFetch(hstmt); - if (rc == SQL_NO_DATA) - myassert(strcmp(exp_data,"SQL_NO_DATA") ==0 ); - - rc = SQLGetData(hstmt, 1, SQL_C_CHAR, &data, 255, NULL); - if (rc == SQL_ERROR) - { - fprintf(stdout,"*** ERROR: FAILED TO GET THE RESULT ***\n"); - exit(1); - } - fprintf(stdout,"obtained: `%s` (expected: `%s`)\n", data, exp_data); - myassert(strcmp(data,exp_data) == 0); - - SQLFreeStmt(hstmt, SQL_UNBIND); - SQLFreeStmt(hstmt, SQL_CLOSE); -} - - -DECLARE_TEST(t_setpos_del_all) -{ - SQLRETURN rc; - SQLINTEGER nData[4]; - SQLLEN nlen; - SQLCHAR szData[4][10]; - - tmysql_exec(hstmt,"drop table t_sp_del_all"); - rc = tmysql_exec(hstmt,"create table t_sp_del_all(col1 int not null primary key,\ - col2 varchar(20))"); - mystmt(hstmt,rc); - - rc = tmysql_exec(hstmt,"insert into t_sp_del_all values(100,'MySQL1')"); - mystmt(hstmt,rc); - rc = tmysql_exec(hstmt,"insert into t_sp_del_all values(200,'MySQL2')"); - mystmt(hstmt,rc); - rc = tmysql_exec(hstmt,"insert into t_sp_del_all values(300,'MySQL3')"); - mystmt(hstmt,rc); - rc = tmysql_exec(hstmt,"insert into t_sp_del_all values(400,'MySQL4')"); - mystmt(hstmt,rc); - - rc = SQLTransact(NULL,hdbc,SQL_COMMIT); - mycon(hdbc,rc); - - rc = SQLFreeStmt(hstmt,SQL_CLOSE); - mystmt(hstmt,rc); - - rc = SQLSetCursorName(hstmt,"venu",SQL_NTS); - mystmt(hstmt,rc); - - rc = SQLSetStmtOption(hstmt, SQL_ROWSET_SIZE, 4); - mystmt(hstmt,rc); - - rc = tmysql_exec(hstmt,"select * from t_sp_del_all order by col1 asc"); - mystmt(hstmt,rc); - - rc = SQLBindCol(hstmt,1,SQL_C_LONG,&nData,100,NULL); - mystmt(hstmt,rc); - - rc = SQLBindCol(hstmt,2,SQL_C_CHAR,&szData[0],sizeof(szData[0]),NULL); - mystmt(hstmt,rc); - - rc = SQLExtendedFetch(hstmt,SQL_FETCH_FIRST,1,NULL,NULL); - mystmt(hstmt,rc); - - fprintf(stdout," row1 : %d, %s\n",nData[0],szData[0]); - fprintf(stdout," row2 : %d, %s\n",nData[1],szData[1]); - fprintf(stdout," row3 : %d, %s\n",nData[2],szData[2]); - fprintf(stdout," row4 : %d, %s\n",nData[3],szData[3]); - - rc = SQLSetPos(hstmt,1,SQL_POSITION,SQL_LOCK_NO_CHANGE); - mystmt(hstmt,rc); - - rc = SQLSetPos(hstmt,0,SQL_DELETE,SQL_LOCK_NO_CHANGE); - mystmt(hstmt,rc); - - rc = SQLRowCount(hstmt,&nlen); - mystmt(hstmt,rc); - - fprintf(stdout," total rows deleted: %d\n",nlen); - myassert(nlen == 4); - - rc = SQLFreeStmt(hstmt,SQL_UNBIND); - mystmt(hstmt,rc); - - rc = SQLFreeStmt(hstmt,SQL_CLOSE); - mystmt(hstmt,rc); - - rc = tmysql_exec(hstmt,"select * from t_sp_del_all"); - mystmt(hstmt,rc); - - my_assert(0 == myresult(hstmt)); - - rc = SQLFreeStmt(hstmt,SQL_CLOSE); - mystmt(hstmt,rc); - - rc = SQLSetStmtOption(hstmt, SQL_ROWSET_SIZE, 1); - mystmt(hstmt,rc); - - return OK; -} - - -DECLARE_TEST(t_setpos_upd_decimal) -{ - SQLRETURN rc; - SQLINTEGER rec; - - tmysql_exec(hstmt,"drop table t_setpos_upd_decimal"); - rc = tmysql_exec(hstmt,"create table t_setpos_upd_decimal(record decimal(3,0),\ - num1 float, num2 decimal(6,0),num3 decimal(10,3))"); - mystmt(hstmt,rc); - - rc = tmysql_exec(hstmt,"insert into t_setpos_upd_decimal values(001,12.3,134,0.100)"); - mystmt(hstmt,rc); - - rc = SQLTransact(NULL,hdbc,SQL_COMMIT); - mycon(hdbc,rc); - - rc = SQLFreeStmt(hstmt,SQL_CLOSE); - mystmt(hstmt,rc); - - /* MS SQL Server to work...*/ - SQLSetStmtAttr(hstmt, SQL_ATTR_CONCURRENCY, (SQLPOINTER) SQL_CONCUR_ROWVER, 0); - SQLSetStmtAttr(hstmt, SQL_ATTR_CURSOR_TYPE, (SQLPOINTER) SQL_CURSOR_DYNAMIC, 0); - SQLSetStmtOption(hstmt,SQL_SIMULATE_CURSOR,SQL_SC_NON_UNIQUE); - - rc = tmysql_exec(hstmt,"select record from t_setpos_upd_decimal"); - mystmt(hstmt,rc); - - rc = SQLBindCol(hstmt,1,SQL_C_LONG,&rec,100,NULL); - mystmt(hstmt,rc); - - rc = SQLExtendedFetch(hstmt,SQL_FETCH_NEXT,1,NULL,NULL); - mystmt(hstmt,rc); - fprintf(stdout," row1: %d",rec); - - rc = SQLSetPos(hstmt,1,SQL_POSITION,SQL_LOCK_NO_CHANGE); - mystmt(hstmt,rc); - - rec = 100; - - rc = SQLSetPos(hstmt,1,SQL_UPDATE,SQL_LOCK_NO_CHANGE); - mystmt_r(hstmt,rc); - - rc = SQLFreeStmt(hstmt,SQL_UNBIND); - mystmt(hstmt,rc); - - rc = SQLFreeStmt(hstmt,SQL_CLOSE); - mystmt(hstmt,rc); - - rc = tmysql_exec(hstmt,"select * from t_setpos_upd_decimal"); - mystmt(hstmt,rc); - - myresult(hstmt); - - rc = SQLFreeStmt(hstmt,SQL_CLOSE); - mystmt(hstmt,rc); - - return OK; -} - - -DECLARE_TEST(tmysql_specialcols) -{ - SQLRETURN rc; - - tmysql_exec(hstmt,"drop table tmysql_specialcols"); - rc = tmysql_exec(hstmt,"create table tmysql_specialcols(col1 int primary key, col2 varchar(30), col3 int)"); - mystmt(hstmt,rc); - - rc = tmysql_exec(hstmt,"create index tmysql_ind1 on tmysql_specialcols(col1)"); - mystmt(hstmt,rc); - - rc = tmysql_exec(hstmt,"insert into tmysql_specialcols values(100,'venu',1)"); - mystmt(hstmt,rc); - - rc = tmysql_exec(hstmt,"insert into tmysql_specialcols values(200,'MySQL',2)"); - mystmt(hstmt,rc); - - rc = SQLTransact(NULL,hdbc,SQL_COMMIT); - mycon(hdbc,rc); - - rc = SQLFreeStmt(hstmt,SQL_CLOSE); - mystmt(hstmt,rc); - - rc = tmysql_exec(hstmt,"select * from tmysql_specialcols"); - mystmt(hstmt,rc); - - myresult(hstmt); - - rc = SQLFreeStmt(hstmt,SQL_CLOSE); - mystmt(hstmt,rc); - - rc = SQLSpecialColumns(hstmt, - SQL_BEST_ROWID, - NULL,0, - NULL,0, - "tmysql_specialcols",SQL_NTS, - SQL_SCOPE_SESSION, - SQL_NULLABLE); - mystmt(hstmt,rc); - - myresult(hstmt); - - rc = SQLFreeStmt(hstmt,SQL_CLOSE); - mystmt(hstmt,rc); - - rc = tmysql_exec(hstmt,"drop table tmysql_specialcols"); - mystmt(hstmt,rc); - - rc = SQLTransact(NULL,hdbc,SQL_COMMIT); - mycon(hdbc,rc); - - return OK; -} - - -DECLARE_TEST(t_max_select) -{ - SQLRETURN rc; - SQLCHAR szData[255]; - SQLINTEGER i; - - tmysql_exec(hstmt,"drop table t_max_select"); - - rc = SQLTransact(NULL,hdbc,SQL_COMMIT); - mycon(hdbc,rc); - - rc = tmysql_exec(hstmt,"create table t_max_select(col1 int ,col2 varchar(30))"); - mystmt(hstmt,rc); - - rc = SQLPrepare(hstmt,"insert into t_max_select values(?,?)",SQL_NTS); - mystmt(hstmt,rc); - - rc = SQLBindParameter(hstmt,1,SQL_PARAM_INPUT,SQL_C_LONG, - SQL_INTEGER,0,0,&i,0,NULL); - mystmt(hstmt,rc); - - rc = SQLBindParameter(hstmt,2,SQL_PARAM_INPUT,SQL_C_CHAR, - SQL_CHAR,0,0,szData,sizeof(szData),NULL); - mystmt(hstmt,rc); - - fprintf(stdout," inserting 1000 rows, it will take some time\n"); - for(i = 1; i <= 1000; i++) - { - fprintf(stdout," \r %d", i); - sprintf((char *)szData,"MySQL%d",i); - rc = SQLExecute(hstmt); - mystmt(hstmt,rc); - } - fprintf(stdout,"\n"); - - rc = SQLFreeStmt(hstmt,SQL_RESET_PARAMS); - mystmt(hstmt,rc); - - rc = SQLFreeStmt(hstmt,SQL_CLOSE); - mystmt(hstmt,rc); - - rc = SQLTransact(NULL,hdbc,SQL_COMMIT); - mycon(hdbc,rc); - - rc = tmysql_exec(hstmt,"select * from t_max_select"); - mystmt(hstmt,rc); - - my_assert( 1000 == myrowcount(hstmt)); - - rc = SQLFreeStmt(hstmt,SQL_UNBIND); - mystmt(hstmt,rc); - - rc = SQLFreeStmt(hstmt,SQL_CLOSE); - mystmt(hstmt,rc); - - return OK; -} - - -DECLARE_TEST(t_getcursor) -{ - SQLRETURN rc; - SQLHSTMT hstmt1,hstmt2,hstmt3; - SQLCHAR curname[50]; - SQLSMALLINT nlen; - - rc = SQLAllocHandle(SQL_HANDLE_STMT,hdbc,&hstmt1); - mycon(hdbc, rc); - rc = SQLAllocHandle(SQL_HANDLE_STMT,hdbc,&hstmt2); - mycon(hdbc, rc); - rc = SQLAllocHandle(SQL_HANDLE_STMT,hdbc,&hstmt3); - mycon(hdbc, rc); - - rc = SQLGetCursorName(hstmt1,curname,50,&nlen); - if (rc == SQL_SUCCESS || rc == SQL_SUCCESS_WITH_INFO) - { - fprintf(stdout,"default cursor name : %s(%d)\n",curname,nlen); - myassert(nlen == 8); - myassert(!strcmp(curname,"SQL_CUR0")); - - rc = SQLGetCursorName(hstmt3,curname,50,&nlen); - mystmt(hstmt1,rc); - fprintf(stdout,"default cursor name : %s(%d)\n",curname,nlen); - - rc = SQLGetCursorName(hstmt1,curname,4,&nlen); - mystmt_err(hstmt1,rc == SQL_SUCCESS_WITH_INFO, rc); - fprintf(stdout,"truncated cursor name: %s(%d)\n",curname,nlen); - myassert(nlen == 8); - myassert(!strcmp(curname,"SQL")); - - rc = SQLGetCursorName(hstmt1,curname,0,&nlen); - mystmt_err(hstmt1,rc == SQL_SUCCESS_WITH_INFO, rc); - fprintf(stdout,"untouched cursor name: %s(%d)\n",curname,nlen); - myassert(nlen == 8); - - rc = SQLGetCursorName(hstmt1,curname,8,&nlen); - mystmt_err(hstmt1,rc == SQL_SUCCESS_WITH_INFO, rc); - fprintf(stdout,"truncated cursor name: %s(%d)\n",curname,nlen); - myassert(nlen == 8); - myassert(!strcmp(curname,"SQL_CUR")); - - rc = SQLGetCursorName(hstmt1,curname,9,&nlen); - mystmt(hstmt1,rc); - fprintf(stdout,"full cursor name : %s(%d)\n",curname,nlen); - myassert(nlen == 8); - myassert(!strcmp(curname,"SQL_CUR0")); - } - - rc = SQLSetCursorName(hstmt1,"venucur123",7); - mystmt(hstmt1,rc); - - rc = SQLGetCursorName(hstmt1,curname,8,&nlen); - mystmt(hstmt1,rc); - fprintf(stdout,"full setcursor name : %s(%d)\n",curname,nlen); - myassert(nlen == 7); - myassert(!strcmp(curname,"venucur")); - - rc = SQLFreeHandle(SQL_HANDLE_STMT,hstmt1); - mystmt(hstmt1,rc); - - return OK; -} - - -DECLARE_TEST(t_getcursor1) -{ - SQLRETURN rc; - SQLHSTMT hstmt1; - SQLCHAR curname[50]; - SQLSMALLINT nlen,index;; - - for(index=0; index < 100; index++) - { - rc = SQLAllocHandle(SQL_HANDLE_STMT,hdbc,&hstmt1); - mycon(hdbc, rc); - - rc = SQLGetCursorName(hstmt1,curname,50,&nlen); - if (rc != SQL_SUCCESS) - break; - fprintf(stdout,"%s(%d) \n",curname,nlen); - - rc = SQLFreeHandle(SQL_HANDLE_STMT,hstmt1); - mystmt(hstmt1,rc); - } - - return OK; -} - - -DECLARE_TEST(t_gettypeinfo) -{ - SQLRETURN rc; - SQLSMALLINT pccol; - - rc = SQLFreeStmt(hstmt,SQL_CLOSE); - mystmt(hstmt,rc); - - rc = SQLGetTypeInfo(hstmt,SQL_ALL_TYPES); - mystmt(hstmt,rc); - - rc = SQLNumResultCols(hstmt,&pccol); - mystmt(hstmt,rc); - fprintf(stdout,"total columns: %d\n",pccol); - myassert(pccol == 19); - myresult(hstmt); - - rc = SQLFreeStmt(hstmt,SQL_RESET_PARAMS); - mystmt(hstmt,rc); - - rc = SQLFreeStmt(hstmt,SQL_CLOSE); - mystmt(hstmt,rc); - - return OK; -} - - -DECLARE_TEST(t_getinfo) -{ - SQLRETURN rc; - SQLCHAR rgbValue[100]; - SQLSMALLINT pcbInfo; - - rc = SQLGetInfo(hdbc,SQL_DRIVER_ODBC_VER,rgbValue,100,&pcbInfo); - mycon(hdbc,rc); - fprintf(stdout,"SQL_DRIVER_ODBC_VER: %s(%d)\n",rgbValue,pcbInfo); - - return OK; -} - - -DECLARE_TEST(t_stmt_attr_status) -{ - SQLRETURN rc; - SQLUSMALLINT rowStatusPtr[3]; - SQLUINTEGER rowsFetchedPtr; - - tmysql_exec(hstmt,"drop table t_stmtstatus"); - - rc = SQLTransact(NULL,hdbc,SQL_COMMIT); - mycon(hdbc,rc); - - rc = tmysql_exec(hstmt,"create table t_stmtstatus(id int, name char(20))"); - mystmt(hstmt,rc); - - rc = SQLTransact(NULL,hdbc,SQL_COMMIT); - mycon(hdbc,rc); - - rc = tmysql_exec(hstmt,"insert into t_stmtstatus values(10,'data1')"); - mystmt(hstmt,rc); - rc = tmysql_exec(hstmt,"insert into t_stmtstatus values(20,'data2')"); - mystmt(hstmt,rc); - - rc = SQLTransact(NULL,hdbc,SQL_COMMIT); - mycon(hdbc,rc); - - rc = SQLFreeStmt(hstmt,SQL_CLOSE); - mystmt(hstmt,rc); - - rc = SQLSetStmtAttr(hstmt,SQL_ATTR_CURSOR_SCROLLABLE,(SQLPOINTER)SQL_NONSCROLLABLE,0); - mystmt(hstmt,rc); - - rc = tmysql_exec(hstmt,"select * from t_stmtstatus"); - mystmt(hstmt,rc); - - rc = SQLSetStmtAttr(hstmt,SQL_ATTR_ROWS_FETCHED_PTR,&rowsFetchedPtr,0); - mystmt(hstmt,rc); - - rc = SQLSetStmtAttr(hstmt,SQL_ATTR_ROW_STATUS_PTR,&rowStatusPtr,0); - mystmt(hstmt,rc); - - rc = SQLFetchScroll(hstmt,SQL_FETCH_ABSOLUTE,2); - mystmt_err(hstmt,rc == SQL_ERROR,rc); - - rc = SQLFreeStmt(hstmt,SQL_CLOSE); - mystmt(hstmt,rc); - - rc = SQLSetStmtAttr(hstmt,SQL_ATTR_CURSOR_SCROLLABLE,(SQLPOINTER)SQL_SCROLLABLE,0); - mystmt(hstmt,rc); - - rc = tmysql_exec(hstmt,"select * from t_stmtstatus"); - mystmt(hstmt,rc); - - rc = SQLFetchScroll(hstmt,SQL_FETCH_ABSOLUTE,2); - mystmt(hstmt,rc); - - printMessage("total rows fetched: %d\n",rowsFetchedPtr); - printMessage("row 0 status : %d\n",rowStatusPtr[0]); - printMessage("row 1 status : %d\n",rowStatusPtr[1]); - printMessage("row 2 status : %d\n",rowStatusPtr[2]); - myassert(rowsFetchedPtr == 1); - myassert(rowStatusPtr[0] == 0); - - rc = SQLFreeStmt(hstmt,SQL_CLOSE); - mystmt(hstmt,rc); - - rc = SQLSetStmtAttr(hstmt,SQL_ATTR_ROWS_FETCHED_PTR,(SQLPOINTER)0,0); - mystmt(hstmt,rc); - - rc = SQLSetStmtAttr(hstmt,SQL_ATTR_ROW_STATUS_PTR,(SQLPOINTER)0,0); - mystmt(hstmt,rc); - - return OK; -} - - -DECLARE_TEST(t_max_rows) -{ - SQLRETURN rc; - SQLUINTEGER i; - - tmysql_exec(hstmt,"drop table t_max_rows"); - - rc = SQLTransact(NULL,hdbc,SQL_COMMIT); - mycon(hdbc,rc); - - rc = tmysql_exec(hstmt,"create table t_max_rows(id int)"); - mystmt(hstmt,rc); - - rc = SQLTransact(NULL,hdbc,SQL_COMMIT); - mycon(hdbc,rc); - - rc = SQLPrepare(hstmt,"insert into t_max_rows values(?)",SQL_NTS); - mystmt(hstmt,rc); - - rc = SQLBindParameter(hstmt,1,SQL_PARAM_INPUT,SQL_C_ULONG,SQL_INTEGER,0,0,&i,0,NULL); - mystmt(hstmt,rc); - - for(i=0; i < 10; i++) - { - rc = SQLExecute(hstmt); - mystmt(hstmt,rc); - } - - SQLFreeStmt(hstmt,SQL_RESET_PARAMS); - SQLFreeStmt(hstmt,SQL_CLOSE); - - rc = SQLTransact(NULL,hdbc,SQL_COMMIT); - mycon(hdbc,rc); - - rc = SQLSetStmtAttr(hstmt,SQL_ATTR_MAX_ROWS,(SQLPOINTER)0,0); - mystmt(hstmt,rc); - - rc = tmysql_exec(hstmt,"select count(*) from t_max_rows"); - mystmt(hstmt,rc); - myassert( 1 == myresult(hstmt) ); - SQLFreeStmt(hstmt,SQL_CLOSE); - - rc = tmysql_exec(hstmt,"select * from t_max_rows"); - mystmt(hstmt,rc); - myassert( 10 == myresult(hstmt) ); - SQLFreeStmt(hstmt,SQL_CLOSE); - - /* MAX rows through connection attribute */ - rc = SQLSetStmtAttr(hstmt,SQL_ATTR_MAX_ROWS,(SQLPOINTER)5,0); - mystmt(hstmt,rc); - - /* - This query includes leading spaces to act as a regression test - for Bug #6609: SQL_ATTR_MAX_ROWS and leading spaces in query result in - truncating end of query. - */ - rc = tmysql_exec(hstmt," select * from t_max_rows"); - mystmt(hstmt,rc); - myassert( 5 == myrowcount(hstmt)); - - SQLFreeStmt(hstmt,SQL_CLOSE); - - rc = SQLSetStmtAttr(hstmt,SQL_ATTR_MAX_ROWS,(SQLPOINTER)15,0); - mystmt(hstmt,rc); - - rc = tmysql_exec(hstmt,"select * from t_max_rows"); - mystmt(hstmt,rc); - myassert( 10 == myrowcount(hstmt)); - - SQLFreeStmt(hstmt,SQL_CLOSE); - - rc = SQLSetStmtAttr(hstmt,SQL_ATTR_MAX_ROWS,(SQLPOINTER)0,0); - mystmt(hstmt,rc); - - rc = tmysql_exec(hstmt,"select * from t_max_rows"); - mystmt(hstmt,rc); - myassert( 10 == myrowcount(hstmt)); - - SQLFreeStmt(hstmt,SQL_CLOSE); - - SQLFreeStmt(hstmt,SQL_CLOSE); - - rc = SQLFreeStmt(hstmt,SQL_CLOSE); - mystmt(hstmt,rc); - - return OK; -} - - -DECLARE_TEST(t_prepare) -{ - SQLRETURN rc; - SQLINTEGER nidata= 200, nodata; - SQLLEN nlen; - char szodata[20],szidata[20]="MySQL"; - short pccol; - - SQLFreeStmt(hstmt,SQL_CLOSE); - - tmysql_exec(hstmt,"drop table t_prepare"); - - rc = tmysql_exec(hstmt,"create table t_prepare(col1 int primary key, col2 varchar(30), col3 set(\"one\", \"two\"))"); - mystmt(hstmt,rc); - - rc = tmysql_exec(hstmt,"insert into t_prepare values(100,'venu','one')"); - mystmt(hstmt,rc); - - rc = tmysql_exec(hstmt,"insert into t_prepare values(200,'MySQL','two')"); - mystmt(hstmt,rc); - - rc = SQLPrepare(hstmt,"select * from t_prepare where col2 = ? AND col1 = ?",SQL_NTS); - mystmt(hstmt,rc); - - rc = SQLNumResultCols(hstmt,&pccol); - mystmt(hstmt,rc); - - rc = SQLBindCol(hstmt,1,SQL_C_LONG,&nodata,0,&nlen); - mystmt(hstmt,rc); - - rc = SQLBindCol(hstmt,2,SQL_C_CHAR,szodata,200,&nlen); - mystmt(hstmt,rc); - - rc = SQLBindParameter(hstmt,1,SQL_PARAM_INPUT, SQL_C_CHAR,SQL_VARCHAR, - 0,0,szidata,20,&nlen); - mystmt(hstmt,rc); - - rc = SQLBindParameter(hstmt,2,SQL_PARAM_INPUT, SQL_C_LONG,SQL_INTEGER, - 0,0,&nidata,20,NULL); - mystmt(hstmt,rc); - - nlen= strlen(szidata); - rc = SQLExecute(hstmt); - mystmt(hstmt,rc); - - rc = SQLFetch(hstmt); - mystmt(hstmt,rc); - - fprintf(stdout," outdata: %d, %s(%d)\n", nodata,szodata,nlen); - my_assert(nodata == 200); - - rc = SQLFetch(hstmt); - my_assert(rc == SQL_NO_DATA_FOUND); - - rc = SQLFreeStmt(hstmt,SQL_CLOSE); - mystmt(hstmt,rc); - - rc = SQLFreeStmt(hstmt,SQL_UNBIND); - mystmt(hstmt,rc); - - rc = SQLFreeStmt(hstmt,SQL_RESET_PARAMS); - mystmt(hstmt,rc); - - return OK; -} - - -DECLARE_TEST(t_prepare1) -{ - SQLRETURN rc; - SQLINTEGER nidata= 1000; - - tmysql_exec(hstmt,"drop table t_prepare1"); - - rc = tmysql_exec(hstmt,"create table t_prepare1(col1 int primary key, col2 varchar(30))"); - mystmt(hstmt,rc); - - rc = tmysql_exec(hstmt,"insert into t_prepare1 values(100,'venu')"); - mystmt(hstmt,rc); - - rc = tmysql_exec(hstmt,"insert into t_prepare1 values(200,'MySQL')"); - mystmt(hstmt,rc); - - rc = SQLTransact(NULL,hdbc,SQL_COMMIT); - mycon(hdbc,rc); - - rc = SQLFreeStmt(hstmt,SQL_CLOSE); - mystmt(hstmt,rc); - - rc = tmysql_prepare(hstmt,"insert into t_prepare1(col1) values(?)"); - mystmt(hstmt,rc); - - rc = SQLBindParameter(hstmt,1,SQL_PARAM_INPUT, SQL_C_LONG,SQL_INTEGER, - 0,0,&nidata,0,NULL); - mystmt(hstmt,rc); - - rc = SQLExecute(hstmt); - mystmt(hstmt,rc); - - rc = SQLTransact(NULL,hdbc,SQL_COMMIT); - mycon(hdbc,rc); - - rc = SQLFreeStmt(hstmt,SQL_CLOSE); - mystmt(hstmt,rc); - - rc = SQLFreeStmt(hstmt,SQL_RESET_PARAMS); - mystmt(hstmt,rc); - - rc = SQLExecDirect(hstmt,"SELECT * FROM t_prepare1",SQL_NTS); - mystmt(hstmt,rc); - - myassert(3 == myresult(hstmt));/* unless prepare is supported..*/ - - rc = SQLFreeStmt(hstmt,SQL_CLOSE); - mystmt(hstmt,rc); - - return OK; -} - - -static void test_diagrec(SQLSMALLINT HandleType,SQLHANDLE Handle, - SQLSMALLINT RecNumber, SQLSMALLINT BufferLength, - SQLRETURN return_value_expected) -{ - SQLRETURN rc; - SQLCHAR sqlstate[6]={0}; - SQLCHAR message[255]={0}; - SQLINTEGER native_err=0; - SQLSMALLINT msglen=0; - - rc = SQLGetDiagRec(HandleType,Handle,RecNumber, - (char *)&sqlstate,&native_err, - (char *)&message,BufferLength,&msglen); - - fprintf(stdout,"%d@%s(%d)\n",rc,message,msglen); - myassert(return_value_expected == rc); -} - - -DECLARE_TEST(t_diagrec) -{ - SQLRETURN rc; - - fprintf(stdout," ** SQL_HANDLE_STMT ** \n"); - - rc = SQLExecDirect(hstmt,"DROP TABLE ODBC3_NON_EXISTANTi_TAB",SQL_NTS); - myassert(rc == SQL_ERROR); - - test_diagrec(SQL_HANDLE_STMT,hstmt,2,0,SQL_NO_DATA_FOUND); - test_diagrec(SQL_HANDLE_STMT,hstmt,1,255,SQL_SUCCESS); - test_diagrec(SQL_HANDLE_STMT,hstmt,1,0,SQL_SUCCESS_WITH_INFO); - test_diagrec(SQL_HANDLE_STMT,hstmt,1,10,SQL_SUCCESS_WITH_INFO); - test_diagrec(SQL_HANDLE_STMT,hstmt,1,-1,SQL_ERROR); - - return OK; -} - - -DECLARE_TEST(t_acc_crash) -{ - SQLRETURN rc; - SQLINTEGER id; - SQLCHAR name[20], data[30]; - SQL_TIMESTAMP_STRUCT ts; - - tmysql_exec(hstmt,"drop table if exists t_acc_crash"); - rc = tmysql_exec(hstmt,"create table t_acc_crash(id int(11) not null auto_increment,\ - name char(20),\ - ts date,\ - primary key(id))"); - mystmt(hstmt,rc); - - rc = tmysql_exec(hstmt,"insert into t_acc_crash(id,name) values(1,'venu')"); - mystmt(hstmt,rc); - - rc = tmysql_exec(hstmt,"insert into t_acc_crash(name) values('monty')"); - mystmt(hstmt,rc); - - rc = tmysql_exec(hstmt,"insert into t_acc_crash(name) values('mysql')"); - mystmt(hstmt,rc); - - rc = SQLTransact(NULL,hdbc,SQL_COMMIT); - mycon(hdbc,rc); - - rc = SQLFreeStmt(hstmt,SQL_CLOSE); - mystmt(hstmt,rc); - - rc = SQLSetStmtOption(hstmt, SQL_ROWSET_SIZE, 1); - mystmt(hstmt,rc); - - rc = tmysql_exec(hstmt,"select * from t_acc_crash order by id asc"); - mystmt(hstmt,rc); - - rc = SQLBindCol(hstmt,1,SQL_C_LONG,&id,0,NULL); - mystmt(hstmt,rc); - - rc = SQLBindCol(hstmt,2,SQL_C_CHAR,(SQLCHAR *)&name,20,NULL); - mystmt(hstmt,rc); - - rc = SQLBindCol(hstmt,3,SQL_C_DATE,&ts,30,NULL); - mystmt(hstmt,rc); - - rc = SQLFetchScroll(hstmt,SQL_FETCH_FIRST,1); - mystmt(hstmt,rc); - - id = 9; - strcpy(name,"updated"); - ts.year=2010;ts.month=9;ts.day=25; - - rc = SQLSetPos(hstmt,1,SQL_POSITION,SQL_LOCK_NO_CHANGE); - mystmt(hstmt,rc); - - rc = SQLSetPos(hstmt,1,SQL_UPDATE,SQL_LOCK_NO_CHANGE); - mystmt(hstmt,rc); - - SQLFreeStmt(hstmt,SQL_UNBIND); - SQLFreeStmt(hstmt,SQL_CLOSE); - - rc = SQLTransact(NULL,hdbc,SQL_COMMIT); - mycon(hdbc,rc); - - rc = tmysql_exec(hstmt,"select * from t_acc_crash order by id desc"); - mystmt(hstmt,rc); - - rc = SQLFetch(hstmt); - mystmt(hstmt,rc); - - my_assert(9 == my_fetch_int(hstmt,1)); - my_assert(!strcmp("updated", my_fetch_str(hstmt,data,2))); - my_assert(!strcmp("2010-09-25", my_fetch_str(hstmt,data,3))); - - rc = SQLFreeStmt(hstmt,SQL_UNBIND); - mystmt(hstmt,rc); - - rc = SQLFreeStmt(hstmt,SQL_CLOSE); - mystmt(hstmt,rc); - - return OK; -} - - -DECLARE_TEST(t_msdev_bug) -{ - SQLRETURN rc; - SQLCHAR catalog[30]; - SQLLEN len; - - rc = SQLGetConnectOption(hdbc,SQL_CURRENT_QUALIFIER,&catalog); - mycon(hdbc,rc); - fprintf(stdout," SQL_CURRENT_QUALIFIER:%s\n",catalog); - - rc = SQLGetConnectAttr(hdbc,SQL_ATTR_CURRENT_CATALOG,&catalog,30,&len); - mycon(hdbc,rc); - fprintf(stdout," SQL_ATTR_CURRENT_CATRALOG:%s(%d)\n",catalog,len); - - return OK; -} - - -DECLARE_TEST(t_setpos_position) -{ - SQLRETURN rc; - SQLINTEGER nData= 500; - SQLLEN nlen; - SQLCHAR szData[255]={0}; - SQLUINTEGER pcrow; - - tmysql_exec(hstmt,"drop table t_setpos_position"); - rc = tmysql_exec(hstmt,"create table t_setpos_position(col1 int, col2 varchar(30))"); - mystmt(hstmt,rc); - - rc = tmysql_exec(hstmt,"insert into t_setpos_position values(100,'MySQL1')"); - mystmt(hstmt,rc); - rc = tmysql_exec(hstmt,"insert into t_setpos_position values(200,'MySQL2')"); - mystmt(hstmt,rc); - rc = tmysql_exec(hstmt,"insert into t_setpos_position values(300,'MySQL3')"); - mystmt(hstmt,rc); - - rc = SQLTransact(NULL,hdbc,SQL_COMMIT); - mycon(hdbc,rc); - - rc = SQLFreeStmt(hstmt,SQL_CLOSE); - mystmt(hstmt,rc); - - rc = SQLSetCursorName(hstmt,"venu",SQL_NTS); - mystmt(hstmt,rc); - - SQLSetStmtAttr(hstmt, SQL_ATTR_CONCURRENCY, (SQLPOINTER) SQL_CONCUR_ROWVER, 0); - SQLSetStmtAttr(hstmt, SQL_ATTR_CURSOR_TYPE, (SQLPOINTER) SQL_CURSOR_DYNAMIC, 0); - SQLSetStmtOption(hstmt,SQL_SIMULATE_CURSOR,SQL_SC_NON_UNIQUE); - - rc = tmysql_exec(hstmt,"select * from t_setpos_position"); - mystmt(hstmt,rc); - - rc = SQLBindCol(hstmt,1,SQL_C_LONG,&nData,100,NULL); - mystmt(hstmt,rc); - - rc = SQLBindCol(hstmt,2,SQL_C_CHAR,szData,100,NULL); - mystmt(hstmt,rc); - - rc = SQLExtendedFetch(hstmt,SQL_FETCH_NEXT,1,&pcrow,NULL); - mystmt(hstmt,rc); - - rc = SQLExtendedFetch(hstmt,SQL_FETCH_NEXT,1,&pcrow,NULL); - mystmt(hstmt,rc); - - fprintf(stdout," pcrow:%d\n",pcrow); - fprintf(stdout," row1:%d,%s\n",nData,szData); - - rc = SQLSetPos(hstmt,1,SQL_POSITION,SQL_LOCK_NO_CHANGE); - mystmt(hstmt,rc); - - nData = 1000; - strcpy((char *)szData , "updated"); - - rc = SQLSetPos(hstmt,3,SQL_UPDATE,SQL_LOCK_NO_CHANGE); - mystmt_err(hstmt,rc == SQL_ERROR,rc); - - rc = SQLSetPos(hstmt,2,SQL_UPDATE,SQL_LOCK_NO_CHANGE); - mystmt_err(hstmt,rc == SQL_ERROR,rc); - - rc = SQLSetPos(hstmt,1,SQL_UPDATE,SQL_LOCK_NO_CHANGE); - mystmt(hstmt,rc); - - rc = SQLRowCount(hstmt,&nlen); - mystmt(hstmt,rc); - - fprintf(stdout," rows affected:%d\n",nlen); - - rc = SQLFreeStmt(hstmt,SQL_UNBIND); - mystmt(hstmt,rc); - - rc = SQLFreeStmt(hstmt,SQL_CLOSE); - mystmt(hstmt,rc); - - rc = tmysql_exec(hstmt,"select * from t_setpos_position"); - mystmt(hstmt,rc); - - myresult(hstmt); - - rc = SQLFreeStmt(hstmt,SQL_CLOSE); - mystmt(hstmt,rc); - - rc = SQLExecDirect(hstmt,"DELETE FROM t_setpos_position WHERE col2 = 'updated'",SQL_NTS); - mystmt(hstmt,rc); - - rc = SQLRowCount(hstmt,&nlen); - mystmt(hstmt,rc); - fprintf(stdout,"total rows affceted:%d\n",nlen); - my_assert(nlen == 1); - - rc = SQLFreeStmt(hstmt,SQL_CLOSE); - mystmt(hstmt,rc); - - rc = SQLTransact(NULL,hdbc,SQL_COMMIT); - mycon(hdbc,rc); - - rc = tmysql_exec(hstmt,"select * from t_setpos_position"); - mystmt(hstmt,rc); - - my_assert(2 == myresult(hstmt)); - - rc = SQLFreeStmt(hstmt,SQL_CLOSE); - mystmt(hstmt,rc); - - return OK; -} - - -DECLARE_TEST(t_pos_column_ignore) -{ - SQLRETURN rc; - SQLHSTMT hstmt1; - SQLCHAR szData[]="updated"; - SQLINTEGER nData; - SQLLEN pcbValue, nlen, pcrow; - - rc = SQLAllocStmt(hdbc,&hstmt1); - mycon(hdbc,rc); - - tmysql_exec(hstmt,"drop table t_pos_column_ignore"); - rc = tmysql_exec(hstmt,"create table t_pos_column_ignore(col1 int NOT NULL primary key, col2 varchar(30))"); - mystmt(hstmt,rc); - - rc = tmysql_exec(hstmt,"insert into t_pos_column_ignore values(10,'venu')"); - mystmt(hstmt,rc); - - rc = tmysql_exec(hstmt,"insert into t_pos_column_ignore values(100,'MySQL')"); - mystmt(hstmt,rc); - - rc = SQLTransact(NULL,hdbc,SQL_COMMIT); - mycon(hdbc,rc); - - rc = SQLFreeStmt(hstmt,SQL_CLOSE); - mystmt(hstmt,rc); - - SQLSetStmtAttr(hstmt, SQL_ATTR_CONCURRENCY, (SQLPOINTER) SQL_CONCUR_ROWVER, 0); - SQLSetStmtAttr(hstmt, SQL_ATTR_CURSOR_TYPE, (SQLPOINTER) SQL_CURSOR_KEYSET_DRIVEN, 0); - - /* ignore all columns */ - rc = tmysql_exec(hstmt,"select * from t_pos_column_ignore order by col1 asc"); - mystmt(hstmt,rc); - - rc = SQLBindCol(hstmt,1,SQL_C_LONG,&nData,100,&pcbValue); - mystmt(hstmt,rc); - - rc = SQLBindCol(hstmt,2,SQL_C_CHAR,szData,100,&pcbValue); - mystmt(hstmt,rc); - - rc = SQLExtendedFetch(hstmt,SQL_FETCH_NEXT,1,&pcrow,NULL); - mystmt(hstmt,rc); - - rc = SQLSetPos(hstmt,1,SQL_POSITION,SQL_LOCK_NO_CHANGE); - mystmt(hstmt,rc); - - nData = 99; - strcpy((char *)szData , "updated"); - - pcbValue = SQL_COLUMN_IGNORE; - rc = SQLSetPos(hstmt,1,SQL_UPDATE,SQL_LOCK_NO_CHANGE); - mystmt(hstmt,rc); - - rc = SQLRowCount(hstmt,&nlen); - mystmt(hstmt,rc); - - fprintf(stdout," rows affected:%d\n",nlen); - myassert(nlen == 0); - - rc = SQLFreeStmt(hstmt,SQL_UNBIND); - mystmt(hstmt,rc); - - SQLFreeStmt(hstmt1,SQL_CLOSE); - SQLFreeStmt(hstmt,SQL_CLOSE); - - rc = SQLTransact(NULL,hdbc,SQL_COMMIT); - mycon(hdbc,rc); - - rc = tmysql_exec(hstmt,"select * from t_pos_column_ignore order by col1 asc"); - mystmt(hstmt,rc); - - rc = SQLFetch(hstmt); - mystmt(hstmt,rc); - { - SQLCHAR szData[20]; - my_assert(10 == my_fetch_int(hstmt,1)); - my_assert(!strcmp("venu",my_fetch_str(hstmt,szData,2))); - } - - rc = SQLFreeStmt(hstmt,SQL_CLOSE); - mystmt(hstmt,rc); - - /* ignore only one column */ - - rc = tmysql_exec(hstmt,"select * from t_pos_column_ignore order by col1 asc"); - mystmt(hstmt,rc); - - rc = SQLBindCol(hstmt,1,SQL_C_LONG,&nData,100,NULL); - mystmt(hstmt,rc); - - rc = SQLBindCol(hstmt,2,SQL_C_CHAR,szData,100,&pcbValue); - mystmt(hstmt,rc); - - rc = SQLExtendedFetch(hstmt,SQL_FETCH_NEXT,1,&pcrow,NULL); - mystmt(hstmt,rc); - - rc = SQLSetPos(hstmt,1,SQL_POSITION,SQL_LOCK_NO_CHANGE); - mystmt(hstmt,rc); - - nData = 99; - strcpy((char *)szData , "updated"); - - pcbValue = SQL_COLUMN_IGNORE; - rc = SQLSetPos(hstmt,1,SQL_UPDATE,SQL_LOCK_NO_CHANGE); - mystmt(hstmt,rc); - - rc = SQLRowCount(hstmt,&nlen); - mystmt(hstmt,rc); - - fprintf(stdout," rows affected:%d\n",nlen); - - rc = SQLFreeStmt(hstmt,SQL_UNBIND); - mystmt(hstmt,rc); - - SQLFreeStmt(hstmt1,SQL_CLOSE); - SQLFreeStmt(hstmt,SQL_CLOSE); - - rc = SQLTransact(NULL,hdbc,SQL_COMMIT); - mycon(hdbc,rc); - - rc = tmysql_exec(hstmt,"select * from t_pos_column_ignore order by col1 asc"); - mystmt(hstmt,rc); - - rc = SQLFetch(hstmt); - mystmt(hstmt,rc); - { - SQLCHAR szData[20]; - my_assert(99 == my_fetch_int(hstmt,1)); - my_assert(!strcmp("venu",my_fetch_str(hstmt,szData,2))); - } - - rc = SQLFreeStmt(hstmt,SQL_CLOSE); - mystmt(hstmt,rc); - - rc = SQLFreeStmt(hstmt1,SQL_DROP); - mystmt(hstmt1,rc); - - return OK; -} - - -DECLARE_TEST(t_longlong1) -{ - SQLRETURN rc; - SQLINTEGER session_id, ctn; - - tmysql_exec(hstmt,"drop table t_longlong"); - rc = tmysql_exec(hstmt,"create table t_longlong (\ - session_id bigint not null,\ - ctn bigint not null)"); - mystmt(hstmt,rc); - - rc = SQLTransact(NULL,hdbc,SQL_COMMIT); - mycon(hdbc,rc); - - SQLSetStmtAttr(hstmt, SQL_ATTR_CONCURRENCY, (SQLPOINTER) SQL_CONCUR_ROWVER, 0); - SQLSetStmtAttr(hstmt, SQL_ATTR_CURSOR_TYPE, (SQLPOINTER) SQL_CURSOR_STATIC, 0); - - rc = SQLPrepare(hstmt,"insert into t_longlong values (?,?)",SQL_NTS); - mystmt(hstmt,rc); - - rc = SQLBindParameter( hstmt, 1, SQL_PARAM_INPUT, SQL_C_UBIGINT, - SQL_BIGINT, 20, 0, &session_id, 20, NULL ); - - rc = SQLBindParameter( hstmt, 2, SQL_PARAM_INPUT, SQL_C_UBIGINT, - SQL_BIGINT, 20, 0, &ctn, 20, NULL ); - - for (session_id=50; session_id < 100; session_id++) - { - ctn += session_id; - rc = SQLExecute(hstmt); - mystmt(hstmt,rc); - } - - rc = SQLFreeStmt(hstmt,SQL_RESET_PARAMS); - mystmt(hstmt,rc); - - rc = SQLFreeStmt(hstmt,SQL_CLOSE); - mystmt(hstmt,rc); - - rc = SQLTransact(NULL,hdbc,SQL_COMMIT); - mycon(hdbc,rc); - - rc = tmysql_exec(hstmt,"select * from t_longlong"); - mystmt(hstmt,rc); - - my_assert( 50 == myresult(hstmt)); - - rc = SQLFreeStmt(hstmt,SQL_UNBIND); - mystmt(hstmt,rc); - - rc = SQLFreeStmt(hstmt,SQL_CLOSE); - mystmt(hstmt,rc); - - return OK; -} - - -DECLARE_TEST(t_time) -{ - SQLRETURN rc; - SQL_TIME_STRUCT tm; - SQLCHAR str[20]; - - tmysql_exec(hstmt,"drop table t_time"); - rc = tmysql_exec(hstmt,"create table t_time(tm time, ts timestamp(14))"); - mystmt(hstmt,rc); - - rc = SQLTransact(NULL,hdbc,SQL_COMMIT); - mycon(hdbc,rc); - - rc = SQLPrepare(hstmt,"insert into t_time values (?,?)",SQL_NTS); - mystmt(hstmt,rc); - - rc = SQLBindParameter( hstmt, 1, SQL_PARAM_INPUT, SQL_C_TIME, - SQL_TIME, 0, 0, &tm, 0, NULL ); - mystmt(hstmt,rc); - - rc = SQLBindParameter( hstmt, 2, SQL_PARAM_INPUT, SQL_C_TIME, - SQL_TIMESTAMP, 0, 0, &tm, 15, NULL ); - mystmt(hstmt,rc); - - tm.hour = 20; - tm.minute = 59; - tm.second = 45; - - rc = SQLExecute(hstmt); - mystmt(hstmt,rc); - - rc = SQLFreeStmt(hstmt,SQL_RESET_PARAMS); - mystmt(hstmt,rc); - - rc = SQLFreeStmt(hstmt,SQL_CLOSE); - mystmt(hstmt,rc); - - rc = SQLTransact(NULL,hdbc,SQL_COMMIT); - mycon(hdbc,rc); - - rc = SQLExecDirect(hstmt,"select tm from t_time",SQL_NTS); - mystmt(hstmt,rc); - - rc = SQLFetch(hstmt); - mystmt(hstmt,rc); - - rc = SQLGetData(hstmt,1,SQL_C_CHAR,&str,100,NULL); - mystmt(hstmt,rc); - fprintf(stdout,"time:%s\n",str); - my_assert(strcmp(str,"20:59:45")==0); - - rc = SQLFetch(hstmt); - my_assert(rc == SQL_NO_DATA_FOUND); - - rc = SQLFreeStmt(hstmt,SQL_UNBIND); - mystmt(hstmt,rc); - - rc = SQLFreeStmt(hstmt,SQL_CLOSE); - mystmt(hstmt,rc); - - return OK; -} - - -DECLARE_TEST(t_numeric) -{ - SQLRETURN rc; - SQL_NUMERIC_STRUCT num; - - tmysql_exec(hstmt,"drop table t_decimal"); - rc = tmysql_exec(hstmt,"create table t_decimal(d1 decimal(10,6))"); - mystmt(hstmt,rc); - rc = tmysql_exec(hstmt,"insert into t_decimal values(10.2)"); - mystmt(hstmt,rc); - - rc = SQLTransact(NULL,hdbc,SQL_COMMIT); - mycon(hdbc,rc); - - rc = SQLPrepare(hstmt,"insert into t_decimal values (?)",SQL_NTS); - mystmt(hstmt,rc); - - rc = SQLBindParameter( hstmt, 1, SQL_PARAM_INPUT, SQL_C_NUMERIC, - SQL_DECIMAL, 10, 4, &num, 0, NULL ); - mystmt_r(hstmt,rc); - - SQLFreeStmt(hstmt, SQL_CLOSE); - - rc = SQLPrepare(hstmt,"insert into t_decimal values (?),(?)",SQL_NTS); - mystmt(hstmt,rc); - - rc = SQLBindParameter( hstmt, 1, SQL_PARAM_INPUT, SQL_C_LONG, - SQL_DECIMAL, 10, 4, &rc, 0, NULL ); - mystmt(hstmt,rc); - - rc = SQLBindParameter( hstmt, 2, SQL_PARAM_INPUT, SQL_C_NUMERIC, - SQL_DECIMAL, 10, 4, &num, 0, NULL ); - mystmt_r(hstmt,rc); - - SQLFreeStmt(hstmt, SQL_CLOSE); - SQLFreeStmt(hstmt, SQL_RESET_PARAMS); - - rc = SQLBindCol( hstmt, 1, SQL_C_NUMERIC, &num, 0, NULL ); - mystmt_r(hstmt,rc); - - SQLFreeStmt(hstmt, SQL_CLOSE); - SQLFreeStmt(hstmt, SQL_UNBIND); - - rc = SQLExecDirect(hstmt, "select * from t_decimal",SQL_NTS); - mystmt(hstmt,rc); - - rc = SQLFetch(hstmt); - mystmt(hstmt,rc); - - rc = SQLGetData( hstmt, 1, SQL_C_NUMERIC, &num, 0, NULL ); - mystmt_r(hstmt,rc); - - SQLFreeStmt(hstmt, SQL_UNBIND); - SQLFreeStmt(hstmt, SQL_RESET_PARAMS); - SQLFreeStmt(hstmt, SQL_CLOSE); - - return OK; -} - - -DECLARE_TEST(t_decimal) -{ - SQLCHAR str[20],s_data[]="189.4567"; - SQLDOUBLE d_data=189.4567; - SQLINTEGER i_data=189, l_data=-23; - SQLRETURN rc; - - tmysql_exec(hstmt,"drop table t_decimal"); - rc = tmysql_exec(hstmt,"create table t_decimal(d1 decimal(10,6))"); - mystmt(hstmt,rc); - - rc = SQLTransact(NULL,hdbc,SQL_COMMIT); - mycon(hdbc,rc); - - rc = SQLPrepare(hstmt,"insert into t_decimal values (?),(?),(?),(?)",SQL_NTS); - mystmt(hstmt,rc); - - rc = SQLBindParameter( hstmt, 1, SQL_PARAM_INPUT, SQL_C_DOUBLE, - SQL_DECIMAL, 10, 4, &d_data, 0, NULL ); - mystmt(hstmt,rc); - - rc = SQLBindParameter( hstmt, 2, SQL_PARAM_INPUT, SQL_C_LONG, - SQL_DECIMAL, 10, 4, &i_data, 0, NULL ); - mystmt(hstmt,rc); - - rc = SQLBindParameter( hstmt, 3, SQL_PARAM_INPUT, SQL_C_CHAR, - SQL_DECIMAL, 10, 4, &s_data, 9, NULL ); - mystmt(hstmt,rc); - - rc = SQLBindParameter( hstmt, 4, SQL_PARAM_INPUT, SQL_C_LONG, - SQL_DECIMAL, 10, 4, &l_data, 0, NULL ); - mystmt(hstmt,rc); - - rc = SQLExecute(hstmt); - mystmt(hstmt,rc); - - rc = SQLFreeStmt(hstmt,SQL_RESET_PARAMS); - mystmt(hstmt,rc); - - rc = SQLFreeStmt(hstmt,SQL_CLOSE); - mystmt(hstmt,rc); - - rc = SQLTransact(NULL,hdbc,SQL_COMMIT); - mycon(hdbc,rc); - - rc = SQLExecDirect(hstmt,"select d1 from t_decimal",SQL_NTS); - mystmt(hstmt,rc); - - rc = SQLFetch(hstmt); - mystmt(hstmt,rc); - - rc = SQLGetData(hstmt,1,SQL_C_CHAR,&str,19,NULL); - mystmt(hstmt,rc); - fprintf(stdout,"decimal(SQL_C_DOUBLE) : %s\n",str); - my_assert(strncmp(str,"189.4567",8)==0); - - rc = SQLFetch(hstmt); - mystmt(hstmt,rc); - - rc = SQLGetData(hstmt,1,SQL_C_CHAR,&str,19,NULL); - mystmt(hstmt,rc); - fprintf(stdout,"decimal(SQL_C_INTEGER): %s\n",str); - my_assert(strncmp(str,"189.0000",5)==0); - - rc = SQLFetch(hstmt); - mystmt(hstmt,rc); - - rc = SQLGetData(hstmt,1,SQL_C_CHAR,&str,19,NULL); - mystmt(hstmt,rc); - fprintf(stdout,"decimal(SQL_C_CHAR) : %s\n",str); - my_assert(strncmp(str,"189.4567",8)==0); - - rc = SQLFetch(hstmt); - mystmt(hstmt,rc); - - rc = SQLGetData(hstmt,1,SQL_C_CHAR,&str,19,NULL); - mystmt(hstmt,rc); - fprintf(stdout,"decimal(SQL_C_LONG) : %s\n",str); - my_assert(strncmp(str,"-23.00",6)==0); - - rc = SQLFetch(hstmt); - my_assert(rc == SQL_NO_DATA_FOUND); - - rc = SQLFreeStmt(hstmt,SQL_UNBIND); - mystmt(hstmt,rc); - - rc = SQLFreeStmt(hstmt,SQL_CLOSE); - mystmt(hstmt,rc); - - return OK; -} - - -DECLARE_TEST(t_warning) -{ - SQLRETURN rc; - SQLCHAR szData[20]; - SQLINTEGER pcbValue; - - tmysql_exec(hstmt,"drop table t_warning"); - rc = tmysql_exec(hstmt,"create table t_warning(col2 char(20))"); - mystmt(hstmt,rc); - - rc = tmysql_exec(hstmt,"insert into t_warning values('venu anuganti')"); - mystmt(hstmt,rc); - - rc = SQLTransact(NULL,hdbc,SQL_COMMIT); - mycon(hdbc,rc); - - rc = SQLFreeStmt(hstmt,SQL_CLOSE); - mystmt(hstmt,rc); - - SQLSetStmtAttr(hstmt, SQL_ATTR_CONCURRENCY, (SQLPOINTER) SQL_CONCUR_ROWVER, 0); - SQLSetStmtAttr(hstmt, SQL_ATTR_CURSOR_TYPE, (SQLPOINTER) SQL_CURSOR_KEYSET_DRIVEN, 0); - - /* ignore all columns */ - rc = tmysql_exec(hstmt,"select * from t_warning"); - mystmt(hstmt,rc); - - rc = SQLFetch(hstmt); - mystmt(hstmt, rc); - - rc = SQLGetData(hstmt,1,SQL_C_CHAR,szData,4,&pcbValue); - mystmt_err(hstmt, rc == SQL_SUCCESS_WITH_INFO, rc); - fprintf(stdout,"data: %s(%d)\n",szData,pcbValue); - - rc = SQLGetData(hstmt,1,SQL_C_CHAR,szData,4,&pcbValue); - mystmt_err(hstmt, rc == SQL_SUCCESS_WITH_INFO, rc); - fprintf(stdout,"data: %s(%d)\n",szData,pcbValue); - - rc = SQLGetData(hstmt,1,SQL_C_CHAR,szData,4,&pcbValue); - mystmt_err(hstmt, rc == SQL_SUCCESS_WITH_INFO, rc); - fprintf(stdout,"data: %s(%d)\n",szData,pcbValue); - - rc = SQLGetData(hstmt,1,SQL_C_CHAR,szData,4,&pcbValue); - mystmt(hstmt,rc); - fprintf(stdout,"data: %s(%d)\n",szData,pcbValue); - - rc = SQLFetch(hstmt); - mystmt_err(hstmt, rc == SQL_NO_DATA_FOUND, rc); - - SQLFreeStmt(hstmt,SQL_UNBIND); - SQLFreeStmt(hstmt,SQL_CLOSE); - - return OK; -} - - -DECLARE_TEST(t_multistep) -{ - SQLRETURN rc; - SQLCHAR szData[150]; - SQLLEN pcbValue; - SQLINTEGER id; - - tmysql_exec(hstmt,"drop table t_multistep"); - rc = tmysql_exec(hstmt,"create table t_multistep(col1 int,col2 varchar(200))"); - mystmt(hstmt,rc); - - rc = tmysql_exec(hstmt,"insert into t_multistep values(10,'MySQL - Open Source Database')"); - mystmt(hstmt,rc); - - rc = SQLTransact(NULL,hdbc,SQL_COMMIT); - mycon(hdbc,rc); - - rc = SQLFreeStmt(hstmt,SQL_CLOSE); - mystmt(hstmt,rc); - - SQLSetStmtAttr(hstmt, SQL_ATTR_CONCURRENCY, (SQLPOINTER) SQL_CONCUR_ROWVER, 0); - SQLSetStmtAttr(hstmt, SQL_ATTR_CURSOR_TYPE, (SQLPOINTER) SQL_CURSOR_KEYSET_DRIVEN, 0); - - rc = SQLBindCol(hstmt,1,SQL_C_LONG,&id,0,NULL); - mystmt(hstmt,rc); - - rc = tmysql_exec(hstmt,"select * from t_multistep"); - mystmt(hstmt,rc); - - rc = SQLFetch(hstmt); - mystmt(hstmt,rc); - fprintf(stdout,"id: %ld\n",id); - myassert(id == 10); - - rc = SQLGetData(hstmt,2,SQL_C_CHAR,szData,0,&pcbValue); - myassert(rc == SQL_SUCCESS_WITH_INFO); - fprintf(stdout,"length: %ld\n", pcbValue); - myassert(pcbValue == 28); - - rc = SQLGetData(hstmt,2,SQL_C_CHAR,szData,0,&pcbValue); - myassert(rc == SQL_SUCCESS_WITH_INFO); - fprintf(stdout,"length: %ld\n", pcbValue); - myassert(pcbValue == 28); - - rc = SQLGetData(hstmt,2,SQL_C_BINARY,szData,0,&pcbValue); - myassert(rc == SQL_SUCCESS_WITH_INFO); - fprintf(stdout,"length: %ld\n", pcbValue); - myassert(pcbValue == 28); - - rc = SQLGetData(hstmt,2,SQL_C_BINARY,szData,0,&pcbValue); - myassert(rc == SQL_SUCCESS_WITH_INFO); - fprintf(stdout,"length: %ld\n", pcbValue); - myassert(pcbValue == 28); - - rc = SQLGetData(hstmt,2,SQL_C_CHAR,szData,0,&pcbValue); - myassert(rc == SQL_SUCCESS_WITH_INFO); - fprintf(stdout,"length: %ld\n", pcbValue); - myassert(pcbValue == 28); - - rc = SQLGetData(hstmt,2,SQL_C_CHAR,szData,10,&pcbValue); - myassert(rc == SQL_SUCCESS_WITH_INFO); - fprintf(stdout,"data : %s (%ld)\n",szData,pcbValue); - myassert(pcbValue == 28); - myassert(strcmp(szData,"MySQL - O") == 0); - - pcbValue= 0; - rc = SQLGetData(hstmt,2,SQL_C_CHAR,szData,5,&pcbValue); - myassert(rc == SQL_SUCCESS_WITH_INFO); - fprintf(stdout,"data : %s (%ld)\n",szData,pcbValue); - myassert(pcbValue == 19); - myassert(strcmp(szData,"pen ") == 0); - - pcbValue= 0; - szData[0]='A'; - rc = SQLGetData(hstmt,2,SQL_C_CHAR,szData,0,&pcbValue); - myassert(rc == SQL_SUCCESS_WITH_INFO); - fprintf(stdout,"data : %s (%ld)\n",szData,pcbValue); - myassert(pcbValue == 15); - myassert(szData[0] == 'A'); - - rc = SQLGetData(hstmt,2,SQL_C_CHAR,szData,pcbValue+1,&pcbValue); - mystmt(hstmt,rc); - fprintf(stdout,"data : %s (%ld)\n",szData,pcbValue); - myassert(pcbValue == 15); - myassert(strcmp(szData,"Source Database") == 0); - - pcbValue= 99; - szData[0]='A'; - rc = SQLGetData(hstmt,2,SQL_C_CHAR,szData,0,&pcbValue); - myassert(rc == SQL_SUCCESS_WITH_INFO); - fprintf(stdout,"data : %s (%ld)\n",szData,pcbValue); - myassert(pcbValue == 0); - myassert(szData[0] == 'A'); - - - rc = SQLFetch(hstmt); - myassert(rc == SQL_NO_DATA_FOUND); - - SQLFreeStmt(hstmt,SQL_UNBIND); - SQLFreeStmt(hstmt,SQL_CLOSE); -} - - -DECLARE_TEST(t_zerolength) -{ - SQLRETURN rc; - SQLCHAR szData[100], bData[100], bData1[100]; - SQLLEN pcbValue,pcbValue1,pcbValue2; - - tmysql_exec(hstmt,"drop table t_zerolength"); - rc = tmysql_exec(hstmt,"create table t_zerolength(str varchar(20), bin varbinary(20), blb blob)"); - mystmt(hstmt,rc); - - rc = tmysql_exec(hstmt,"insert into t_zerolength values('','','')"); - mystmt(hstmt,rc); - - rc = tmysql_exec(hstmt,"insert into t_zerolength values('venu','mysql','monty')"); - mystmt(hstmt,rc); - - rc = SQLTransact(NULL,hdbc,SQL_COMMIT); - mycon(hdbc,rc); - - rc = SQLFreeStmt(hstmt,SQL_CLOSE); - mystmt(hstmt,rc); - - SQLSetStmtAttr(hstmt, SQL_ATTR_CONCURRENCY, (SQLPOINTER) SQL_CONCUR_ROWVER, 0); - SQLSetStmtAttr(hstmt, SQL_ATTR_CURSOR_TYPE, (SQLPOINTER) SQL_CURSOR_KEYSET_DRIVEN, 0); - - rc = tmysql_exec(hstmt,"select * from t_zerolength"); - mystmt(hstmt,rc); - - rc = SQLFetch(hstmt); - mystmt(hstmt,rc); - - pcbValue= pcbValue1= 99; - rc = SQLGetData(hstmt,1,SQL_C_CHAR,szData,0,&pcbValue); - mystmt_err(hstmt,rc == SQL_SUCCESS_WITH_INFO,rc); - fprintf(stdout,"length: %d\n", pcbValue); - myassert(pcbValue == 0); - - bData[0]=bData[1]='z'; - rc = SQLGetData(hstmt,2,SQL_C_BINARY,bData,0,&pcbValue1); - mystmt_err(hstmt,rc == SQL_SUCCESS_WITH_INFO,rc); - fprintf(stdout,"length: %d\n", pcbValue1); - myassert(pcbValue1 == 0); - myassert(bData[0] == 'z'); - myassert(bData[1] == 'z'); - - bData1[0]=bData1[1]='z'; - rc = SQLGetData(hstmt,3,SQL_C_BINARY,bData1,0,&pcbValue2); - mystmt_err(hstmt,rc == SQL_SUCCESS_WITH_INFO,rc); - fprintf(stdout,"length: %d\n", pcbValue2); - myassert(pcbValue2 == 0); - myassert(bData1[0] == 'z'); - myassert(bData1[1] == 'z'); - - pcbValue= pcbValue1= 99; - rc = SQLGetData(hstmt,1,SQL_C_CHAR,szData,1,&pcbValue); - mystmt(hstmt,rc); - fprintf(stdout,"data: %s, length: %d\n", szData, pcbValue); - myassert(pcbValue == 0); - myassert(szData[0] == '\0'); - - bData[0]=bData[1]='z'; - rc = SQLGetData(hstmt,2,SQL_C_BINARY,bData,1,&pcbValue1); - mystmt(hstmt,rc); - fprintf(stdout,"data: %s, length: %d\n", bData, pcbValue1); - myassert(pcbValue1 == 0); - myassert(bData[0]== '\0'); - - bData1[0]=bData1[1]='z'; - rc = SQLGetData(hstmt,3,SQL_C_CHAR,bData1,1,&pcbValue2); - mystmt(hstmt,rc); - fprintf(stdout,"data: %s, length: %d\n", bData1, pcbValue2); - myassert(pcbValue2 == 0); - myassert(bData1[0] == '\0'); - myassert(bData1[1] == 'z'); - - rc = SQLFetch(hstmt); - mystmt(hstmt,rc); - - pcbValue= pcbValue1= 99; - szData[0]= bData[0]= 'z'; - rc = SQLGetData(hstmt,1,SQL_C_CHAR,szData,0,&pcbValue); - mystmt_err(hstmt,rc == SQL_SUCCESS_WITH_INFO,rc); - fprintf(stdout,"length: %d\n", pcbValue); - myassert(pcbValue == 4); - myassert(szData[0] == 'z'); - - rc = SQLGetData(hstmt,2,SQL_C_BINARY,bData,0,&pcbValue1); - mystmt_err(hstmt,rc == SQL_SUCCESS_WITH_INFO,rc); - fprintf(stdout,"length: %d\n", pcbValue1); - myassert(pcbValue1 == 5); - myassert(bData[0] == 'z'); - - bData[0]=bData1[1]='z'; - rc = SQLGetData(hstmt,3,SQL_C_BINARY,bData1,0,&pcbValue2); - mystmt_err(hstmt,rc == SQL_SUCCESS_WITH_INFO,rc); - fprintf(stdout,"length: %d\n", pcbValue2); - myassert(pcbValue2 == 5); - - pcbValue= pcbValue1= 99; - szData[0]= szData[1]= bData[0]= bData[1]= 'z'; - rc = SQLGetData(hstmt,1,SQL_C_CHAR,szData,1,&pcbValue); - mystmt_err(hstmt,rc == SQL_SUCCESS_WITH_INFO,rc); - fprintf(stdout,"data: %s, length: %d\n", szData,pcbValue); - myassert(pcbValue == 4); - myassert(szData[0] == '\0'); - - rc = SQLGetData(hstmt,2,SQL_C_BINARY,bData,1,&pcbValue1); - mystmt_err(hstmt,rc == SQL_SUCCESS_WITH_INFO,rc); - fprintf(stdout,"data; %s, length: %d\n", bData, pcbValue1); - myassert(pcbValue1 == 5); - myassert(bData[0] == 'm'); - - bData[0]=bData1[1]='z'; - rc = SQLGetData(hstmt,3,SQL_C_BINARY,bData1,1,&pcbValue2); - mystmt_err(hstmt,rc == SQL_SUCCESS_WITH_INFO,rc); - fprintf(stdout,"length: %d\n", pcbValue2); - myassert(pcbValue2 == 5); - myassert(bData1[0] == 'm'); - myassert(bData1[1] == 'z'); - - pcbValue= pcbValue1= 99; - rc = SQLGetData(hstmt,1,SQL_C_CHAR,szData,4,&pcbValue); - mystmt_err(hstmt,rc == SQL_SUCCESS_WITH_INFO,rc); - fprintf(stdout,"data: %s, length: %d\n", szData, pcbValue); - myassert(pcbValue == 4); - myassert(strcmp(szData,"ven")==0); - - rc = SQLGetData(hstmt,2,SQL_C_BINARY,bData,4,&pcbValue1); - mystmt_err(hstmt,rc == SQL_SUCCESS_WITH_INFO,rc); - fprintf(stdout,"data: %s, length: %d\n", bData, pcbValue1); - myassert(pcbValue1 == 5); - myassert(strncmp(bData,"mysq",4)==0); - - pcbValue= pcbValue1= 99; - rc = SQLGetData(hstmt,1,SQL_C_CHAR,szData,5,&pcbValue); - mystmt(hstmt,rc); - fprintf(stdout,"data: %s, length: %d\n", szData, pcbValue); - myassert(pcbValue == 4); - myassert(strcmp(szData,"venu")==0); - - rc = SQLGetData(hstmt,2,SQL_C_BINARY,bData,5,&pcbValue1); - mystmt(hstmt,rc); - fprintf(stdout,"data: %s, length: %d\n", bData, pcbValue1); - myassert(pcbValue1 == 5); - myassert(strncmp(bData,"mysql",5)==0); - - szData[0]= 'z'; - rc = SQLGetData(hstmt,3,SQL_C_CHAR,szData,0,&pcbValue); - mystmt_err(hstmt,rc == SQL_SUCCESS_WITH_INFO,rc); - fprintf(stdout,"data: %s, length: %d\n", szData, pcbValue); - myassert(pcbValue == 5 || pcbValue == 10); - myassert(szData[0] == 'z'); - -#if TO_BE_FIXED_IN_DRIVER - szData[0]=szData[1]='z'; - rc = SQLGetData(hstmt,3,SQL_C_CHAR,szData,1,&pcbValue); - mystmt_err(hstmt,rc == SQL_SUCCESS_WITH_INFO,rc); - fprintf(stdout,"data: %s, length: %d\n", szData, pcbValue); - myassert(pcbValue == 10); - myassert(szData[0] == 'm'); - myassert(szData[1] == 'z'); - - rc = SQLGetData(hstmt,3,SQL_C_CHAR,szData,4,&pcbValue); - mystmt_err(hstmt,rc == SQL_SUCCESS_WITH_INFO,rc); - fprintf(stdout,"data: %s, length: %d\n", szData, pcbValue); - myassert(pcbValue == 10); - myassert(strncmp(szData,"mont",4) == 0); - - rc = SQLGetData(hstmt,3,SQL_C_CHAR,szData,5,&pcbValue); - mystmt(hstmt,rc); - fprintf(stdout,"data: %s, length: %d\n", szData, pcbValue); - myassert(pcbValue == 10); - myassert(strncmp(szData,"monty",5) == 0); -#endif - - rc = SQLFetch(hstmt); - myassert(rc == SQL_NO_DATA_FOUND); - - SQLFreeStmt(hstmt,SQL_UNBIND); - SQLFreeStmt(hstmt,SQL_CLOSE); - - return OK; -} - - -DECLARE_TEST(t_pos_datetime_delete) -{ - SQLRETURN rc; - SQLHSTMT hstmt1; - SQLINTEGER int_data; - SQLLEN row_count, cur_type; - - rc = SQLAllocStmt(hdbc,&hstmt1); - mycon(hdbc,rc); - - tmysql_exec(hstmt,"drop table t_pos_delete"); - rc = tmysql_exec(hstmt,"create table t_pos_delete(id int not null default '0',\ - name varchar(20) NOT NULL default '',\ - created datetime NOT NULL default '2000-01-01')"); - mystmt(hstmt,rc); - - rc = tmysql_exec(hstmt,"insert into t_pos_delete values(1,'venu','2003-02-10 14:45:39')"); - mystmt(hstmt,rc); - - rc = tmysql_exec(hstmt,"insert into t_pos_delete(name) values('')"); - mystmt(hstmt,rc); - - rc = tmysql_exec(hstmt,"insert into t_pos_delete(id) values(2)"); - mystmt(hstmt,rc); - - rc = SQLTransact(NULL,hdbc,SQL_COMMIT); - mycon(hdbc,rc); - - rc = SQLFreeStmt(hstmt,SQL_CLOSE); - mystmt(hstmt,rc); - - rc = tmysql_exec(hstmt,"select * from t_pos_delete"); - mystmt(hstmt,rc); - - my_assert(3 == myresult(hstmt)); - - rc = SQLFreeStmt(hstmt,SQL_CLOSE); - mystmt(hstmt,rc); - - SQLSetStmtAttr(hstmt, SQL_ATTR_CONCURRENCY, (SQLPOINTER) SQL_CONCUR_ROWVER, 0); - SQLSetStmtAttr(hstmt, SQL_ATTR_CURSOR_TYPE, (SQLPOINTER) SQL_CURSOR_DYNAMIC, 0); - SQLSetStmtOption(hstmt,SQL_SIMULATE_CURSOR,SQL_SC_TRY_UNIQUE); - - SQLSetStmtAttr(hstmt1, SQL_ATTR_CONCURRENCY, (SQLPOINTER) SQL_CONCUR_ROWVER, 0); - SQLSetStmtAttr(hstmt1, SQL_ATTR_CURSOR_TYPE, (SQLPOINTER) SQL_CURSOR_DYNAMIC, 0); - SQLSetStmtOption(hstmt1,SQL_SIMULATE_CURSOR,SQL_SC_TRY_UNIQUE); - - rc = SQLSetCursorName(hstmt,"venu_cur",8); - mystmt(hstmt,rc); - - rc = SQLGetStmtAttr(hstmt, SQL_ATTR_CURSOR_TYPE, &cur_type, 0, NULL); - mystmt(hstmt,rc); - - rc = tmysql_exec(hstmt,"select * from t_pos_delete"); - mystmt(hstmt,rc); - - rc = SQLBindCol(hstmt,1,SQL_C_LONG,&int_data,0,NULL); - mystmt(hstmt,rc); - - rc = SQLExtendedFetch(hstmt,SQL_FETCH_NEXT,1,NULL,NULL); - mystmt(hstmt,rc); - fprintf(stdout,"current_row: %d\n", int_data); - myassert(int_data == 1); - - rc = SQLSetPos(hstmt,1,SQL_POSITION,SQL_LOCK_NO_CHANGE); - mystmt(hstmt,rc); - - rc = SQLExecDirect(hstmt1,"DELETE FROM t_pos_delete WHERE CURRENT OF venu_cur",SQL_NTS); - mystmt(hstmt1,rc); - - rc = SQLRowCount(hstmt1,&row_count); - mystmt(hstmt1,rc); - fprintf(stdout, "rows affected: %d\n", row_count); - myassert(row_count == 1); - - rc = SQLExtendedFetch(hstmt,SQL_FETCH_NEXT,1,NULL,NULL); - mystmt(hstmt,rc); - fprintf(stdout,"current_row: %d\n", int_data); - if (cur_type == SQL_CURSOR_DYNAMIC) - myassert(int_data == 2); - else - myassert(int_data == 0); - - /*rc = SQLExtendedFetch(hstmt,SQL_FETCH_NEXT,1,NULL,NULL); - mystmt(hstmt,rc);*/ - - rc = SQLSetPos(hstmt,1,SQL_POSITION,SQL_LOCK_NO_CHANGE); - mystmt(hstmt,rc); - - rc = SQLExecDirect(hstmt1,"DELETE FROM t_pos_delete WHERE CURRENT OF venu_cur",SQL_NTS); - mystmt(hstmt1,rc); - - rc = SQLRowCount(hstmt1,&row_count); - mystmt(hstmt1,rc); - fprintf(stdout, "rows affected: %d\n", row_count); - myassert(row_count == 1); - - SQLFreeStmt(hstmt,SQL_UNBIND); - SQLFreeStmt(hstmt,SQL_CLOSE); - SQLFreeStmt(hstmt1,SQL_CLOSE); - - rc = SQLTransact(NULL,hdbc,SQL_COMMIT); - mycon(hdbc,rc); - - rc = tmysql_exec(hstmt,"select * from t_pos_delete"); - mystmt(hstmt,rc); - - my_assert(1 == myresult(hstmt)); - - rc = SQLFreeStmt(hstmt,SQL_CLOSE); - mystmt(hstmt,rc); - - if (cur_type == SQL_CURSOR_DYNAMIC) - verify_col_data(hstmt,"t_pos_delete","id","0"); - else - verify_col_data(hstmt,"t_pos_delete","id","2"); - - rc = SQLFreeStmt(hstmt1,SQL_DROP); - mystmt(hstmt1,rc); - - return OK; -} - - -DECLARE_TEST(t_pos_datetime_delete1) -{ - SQLRETURN rc; - SQLHSTMT hstmt1; - SQLINTEGER int_data; - SQLLEN row_count, cur_type; - - rc = SQLAllocStmt(hdbc,&hstmt1); - mycon(hdbc,rc); - - tmysql_exec(hstmt,"drop table t_pos_delete"); - rc = tmysql_exec(hstmt,"create table t_pos_delete(id int not null default '0',\ - name varchar(20) NOT NULL default '',\ - created datetime NOT NULL default '2000-01-01')"); - mystmt(hstmt,rc); - - rc = tmysql_exec(hstmt,"insert into t_pos_delete values(1,'venu','2003-02-10 14:45:39')"); - mystmt(hstmt,rc); - - rc = tmysql_exec(hstmt,"insert into t_pos_delete(name) values('')"); - mystmt(hstmt,rc); - - rc = tmysql_exec(hstmt,"insert into t_pos_delete(id) values(2)"); - mystmt(hstmt,rc); - - rc = tmysql_exec(hstmt,"insert into t_pos_delete(id) values(3)"); - mystmt(hstmt,rc); - - rc = tmysql_exec(hstmt,"insert into t_pos_delete(id) values(4)"); - mystmt(hstmt,rc); - - rc = tmysql_exec(hstmt,"insert into t_pos_delete(id) values(5)"); - mystmt(hstmt,rc); - - rc = SQLTransact(NULL,hdbc,SQL_COMMIT); - mycon(hdbc,rc); - - rc = SQLFreeStmt(hstmt,SQL_CLOSE); - mystmt(hstmt,rc); - - rc = tmysql_exec(hstmt,"select * from t_pos_delete"); - mystmt(hstmt,rc); - - my_assert(6 == myresult(hstmt)); - - rc = SQLFreeStmt(hstmt,SQL_CLOSE); - mystmt(hstmt,rc); - - SQLSetStmtAttr(hstmt, SQL_ATTR_CONCURRENCY, (SQLPOINTER) SQL_CONCUR_ROWVER, 0); - SQLSetStmtAttr(hstmt, SQL_ATTR_CURSOR_TYPE, (SQLPOINTER) SQL_CURSOR_DYNAMIC, 0); - SQLSetStmtOption(hstmt,SQL_SIMULATE_CURSOR,SQL_SC_NON_UNIQUE); - - SQLSetStmtAttr(hstmt1, SQL_ATTR_CONCURRENCY, (SQLPOINTER) SQL_CONCUR_ROWVER, 0); - SQLSetStmtAttr(hstmt1, SQL_ATTR_CURSOR_TYPE, (SQLPOINTER) SQL_CURSOR_DYNAMIC, 0); - SQLSetStmtOption(hstmt1,SQL_SIMULATE_CURSOR,SQL_SC_NON_UNIQUE); - - rc = SQLSetCursorName(hstmt,"venu_cur",8); - mystmt(hstmt,rc); - - rc = SQLGetStmtAttr(hstmt, SQL_ATTR_CURSOR_TYPE, &cur_type, 0, NULL); - mystmt(hstmt,rc); - - rc = tmysql_exec(hstmt,"select * from t_pos_delete"); - mystmt(hstmt,rc); - - rc = SQLBindCol(hstmt,1,SQL_C_LONG,&int_data,0,NULL); - mystmt(hstmt,rc); - - rc = SQLExtendedFetch(hstmt,SQL_FETCH_ABSOLUTE,3,NULL,NULL); - mystmt(hstmt,rc); - fprintf(stdout,"current_row: %d\n", int_data); - myassert(int_data == 2); - - rc = SQLSetPos(hstmt,1,SQL_POSITION,SQL_LOCK_NO_CHANGE); - mystmt(hstmt,rc); - - rc = SQLExecDirect(hstmt1,"DELETE FROM t_pos_delete WHERE CURRENT OF venu_cur",SQL_NTS); - mystmt(hstmt1,rc); - - rc = SQLRowCount(hstmt1,&row_count); - mystmt(hstmt1,rc); - fprintf(stdout, "rows affected: %d\n", row_count); - myassert(row_count == 1); - - rc = SQLExtendedFetch(hstmt,SQL_FETCH_NEXT,1,NULL,NULL); - mystmt(hstmt,rc); - fprintf(stdout,"current_row: %d\n", int_data); - - rc = SQLExtendedFetch(hstmt,SQL_FETCH_NEXT,1,NULL,NULL); - mystmt(hstmt,rc); - fprintf(stdout,"current_row: %d\n", int_data); - - /*rc = SQLExtendedFetch(hstmt,SQL_FETCH_NEXT,1,NULL,NULL); - mystmt(hstmt,rc);*/ - - rc = SQLSetPos(hstmt,1,SQL_POSITION,SQL_LOCK_NO_CHANGE); - mystmt(hstmt,rc); - - rc = SQLExecDirect(hstmt1,"DELETE FROM t_pos_delete WHERE CURRENT OF venu_cur",SQL_NTS); - mystmt(hstmt1,rc); - - rc = SQLRowCount(hstmt1,&row_count); - mystmt(hstmt1,rc); - fprintf(stdout, "rows affected: %d\n", row_count); - myassert(row_count == 1); - - SQLFreeStmt(hstmt,SQL_UNBIND); - SQLFreeStmt(hstmt,SQL_CLOSE); - SQLFreeStmt(hstmt1,SQL_CLOSE); - - rc = SQLTransact(NULL,hdbc,SQL_COMMIT); - mycon(hdbc,rc); - - rc = tmysql_exec(hstmt,"select * from t_pos_delete"); - mystmt(hstmt,rc); - - my_assert(4 == myresult(hstmt)); - - rc = SQLFreeStmt(hstmt,SQL_CLOSE); - mystmt(hstmt,rc); - - rc = SQLFreeStmt(hstmt1,SQL_DROP); - mystmt(hstmt1,rc); - - return OK; -} - - -#define TEST_ODBC_TEXT_LEN 3000 -DECLARE_TEST(t_text_fetch) -{ - SQLRETURN rc; - SQLINTEGER i; - SQLLEN row_count, length; - SQLCHAR data[TEST_ODBC_TEXT_LEN+1]; - - SQLExecDirect(hstmt,"drop table t_text_fetch",SQL_NTS); - rc = SQLExecDirect(hstmt,"create table t_text_fetch(t1 tinytext, \ - t2 text, \ - t3 mediumtext, \ - t4 longtext)",SQL_NTS); - mystmt(hstmt,rc); - - rc = SQLPrepare(hstmt,"insert into t_text_fetch values(?,?,?,?)",SQL_NTS); - mystmt(hstmt,rc); - - rc = SQLBindParameter(hstmt, 1, SQL_PARAM_INPUT, SQL_C_CHAR, SQL_CHAR, - 0,0,(char *)data, TEST_ODBC_TEXT_LEN/3, NULL); - mystmt(hstmt,rc); - - rc = SQLBindParameter(hstmt, 2, SQL_PARAM_INPUT, SQL_C_CHAR, SQL_CHAR, - 0,0,(char *)data, TEST_ODBC_TEXT_LEN/2, NULL); - mystmt(hstmt,rc); - - rc = SQLBindParameter(hstmt, 3, SQL_PARAM_INPUT, SQL_C_CHAR, SQL_CHAR, - 0,0,(char *)data, - (SQLINTEGER)(TEST_ODBC_TEXT_LEN/1.5), NULL); - mystmt(hstmt,rc); - - rc = SQLBindParameter(hstmt, 4, SQL_PARAM_INPUT, SQL_C_CHAR, SQL_CHAR, - 0,0,(char *)data, TEST_ODBC_TEXT_LEN-1, NULL); - mystmt(hstmt,rc); - - memset(data,'A',TEST_ODBC_TEXT_LEN); - data[TEST_ODBC_TEXT_LEN]='\0'; - - for (i=0; i < 10; i++) - { - rc = SQLExecute(hstmt); - mystmt(hstmt,rc); - } - - SQLFreeStmt(hstmt, SQL_RESET_PARAMS); - SQLFreeStmt(hstmt, SQL_CLOSE); - - rc = SQLExecDirect(hstmt,"SELECT * FROM t_text_fetch",SQL_NTS); - mystmt(hstmt,rc); - - row_count= 0; - rc = SQLFetch(hstmt); - while (rc == SQL_SUCCESS || rc == SQL_SUCCESS_WITH_INFO) - { - fprintf(stdout,"row '%d' (lengths: \n", row_count); - rc = SQLGetData(hstmt,1,SQL_C_CHAR,(char *)data,TEST_ODBC_TEXT_LEN,&length); - mystmt(hstmt,rc); - fprintf(stdout,"%d", length); - myassert(length == 255); - - rc = SQLGetData(hstmt,2,SQL_C_CHAR,(char *)data,TEST_ODBC_TEXT_LEN,&length); - mystmt(hstmt,rc); - fprintf(stdout,",%d", length); - myassert(length == TEST_ODBC_TEXT_LEN/2); - - rc = SQLGetData(hstmt,3,SQL_C_CHAR,(char *)data,TEST_ODBC_TEXT_LEN,&length); - mystmt(hstmt,rc); - fprintf(stdout,",%d", length); - myassert(length == (SQLINTEGER)(TEST_ODBC_TEXT_LEN/1.5)); - - rc = SQLGetData(hstmt,4,SQL_C_CHAR,(char *)data,TEST_ODBC_TEXT_LEN,&length); - mystmt(hstmt,rc); - fprintf(stdout,",%d)", length); - myassert(length == TEST_ODBC_TEXT_LEN-1); - row_count++; - - rc = SQLFetch(hstmt); - } - fprintf(stdout,"total rows: %d\n", row_count); - myassert(row_count == i); - - SQLFreeStmt(hstmt, SQL_UNBIND); - SQLFreeStmt(hstmt, SQL_CLOSE); - - rc = SQLExecDirect(hstmt,"DROP TABLE t_text_fetch",SQL_NTS); - mystmt(hstmt,rc); - - return OK; -} - - -/* To test SQLColumns misc case */ -DECLARE_TEST(t_columns) -{ - SQLSMALLINT NumPrecRadix, DataType, Nullable, DecimalDigits; - SQLLEN cbColumnSize, cbDecimalDigits, cbNumPrecRadix, - cbDatabaseName, cbDataType, cbNullable; - SQLRETURN rc; - SQLUINTEGER ColumnSize, i; - SQLUINTEGER ColumnCount= 7; - SQLCHAR ColumnName[MAX_NAME_LEN], DatabaseName[MAX_NAME_LEN]; - SQLINTEGER Values[7][5][2]= - { - { {5,2}, {6,4}, {0,2}, {10,2}, {1,2}}, - { {1,2}, {5,4}, {0,-1}, {10,-1}, {1,2}}, - { {12,2}, {20,4}, {0,-1}, {10,-1}, {0,2}}, - { {3,2}, {10,4}, {2,2}, {10,2}, {1,2}}, - { {-6,2}, {4,4}, {0,2}, {10,2}, {0,2}}, - { {4,2}, {11,4}, {0,2}, {10,2}, {0,2}}, - { {-6,2}, {4,4}, {0,2}, {10,2}, {0,2}} - }; - - SQLFreeStmt(hstmt, SQL_CLOSE); - SQLExecDirect(hstmt,"DROP TABLE test_column",SQL_NTS); - - rc = SQLExecDirect(hstmt,"CREATE TABLE test_column(col0 smallint, \ - col1 char(5),\ - col2 varchar(20) not null,\ - col3 decimal(10,2),\ - col4 tinyint not null,\ - col5 integer primary key,\ - col6 tinyint not null unique auto_increment)",SQL_NTS); - mystmt(hstmt,rc); - - mystmt(hstmt,rc); - - rc= SQLSetStmtAttr(hstmt, SQL_ATTR_METADATA_ID, - (SQLPOINTER)SQL_FALSE, SQL_IS_UINTEGER); - mystmt(hstmt,rc); - - SQLSetStmtAttr(hstmt, SQL_ATTR_CURSOR_TYPE, (SQLPOINTER) SQL_CURSOR_STATIC, 0); - - rc= SQLGetConnectAttr(hdbc, SQL_ATTR_CURRENT_CATALOG,(SQLCHAR *)DatabaseName, - MAX_NAME_LEN, &cbDatabaseName);/* Current Catalog */ - mycon(hdbc,rc); - - for (i=0; i< ColumnCount; i++) - { - sprintf(ColumnName,"col%d",i); - - rc= SQLColumns(hstmt, - (SQLCHAR *)DatabaseName, (SQLUSMALLINT)cbDatabaseName, - SQL_NULL_HANDLE, 0, - (SQLCHAR *)"test_column", SQL_NTS, - (SQLCHAR *)ColumnName, SQL_NTS); - mystmt(hstmt,rc); - - /* 5 -- Data type */ - rc= SQLBindCol(hstmt, 5, SQL_C_SSHORT, &DataType, 0, &cbDataType); - mystmt(hstmt,rc); - - /* 7 -- Column Size */ - rc= SQLBindCol(hstmt, 7, SQL_C_ULONG, &ColumnSize, 0, &cbColumnSize); - mystmt(hstmt,rc); - - /* 9 -- Decimal Digits */ - rc= SQLBindCol(hstmt, 9, SQL_C_SSHORT, &DecimalDigits, 0, &cbDecimalDigits); - mystmt(hstmt,rc); - - /* 10 -- Num Prec Radix */ - rc= SQLBindCol(hstmt, 10, SQL_C_SSHORT, &NumPrecRadix, 0, &cbNumPrecRadix); - mystmt(hstmt,rc); - - /* 11 -- Nullable */ - rc= SQLBindCol(hstmt, 11, SQL_C_SSHORT, &Nullable, 0, &cbNullable); - mystmt(hstmt,rc); - - rc= SQLFetch(hstmt); - mystmt(hstmt,rc); - - fprintf(stdout,"Column %s:\n", ColumnName); - fprintf(stdout,"\t DataType = %d(%d)\n", DataType, cbDataType); - fprintf(stdout,"\t ColumnSize = %d(%d)\n", ColumnSize, cbColumnSize); - fprintf(stdout,"\t DecimalDigits= %d(%d)\n", DecimalDigits, cbDecimalDigits); - fprintf(stdout,"\t NumPrecRadix = %d(%d)\n", NumPrecRadix, cbNumPrecRadix); - fprintf(stdout,"\t Nullable = %s(%d)\n\n", - Nullable == SQL_NO_NULLS ? "NO": "YES", cbNullable); - - myassert(DataType == Values[i][0][0]); - myassert(cbDataType == Values[i][0][1]); - - myassert(ColumnSize == Values[i][1][0]); - myassert(cbColumnSize == Values[i][1][1]); - - myassert(DecimalDigits == Values[i][2][0]); - myassert(cbDecimalDigits == Values[i][2][1]); - - myassert(NumPrecRadix == Values[i][3][0]); - myassert(cbNumPrecRadix == Values[i][3][1]); - - myassert(Nullable == Values[i][4][0]); - myassert(cbNullable == Values[i][4][1]); - - rc= SQLFetch(hstmt); - myassert(rc == SQL_NO_DATA); - - SQLFreeStmt(hstmt,SQL_UNBIND); - SQLFreeStmt(hstmt,SQL_CLOSE); - } - - SQLFreeStmt(hstmt,SQL_UNBIND); - SQLFreeStmt(hstmt,SQL_CLOSE); - - rc = SQLExecDirect(hstmt,"DROP TABLE test_column",SQL_NTS); - mystmt(hstmt,rc); - SQLFreeStmt(hstmt,SQL_CLOSE); - - return OK; -} - - -/* To test a convertion type */ -DECLARE_TEST(t_convert_type) -{ - SQLRETURN rc; - SQLSMALLINT SqlType, DateType; - SQLCHAR ColName[MAX_NAME_LEN]; - SQLCHAR DbVersion[MAX_NAME_LEN]; - SQLINTEGER OdbcVersion; - - SQLFreeStmt(hstmt, SQL_CLOSE); - - rc = SQLGetEnvAttr(henv,SQL_ATTR_ODBC_VERSION,&OdbcVersion,0,NULL); - myenv(henv,rc); - - fprintf(stdout,"odbc version:\n"); - if (OdbcVersion == SQL_OV_ODBC2) - { - fprintf(stdout," SQL_OV_ODBC2"); - DateType= SQL_DATE; - } - else - { - fprintf(stdout," SQL_OV_ODBC3"); - DateType= SQL_TYPE_DATE; - } - - rc = SQLGetInfo(hdbc,SQL_DBMS_VER,(SQLCHAR *)&DbVersion,MAX_NAME_LEN,NULL); - mycon(hdbc,rc); - - SQLExecDirect(hstmt,"DROP TABLE t_convert",SQL_NTS); - - rc = SQLExecDirect(hstmt,"CREATE TABLE t_convert(col0 integer, \ - col1 date,\ - col2 char(10))",SQL_NTS); - mystmt(hstmt,rc); - - rc = SQLExecDirect(hstmt,"INSERT INTO t_convert VALUES(10,'2002-10-24','venu')",SQL_NTS); - mystmt(hstmt,rc); - - rc = SQLExecDirect(hstmt,"INSERT INTO t_convert VALUES(20,'2002-10-23','venu1')",SQL_NTS); - mystmt(hstmt,rc); - - rc = SQLExecDirect(hstmt,"INSERT INTO t_convert VALUES(30,'2002-10-25','venu2')",SQL_NTS); - mystmt(hstmt,rc); - - rc = SQLExecDirect(hstmt,"INSERT INTO t_convert VALUES(40,'2002-10-24','venu3')",SQL_NTS); - mystmt(hstmt,rc); - - rc = SQLExecDirect(hstmt,"SELECT MAX(col0) FROM t_convert",SQL_NTS); - mystmt(hstmt,rc); - - rc = SQLDescribeCol(hstmt,1,(SQLCHAR *)&ColName,MAX_NAME_LEN,NULL,&SqlType,NULL,NULL,NULL); - mystmt(hstmt,rc); - - fprintf(stdout,"MAX(col0): %d\n", SqlType); - myassert(SqlType == SQL_INTEGER); - - SQLFreeStmt(hstmt,SQL_CLOSE); - - rc = SQLExecDirect(hstmt,"SELECT MAX(col1) FROM t_convert",SQL_NTS); - mystmt(hstmt,rc); - - rc = SQLDescribeCol(hstmt,1,(SQLCHAR *)&ColName,MAX_NAME_LEN,NULL,&SqlType,NULL,NULL,NULL); - mystmt(hstmt,rc); - - fprintf(stdout,"MAX(col1): %d\n", SqlType); - myassert(SqlType == DateType); - - SQLFreeStmt(hstmt,SQL_CLOSE); - - rc = SQLExecDirect(hstmt,"SELECT MAX(col2) FROM t_convert",SQL_NTS); - mystmt(hstmt,rc); - - rc = SQLDescribeCol(hstmt,1,(SQLCHAR *)&ColName,MAX_NAME_LEN,NULL,&SqlType,NULL,NULL,NULL); - mystmt(hstmt,rc); - - fprintf(stdout,"MAX(col0): %d\n", SqlType); - - SQLFreeStmt(hstmt,SQL_CLOSE); - - if (strncmp(DbVersion,"4.",2) >= 0) - { - rc = SQLExecDirect(hstmt,"SELECT CAST(MAX(col1) AS DATE) AS col1 FROM t_convert",SQL_NTS); - mystmt(hstmt,rc); - - rc = SQLDescribeCol(hstmt,1,(SQLCHAR *)&ColName,MAX_NAME_LEN,NULL,&SqlType,NULL,NULL,NULL); - mystmt(hstmt,rc); - - fprintf(stdout,"CAST(MAX(col1) AS DATE): %d\n", SqlType); - myassert(SqlType == DateType); - - SQLFreeStmt(hstmt,SQL_CLOSE); - - rc = SQLExecDirect(hstmt,"SELECT CONVERT(MAX(col1),DATE) AS col1 FROM t_convert",SQL_NTS); - mystmt(hstmt,rc); - - rc = SQLDescribeCol(hstmt,1,(SQLCHAR *)&ColName,MAX_NAME_LEN,NULL,&SqlType,NULL,NULL,NULL); - mystmt(hstmt,rc); - - fprintf(stdout,"CONVERT(MAX(col1),DATE): %d\n", SqlType); - myassert(SqlType == DateType); - - SQLFreeStmt(hstmt,SQL_CLOSE); - - rc = SQLExecDirect(hstmt,"SELECT CAST(MAX(col1) AS CHAR) AS col1 FROM t_convert",SQL_NTS); - mystmt(hstmt,rc); - - rc = SQLDescribeCol(hstmt,1,(SQLCHAR *)&ColName,MAX_NAME_LEN,NULL,&SqlType,NULL,NULL,NULL); - mystmt(hstmt,rc); - - fprintf(stdout,"CAST(MAX(col1) AS CHAR): %d\n", SqlType); - myassert(SqlType == SQL_VARCHAR || SqlType == SQL_LONGVARCHAR); - - SQLFreeStmt(hstmt,SQL_CLOSE); - } - - rc = SQLExecDirect(hstmt,"DROP TABLE t_convert",SQL_NTS); - mystmt(hstmt,rc); - - SQLFreeStmt(hstmt,SQL_CLOSE); - - return OK; -} - -/* Test the bug when two stmts are used with the don't cache results */ -DECLARE_TEST(t_cache_bug) -{ - SQLRETURN rc; - SQLHENV henv1; - SQLHDBC hdbc1; - SQLHSTMT hstmt11, hstmt12; - SQLCHAR conn[MAX_NAME_LEN]; - - sprintf(conn,"DSN=%s;USER=%s;PASSWORD=%s;OPTION=1048579", - mydsn,myuid,mypwd); - if (mysock != NULL) - { - strcat(conn, ";SOCKET="); - strcat(conn, mysock); - } - mydrvconnect(&henv1,&hdbc1,&hstmt11,conn); - - tmysql_exec(hstmt11,"drop table t_cache"); - rc = tmysql_exec(hstmt11,"create table t_cache(id int)"); - mystmt(hstmt11,rc); - - rc = tmysql_exec(hstmt11,"insert into t_cache values(1)"); - mystmt(hstmt11,rc); - - rc = tmysql_exec(hstmt11,"insert into t_cache values(2)"); - mystmt(hstmt11,rc); - - rc = tmysql_exec(hstmt11,"insert into t_cache values(3)"); - mystmt(hstmt11,rc); - - rc = tmysql_exec(hstmt11,"insert into t_cache values(4)"); - mystmt(hstmt11,rc); - - rc = tmysql_exec(hstmt11,"insert into t_cache values(5)"); - mystmt(hstmt11,rc); - - rc = SQLExecDirect(hstmt11,"select * from t_cache",SQL_NTS); - mystmt(hstmt11,rc); - - rc = SQLFetch(hstmt11); - mystmt(hstmt11,rc); - - rc = SQLFetch(hstmt11); - mystmt(hstmt11,rc); - - rc = SQLAllocHandle(SQL_HANDLE_STMT,hdbc1,&hstmt12); - mycon(hdbc1,rc); - - rc = SQLColumns(hstmt12,test_db,SQL_NTS, - NULL,0,"t_cache",SQL_NTS, - NULL,0); - mystmt(hstmt12,rc); - - rc = SQLFetch(hstmt12); - mystmt(hstmt12,rc); - - rc = SQLFetch(hstmt11); - mystmt(hstmt11,rc); - - rc = SQLFetch(hstmt12); - myassert(rc == SQL_NO_DATA); - - rc = SQLFetch(hstmt11); - mystmt(hstmt12,rc); - - rc = SQLFreeHandle(SQL_HANDLE_STMT,hstmt12); - mystmt(hstmt12,rc); - - rc = SQLFetch(hstmt11); - mystmt(hstmt12,rc); - - rc = SQLFetch(hstmt11); - myassert(rc == SQL_NO_DATA); - - rc = SQLFreeStmt(hstmt11, SQL_DROP); - mystmt(hstmt11,rc); - - rc = SQLDisconnect(hdbc1); - mycon(hdbc1,rc); - - rc = SQLFreeConnect(hdbc1); - mycon(hdbc1,rc); - - rc = SQLFreeEnv(henv1); - myenv(henv1,rc); - - return OK; -} - - -/* Test the bug when two stmts are used with the don't cache results */ -DECLARE_TEST(t_non_cache_bug) -{ - SQLRETURN rc; - SQLHENV henv1; - SQLHDBC hdbc1; - SQLHSTMT hstmt11, hstmt12; - SQLCHAR conn[MAX_NAME_LEN]; - - sprintf(conn,"DSN=%s;USER=%s;PASSWORD=%s;OPTION=3", - mydsn,myuid,mypwd); - if (mysock != NULL) - { - strcat(conn, ";SOCKET="); - strcat(conn, mysock); - } - mydrvconnect(&henv1,&hdbc1,&hstmt11,conn); - - tmysql_exec(hstmt11,"drop table t_cache"); - rc = tmysql_exec(hstmt11,"create table t_cache(id int)"); - mystmt(hstmt11,rc); - - rc = tmysql_exec(hstmt11,"insert into t_cache values(1)"); - mystmt(hstmt11,rc); - - rc = tmysql_exec(hstmt11,"insert into t_cache values(2)"); - mystmt(hstmt11,rc); - - rc = tmysql_exec(hstmt11,"insert into t_cache values(3)"); - mystmt(hstmt11,rc); - - rc = tmysql_exec(hstmt11,"insert into t_cache values(4)"); - mystmt(hstmt11,rc); - - rc = tmysql_exec(hstmt11,"insert into t_cache values(5)"); - mystmt(hstmt11,rc); - - rc = SQLExecDirect(hstmt11,"select * from t_cache",SQL_NTS); - mystmt(hstmt11,rc); - - rc = SQLFetch(hstmt11); - mystmt(hstmt11,rc); - - rc = SQLFetch(hstmt11); - mystmt(hstmt11,rc); - - rc = SQLAllocHandle(SQL_HANDLE_STMT,hdbc1,&hstmt12); - mycon(hdbc1,rc); - - rc = SQLColumns(hstmt12,test_db,SQL_NTS, - NULL,0,"t_cache",SQL_NTS, - NULL,0); - mystmt(hstmt12,rc); - - rc = SQLFetch(hstmt12); - mystmt(hstmt12,rc); - - rc = SQLFetch(hstmt11); - mystmt(hstmt11,rc); - - rc = SQLFetch(hstmt12); - myassert(rc == SQL_NO_DATA); - - rc = SQLFetch(hstmt11); - mystmt(hstmt12,rc); - - rc = SQLFreeHandle(SQL_HANDLE_STMT,hstmt12); - mystmt(hstmt12,rc); - - rc = SQLFetch(hstmt11); - mystmt(hstmt12,rc); - - rc = SQLFetch(hstmt11); - myassert(rc == SQL_NO_DATA); - - rc = SQLFreeStmt(hstmt11, SQL_DROP); - mystmt(hstmt11,rc); - - rc = SQLDisconnect(hdbc1); - mycon(hdbc1,rc); - - rc = SQLFreeConnect(hdbc1); - mycon(hdbc1,rc); - - rc = SQLFreeEnv(henv1); - myenv(henv1,rc); - - return OK; -} - - -/* Test the bug when blob size > 8k */ -DECLARE_TEST(t_blob_bug) -{ - SQLRETURN rc; - SQLCHAR *data; - SQLINTEGER i; - SQLLEN length; - const SQLINTEGER max_blob_size=1024*100; - - SQLExecDirect(hstmt,"drop table t_blob",SQL_NTS); - rc = SQLExecDirect(hstmt,"create table t_blob(blb long varbinary)",SQL_NTS); - mystmt(hstmt,rc); - - rc = SQLPrepare(hstmt,"insert into t_blob values(?)",SQL_NTS); - mystmt(hstmt,rc); - - if (!(data = (SQLCHAR *)calloc(max_blob_size,sizeof(SQLCHAR)))) - { - SQLFreeStmt(hstmt,SQL_RESET_PARAMS); - SQLFreeStmt(hstmt,SQL_CLOSE); - return; - } - - rc = SQLBindParameter(hstmt,1,SQL_PARAM_INPUT,SQL_C_CHAR,SQL_VARBINARY, - 0,0,data,0,&length); - mystmt(hstmt,rc); - - memset(data,'X',max_blob_size); - - fprintf(stdout,"inserting %d rows\n\n", max_blob_size / 1024); - for (length=1024; length <= max_blob_size; length+= 1024) - { - fprintf(stdout,"\r %d", length/1024); - rc = SQLExecute(hstmt); - mystmt(hstmt,rc); - } - - SQLFreeStmt(hstmt,SQL_RESET_PARAMS); - SQLFreeStmt(hstmt,SQL_CLOSE); - - rc = SQLExecDirect(hstmt,"SELECT length(blb) FROM t_blob",SQL_NTS); - mystmt(hstmt,rc); - - rc = SQLBindCol(hstmt,1,SQL_C_LONG,&length,0,NULL); - mystmt(hstmt,rc); - - for (i= 1; i <= max_blob_size/1024; i++) - { - rc = SQLFetch(hstmt); - mystmt(hstmt,rc); - - fprintf(stdout,"row %d length: %d\n", i, length); - myassert(length == i * 1024); - } - rc = SQLFetch(hstmt); - myassert(rc == SQL_NO_DATA); - - free(data); - - SQLFreeStmt(hstmt,SQL_UNBIND); - SQLFreeStmt(hstmt,SQL_CLOSE); - - return OK; -} - - -/* Test the bug SQLTables */ -typedef struct t_table_bug -{ - SQLCHAR szColName[MAX_NAME_LEN]; - SQLSMALLINT pcbColName; - SQLSMALLINT pfSqlType; - SQLUINTEGER pcbColDef; - SQLSMALLINT pibScale; - SQLSMALLINT pfNullable; -} t_describe_col; - - -t_describe_col t_tables_bug_data[5] = -{ - {"TABLE_CAT", 9, SQL_VARCHAR, MYSQL_NAME_LEN, 0, SQL_NULLABLE}, - {"TABLE_SCHEM",11, SQL_VARCHAR, MYSQL_NAME_LEN, 0, SQL_NULLABLE}, - {"TABLE_NAME", 10, SQL_VARCHAR, MYSQL_NAME_LEN, 0, SQL_NULLABLE}, - {"TABLE_TYPE", 10, SQL_VARCHAR, MYSQL_NAME_LEN, 0, SQL_NULLABLE}, - {"REMARKS", 7, SQL_VARCHAR, MYSQL_NAME_LEN, 0, SQL_NULLABLE}, -}; - - -DECLARE_TEST(t_tables_bug) -{ - SQLRETURN rc; - SQLSMALLINT i, ColumnCount, pcbColName, pfSqlType, pibScale, pfNullable; - SQLUINTEGER pcbColDef; - SQLCHAR szColName[MAX_NAME_LEN]; - - SQLFreeStmt(hstmt, SQL_CLOSE); - - rc = SQLTables(hstmt,NULL,0,NULL,0,NULL,0,"'TABLE'",SQL_NTS); - mystmt(hstmt,rc); - - rc = SQLNumResultCols(hstmt,&ColumnCount); - mystmt(hstmt,rc); - - fprintf(stdout, "total columns in SQLTables: %d\n", ColumnCount); - myassert(ColumnCount == 5); - - for (i= 1; i <= ColumnCount; i++) - { - rc = SQLDescribeCol(hstmt, (SQLUSMALLINT)i, - szColName,MAX_NAME_LEN,&pcbColName, - &pfSqlType,&pcbColDef,&pibScale,&pfNullable); - mystmt(hstmt,rc); - - fprintf(stdout, "Column Number'%d':\n", i); - fprintf(stdout, "\t Column Name : %s\n", szColName); - fprintf(stdout, "\t NameLengh : %d\n", pcbColName); - fprintf(stdout, "\t DataType : %d\n", pfSqlType); - fprintf(stdout, "\t ColumnSize : %d\n", pcbColDef); - fprintf(stdout, "\t DecimalDigits : %d\n", pibScale); - fprintf(stdout, "\t Nullable : %d\n", pfNullable); - - myassert(strcmp(t_tables_bug_data[i-1].szColName,szColName) == 0); - myassert(t_tables_bug_data[i-1].pcbColName == pcbColName); - myassert(t_tables_bug_data[i-1].pfSqlType == pfSqlType); - myassert(t_tables_bug_data[i-1].pcbColDef == pcbColDef); - myassert(t_tables_bug_data[i-1].pibScale == pibScale); - myassert(t_tables_bug_data[i-1].pfNullable == pfNullable); - } - SQLFreeStmt(hstmt,SQL_CLOSE); - - return OK; -} - - -/* Test for a simple SQLPutData and SQLParamData handling for longtext */ -DECLARE_TEST(t_putdata) -{ - SQLRETURN rc; - SQLLEN pcbLength; - SQLINTEGER c1; - SQLCHAR data[255]; - SQLPOINTER token; - - SQLExecDirect(hstmt,"drop table t_putdata",SQL_NTS); - rc = SQLExecDirect(hstmt,"create table t_putdata(c1 int, c2 long varchar)",SQL_NTS); - mystmt(hstmt,rc); - - rc = SQLPrepare(hstmt,"insert into t_putdata values(?,?)",SQL_NTS); - mystmt(hstmt,rc); - - rc = SQLBindParameter(hstmt,1,SQL_PARAM_INPUT,SQL_C_LONG, - SQL_INTEGER,0,0,&c1,0,NULL); - - rc = SQLBindParameter(hstmt,2,SQL_PARAM_INPUT,SQL_C_CHAR, - SQL_LONGVARCHAR,0,0, - (SQLPOINTER)1,0,&pcbLength); - - pcbLength = SQL_LEN_DATA_AT_EXEC(0); - - c1 = 10; - rc = SQLExecute(hstmt); - myassert(rc == SQL_NEED_DATA); - - rc = SQLParamData(hstmt, &token); - myassert(rc == SQL_NEED_DATA); - - strcpy(data,"mysql ab"); - rc = SQLPutData(hstmt,data,6); - mystmt(hstmt,rc); - - strcpy(data,"- the open source database company"); - rc = SQLPutData(hstmt,data,strlen(data)); - mystmt(hstmt,rc); - - rc = SQLParamData(hstmt, &token); - mystmt(hstmt,rc); - - SQLFreeStmt(hstmt, SQL_RESET_PARAMS); - SQLFreeStmt(hstmt, SQL_CLOSE); - - rc = SQLExecDirect(hstmt,"select c2 from t_putdata where c1= 10",SQL_NTS); - mystmt(hstmt,rc); - - rc = SQLFetch(hstmt); - mystmt(hstmt,rc); - - pcbLength= 0; - rc = SQLGetData(hstmt, 1, SQL_C_CHAR, data, sizeof(data), &pcbLength); - mystmt(hstmt,rc); - fprintf(stdout,"data: %s(%d)\n", data, pcbLength); - myassert(strcmp(data,"mysql - the open source database company")==0); - myassert(pcbLength == 40); - - SQLFreeStmt(hstmt, SQL_UNBIND); - SQLFreeStmt(hstmt, SQL_CLOSE); - - return OK; -} - -/* Test for a simple SQLPutData and SQLParamData handling for longtext */ -DECLARE_TEST(t_putdata1) -{ - SQLRETURN rc; - SQLLEN pcbLength; - SQLINTEGER c1; - SQLCHAR data[255]; - SQLPOINTER token; - - SQLExecDirect(hstmt,"drop table t_putdata",SQL_NTS); - rc = SQLExecDirect(hstmt,"create table t_putdata(c1 int, c2 long varchar)",SQL_NTS); - mystmt(hstmt,rc); - - rc = SQLExecDirect(hstmt,"insert into t_putdata values(10,'venu')",SQL_NTS); - mystmt(hstmt,rc); - - rc = SQLPrepare(hstmt,"update t_putdata set c2= ? where c1 = ?",SQL_NTS); - mystmt(hstmt,rc); - - rc = SQLBindParameter(hstmt,1,SQL_PARAM_INPUT,SQL_C_CHAR, - SQL_LONGVARCHAR,0,0, - (SQLPOINTER)1,0,&pcbLength); - - rc = SQLBindParameter(hstmt,2,SQL_PARAM_INPUT,SQL_C_LONG, - SQL_INTEGER,0,0,&c1,0,NULL); - - pcbLength = SQL_LEN_DATA_AT_EXEC(0); - - c1 = 10; - rc = SQLExecute(hstmt); - myassert(rc == SQL_NEED_DATA); - - rc = SQLParamData(hstmt, &token); - myassert(rc == SQL_NEED_DATA); - - strcpy(data,"mysql ab"); - rc = SQLPutData(hstmt,data,6); - mystmt(hstmt,rc); - - strcpy(data,"- the open source database company"); - rc = SQLPutData(hstmt,data,strlen(data)); - mystmt(hstmt,rc); - - rc = SQLParamData(hstmt, &token); - mystmt(hstmt,rc); - - SQLFreeStmt(hstmt, SQL_RESET_PARAMS); - SQLFreeStmt(hstmt, SQL_CLOSE); - - rc = SQLExecDirect(hstmt,"select c2 from t_putdata where c1= 10",SQL_NTS); - mystmt(hstmt,rc); - - rc = SQLFetch(hstmt); - mystmt(hstmt,rc); - - pcbLength= 0; - rc = SQLGetData(hstmt, 1, SQL_C_CHAR, data, sizeof(data), &pcbLength); - mystmt(hstmt,rc); - fprintf(stdout,"data: %s(%d)\n", data, pcbLength); - myassert(strcmp(data,"mysql - the open source database company")==0); - myassert(pcbLength == 40); - - SQLFreeStmt(hstmt, SQL_UNBIND); - SQLFreeStmt(hstmt, SQL_CLOSE); - - return OK; -} - - -/* Test for a simple SQLPutData and SQLParamData handling for longtext */ -DECLARE_TEST(t_putdata2) -{ - SQLRETURN rc; - SQLLEN pcbLength; - SQLINTEGER c1; - SQLCHAR data[255]; - SQLPOINTER token; - - SQLExecDirect(hstmt,"drop table t_putdata",SQL_NTS); - rc = SQLExecDirect(hstmt,"create table t_putdata(c1 int, c2 long varchar, c3 long varchar)",SQL_NTS); - mystmt(hstmt,rc); - - rc = SQLPrepare(hstmt,"insert into t_putdata values(?,?,?)",SQL_NTS); - mystmt(hstmt,rc); - - rc = SQLBindParameter(hstmt,1,SQL_PARAM_INPUT,SQL_C_LONG, - SQL_INTEGER,0,0,&c1,0,NULL); - - rc = SQLBindParameter(hstmt,2,SQL_PARAM_INPUT,SQL_C_CHAR, - SQL_LONGVARCHAR,0,0, - (SQLPOINTER)1,0,&pcbLength); - - rc = SQLBindParameter(hstmt,3,SQL_PARAM_INPUT,SQL_C_CHAR, - SQL_LONGVARCHAR,0,0, - (SQLPOINTER)1,0,&pcbLength); - - pcbLength = SQL_LEN_DATA_AT_EXEC(0); - - c1 = 10; - rc = SQLExecute(hstmt); - myassert(rc == SQL_NEED_DATA); - - rc = SQLParamData(hstmt, &token); - myassert(rc == SQL_NEED_DATA); - - strcpy(data,"mysql ab"); - rc = SQLPutData(hstmt,data,6); - mystmt(hstmt,rc); - - strcpy(data,"- the open source database company"); - rc = SQLPutData(hstmt,data,strlen(data)); - mystmt(hstmt,rc); - - rc = SQLParamData(hstmt, &token); - myassert(rc == SQL_NEED_DATA); - - strcpy(data,"MySQL AB"); - rc = SQLPutData(hstmt,data, 8); - mystmt(hstmt,rc); - - rc = SQLParamData(hstmt, &token); - mystmt(hstmt,rc); - - SQLFreeStmt(hstmt, SQL_RESET_PARAMS); - SQLFreeStmt(hstmt, SQL_CLOSE); - - rc = SQLExecDirect(hstmt,"select c2,c3 from t_putdata where c1= 10",SQL_NTS); - mystmt(hstmt,rc); - - rc = SQLFetch(hstmt); - mystmt(hstmt,rc); - - pcbLength= 0; - rc = SQLGetData(hstmt, 1, SQL_C_CHAR, data, sizeof(data), &pcbLength); - mystmt(hstmt,rc); - fprintf(stdout,"data: %s(%d)\n", data, pcbLength); - myassert(strcmp(data,"mysql - the open source database company")==0); - myassert(pcbLength == 40); - - pcbLength= 0; - rc = SQLGetData(hstmt, 2, SQL_C_CHAR, data, sizeof(data), &pcbLength); - mystmt(hstmt,rc); - fprintf(stdout,"data: %s(%d)\n", data, pcbLength); - myassert(strcmp(data,"MySQL AB")==0); - myassert(pcbLength == 8); - - SQLFreeStmt(hstmt, SQL_RESET_PARAMS); - SQLFreeStmt(hstmt, SQL_UNBIND); - SQLFreeStmt(hstmt, SQL_CLOSE); - - return OK; -} - - -/* Test for a simple time struct */ -DECLARE_TEST(t_time1) -{ - SQLRETURN rc; - SQL_TIME_STRUCT tt; - SQLCHAR data[30]; - SQLLEN length; - - SQLExecDirect(hstmt,"drop table t_time",SQL_NTS); - rc = SQLExecDirect(hstmt,"create table t_time(t time, t1 timestamp, t2 datetime, t3 date)",SQL_NTS); - mystmt(hstmt,rc); - - rc = SQLPrepare(hstmt,"insert into t_time(t) values(?)",SQL_NTS); - mystmt(hstmt,rc); - - rc = SQLBindParameter(hstmt,1,SQL_PARAM_INPUT,SQL_C_TYPE_TIME, - SQL_TIME,0,0,&tt,0,NULL); - - - tt.hour= 00; - tt.minute= 00; - tt.second= 03; - - rc = SQLExecute(hstmt); - mystmt(hstmt, rc); - - tt.hour= 01; - tt.minute= 00; - tt.second= 00; - - rc = SQLExecute(hstmt); - mystmt(hstmt, rc); - - tt.hour= 19; - tt.minute= 00; - tt.second= 00; - - rc = SQLExecute(hstmt); - mystmt(hstmt, rc); - - tt.hour= 01; - tt.minute= 01; - tt.second= 00; - - rc = SQLExecute(hstmt); - mystmt(hstmt, rc); - - tt.hour= 01; - tt.minute= 00; - tt.second= 01; - - rc = SQLExecute(hstmt); - mystmt(hstmt, rc); - - tt.hour= 00; - tt.minute= 01; - tt.second= 00; - - rc = SQLExecute(hstmt); - mystmt(hstmt, rc); - - tt.hour= 00; - tt.minute= 11; - tt.second= 12; - - rc = SQLExecute(hstmt); - mystmt(hstmt, rc); - - tt.hour= 01; - tt.minute= 01; - tt.second= 01; - - rc = SQLExecute(hstmt); - mystmt(hstmt, rc); - - tt.hour= 00; - tt.minute= 00; - tt.second= 00; - - rc = SQLExecute(hstmt); - mystmt(hstmt, rc); - - tt.hour= 10; - tt.minute= 11; - tt.second= 12; - - rc = SQLExecute(hstmt); - mystmt(hstmt, rc); - - SQLFreeStmt(hstmt, SQL_RESET_PARAMS); - SQLFreeStmt(hstmt, SQL_CLOSE); - - rc = SQLExecDirect(hstmt,"select t from t_time",SQL_NTS); - mystmt(hstmt,rc); - - rc = SQLFetch(hstmt); - mystmt(hstmt,rc); - - rc = SQLGetData(hstmt, 1, SQL_C_CHAR, data, sizeof(data), &length); - mystmt(hstmt,rc); - fprintf(stdout,"time: %s(%d)\n", data, length); - myassert(strcmp(data,"00:00:03")==0); - myassert(length == 8); - - rc = SQLFetch(hstmt); - mystmt(hstmt,rc); - - rc = SQLGetData(hstmt, 1, SQL_C_CHAR, data, sizeof(data), &length); - mystmt(hstmt,rc); - fprintf(stdout,"time: %s(%d)\n", data, length); - myassert(strcmp(data,"01:00:00")==0); - myassert(length == 8); - - rc = SQLFetch(hstmt); - mystmt(hstmt,rc); - - rc = SQLGetData(hstmt, 1, SQL_C_CHAR, data, sizeof(data), &length); - mystmt(hstmt,rc); - fprintf(stdout,"time: %s(%d)\n", data, length); - myassert(strcmp(data,"19:00:00")==0); - myassert(length == 8); - - rc = SQLFetch(hstmt); - mystmt(hstmt,rc); - - rc = SQLGetData(hstmt, 1, SQL_C_CHAR, data, sizeof(data), &length); - mystmt(hstmt,rc); - fprintf(stdout,"time: %s(%d)\n", data, length); - myassert(strcmp(data,"01:01:00")==0); - myassert(length == 8); - - rc = SQLFetch(hstmt); - mystmt(hstmt,rc); - - rc = SQLGetData(hstmt, 1, SQL_C_CHAR, data, sizeof(data), &length); - mystmt(hstmt,rc); - fprintf(stdout,"time: %s(%d)\n", data, length); - myassert(strcmp(data,"01:00:01")==0); - myassert(length == 8); - - rc = SQLFetch(hstmt); - mystmt(hstmt,rc); - - rc = SQLGetData(hstmt, 1, SQL_C_CHAR, data, sizeof(data), &length); - mystmt(hstmt,rc); - fprintf(stdout,"time: %s(%d)\n", data, length); - myassert(strcmp(data,"00:01:00")==0); - myassert(length == 8); - - rc = SQLFetch(hstmt); - mystmt(hstmt,rc); - - rc = SQLGetData(hstmt, 1, SQL_C_CHAR, data, sizeof(data), &length); - mystmt(hstmt,rc); - fprintf(stdout,"time: %s(%d)\n", data, length); - myassert(strcmp(data,"00:11:12")==0); - myassert(length == 8); - - rc = SQLFetch(hstmt); - mystmt(hstmt,rc); - - rc = SQLGetData(hstmt, 1, SQL_C_CHAR, data, sizeof(data), &length); - mystmt(hstmt,rc); - fprintf(stdout,"time: %s(%d)\n", data, length); - myassert(strcmp(data,"01:01:01")==0); - myassert(length == 8); - - rc = SQLFetch(hstmt); - mystmt(hstmt,rc); - - rc = SQLGetData(hstmt, 1, SQL_C_CHAR, data, sizeof(data), &length); - mystmt(hstmt,rc); - fprintf(stdout,"time: %s(%d)\n", data, length); - - myassert(strcmp(data,"00:00:00")==0); - myassert(length == 8); - - rc = SQLFetch(hstmt); - mystmt(hstmt,rc); - - rc = SQLGetData(hstmt, 1, SQL_C_CHAR, data, sizeof(data), &length); - mystmt(hstmt,rc); - fprintf(stdout,"time: %s(%d)\n", data, length); - myassert(strcmp(data,"10:11:12")==0); - myassert(length == 8); - - rc = SQLFetch(hstmt); - myassert(rc == SQL_NO_DATA); - - SQLFreeStmt(hstmt, SQL_UNBIND); - SQLFreeStmt(hstmt, SQL_CLOSE); - - rc = SQLExecDirect(hstmt,"delete from t_time",SQL_NTS); - mystmt(hstmt,rc); - - rc = SQLExecDirect(hstmt,"insert into t_time(t1) values('2003-05-12 10:11:12')",SQL_NTS); - mystmt(hstmt,rc); - - rc = SQLExecDirect(hstmt,"select t1 from t_time", SQL_NTS); - mystmt(hstmt,rc); - - rc = SQLFetch(hstmt); - mystmt(hstmt,rc); - - rc = SQLGetData(hstmt, 1, SQL_C_TIME, &tt, sizeof(tt), &length); - mystmt(hstmt,rc); - fprintf(stdout,"time: %d:%d:%d(%d)\n", tt.hour, tt.minute, tt.second, length); - - myassert(tt.hour == 10 && tt.minute == 11 && tt.second == 12); - myassert(length == sizeof(SQL_TIME_STRUCT)); - - rc = SQLFetch(hstmt); - myassert(rc == SQL_NO_DATA); - - SQLFreeStmt(hstmt, SQL_UNBIND); - SQLFreeStmt(hstmt, SQL_CLOSE); - - rc = SQLExecDirect(hstmt,"delete from t_time",SQL_NTS); - mystmt(hstmt,rc); - - rc = SQLExecDirect(hstmt,"insert into t_time(t2) values('03-12-28 05:59:59')",SQL_NTS); - mystmt(hstmt,rc); - - rc = SQLExecDirect(hstmt,"select t2 from t_time", SQL_NTS); - mystmt(hstmt,rc); - - rc = SQLFetch(hstmt); - mystmt(hstmt,rc); - - rc = SQLGetData(hstmt, 1, SQL_C_TIME, &tt, sizeof(tt), &length); - mystmt(hstmt,rc); - fprintf(stdout,"time: %d:%d:%d(%d)\n", tt.hour, tt.minute, tt.second, length); - myassert(tt.hour == 05 && tt.minute == 59 && tt.second == 59); - myassert(length == sizeof(SQL_TIME_STRUCT)); - - rc = SQLFetch(hstmt); - myassert(rc == SQL_NO_DATA); - - SQLFreeStmt(hstmt, SQL_UNBIND); - SQLFreeStmt(hstmt, SQL_CLOSE); - - rc = SQLExecDirect(hstmt,"delete from t_time",SQL_NTS); - mystmt(hstmt,rc); - - rc = SQLExecDirect(hstmt,"insert into t_time(t3) values('2003-05-12 10:11:12')",SQL_NTS); - mystmt(hstmt,rc); - - rc = SQLExecDirect(hstmt,"select t3 from t_time", SQL_NTS); - mystmt(hstmt,rc); - - rc = SQLFetch(hstmt); - mystmt(hstmt,rc); - - rc = SQLGetData(hstmt, 1, SQL_C_TIME, &tt, sizeof(tt), &length); - mystmt(hstmt,rc); - fprintf(stdout,"time: %d:%d:%d(%d)\n", tt.hour, tt.minute, tt.second, length); - myassert(tt.hour == 00 || tt.minute == 00 || tt.second == 00); - myassert(length == sizeof(SQL_TIME_STRUCT)); - - rc = SQLFetch(hstmt); - myassert(rc == SQL_NO_DATA); - - SQLFreeStmt(hstmt, SQL_UNBIND); - SQLFreeStmt(hstmt, SQL_CLOSE); - - return OK; -} - - -/* test for SQL_ATTR_ROW_ARRAY_SIZE */ -DECLARE_TEST(t_row_array_size) -{ - SQLRETURN rc; - SQLINTEGER i, iarray[15]; - SQLLEN nrows; - const int max_rows=9; - - SQLExecDirect(hstmt,"drop table t_row_array_size",SQL_NTS); - - rc = SQLExecDirect(hstmt,"create table t_row_array_size(id int)",SQL_NTS); - mystmt(hstmt,rc); - - rc = SQLPrepare(hstmt,"insert into t_row_array_size values(?)",SQL_NTS); - mystmt(hstmt,rc); - - rc = SQLBindParameter(hstmt,1,SQL_PARAM_INPUT, SQL_C_ULONG, - SQL_INTEGER,0,0,&i,0,NULL); - mystmt(hstmt,rc); - - for( i = 1; i <= max_rows; i++ ) - { - rc = SQLExecute(hstmt); - mystmt(hstmt,rc); - } - - SQLFreeStmt(hstmt,SQL_RESET_PARAMS); - SQLFreeStmt(hstmt,SQL_CLOSE); - - rc = SQLEndTran(SQL_HANDLE_DBC,hdbc,SQL_COMMIT); - mycon(hdbc,rc); - - /* set row_size as 2 */ - rc = SQLSetStmtAttr(hstmt,SQL_ATTR_ROW_ARRAY_SIZE,(SQLPOINTER)2,SQL_IS_UINTEGER); - mystmt(hstmt,rc); - - rc = SQLSetStmtAttr(hstmt,SQL_ATTR_ROWS_FETCHED_PTR,&nrows,SQL_IS_POINTER); - mystmt(hstmt,rc); - - rc = SQLExecDirect(hstmt,"select * from t_row_array_size",SQL_NTS); - mystmt(hstmt,rc); - - rc = SQLBindCol(hstmt,1,SQL_C_LONG,&iarray,0,NULL); - mystmt(hstmt,rc); - - /* row 1-2 */ - rc = SQLFetchScroll(hstmt, SQL_FETCH_NEXT, 0); - mystmt(hstmt,rc); - my_assert(nrows == 2); - my_assert(iarray[0]==1); - my_assert(iarray[1]==2); - - /* row 3-4 */ - rc = SQLFetchScroll(hstmt, SQL_FETCH_NEXT, 0); - mystmt(hstmt,rc); - my_assert(nrows == 2); - my_assert(iarray[0]==3); - my_assert(iarray[1]==4); - - /* row 5-6 */ - rc = SQLFetchScroll(hstmt,SQL_FETCH_NEXT,1);/* 1 */ - mystmt(hstmt,rc); - my_assert(nrows == 2); - my_assert(iarray[0]==5); - my_assert(iarray[1]==6); - - /* row 7-8 */ - rc = SQLFetchScroll(hstmt, SQL_FETCH_NEXT, 0); - mystmt(hstmt,rc); - my_assert(nrows == 2); - my_assert(iarray[0]==7); - my_assert(iarray[1]==8); - - /* row 9 */ - rc = SQLFetchScroll(hstmt, SQL_FETCH_NEXT, 0); - mystmt(hstmt,rc); - my_assert(nrows == 1); - my_assert(iarray[0]==9); - - rc = SQLFetchScroll(hstmt, SQL_FETCH_NEXT, 0); - mystmt_err(hstmt,rc==SQL_NO_DATA_FOUND,rc); - - SQLFreeStmt(hstmt,SQL_UNBIND); - SQLFreeStmt(hstmt,SQL_CLOSE); - - rc = SQLSetStmtAttr(hstmt,SQL_ATTR_ROW_ARRAY_SIZE,(SQLPOINTER)1,0); - mystmt(hstmt,rc); - - rc = SQLSetStmtAttr(hstmt,SQL_ATTR_ROWS_FETCHED_PTR,(SQLPOINTER)0,SQL_IS_POINTER); - mystmt(hstmt,rc); - - return OK; -} - - -DECLARE_TEST(t_empty_str_bug) -{ - SQLRETURN rc; - SQLINTEGER id; - SQLLEN name_len, desc_len; - SQLCHAR name[20], desc[20]; - - tmysql_exec(hstmt,"drop table t_empty_str_bug"); - - rc = SQLTransact(NULL,hdbc,SQL_COMMIT); - mycon(hdbc,rc); - - rc = tmysql_exec(hstmt,"CREATE TABLE t_empty_str_bug(Id int NOT NULL,\ - Name varchar(10) default NULL, \ - Description varchar(10) default NULL, \ - PRIMARY KEY (Id))"); - mystmt(hstmt,rc); - - rc = SQLTransact(NULL,hdbc,SQL_COMMIT); - mycon(hdbc,rc); - - rc = SQLFreeStmt(hstmt,SQL_CLOSE); - mystmt(hstmt,rc); - - rc = SQLSetCursorName(hstmt,"venu",SQL_NTS); - mystmt(hstmt,rc); - - rc = tmysql_exec(hstmt,"select * from t_empty_str_bug"); - mystmt(hstmt,rc); - - rc = SQLBindCol(hstmt,1,SQL_C_LONG,&id,0,NULL); - mystmt(hstmt,rc); - - rc = SQLBindCol(hstmt,2,SQL_C_CHAR,&name,100,&name_len); - mystmt(hstmt,rc); - - rc = SQLBindCol(hstmt,3,SQL_C_CHAR,&desc,100,&desc_len); - mystmt(hstmt,rc); - - rc = SQLExtendedFetch(hstmt,SQL_FETCH_NEXT,1,NULL,NULL); - myassert(rc == SQL_NO_DATA_FOUND); - - id= 10; - strcpy(name,"MySQL AB");name_len= SQL_NTS; - strcpy(desc,"");desc_len= SQL_COLUMN_IGNORE; - - rc = SQLSetPos(hstmt,1,SQL_ADD,SQL_LOCK_NO_CHANGE); - mystmt(hstmt,rc); - - rc = SQLRowCount(hstmt,&name_len); - mystmt(hstmt,rc); - - fprintf(stdout," rows affected:%d\n",name_len); - myassert(name_len == 1); - - rc = SQLFreeStmt(hstmt,SQL_UNBIND); - mystmt(hstmt,rc); - - rc = SQLFreeStmt(hstmt,SQL_CLOSE); - mystmt(hstmt,rc); - - rc = tmysql_exec(hstmt,"select * from t_empty_str_bug"); - mystmt(hstmt,rc); - - my_assert( 1 == myresult(hstmt)); - - rc = SQLFreeStmt(hstmt,SQL_CLOSE); - mystmt(hstmt,rc); - - rc = tmysql_exec(hstmt,"select * from t_empty_str_bug"); - mystmt(hstmt,rc); - - rc = SQLExtendedFetch(hstmt,SQL_FETCH_ABSOLUTE,1,NULL,NULL); - mystmt(hstmt,rc); - - name[0]='\0'; - my_assert(10 == my_fetch_int(hstmt,1)); - my_assert(!strcmp((const char *)"MySQL AB",my_fetch_str(hstmt,name,2))); - my_assert(!strcmp((const char *)"MySQL AB",my_fetch_str(hstmt,name,3))); /* NULL */ - - rc = SQLFreeStmt(hstmt,SQL_CLOSE); - mystmt(hstmt,rc); - - return OK; -} - - -DECLARE_TEST(t_current_catalog) -{ - SQLCHAR cur_db[255], db[255]; - SQLRETURN rc; - SQLUINTEGER len; - - rc = SQLFreeStmt(hstmt,SQL_CLOSE); - mystmt(hstmt,rc); - - rc = SQLGetConnectAttr(hdbc, SQL_ATTR_CURRENT_CATALOG, (char *)db, 255, &len); - mycon(hdbc,rc); - fprintf(stdout,"current_catalog: %s (%ld)\n", db, len); - myassert(strcmp(db, "test") == 0 || strlen("test") == len); - - rc = SQLSetConnectAttr(hdbc, SQL_ATTR_CURRENT_CATALOG, (char *)db, SQL_NTS); - mycon(hdbc,rc); - - SQLExecDirect(hstmt, "DROP DATABASE t_odbc_test_cur_catalog", SQL_NTS); - - strcpy(cur_db, "t_odbc_test_cur_catalog"); - rc = SQLSetConnectAttr(hdbc, SQL_ATTR_CURRENT_CATALOG, (char *)cur_db, SQL_NTS); - mycon_r(hdbc,rc); - - rc = SQLExecDirect(hstmt, "CREATE DATABASE t_odbc_test_cur_catalog", SQL_NTS); - mystmt(hstmt,rc); - - strcpy(cur_db, "t_odbc_test_cur_catalog"); - rc = SQLSetConnectAttr(hdbc, SQL_ATTR_CURRENT_CATALOG, (char *)cur_db, SQL_NTS); - mycon(hdbc,rc); - - rc = SQLGetConnectAttr(hdbc, SQL_ATTR_CURRENT_CATALOG, (char *)db, 255, &len); - mycon(hdbc,rc); - fprintf(stdout,"current_catalog: %s (%ld)\n", db, len); - myassert(strcmp(cur_db, db) == 0 || strlen(cur_db) == len); - - strcpy(cur_db, "t_odbc_test_cur_catalog-test-12455"); - rc = SQLSetConnectAttr(hdbc, SQL_ATTR_CURRENT_CATALOG, (char *)cur_db, SQL_NTS); - mycon_r(hdbc,rc); - - rc = SQLSetConnectAttr(hdbc, SQL_ATTR_CURRENT_CATALOG, (char *)cur_db, len); - mycon(hdbc,rc); - - /* reset for further tests */ - rc = SQLSetConnectAttr(hdbc, SQL_ATTR_CURRENT_CATALOG, (char *)test_db, SQL_NTS); - mycon(hdbc,rc); - - rc = SQLExecDirect(hstmt, "DROP DATABASE t_odbc_test_cur_catalog", SQL_NTS); - mycon(hstmt,rc); - - return OK; -} - - -DECLARE_TEST(t_rows_fetched_ptr1) -{ - SQLRETURN rc; - SQLLEN rowsFetched, rowsSize; - SQLINTEGER i; - - SQLExecDirect(hstmt,"drop table t_rows_fetched_ptr",SQL_NTS); - - rc = SQLExecDirect(hstmt,"create table t_rows_fetched_ptr(a int)",SQL_NTS); - mystmt(hstmt,rc); - - rc = SQLExecDirect(hstmt,"insert into t_rows_fetched_ptr values(0)",SQL_NTS); - mystmt(hstmt,rc); - - rc = SQLExecDirect(hstmt,"insert into t_rows_fetched_ptr values(1)",SQL_NTS); - mystmt(hstmt,rc); - - rc = SQLExecDirect(hstmt,"insert into t_rows_fetched_ptr values(2)",SQL_NTS); - mystmt(hstmt,rc); - - rc = SQLExecDirect(hstmt,"insert into t_rows_fetched_ptr values(3)",SQL_NTS); - mystmt(hstmt,rc); - - rc = SQLExecDirect(hstmt,"insert into t_rows_fetched_ptr values(4)",SQL_NTS); - mystmt(hstmt,rc); - - rc = SQLExecDirect(hstmt,"insert into t_rows_fetched_ptr values(5)",SQL_NTS); - mystmt(hstmt,rc); - - rowsSize= 1; - rc = SQLSetStmtAttr(hstmt, SQL_ATTR_ROW_ARRAY_SIZE, (SQLPOINTER)rowsSize, 0); - mystmt(hstmt,rc); - - rc = SQLSetStmtAttr(hstmt, SQL_ATTR_ROWS_FETCHED_PTR, &rowsFetched, 0); - mystmt(hstmt,rc); - - rc = SQLExecDirect(hstmt, "SELECT * FROM t_rows_fetched_ptr",SQL_NTS); - mystmt(hstmt,rc); - - i= 0; - rc = SQLFetchScroll(hstmt,SQL_FETCH_NEXT,0); - while (rc == SQL_SUCCESS || rc == SQL_SUCCESS_WITH_INFO) - { - fprintf(stdout,"total rows fetched: %ld\n", rowsFetched); - myassert(rowsFetched == rowsSize); - i++; rowsFetched= 0; - rc = SQLFetchScroll(hstmt, SQL_FETCH_NEXT, 0); - } - myassert( i == 6); - SQLFreeStmt(hstmt, SQL_CLOSE); - - rowsSize= 2; - rc = SQLSetStmtAttr(hstmt, SQL_ATTR_ROW_ARRAY_SIZE, (SQLPOINTER)rowsSize, 0); - mystmt(hstmt,rc); - - rc = SQLSetStmtAttr(hstmt, SQL_ATTR_ROWS_FETCHED_PTR, &rowsFetched, 0); - mystmt(hstmt,rc); - - rc = SQLExecDirect(hstmt, "SELECT * FROM t_rows_fetched_ptr",SQL_NTS); - mystmt(hstmt,rc); - - i= 0; - rc = SQLFetchScroll(hstmt,SQL_FETCH_NEXT,0); - while (rc == SQL_SUCCESS || rc == SQL_SUCCESS_WITH_INFO) - { - fprintf(stdout,"total rows fetched: %ld\n", rowsFetched); - myassert(rowsFetched == rowsSize); - i++;rowsFetched= 0; - rc = SQLFetchScroll(hstmt,SQL_FETCH_NEXT,0); - } - myassert( i == 3); - SQLFreeStmt(hstmt, SQL_CLOSE); - - rowsSize= 3; - rc = SQLSetStmtAttr(hstmt, SQL_ATTR_ROW_ARRAY_SIZE, (SQLPOINTER)rowsSize, 0); - mystmt(hstmt,rc); - - rc = SQLSetStmtAttr(hstmt, SQL_ATTR_ROWS_FETCHED_PTR, &rowsFetched, 0); - mystmt(hstmt,rc); - - rc = SQLExecDirect(hstmt, "SELECT * FROM t_rows_fetched_ptr",SQL_NTS); - mystmt(hstmt,rc); - - i= 0; - rc = SQLFetchScroll(hstmt,SQL_FETCH_NEXT,0); - while (rc == SQL_SUCCESS || rc == SQL_SUCCESS_WITH_INFO) - { - printMessage("total rows fetched: %ld\n", rowsFetched); - myassert(rowsFetched == rowsSize); - i++;rowsFetched= 0; - rc = SQLFetchScroll(hstmt, SQL_FETCH_NEXT, 0); - } - myassert( i == 2); - SQLFreeStmt(hstmt, SQL_CLOSE); - - rowsSize= 4; - rc = SQLSetStmtAttr(hstmt, SQL_ATTR_ROW_ARRAY_SIZE, (SQLPOINTER)rowsSize, 0); - mystmt(hstmt,rc); - - rc = SQLSetStmtAttr(hstmt, SQL_ATTR_ROWS_FETCHED_PTR, &rowsFetched, 0); - mystmt(hstmt,rc); - - rc = SQLExecDirect(hstmt, "SELECT * FROM t_rows_fetched_ptr",SQL_NTS); - mystmt(hstmt,rc); - - rc = SQLFetch(hstmt); - mystmt(hstmt,rc); - - printMessage("total rows fetched: %ld\n", rowsFetched); - myassert(rowsFetched == rowsSize); - - rc = SQLFetch(hstmt); - mystmt(hstmt,rc); - - printMessage("total rows fetched: %ld\n", rowsFetched); - myassert(rowsFetched == 2); - - rc = SQLFetch(hstmt); - myassert(rc == SQL_NO_DATA); - - SQLFreeStmt(hstmt, SQL_CLOSE); - - rc = SQLSetStmtAttr(hstmt, SQL_ATTR_ROW_ARRAY_SIZE, (SQLPOINTER)1, 0);/* reset */ - mystmt(hstmt,rc); - - rc = SQLSetStmtAttr(hstmt, SQL_ATTR_ROWS_FETCHED_PTR, NULL, 0); - mystmt(hstmt,rc); - - return OK; -} - - -static void desc_col_check(SQLHSTMT hstmt, - SQLUSMALLINT icol, - const char *name, - SQLSMALLINT sql_type, - SQLUINTEGER col_def, - SQLUINTEGER col_def1, - SQLSMALLINT scale, - SQLSMALLINT nullable) -{ - SQLRETURN rc; - SQLSMALLINT pcbColName, pfSqlType, pibScale, pfNullable; - SQLUINTEGER pcbColDef; - SQLCHAR szColName[MAX_NAME_LEN]; - - rc = SQLDescribeCol(hstmt, icol, - szColName,MAX_NAME_LEN,&pcbColName, - &pfSqlType,&pcbColDef,&pibScale,&pfNullable); - mystmt(hstmt,rc); - - fprintf(stdout, "\n\n Column Number'%d':", icol); - - fprintf(stdout, "\t Column Name : %s\n", szColName); - fprintf(stdout, "\t NameLengh : %d\n", pcbColName); - fprintf(stdout, "\t DataType : %d\n", pfSqlType); - fprintf(stdout, "\t ColumnSize : %d\n", pcbColDef); - fprintf(stdout, "\t DecimalDigits : %d\n", pibScale); - fprintf(stdout, "\t Nullable : %d\n", pfNullable); - - myassert(strcmp(name,szColName) == 0); - myassert(sql_type == pfSqlType); - myassert(col_def == pcbColDef || col_def1 == pcbColDef); - myassert(scale == pibScale); - myassert(nullable == pfNullable); -} - - -/* To test SQLDescribeCol */ -DECLARE_TEST(t_desc_col) -{ - SQLRETURN rc; - SQLSMALLINT ColumnCount; - - SQLFreeStmt(hstmt, SQL_CLOSE); - - SQLExecDirect(hstmt,"DROP TABLE t_desc_col",SQL_NTS); - - rc = SQLExecDirect(hstmt,"CREATE TABLE t_desc_col(c1 integer, \ - c2 binary(2) NOT NULL,\ - c3 char(1), \ - c4 varchar(5),\ - c5 decimal(10,3) NOT NULL,\ - c6 tinyint,\ - c7 smallint,\ - c8 numeric(4,2),\ - c9 real,\ - c10 float(5),\ - c11 bigint NOT NULL,\ - c12 varbinary(12),\ - c13 char(20) NOT NULL,\ - c14 float(10,3),\ - c15 tinytext,\ - c16 text,\ - c17 mediumtext,\ - c18 longtext,\ - c19 tinyblob,\ - c20 blob,\ - c21 mediumblob,\ - c22 longblob,\ - c23 tinyblob)",SQL_NTS); - mystmt(hstmt,rc); - - rc = SQLExecDirect(hstmt,"SELECT * FROM t_desc_col",SQL_NTS); - mystmt(hstmt,rc); - - rc = SQLNumResultCols(hstmt, &ColumnCount); - mystmt(hstmt,rc); - - fprintf(stdout,"total columns: %d\n", ColumnCount); - my_assert(ColumnCount == 23); - - desc_col_check(hstmt, 1, "c1", SQL_INTEGER, 10, 11, 0, SQL_NULLABLE); - desc_col_check(hstmt, 2, "c2", SQL_BINARY, 2, 2, 0, SQL_NO_NULLS); - desc_col_check(hstmt, 3, "c3", SQL_CHAR, 1, 1, 0, SQL_NULLABLE); - desc_col_check(hstmt, 4, "c4", SQL_VARCHAR, 5, 5, 0, SQL_NULLABLE); - desc_col_check(hstmt, 5, "c5", SQL_DECIMAL, 10, 10, 3, SQL_NO_NULLS); - desc_col_check(hstmt, 6, "c6", SQL_TINYINT, 3, 4, 0, SQL_NULLABLE); - desc_col_check(hstmt, 7, "c7", SQL_SMALLINT, 5, 6, 0, SQL_NULLABLE); - desc_col_check(hstmt, 8, "c8", SQL_DECIMAL, 4, 4, 2, SQL_NULLABLE); - desc_col_check(hstmt, 9, "c9", SQL_DOUBLE, 22, 24, 31, SQL_NULLABLE); - desc_col_check(hstmt, 10, "c10", SQL_REAL, 12, 24, 31, SQL_NULLABLE); - desc_col_check(hstmt, 11, "c11", SQL_BIGINT, 19, 19, 0, SQL_NO_NULLS); - desc_col_check(hstmt, 12, "c12", SQL_VARBINARY, 12, 12, 0, SQL_NULLABLE); - desc_col_check(hstmt, 13, "c13", SQL_CHAR, 20, 20, 0, SQL_NO_NULLS); - desc_col_check(hstmt, 14, "c14", SQL_REAL, 10, 24, 3, SQL_NULLABLE); - desc_col_check(hstmt, 15, "c15", SQL_LONGVARCHAR, 255, 255, 0, SQL_NULLABLE); - desc_col_check(hstmt, 16, "c16", SQL_LONGVARCHAR, 65535, 65535, 0, SQL_NULLABLE); - desc_col_check(hstmt, 17, "c17", SQL_LONGVARCHAR, 16777215, 16777215, 0, SQL_NULLABLE); - desc_col_check(hstmt, 18, "c18", SQL_LONGVARCHAR, 4294967295 , 16777215 , 0, SQL_NULLABLE); - desc_col_check(hstmt, 19, "c19", SQL_LONGVARBINARY, 255, 255, 0, SQL_NULLABLE); - desc_col_check(hstmt, 20, "c20", SQL_LONGVARBINARY, 65535, 65535, 0, SQL_NULLABLE); - desc_col_check(hstmt, 21, "c21", SQL_LONGVARBINARY, 16777215, 16777215, 0, SQL_NULLABLE); - desc_col_check(hstmt, 22, "c22", SQL_LONGVARBINARY, 4294967295 , 16777215 , 0, SQL_NULLABLE); - desc_col_check(hstmt, 23, "c23", SQL_LONGVARBINARY, 255, 5, 0, SQL_NULLABLE); - - SQLFreeStmt(hstmt,SQL_CLOSE); -} - - -/* Test for a simple SQLPutData and SQLParamData handling bug #1316 */ -DECLARE_TEST(t_putdata3) -{ - char buffer[]= "MySQL - The worlds's most popular open source database"; - SQLRETURN rc; - const int MAX_PART_SIZE = 5; - - char *pdata= 0, data[50]; - int dynData; - int commonLen= 20; - - SQLINTEGER id, id1, id2, id3, resId; - SQLINTEGER resUTimeSec; - SQLINTEGER resUTimeMSec; - SQLINTEGER resDataLen; - SQLLEN resData; - - SQLExecDirect(hstmt,"drop table t_putdata3",SQL_NTS); - rc = SQLExecDirect(hstmt,"CREATE TABLE t_putdata3 ( id INT, id1 INT, \ - id2 INT, id3 INT, pdata blob);",SQL_NTS); - mystmt(hstmt,rc); - - dynData = 1; - - rc = SQLPrepare(hstmt, "INSERT INTO t_putdata3 VALUES ( ?, ?, ?, ?, ? )", SQL_NTS); - mystmt(hstmt,rc); - - id= 1, id1= 2, id2= 3, id3= 4; - resId = 0; - resUTimeSec = 0; - resUTimeMSec = 0; - resDataLen = 0; - resData = SQL_LEN_DATA_AT_EXEC(0); - - rc = SQLBindParameter(hstmt, 1, SQL_PARAM_INPUT, SQL_C_SLONG, - SQL_INTEGER, 0, 0, &id, 0, &resId); - mystmt(hstmt,rc); - - rc = SQLBindParameter(hstmt, 2, SQL_PARAM_INPUT, SQL_C_SLONG, - SQL_INTEGER, 0, 0, &id1, 0, &resUTimeSec); - mystmt(hstmt,rc); - - rc = SQLBindParameter(hstmt, 3, SQL_PARAM_INPUT, SQL_C_SLONG, - SQL_INTEGER, 0, 0, &id2, 0, &resUTimeMSec); - mystmt(hstmt,rc); - - rc = SQLBindParameter(hstmt, 4, SQL_PARAM_INPUT, SQL_C_SLONG, - SQL_INTEGER, 0, 0, &id3, 0, - &resDataLen); - mystmt(hstmt,rc); - - rc = SQLBindParameter(hstmt, 5, SQL_PARAM_INPUT, - SQL_C_BINARY, SQL_LONGVARBINARY, 10, 10, - dynData ? (SQLPOINTER)5 : - pdata, 0, &resData); - mystmt(hstmt,rc); - - rc = SQLExecute(hstmt); - if (rc == SQL_NEED_DATA) - { - int parameter; - if (SQLParamData(hstmt,(void**)¶meter) == SQL_NEED_DATA && parameter == 5) - { - int len = 0; - int partsize; - - /* storing long data by parts */ - while (len < commonLen) - { - partsize = commonLen - len; - if (partsize > MAX_PART_SIZE) - partsize = MAX_PART_SIZE; - - rc = SQLPutData(hstmt, buffer+len, partsize); - mystmt(hstmt,rc); - len += partsize; - } - if (SQLParamData(hstmt,(void**)¶meter) == SQL_ERROR) - { - - } - } - } /* end if (rc == SQL_NEED_DATA) */ - - SQLFreeStmt(hstmt, SQL_UNBIND); - SQLFreeStmt(hstmt, SQL_CLOSE); - - if (mysql_min_version(hdbc, "4.0", 3)) - { - rc = tmysql_exec(hstmt,"select id, id1, id2, id3, convert(pdata,char) from t_putdata3"); - mystmt(hstmt,rc); - - rc = SQLFetch(hstmt); - - my_assert(1 == my_fetch_int(hstmt,1)); - my_assert(2 == my_fetch_int(hstmt,2)); - my_assert(3 == my_fetch_int(hstmt,3)); - my_assert(4 == my_fetch_int(hstmt,4)); - - my_assert(strncmp(buffer, my_fetch_str(hstmt,data,5), commonLen) == 0); - } - else - { - rc = tmysql_exec(hstmt,"select id, id1, id2, id3, pdata from t_putdata3"); - mystmt(hstmt,rc); - - rc = SQLFetch(hstmt); - - my_assert(1 == my_fetch_int(hstmt,1)); - my_assert(2 == my_fetch_int(hstmt,2)); - my_assert(3 == my_fetch_int(hstmt,3)); - my_assert(4 == my_fetch_int(hstmt,4)); - my_assert(strncmp("4D7953514C202D2054686520776F726C64732773", - my_fetch_str(hstmt,data,5), commonLen) == 0); - } - - rc = SQLFreeStmt(hstmt,SQL_CLOSE); - mystmt(hstmt,rc); - - /* - output: - - ###################################### - t_putdata3 - ###################################### - my_fetch_int: 1 - my_fetch_int: 2 - my_fetch_int: 3 - my_fetch_int: 4 - my_fetch_str: MySQL - The worlds's(20) - */ - - return OK; -} - - -/* Test for misc CONVERT bug #1082 */ -DECLARE_TEST(t_convert) -{ - SQLRETURN rc; - SQLLEN data_len; - SQLCHAR data[50]; - - tmysql_exec(hstmt,"drop table t_convert"); - - rc = SQLTransact(NULL,hdbc,SQL_COMMIT); - mycon(hdbc,rc); - - rc = tmysql_exec(hstmt,"CREATE TABLE t_convert(testing tinytext)"); - mystmt(hstmt,rc); - - rc = tmysql_exec(hstmt,"INSERT INTO t_convert VALUES('record1')"); - mystmt(hstmt,rc); - - rc = tmysql_exec(hstmt,"INSERT INTO t_convert VALUES('record2')"); - mystmt(hstmt,rc); - - rc = SQLTransact(NULL,hdbc,SQL_COMMIT); - mycon(hdbc,rc); - - rc = SQLFreeStmt(hstmt,SQL_CLOSE); - mystmt(hstmt,rc); - - rc = tmysql_exec(hstmt,"SELECT CONCAT(testing, '-must be string') FROM t_convert ORDER BY RAND()"); - mystmt(hstmt,rc); - - rc = SQLBindCol(hstmt,1,SQL_C_CHAR, &data, 100, &data_len); - mystmt(hstmt,rc); - - rc = SQLFetch(hstmt); - mystmt(hstmt,rc); - myassert(strcmp(data,"record1-must be string") == 0 || - strcmp(data,"record2-must be string") == 0); - - rc = SQLFetch(hstmt); - mystmt(hstmt,rc); - myassert(strcmp(data,"record1-must be string") == 0 || - strcmp(data,"record2-must be string") == 0); - - rc = SQLFetch(hstmt); - myassert( rc == SQL_NO_DATA); - - rc = SQLFreeStmt(hstmt,SQL_UNBIND); - mystmt(hstmt,rc); - - rc = SQLFreeStmt(hstmt,SQL_CLOSE); - mystmt(hstmt,rc); - - return OK; -} - - -BEGIN_TESTS - ADD_TEST(t_setpos_del_all) - ADD_TEST(t_setpos_upd_decimal) - ADD_TEST(tmysql_specialcols) - ADD_TEST(t_max_select) - ADD_TEST(t_getcursor) - ADD_TEST(t_getcursor1) - ADD_TEST(t_gettypeinfo) - ADD_TEST(t_getinfo) - ADD_TEST(t_stmt_attr_status) - ADD_TEST(t_max_rows) - ADD_TEST(t_prepare) - ADD_TEST(t_prepare1) - ADD_TEST(t_diagrec) - ADD_TEST(t_acc_crash) - ADD_TEST(t_msdev_bug) - ADD_TEST(t_setpos_position) - ADD_TEST(t_pos_column_ignore) - ADD_TEST(t_longlong1) - ADD_TEST(t_time) - ADD_TEST(t_numeric) - ADD_TEST(t_decimal) - ADD_TEST(t_warning) - ADD_TEST(t_multistep) - ADD_TEST(t_zerolength) - ADD_TEST(t_pos_datetime_delete) - ADD_TEST(t_pos_datetime_delete1) - ADD_TEST(t_text_fetch) - ADD_TEST(t_columns) - ADD_TEST(t_convert_type) - ADD_TEST(t_cache_bug) - ADD_TEST(t_non_cache_bug) - ADD_TEST(t_blob_bug) - ADD_TEST(t_tables_bug) - ADD_TEST(t_putdata) - ADD_TEST(t_putdata1) - ADD_TEST(t_putdata2) - ADD_TEST(t_time1) - ADD_TEST(t_row_array_size) - ADD_TEST(t_empty_str_bug) - ADD_TEST(t_current_catalog) - ADD_TEST(t_rows_fetched_ptr1) - ADD_TEST(t_desc_col) - ADD_TEST(t_putdata3) - ADD_TEST(t_convert) -END_TESTS - - -RUN_TESTS
| Thread | ||
|---|---|---|
| • Connector/ODBC 3.51 commit: r298 - trunk/test | jwinstead | 6 Apr |
© 1995-2008 MySQL AB, 2008-2009 Sun Microsystems, Inc.
Page generated in 2.114 sec. using MySQL 5.1.14-beta-log