// This cpp file is a generated trace that consists of the following "sections":
//
// - Connection parameters for mysql_real_connect:
// - Helper functions
// - The actual trace (marked by ****** Begin/End of trace ******)
// - Functions to create and populate the necessary tables
// - A dump of the current mysql variables

// This cpp file should be compilable with:
// 	gcc -g -I ${MYSQL_DIR}/include ${THIS_FILE} ${MYSQL_DIR}/lib/libmysqlclient.a -lm -lz -lstdc++

// To replay the trace you should have a database "baan", or you can change the
// DB_NAME variable below. 
// You should also have two users: bsp/bsp, who has SELECT, INSERT, UPDATE, DELETE
// privileges on all objects and baan/baan (the owner), who has ALL PRIVILEGES.
// You may choose to use other users/passwords by changing the USER_*/OWNER_*
// variables below.
// You can connect to MySQL through TCP/IP by setting the HOST_NAME variable, or
// you can use sockets by setting HOST_NAME to NULL and setting the right UNIX_SOCKET.
//
// The trace replays successfully if the program silently terminates with exit status 0.

#include <stdlib.h>
#include <stdio.h>
#include <string.h>
#include <assert.h>
#include <string>

// Connection parameters
const char *HOST_NAME = NULL;
const char *USER_NAME = "bsp";
const char *USER_PWD = "bsp";
const char *DB_NAME = "baan";
const char *UNIX_SOCKET = "/var/lib/mysql/mysql.sock";
// For ddl statements we use a different user/pwd
const char *OWNER_NAME = "baan";
const char *OWNER_PWD = "baan";

// use "#define ASSERT_EQ (void)" to disable data validation
#define ASSERT(C) assert(C)
#define ASSERT_EQ(X,Y) assert( check_eq(X,Y) )
#define ASSERT_EQ_DATETIME(X,Y,M,D,h,m,s) assert( check_eq_datetime(X,Y,M,D,h,m,s) )

#include "mysql.h"

void create_tables(void);

// Global variables
const char *stmt_text;
int mysql_ret;
int count;
int mysql_err;
MYSQL_TIME mysql_time;
MYSQL_RES *mysql_result;
MYSQL_ROW mysql_row;

const unsigned long select_cursor = CURSOR_TYPE_READ_ONLY;
const unsigned long update_cursor = CURSOR_TYPE_FOR_UPDATE;
const unsigned long no_cursor = CURSOR_TYPE_NO_CURSOR;

// Helper functions
void set_bind_attrs( MYSQL_BIND *mysql_bind, enum_field_types ext_type, void *buf, int bufsz, unsigned long *act_len, my_bool *is_null )
{
	mysql_bind->buffer_type = ext_type;
	mysql_bind->buffer = buf;
	mysql_bind->length = act_len;
	mysql_bind->is_null = is_null;
	mysql_bind->buffer_length = bufsz;
}

void bind_time(void *ptr,int ye,int mo,int da,int ho,int mi,int se)
{
	MYSQL_TIME t = {ye,mo,da,ho,mi,se};
	memcpy(ptr,&t,sizeof(t));
}

int check_eq(unsigned long v,unsigned long val)
	{ return( v == val ); }
int check_eq(void *ptr,const char *val)
	{ return( memcmp((char*)ptr,val,strlen(val))==0); }
int check_eq(void *ptr,int val)
	{ return( *((int*)ptr) == val ); }
int check_eq(void *ptr,float val)
	{ return( *((float*)ptr) == val ); }
int check_eq(void *ptr,double val)
	{ return( *((double*)ptr) == val ); }
int check_eq_datetime(void *ptr,int ye,int mo,int da,int ho,int mi,int se)
{
	MYSQL_TIME *t = (MYSQL_TIME*)ptr;
	return (t->year == ye) && (t->month == mo) && (t->day == da)
		 && (t->hour == ho) && (t->minute == mi) && (t->second == se);
}

