//gcc bug27643.c -g -o bug27643 -L/home/sbester/server/5.0/mysql-5.0.36-linux-i686/lib -I/home/sbester/server/5.0/mysql-5.0.36-linux-i686/include   -lmysqlclient_r -lz -lpthread

/*This is generated code!*/

/*section: includes*/
#include <stdio.h>
#include <stdlib.h>
#include <time.h>
#include <mysql.h>
#include <pthread.h>

#define TESTTIME (6000)
#define SEED (123456)
#define NUMTHREADS (1)


/*section: globals*/
char host[]="127.0.0.1";
char username[]="root";
char password[]="";
char database[]="test";
int port=3306;
pthread_t pthreads[NUMTHREADS];
int threaddone=0;
char *databucket=NULL;

/*section: function declarations*/
void *worker_thread(void *arg);
MYSQL *db_connect(MYSQL *dbc);
int make_random_utf8_string(char *out, int maxleng);

/*section: functions*/
int db_query(MYSQL *dbc,char *sql,int showresults)
{
	int res=0;
	MYSQL_RES *r=NULL;
	MYSQL_ROW w;
	MYSQL_FIELD *field=NULL;
	int i=0,moreresult=0;
	if(NULL == dbc) return 0;
	res = mysql_query(dbc,sql);
	if(res != 0 && showresults > 0)
	{
		printf("query failed : %d (%s)\n",mysql_errno(dbc),mysql_error(dbc));
		return 0;
	}

	do
	{
		r = mysql_store_result(dbc);
		if(r)
		{
			unsigned int numfields = mysql_num_fields(r);
			unsigned int numrows=mysql_num_rows(r);
			while((field = mysql_fetch_field(r)))
			{
					//print metadata information about each field
					if(showresults > 1)
					{
						printf("%s	",field->name);
					}
			}
			if(showresults > 1)
			{
				printf("\n------------------------------------\n");
			}

			while ((w = mysql_fetch_row(r)))
			{
				for(i = 0; i < numfields; i++)
				{
					//print each field here
					if(showresults > 1)
					{
						printf("%s\t",w[i]);
					}
				}

				if(showresults > 1)
				{
						printf("\n");
				}
			}
			if(showresults > 1)
			{
				printf("\n");
			}
			mysql_free_result(r);
		}
		else //no rows returned. was it a select?
		{
			if(mysql_field_count(dbc) > 0 && showresults > 0)
			{
				printf("No results for '%s'.  (%d) - %s\n",sql,mysql_errno(dbc),mysql_error(dbc));
			}
			else //it could have been some insert/update/delete
			{
				//this is successful query
			}
		}
		moreresult=mysql_next_result(dbc);
		if(moreresult > 0 && showresults > 0)
		{
			printf("mysql_next_result returned %d, mysql error %s, (%d)\n",moreresult,mysql_error(dbc),mysql_errno(dbc));
			break;
		}
	} while (0==moreresult);
}

char* alocmem(const int num)
{
	char *r=calloc(num,1);
	if(NULL == r)
	{
		printf("cannot calloc %d bytes of memory\n",num);
		exit(1);
	}
	return r;
}


void *worker_thread(void *arg)
{
	MYSQL *dbc=NULL;
	int cancelstate=0;
	pthread_setcancelstate(PTHREAD_CANCEL_DISABLE,&cancelstate);

	if (!(dbc = mysql_init(NULL)))
	{
		printf("mysql_init\n");
		dbc=NULL;
		goto threadexit;
	}
	else
	{
		if (!mysql_real_connect(dbc,host,username,password,database,port, NULL, CLIENT_FOUND_ROWS|CLIENT_MULTI_STATEMENTS|CLIENT_MULTI_RESULTS))
		{
			printf("mysql_real_connect failed: %s (%d)", mysql_error(dbc),mysql_errno(dbc));
			dbc=NULL;
		}
	}

	unsigned int counter=0;
	char shortquery[1024]={0};
	char utf8[255]={0};
	int utf8lengt=0;
	int iteration=0;
	char *longquery=NULL;
	char *c=NULL;
	while(!threaddone && dbc!=NULL)
	{
	        fflush(stdout);
	        c=shortquery;
		c+=sprintf(c,"%s","set names utf8");
		db_query(dbc,shortquery,1);



		longquery = alocmem(2734);
		for(counter=0;counter<1000;counter++)
		{
			c=longquery;
			c+=sprintf(c,"%s","INSERT INTO `t1` SET `c3`=");
			c+=sprintf(c,"%d",-128 + lrand48()%255);
			c+=sprintf(c,"%s",",`c2`=");
			c+=sprintf(c,"%d",-128 + lrand48()%255);
			c+=sprintf(c,"%s",",`c4`='");
			
			utf8lengt=make_random_utf8_string(utf8,255);
			c+=mysql_real_escape_string(dbc,c,utf8,utf8lengt);
			
			c+=sprintf(c,"%s","',`c7`='");
			
			utf8lengt=make_random_utf8_string(utf8,255);
			c+=mysql_real_escape_string(dbc,c,utf8,utf8lengt);
			
			c+=sprintf(c,"%s","',`c8`='");
			
			utf8lengt=make_random_utf8_string(utf8,255);
			c+=mysql_real_escape_string(dbc,c,utf8,utf8lengt);
			
			c+=sprintf(c,"%s","',`c5`='");
			
			utf8lengt=make_random_utf8_string(utf8,255);
			c+=mysql_real_escape_string(dbc,c,utf8,utf8lengt);
			
			c+=sprintf(c,"%s","',`c9`='");
			
			utf8lengt=make_random_utf8_string(utf8,255);
			c+=mysql_real_escape_string(dbc,c,utf8,utf8lengt);
			
			c+=sprintf(c,"%s","'");
			if(0==db_query(dbc,longquery,1))
			{
		                printf("failure on iteration %d\n",iteration);                
                        } 
			if(c > longquery + 2734)
			{
			        printf("overflow!!!\n");
                        }
		}
		free(longquery);

		c=shortquery;
		c+=sprintf(c,"%s","SELECT max(`c1`) AS `c1` FROM `t1` GROUP BY `c3`,`c7`,`c2`");
		if(0==db_query(dbc,shortquery,1))
		{
		        printf("failure on iteration %d\n",iteration);                
                }
                iteration++;
        }
threadexit:
	mysql_close(dbc);
	mysql_thread_end();
	pthread_exit(0);
}


