#include "fplib01.h"
#include <prefix.h>
#include <config.h>
#include <utility.h>
#include <scanner.h>
#include <xvt.h>
#include <diction.h>
#include "text.h"
#include <isam.h>

void set_connection(SSimple_query& s)
{
	if (s.sq_connect(
		TString() << ini_get_string(CONFIG_DITTA, "fp", "ip") << "@" << ini_get_string(CONFIG_DITTA, "fp", "db"),
		ini_get_string(CONFIG_DITTA, "fp", "usr"),
		decode(ini_get_string(CONFIG_DITTA, "fp", "psw")),
		TSDB_MSSQL) != NOERR)
		fatal_box("Impossibile connettersi al DB esterno");

}

SSimple_query& db()
{
	static SSimple_query* db = nullptr;

	if (db == nullptr)
	{
		db = new SSimple_query();
		set_connection(*db);
		// Non utilizzo l'autocommit, viene gestito manualmente
		db->sq_set_autocommit(false);
	}
	return *db;
}

string getline(ifstream& f);

bool check_tables()
{
	/* 
	 * Da questo programma in poi verrą utilizzato un sistema diverso per la creazione e aggiornamento delle tabelle
	 * Verranno utilizzati dei file.sql aggiornati con il numero di patch, leggermente scomodo durante la creazione ma facile per i controlli successivamente
	 */
	SLIST files = xvt_fsys_list_files(".sql", "sql/fp0/", false);
	TLocalisamfile tabmod(LF_TABMOD);
	tabmod.put("MOD", "FP");
	tabmod.put("COD", "SQL");
	tabmod.put("CODTAB", "VERSION");
	TString version;
	if (tabmod.read() == NOERR)
		version = tabmod.get("S0");
	for(SLIST_ELT file = xvt_slist_get_first(files); file; file = xvt_slist_get_next(files, file))
	{
		TString file_version = TFilename(file->str).name_only();
		file_version = file_version.mid(2, 4);
		if (file_version <= version)
			continue;
		ifstream f(file->str);
		if(f.is_open())
		{
			string s;
			while(!f.eof())
			{ 
				static string r; 
				r = getline(f);
				if (r[0] == '-' && r[1] == '-')
						continue;
				s += r;
				// Cerco un ;
				const int limiter = s.find(';') + 1;
				if(limiter > 0)
				{
					string query = s.substr(0, limiter);
					s.erase(0, limiter);
					if(!db().sq_set_exec(query) || !db().sq_commit())
					{
						fatal_box("Impossibile eseguire/salvare la query:\n%s\n%s", query.c_str(), db().sq_get_string_error());
					}
				}
			}
		}
		else
		{
			cantread_box(file->str);
			return false;
		}
		// Salvo su tabmod
		tabmod.zero();
		tabmod.put("MOD", "FP");
		tabmod.put("COD", "SQL");
		tabmod.put("CODTAB", "VERSION");
		tabmod.put("S0", file_version);
		if(tabmod.rewrite_write() != NOERR && !yesno_box("Attenzione! Errore di aggiornamento versione di Database in Campo, continuare? %s", file_version))
		{
			return false;
		}
	}
	return true;
}

string getline(ifstream& f)
{
	string app;
	getline(f, app);
	return app;
}