#include <MySql/MySql.h>

// debian: sudo apt-get install libmysqlclient-dev

using namespace Upp;

#define SCHEMADIALECT <MySql/MySqlSchema.h>
#define MODEL <mysqlCrash/schema.sch>
#include <Sql/sch_header.h>
#include <Sql/sch_source.h>
#include <Sql/sch_schema.h>

CONSOLE_APP_MAIN
{
	MySqlSession session;
	// edit the connection parameters if necessary
	if(session.Connect("test_user", "test", "test")) {
		Cout() << "Connected\n";
		SQL = session;
		
		SqlSchema sch(MY_SQL);
		All_Tables(sch);
		// create the table if necessary
		SqlPerformScript(sch.Upgrade());
		SqlPerformScript(sch.Attributes());
		SQL.ClearError();


		try {
			// insert some random data
			SQL & Insert(TEST_TABLE)(VALUE, Uuid::Create().ToString());
			// fetch some data
			Sql sql;
			sql * Select(ID, VALUE).From(TEST_TABLE)
			                       .OrderBy(Descending(ID))
			                       .Limit(5);
			while(sql.Fetch())
				Cout() << AsString(sql[0]) << ": " << AsString(sql[VALUE]) << "\n";
		}
		catch(SqlExc &ex) {
			Cerr() << "ERROR: " << ex << "\n";
			SetExitCode(1);
		}
		
		session.Close();
		
		Sleep(2000);

		if(session.IsOpen()) {
			Cout() << "Connection closed FAILED!\n";
		} else {
			Cout() << "Connection closed!\n";
		}
		
		Sleep(2000);
		
		Cout() << "Try open Connection again\n";
		
		if(session.Reconnect()) { // CRASH !!!!!!!!!
			try {
				Sql sql;
				sql * Select(ID, VALUE).From(TEST_TABLE)
				                       .OrderBy(Descending(ID))
				                       .Limit(3);
				while(sql.Fetch())
					Cout() << AsString(sql[0]) << ": " << AsString(sql[VALUE]) << "\n";
			}
			catch(SqlExc &ex) {
				Cerr() << "ERROR: " << ex << "\n";
				SetExitCode(1);
			}
		} else {
			Cout() << "ERROR: " << session.GetLastError() << "\n";
		}
	}
	else {
		Cerr() <<"ERROR: Unable to connect to database\n";
		SetExitCode(1);
	}
}

mysqltest::mysqltest()
{
	CtrlLayout(*this, "Window title");
	
	acResult.AddColumn("Text");
	btConnect.WhenAction = THISBACK(mysqlConnect);
	btReConnect.WhenAction = THISBACK(mysqlReconnect);
	btDisconnect.WhenAction = THISBACK(mysqlDisconnect);
	btSelect.WhenAction = THISBACK(mysqlSelect);
	
	btConnect.Enable();
	btReConnect.Disable();
	btDisconnect.Disable();
	btSelect.Disable();
}

void mysqltest::mysqlConnect()
{
	if(session.Connect("user", "pw", "db", "localhost")) {
		SQL = session;
		
		btDisconnect.Enable();
		btSelect.Enable();
		btConnect.Disable();
		
		firstConnect = true;
	} else {
		Exclamation(session.GetLastError());
	}
}

void mysqltest::mysqlReconnect()
{
	if(!session.IsOpen()) {
		if(firstConnect) {
			if(session.Reconnect()) {
				SQL = session;
				
				btReConnect.Disable();
				btConnect.Disable();
				btSelect.Enable();
				btDisconnect.Enable();
				
				Exclamation("Reconnect succesfull!");
			} else {
				Exclamation(String() << "Reconnect failed with " << session.GetLastError());
			}
		} else {
			Exclamation("Use Connect first!");
		}
	}
}

void mysqltest::mysqlDisconnect()
{
	if(session.IsOpen()) {
		session.Close();
		
		acResult.Clear();
		
		if(!session.IsOpen()) {
			btConnect.Enable();
			btReConnect.Enable();
			btDisconnect.Disable();
			btSelect.Disable();
		
			Exclamation("Connection closed!");
		} else {
			Exclamation("Connection NOT closed!!!!!!!");
		}
	}
}

void mysqltest::mysqlSelect()
{
	if(session.IsOpen()) {
		
		try {
			Sql sql;
			sql.Execute("select name from names");
			
			if(sql.WasError()) {
				Exclamation(sql.GetLastError());
			} else {
				while(sql.Fetch()) {
					acResult.Add(sql[0]);
				}
			}
		} catch(SqlExc &ex) {
			Exclamation(ex);
		}
	} else {
		Exclamation("Database not opened!");
	}
}


GUI_APP_MAIN
{
	mysqltest().Run();
}