int main(int argc, const char *argv[])
{
	MYSQL *dbc=NULL;
	int i=0,err=0;

	time_t timestart=0,timenow=0;
        
	unsigned int counter=0;
	char shortquery[1024]={0};
	char *longquery=NULL;
	char *c=NULL;
	my_init();
	if (!(dbc = mysql_init(NULL)))
	{
		printf("mysql_init\n");
		dbc=NULL;
		goto threadexit;
	}
	else
	{
		if (!mysql_real_connect(dbc,host,username,password,database,port, NULL, CLIENT_FOUND_ROWS|CLIENT_MULTI_STATEMENTS|CLIENT_MULTI_RESULTS))
		{
			printf("mysql_real_connect failed: %s (%d)", mysql_error(dbc),mysql_errno(dbc));
			dbc=NULL;
			goto threadexit;
		}
	}

	printf("running initializations..\n");
   
        srand48(SEED);
	c=shortquery;
        c+=sprintf(c,"%s","DROP TABLE IF EXISTS `t1`");
	db_query(dbc,shortquery,1);

	c=shortquery;
	c+=sprintf(c,"%s","CREATE TABLE `t1` (`c1` bigint NOT NULL auto_increment,`c3` int NOT NULL,`c4` varchar(127) character set utf8 collate utf8_bin NOT NULL,`c2` tinyint(4) NOT NULL default '0',`c6` bigint(20) NOT NULL,`c7` varchar(32) character set utf8 collate utf8_bin NOT NULL,`c8` varchar(32) character set utf8 collate utf8_bin NOT NULL,`c5` varchar(255) character set utf8 collate utf8_bin default NULL,`c9` varchar(255) character set utf8 collate utf8_bin default NULL,PRIMARY KEY (`c1`),KEY(`c3`,`c4`,`c2`)) ENGINE=MyISAM DEFAULT CHARSET=utf8");
	db_query(dbc,shortquery,1);

	mysql_close(dbc);

	printf("about to spawn %d threads\n",NUMTHREADS);
	for (i=0;i<NUMTHREADS;i++)
	{
		err=pthread_create(&pthreads[i], NULL, worker_thread, (void *)i);
		if(err!=0)
		{
			printf("error spawning thread %lu, pthread_create returned %lu\n",(unsigned long)i,(unsigned long)err);
		}
	}
	printf("\n");
	printf("completed spawning new database worker threads\n");

	printf("testcase is now running, so watch for error output\n");

	timestart=time(NULL);
	timenow=time(NULL);
	for(i=0;(timenow-timestart) < TESTTIME;timenow=time(NULL))
	{
		sleep(1);
	}
	threaddone=1;

	printf("waiting for worker threads to finish...\n");

	for (i=0;i<NUMTHREADS;i++)
	{
		pthread_join(pthreads[i], NULL);
	}

	exit(0);
threadexit:
	exit(-1);
}


int make_random_utf8_string(char *out, int maxleng)
{
	
	int lengt=0;
	char *ptr=NULL;
	int numbytes=0; //number of bytes the char will be, 1,2, or 3
	
	lengt=lrand48() % maxleng;
		
	for(ptr=out;ptr<(out+lengt-3);)
	{
		numbytes=1+lrand48()%3;		
		switch(numbytes)
		{
			case 1:
				*ptr++ = (char)(lrand48() % 0x7f);	//0xxxxxxx
				break;
			case 2:
				*ptr++ = (char)((lrand48() % 0x1f) | 0xC0); //110xxxxx
				*ptr++ = (char)((lrand48() % 0x3f) | 0x80); //10xxxxxx
				break;
			case 3:	
				*ptr++ = (char)((lrand48() % 0xf)  | 0xE0); //1110xxxx
				*ptr++ = (char)((lrand48() % 0x3f) | 0x80); //10xxxxxx
				*ptr++ = (char)((lrand48() % 0x3f) | 0x80); //10xxxxxx
				break;
		}
	}
	*ptr=0;
	lengt = (int)(ptr - out);
	return lengt;	
}