int main(void)
{
	// Create the tables needed to run this trace
	create_tables();

	// ****** Begin of trace ******

	MYSQL *sess_1;
	sess_1 = mysql_init( NULL ); assert(sess_1);
	mysql_real_connect(sess_1, HOST_NAME, USER_NAME, USER_PWD, DB_NAME, 0, UNIX_SOCKET, 0); 
	mysql_autocommit(sess_1, 0);

	MYSQL_STMT *stmt_1 = mysql_stmt_init(sess_1);
	stmt_text = "SELECT table_name FROM table_locks WHERE table_name = 'tdbtst120000' FOR UPDATE";
	mysql_ret = mysql_stmt_prepare(stmt_1,stmt_text,strlen(stmt_text)); assert( mysql_ret == 0 );
	mysql_ret = mysql_stmt_execute(stmt_1); assert( mysql_ret == 0 );
	mysql_ret = mysql_stmt_fetch(stmt_1); assert( mysql_ret == 0 );
	mysql_stmt_close(stmt_1);

	MYSQL *sess_2;
	sess_2 = mysql_init( NULL ); assert(sess_2);
	mysql_real_connect(sess_2, HOST_NAME, USER_NAME, USER_PWD, DB_NAME, 0, UNIX_SOCKET, 0); 
	mysql_autocommit(sess_2, 0);

	MYSQL_STMT *stmt_4 = mysql_stmt_init(sess_2);
	stmt_text = "SELECT table_name FROM table_locks WHERE table_name = 'tdbtst120000' LOCK IN SHARE MODE";
	mysql_ret = mysql_stmt_prepare(stmt_4,stmt_text,strlen(stmt_text)); assert( mysql_ret == 0 );

// ERROR: next statement makes the server crash

	mysql_ret = mysql_stmt_execute(stmt_4); assert( mysql_ret == 1 ); // Lost connection to MySQL server during query
	mysql_ret = mysql_stmt_errno(stmt_4); assert( mysql_ret == 2013);
	mysql_stmt_close(stmt_4);
	mysql_ret = mysql_rollback(sess_2); assert(mysql_ret==1);
	mysql_err = mysql_errno(sess_2); assert( mysql_err==2006 ); // MySQL server has gone away
	mysql_ret = mysql_rollback(sess_1); assert(mysql_ret==1);
	mysql_err = mysql_errno(sess_1); assert( mysql_err==2006 ); // MySQL server has gone away

	// ****** End of trace ******

}

// Following code creates all tables needed to run this trace

void create_table_locks( void )
{
	FILE *fp = fopen("/tmp/baan_table_dump","w");
	fprintf(fp,"%s\n","-- MySQL dump 10.10");
	fprintf(fp,"%s\n","--");
	fprintf(fp,"%s\n","-- Host: localhost    Database: baan");
	fprintf(fp,"%s\n","-- ------------------------------------------------------");
	fprintf(fp,"%s\n","-- Server version\0115.0.10-beta-nightly-20050712-debug");
	fprintf(fp,"%s\n","");
	fprintf(fp,"%s\n","/*!40101 SET @OLD_CHARACTER_SET_CLIENT=@@CHARACTER_SET_CLIENT */;");
	fprintf(fp,"%s\n","/*!40101 SET @OLD_CHARACTER_SET_RESULTS=@@CHARACTER_SET_RESULTS */;");
	fprintf(fp,"%s\n","/*!40101 SET @OLD_COLLATION_CONNECTION=@@COLLATION_CONNECTION */;");
	fprintf(fp,"%s\n","/*!40101 SET NAMES utf8 */;");
	fprintf(fp,"%s\n","/*!40014 SET @OLD_UNIQUE_CHECKS=@@UNIQUE_CHECKS, UNIQUE_CHECKS=0 */;");
	fprintf(fp,"%s\n","/*!40014 SET @OLD_FOREIGN_KEY_CHECKS=@@FOREIGN_KEY_CHECKS, FOREIGN_KEY_CHECKS=0 */;");
	fprintf(fp,"%s\n","/*!40101 SET @OLD_SQL_MODE=@@SQL_MODE, SQL_MODE='NO_AUTO_VALUE_ON_ZERO' */;");
	fprintf(fp,"%s\n","/*!40111 SET @OLD_SQL_NOTES=@@SQL_NOTES, SQL_NOTES=0 */;");
	fprintf(fp,"%s\n","");
	fprintf(fp,"%s\n","--");
	fprintf(fp,"%s\n","-- Table structure for table `table_locks`");
	fprintf(fp,"%s\n","--");
	fprintf(fp,"%s\n","");
	fprintf(fp,"%s\n","DROP TABLE IF EXISTS `table_locks`;");
	fprintf(fp,"%s\n","CREATE TABLE `table_locks` (");
	fprintf(fp,"%s\n","  `table_name` char(30) collate latin1_bin NOT NULL,");
	fprintf(fp,"%s\n","  PRIMARY KEY  (`table_name`)");
	fprintf(fp,"%s\n",") ENGINE=InnoDB DEFAULT CHARSET=latin1 COLLATE=latin1_bin;");
	fprintf(fp,"%s\n","");
	fprintf(fp,"%s\n","--");
	fprintf(fp,"%s\n","-- Dumping data for table `table_locks`");
	fprintf(fp,"%s\n","--");
	fprintf(fp,"%s\n","");
	fprintf(fp,"%s\n","");
	fprintf(fp,"%s\n","/*!40000 ALTER TABLE `table_locks` DISABLE KEYS */;");
	fprintf(fp,"%s\n","LOCK TABLES `table_locks` WRITE;");
	fprintf(fp,"%s\n","INSERT INTO `table_locks` VALUES ('tdbtst100280'),('tdbtst100282'),('tdbtst120000'),('tdbtst146000'),('tdbtst160282'),('tdbtst180000');");
	fprintf(fp,"%s\n","UNLOCK TABLES;");
	fprintf(fp,"%s\n","/*!40000 ALTER TABLE `table_locks` ENABLE KEYS */;");
	fprintf(fp,"%s\n","");
	fprintf(fp,"%s\n","/*!40101 SET SQL_MODE=@OLD_SQL_MODE */;");
	fprintf(fp,"%s\n","/*!40014 SET FOREIGN_KEY_CHECKS=@OLD_FOREIGN_KEY_CHECKS */;");
	fprintf(fp,"%s\n","/*!40014 SET UNIQUE_CHECKS=@OLD_UNIQUE_CHECKS */;");
	fprintf(fp,"%s\n","/*!40101 SET CHARACTER_SET_CLIENT=@OLD_CHARACTER_SET_CLIENT */;");
	fprintf(fp,"%s\n","/*!40101 SET CHARACTER_SET_RESULTS=@OLD_CHARACTER_SET_RESULTS */;");
	fprintf(fp,"%s\n","/*!40101 SET COLLATION_CONNECTION=@OLD_COLLATION_CONNECTION */;");
	fprintf(fp,"%s\n","/*!40111 SET SQL_NOTES=@OLD_SQL_NOTES */;");
	fprintf(fp,"%s\n","");
	fclose(fp);
	std::string cmd = std::string("mysql");
	if ( OWNER_NAME ) cmd += std::string(" --user=") + OWNER_NAME;
	if ( OWNER_PWD ) cmd += std::string(" --password=") + OWNER_PWD;
	if ( HOST_NAME ) cmd += std::string(" --host=") + HOST_NAME;
	if ( UNIX_SOCKET ) cmd += std::string(" --socket=") + UNIX_SOCKET;
	cmd += std::string(" ") + DB_NAME;
	cmd += " < /tmp/baan_table_dump";
	int ret = system(cmd.data());
	if ( ret != 0 ) fprintf(stderr,"Command \"%s\" failed\n",cmd.data());
}

void create_tables( void )
{
	create_table_locks();
}

#if 0 // Output of "show variables"
#
#	Variable_name                 	Value
#	auto_increment_increment      	1
#	auto_increment_offset         	1
#	automatic_sp_privileges       	ON
#	back_log                      	50
#	basedir                       	/usr1/mysql/mysql-5.0.10-beta-nightly-20050712-linux-i686/
#	binlog_cache_size             	32768
#	bulk_insert_buffer_size       	8388608
#	character_set_client          	latin1
#	character_set_connection      	latin1
#	character_set_database        	latin1
#	character_set_results         	latin1
#	character_set_server          	latin1
#	character_set_system          	utf8
#	character_sets_dir            	/usr1/mysql/mysql-5.0.10-beta-nightly-20050712-linux-i686/share/mysql/charsets/
#	collation_connection          	latin1_swedish_ci
#	collation_database            	latin1_swedish_ci
#	collation_server              	latin1_swedish_ci
#	completion_type               	0
#	concurrent_insert             	1
#	connect_timeout               	5
#	datadir                       	/usr1/mysql/mysql-5.0.10-beta-nightly-20050712-linux-i686/data/
#	date_format                   	%Y-%m-%d
#	datetime_format               	%Y-%m-%d %H:%i:%s
#	div_precision_increment       	4
#	default_week_format           	0
#	delay_key_write               	ON
#	delayed_insert_limit          	100
#	delayed_insert_timeout        	300
#	delayed_queue_size            	1000
#	expire_logs_days              	0
#	flush                         	OFF
#	flush_time                    	0
#	ft_boolean_syntax             	+ -><()~*:""&|
#	ft_max_word_len               	84
#	ft_min_word_len               	4
#	ft_query_expansion_limit      	20
#	ft_stopword_file              	(built-in)
#	group_concat_max_len          	1024
#	have_archive                  	NO
#	have_bdb                      	NO
#	have_blackhole_engine         	NO
#	have_compress                 	YES
#	have_crypt                    	YES
#	have_csv                      	NO
#	have_example_engine           	NO
#	have_federated_engine         	NO
#	have_geometry                 	YES
#	have_innodb                   	YES
#	have_isam                     	NO
#	have_ndbcluster               	NO
#	have_openssl                  	NO
#	have_query_cache              	YES
#	have_raid                     	NO
#	have_rtree_keys               	YES
#	have_symlink                  	YES
#	init_connect                  	
#	init_file                     	
#	init_slave                    	
#	innodb_additional_mem_pool_size	1048576
#	innodb_autoextend_increment   	8
#	innodb_buffer_pool_awe_mem_mb 	0
#	innodb_buffer_pool_size       	8388608
#	innodb_checksums              	ON
#	innodb_concurrency_tickets    	500
#	innodb_data_file_path         	ibdata1:10M:autoextend
#	innodb_data_home_dir          	
#	innodb_doublewrite            	ON
#	innodb_fast_shutdown          	1
#	innodb_file_io_threads        	4
#	innodb_file_per_table         	OFF
#	innodb_flush_log_at_trx_commit	1
#	innodb_flush_method           	
#	innodb_force_recovery         	0
#	innodb_lock_wait_timeout      	2
#	innodb_locks_unsafe_for_binlog	OFF
#	innodb_log_arch_dir           	
#	innodb_log_archive            	OFF
#	innodb_log_buffer_size        	1048576
#	innodb_log_file_size          	5242880
#	innodb_log_files_in_group     	2
#	innodb_log_group_home_dir     	./
#	innodb_max_dirty_pages_pct    	90
#	innodb_max_purge_lag          	0
#	innodb_mirrored_log_groups    	1
#	innodb_open_files             	300
#	innodb_sync_spin_loops        	20
#	innodb_table_locks            	ON
#	innodb_support_xa             	ON
#	innodb_thread_concurrency     	20
#	innodb_thread_sleep_delay     	10000
#	interactive_timeout           	28800
#	join_buffer_size              	131072
#	key_buffer_size               	16777216
#	key_cache_age_threshold       	300
#	key_cache_block_size          	1024
#	key_cache_division_limit      	100
#	language                      	/usr1/mysql/mysql-5.0.10-beta-nightly-20050712-linux-i686/share/mysql/english/
#	large_files_support           	ON
#	large_pages                   	OFF
#	large_page_size               	0
#	license                       	GPL
#	local_infile                  	ON
#	locked_in_memory              	OFF
#	log                           	OFF
#	log_bin                       	OFF
#	log_bin_trust_routine_creators	OFF
#	log_error                     	
#	log_slave_updates             	OFF
#	log_slow_queries              	OFF
#	log_warnings                  	1
#	long_query_time               	10
#	low_priority_updates          	OFF
#	lower_case_file_system        	OFF
#	lower_case_table_names        	0
#	max_allowed_packet            	1047552
#	max_binlog_cache_size         	4294967295
#	max_binlog_size               	1073741824
#	max_connect_errors            	10
#	max_connections               	100
#	max_delayed_threads           	20
#	max_error_count               	64
#	max_heap_table_size           	16777216
#	max_insert_delayed_threads    	20
#	max_join_size                 	4294967295
#	max_length_for_sort_data      	1024
#	max_relay_log_size            	0
#	max_seeks_for_key             	4294967295
#	max_sort_length               	1024
#	max_tmp_tables                	32
#	max_user_connections          	0
#	max_write_lock_count          	4294967295
#	multi_range_count             	256
#	myisam_data_pointer_size      	6
#	myisam_max_sort_file_size     	2147483647
#	myisam_recover_options        	OFF
#	myisam_repair_threads         	1
#	myisam_sort_buffer_size       	8388608
#	engine_condition_pushdown     	OFF
#	net_buffer_length             	8192
#	net_read_timeout              	30
#	net_retry_count               	10
#	net_write_timeout             	60
#	new                           	OFF
#	old_passwords                 	OFF
#	open_files_limit              	1024
#	optimizer_prune_level         	1
#	optimizer_search_depth        	62
#	pid_file                      	/usr1/mysql/mysql-5.0.10-beta-nightly-20050712-linux-i686/data/nlbaldev1.pid
#	port                          	3306
#	preload_buffer_size           	32768
#	protocol_version              	10
#	query_alloc_block_size        	8192
#	query_cache_limit             	1048576
#	query_cache_min_res_unit      	4096
#	query_cache_size              	0
#	query_cache_type              	ON
#	query_cache_wlock_invalidate  	OFF
#	query_prealloc_size           	8192
#	range_alloc_block_size        	2048
#	read_buffer_size              	131072
#	read_only                     	OFF
#	read_rnd_buffer_size          	262144
#	relay_log_purge               	ON
#	relay_log_space_limit         	0
#	rpl_recovery_rank             	0
#	secure_auth                   	OFF
#	server_id                     	1
#	skip_external_locking         	ON
#	skip_networking               	OFF
#	skip_show_database            	OFF
#	slave_compressed_protocol     	OFF
#	slave_load_tmpdir             	/tmp/
#	slave_net_timeout             	3600
#	slave_skip_errors             	OFF
#	slave_transaction_retries     	10
#	slow_launch_time              	2
#	socket                        	/var/lib/mysql/mysql.sock
#	sort_buffer_size              	524252
#	sql_mode                      	
#	storage_engine                	MyISAM
#	sql_notes                     	ON
#	sql_warnings                  	ON
#	sync_binlog                   	0
#	sync_replication              	0
#	sync_replication_slave_id     	0
#	sync_replication_timeout      	10
#	sync_frm                      	ON
#	system_time_zone              	CEST
#	table_cache                   	64
#	table_type                    	MyISAM
#	thread_cache_size             	0
#	thread_stack                  	196608
#	time_format                   	%H:%i:%s
#	time_zone                     	SYSTEM
#	timed_mutexes                 	OFF
#	tmp_table_size                	33554432
#	tmpdir                        	
#	transaction_alloc_block_size  	8192
#	transaction_prealloc_size     	4096
#	tx_isolation                  	REPEATABLE-READ
#	updatable_views_with_limit    	YES
#	version                       	5.0.10-beta-nightly-20050712-debug
#	version_comment               	Source distribution
#	version_compile_machine       	i686
#	version_compile_os            	pc-linux-gnu
#	wait_timeout                  	28800
#
#endif // Output of "show variables"