se/SE/superedit-SQIX_STRUCTURE_DB_SYNC_test.php

<?php
//@2014-01-20 added joining structure without loos data for CHAR->CHAR - only resize to bigger field if needed in new structure (sqix)
echo "version @2015-05-25 @2015-05-21 added TYPESPECIAL/TYPESPECIALS/VARIABLE/VARIABLES FIX DUBLES
version: @2014-01-21 added joining structure without loos data for ENUM->ENUM, SET->SET - try to add item in enum(sqix)<br>";
//
//[0] =>  alter table `SES_TV_A` CHANGE `P_DEVICE` `P_DEVICE` enum('BRAK','DEKODER SD','DEKODER HD','MODUL CAM','MULTIROOM') ; 
//    [1] => enum('BRAK','DEKODER SD','DEKODER HD','MODUL CAM','MULTIROOM')
//    [2] => enum('BRAK','DEKODER SD','DEKODER HD','MODUL CAM','MULTIROOM')
//    [3] => enum('BRAK','DEKODER SD','DEKODER HD','MODUL CAM')

//todo ID z import_translate nie moga byc podmieniane po imporcie, bo maja juz ID docelowe (wartosci nie klucze)

require_once dirname(__FILE__) . "/se-lib/Lib.php";
require_once dirname(__FILE__) . "/se-lib/ProcesHelper.php";
require_once dirname(__FILE__) . "/se-lib/Data_Source.php";
require_once dirname(__FILE__) . "/se-lib/Config.php";


//$cnf_test=Config::getData();
//DEBUG_S(-3,'Configs_test',$cnf_test,__FILE__,__FUNCTION__,__LINE__);
//


   function SQIX_STRUCTURE_DB_SYNC_test($LOCAL_DB_ZASOB_ID,$REMOTE_DB_ZASOB_ID,$DATABASE_ROOT_ZASOB_ID,$CONFIRM_SQL_UPDATE='',$SYNC_OPTIONS='',$DEBUG_LEVEL=null,$SKIP_OPTIONS=null) {
   		global $CNF_ZASOB,$localpath,$SYSTEM_PROFILE_STRING_IMPORT_EXPORT,$DATABASE_ROOT_ZASOB_ID,$CRM_IMPORT_TRANSLATE,$kodowania_local,$kodowania_remote;

if(empty($DEBUG_LEVEL)) $DEBUG_LEVEL=0;
$_SESSION['DEBUG']=$DEBUG_LEVEL;

//todo zczytaz z konfiga @2013-10
$CNF_ZASOB=array('import_db'=>array('SQL_DATABASE'=>'import_db'),'default_db'=>array('SQL_DATABASE'=>'default_db'),'test_db'=>array('SQL_DATABASE'=>'test_db'),'test3_db'=>array('SQL_DATABASE'=>'test3_db'));

$sql="select `ID`,`DESC` from `CRM_LISTA_ZASOBOW` where `TYPE`='DATABASE_MYSQL' or `TYPE`='DATABASE_POSTGRESQL' or `TYPE`='BAZA_DANYCH' ;";
	$db=DB::getdb();
	$res=$db->query($sql);
	while($h=$db->fetch($res)) {
		$CNF_ZASOB[$h->ID]['SQL_DATABASE']=$h->DESC;
	}


if(empty($DATABASE_ROOT_ZASOB_ID)) $DATABASE_ROOT_ZASOB_ID=2;
//todo powinno dzialac z konfiga

DEBUG_S(-3,'Parametry CRM_IMPORT_TRANSLATE - do ustalania konkretnych ID przy imporcie zasobow',$CRM_IMPORT_TRANSLATE);

if(empty($CRM_IMPORT_TRANSLATE)) {
 $CRM_IMPORT_TRANSLATE['CRM_LISTA_ZASOBOW'][36]=2; //baza danych[36] na baze danych zainicjalizowana
 $CRM_IMPORT_TRANSLATE['CRM_LISTA_ZASOBOW'][14]=1; //server[14]  na zainicjalizowany [1] tutaj definiujemy z zasob
}
DEBUG_S(-3,'Parametry CRM_IMPORT_TRANSLATE - do ustalania konkretnych ID przy imporcie zasobow',$CRM_IMPORT_TRANSLATE);

   			//Funkcja odbudowuje podstawowe zasoby struktur dotyczacych systemu PROCESOW - konfig : CREATE_ZASOBY_STRUCTURES_CONFIG oraz  SYNC_ZASOBY_STRUCTURES_FROM_CONFIG
   			//Nastepnie opcje umozliwiaja synchronizacje struktur pozostalych baz danych na podstawie zapisow w tabeli zasobow ( 
			//$DATABASE_ROOT_ZASOB_ID - w tym miejscu podajemy numer zasobu, od kt￳rego system bedize 
			//  rysowal tabele i komorki w drzewie zasob￳w ( lub je czytal)		
			//$SYNC_OPTIONS='CREATE_ZASOBY_STRUCTURES_CONFIG' from LOCAL -else option - this make base config file for structures
			//$SYNC_OPTIONS='SYNC_ZASOBY_STRUCTURES_FROM_CONFIG' from CONFIG to REMOTE -else option - buduje z konfiga structure i je odswieza dla lokalnej struktury glownych tabel - dziala na zdalnej tabeli
			//$SYNC_OPTIONS='FROM_ZASOBY_TO_DATABASE' from LOCAL to REMOTE -else option 
			//$SYNC_OPTIONS='FROM_DATABASE_TO_ZASOBY' from LOCAL to REMOTE -else option 
			//$SYNC_OPTIONS='FROM_ZASOBY_TO_ZASOBY' - from LOCAL to REMOTE TODO importuje zasoby oraz procesy z oznaczeniem where TAGS=%$SYSTEM_PROFILE_STRING_IMPORT_EXPORT% ,
			// z zasobu LOCAL do zasobu REMOTE ( zasoby powiazuje rekursywnie - zaimportowane zasoby maja oznaczenie LOCAL oraz jego ID w polach DESC )
			// draft dzialania tego algorytmu jest w sprawie BIALL_NET 1412 / 2012-10-06.MAPA_PROCESU.Mapy_procesow_biallnet_system_oraz_procesy5.graffle / Schemat Structure_zasob_sync(procesy)
			// uruchamia sie funkcja FROM_ZASOBY_TO_ZASOBY($CONNLOCAL,$CONNREMOTE,$SYSTEM_PROFILE_STRING_IMPORT_EXPORT)
			//$SYNC_OPTIONS='CLEAR_IMPORTED_ZASOBY_REMOTE' to REMOTE -else option 
			//$CONFIRM_SQL_UPDATE - jezeli tu bedzie jakas wartosc, to system bedzie wykonywac zapytania do bazy danych updatujace strukture, w przeciwnym razie bedzie tylko wypisywac zapytania


/*
if(0){
$LOCAL_DB_ZASOB_ID=$_REQUEST['LOCAL_DB_ZASOB_ID'];
$CONNLOCAL=mysql_connect($CNF_ZASOB[$LOCAL_DB_ZASOB_ID]['INTERFACE_ADDR'], 	$CNF_ZASOB[$LOCAL_DB_ZASOB_ID]['SQL_USER'], $CNF_ZASOB[$LOCAL_DB_ZASOB_ID]['SQL_USER_PASS'])
or die('nie moge polaczyc z '.$CNF_ZASOB[$LOCAL_DB_ZASOB_ID]['INTERFACE_ADDR']);
mysql_select_db($CNF_ZASOB[$LOCAL_DB_ZASOB_ID]['SQL_DATABASE'],$CONNLOCAL);	

$res=$CONNLOCAL->query("SHOW VARIABLES LIKE 'character\_set\_%';");
if ($r = mysql_fetch_object($res)) {
	echo'<pre style="max-height:200px;overflow:auto;border:1px solid red;text-align:left;"> (F.' . __FUNCTION__ . ':' . __LINE__ . '): ';print_r($r);echo'</pre>';
}
$sql = "SELECT * FROM  `CRM_PROCES`  WHERE  `ID` =344";
$res=$CONNLOCAL->query($sql);
if ($r = mysql_fetch_object($res)) {
	echo'<pre style="max-height:200px;overflow:auto;border:1px solid red;text-align:left;"> (F.' . __FUNCTION__ . ':' . __LINE__ . '): ';print_r($r);echo'</pre>';
}
die('404');
}
*/
if($_SESSION['ADM_ADMIN_LEVEL']!=0) { 
	unset($_SESSION['DEBUG']);
	die1('MUST BE USER ADMIN TO RUN THIS MODULE - ADMIN_LEVEL==0 now is:'.$_SESSION['ADM_ADMIN_LEVEL']);
}

if(empty($LOCAL_DB_ZASOB_ID)) {
	$LOCAL_DB_ZASOB_ID=$DATABASE_ROOT_ZASOB_ID; //local oznacza SOURCE
	$REMOTE_DB_ZASOB_ID=$DATABASE_ROOT_ZASOB_ID; //REMOTE oznacza DESTINATION
 //TODO zmienic na sciagniecie domyslnego numeru ID biezacej bazy danych @2014-06-26	//if(empty($DATABASE_ROOT_ZASOB_ID)) $DATABASE_ROOT_ZASOB_ID=$CNF_ZASOB[$REMOTE_DB_ZASOB_ID]['ZASOB_ROOT_ID_PLACE']; //domyslny localhost root numer z konfiga?

}
$SYSTEM_PROFILE_STRING_IMPORT_EXPORT='%GLOBAL%'; //override config


//Generuje menu dla ADMIN_LEVEL=0
if((!isset($LOCAL_DB_ZASOB_ID)||isset($REMOTE_DB_ZASOB_ID)||isset($SYNC_OPTIONS))&&(($_SESSION['ADMIN_LEVEL']==0)||($_SERVER["argv"][1]))) {

		if(!empty($_REQUEST['LOCAL_DB_ZASOB_ID'])) $LOCAL_DB_ZASOB_ID=$_REQUEST['LOCAL_DB_ZASOB_ID'];		
		if(!empty($_REQUEST['REMOTE_DB_ZASOB_ID'])) $REMOTE_DB_ZASOB_ID=$_REQUEST['REMOTE_DB_ZASOB_ID'];		
		if(!empty($_REQUEST['CONFIRM_SQL_UPDATE'])) $CONFIRM_SQL_UPDATE=$_REQUEST['CONFIRM_SQL_UPDATE'];		
		if(!empty($_REQUEST['SYNC_OPTIONS'])) $SYNC_OPTIONS=$_REQUEST['SYNC_OPTIONS'];	
		if(!empty($_REQUEST['DATABASE_ROOT_ZASOB_ID'])) $DATABASE_ROOT_ZASOB_ID=$_REQUEST['DATABASE_ROOT_ZASOB_ID'];		
		if(!empty($_REQUEST['SYSTEM_PROFILE_STRING_IMPORT_EXPORT'])) $SYSTEM_PROFILE_STRING_IMPORT_EXPORT=$_REQUEST['SYSTEM_PROFILE_STRING_IMPORT_EXPORT'];		
		if(!empty($_REQUEST['CREATE_ZASOBY_DATABASE_DESC'])) $CREATE_ZASOBY_DATABASE_DESC=$_REQUEST['CREATE_ZASOBY_DATABASE_DESC'];		
		if(!empty($_REQUEST['DEBUG_LEVEL'])) $DEBUG_LEVEL=$_REQUEST['DEBUG_LEVEL'];		

	//	if(!empty($_REQUEST['MERGE_RESOURCES_OPTION'])) $MERGE_RESOURCES_OPTION=$_REQUEST['MERGE_RESOURCES_OPTION'];		



	echo "\nTu bedzie menu dla Admina ";
	echo "\n<form action=?FUNCTION_INIT=SQIX_STRUCTURE_DB_SYNC>";
		echo "<input type=hidden name=FUNCTION_INIT value=SQIX_STRUCTURE_DB_SYNC>";
		echo "\n<table border=1><tr><td colspan=3>Menu systemu synchronizacji dla ADMINA</td></tr>";
		echo "\n<tr><td>Parametr zrodla</td><td><select name=LOCAL_DB_ZASOB_ID  id=LOCAL_DB_ZASOB_ID onchange=\" document.getElementById('DATABASE_ROOT_ZASOB_ID').value=document.getElementById('LOCAL_DB_ZASOB_ID').value \" >"; //document.getElementById(\"DATABASE_ROOT_ZASOB_ID\").value=10; //TODO
		print_r($CNF_ZASOB);
		foreach ($CNF_ZASOB as $CNF_ZASOB_IND=>$CNF_ZASOB_VAL) {
		echo "<option value='".$CNF_ZASOB_IND."' ";
				if($LOCAL_DB_ZASOB_ID==$CNF_ZASOB_IND) echo " selected=1 ";
		echo ">".$CNF_ZASOB_IND." :IP(".$CNF_ZASOB_VAL['INTERFACE_ADDR'].") DBNAME:(".$CNF_ZASOB_VAL['SQL_DATABASE'].")</option>";
   		  }
		echo "</select></td></tr>";
		echo "\n<tr><td>Parametr celu</td><td><select name='REMOTE_DB_ZASOB_ID'>";

				foreach ($CNF_ZASOB as $CNF_ZASOB_IND=>$CNF_ZASOB_VAL) {
		echo "\n<option value='".$CNF_ZASOB_IND."' ";
				if($REMOTE_DB_ZASOB_ID==$CNF_ZASOB_IND) echo " selected=1 ";
		echo ">".$CNF_ZASOB_IND." :IP(".$CNF_ZASOB_VAL['INTERFACE_ADDR'].") DBNAME:(".$CNF_ZASOB_VAL['SQL_DATABASE'].")</option>";
   		  }
		echo "</select></td></tr>";
		$SYNC_OPTIONS_MENU['CREATE_ZASOBY_STRUCTURES_CONFIG']="from LOCAL -else option - this make base config file for structures";
		$SYNC_OPTIONS_MENU['SYNC_ZASOBY_STRUCTURES_FROM_CONFIG']="from CONFIG to REMOTE -else option - buduje z konfiga structure i je odswieza dla lokalnej struktury glownych tabel - dziala na zdalnej tabeli";
		$SYNC_OPTIONS_MENU['SYNC_ZASOBY_STRUCTURES_FROM_CONFIG_WITHOUT_PROCEDURES_AND_VIEWS']="from CONFIG to REMOTE -else option - buduje z konfiga structure i je odswieza dla lokalnej struktury glownych tabel - dziala na zdalnej tabeli - pomija procedury i widoki";

		$SYNC_OPTIONS_MENU['CREATE_ZASOBY_DATABASE_DESC']=" (na CONNREMOTE) jezeli pierwszy raz uruchamiasz system nalezy dodac strukture do zasobow gdzie bedzie znajdowac sie definicja struktur systemu SE";
		$SYNC_OPTIONS_MENU['FROM_ZASOBY_TO_DATABASE']=" from LOCAL to REMOTE uzupelnia structure z hazy zasobow do BAZY_DANYCH sql";
		$SYNC_OPTIONS_MENU['SYSTEM_IMPORT_FIX_ZASOB_FIX_PROC_FIX_ALIAS']="Use before FROM_DATABASE_TO_ZASOBY to fix all current resources/processes not to being translated like external ones!!!";
		$SYNC_OPTIONS_MENU['FROM_DATABASE_TO_ZASOBY']="from LOCAL to REMOTE - uzupelnia structure zasobow o dane z aktualnej hazy danych razem z CECHAMI";

		$SYNC_OPTIONS_MENU['SYSTEM_IMPORT_FIX_ZASOB_FIX_PROC_FIX_ALIAS']="Uaktualnia pola w dodanych procesach i zasobach przez uzytkownika informacje o tym, ze dane nie pochodza z importu - nalezy wykonac przed importowaniem zasobow/procesow. W przypadku bledu w imporcie nie nalezy tej funkcji uruchamiac do czasu upewnienia sie, ze wszystkie procesy zostaly zaimportowane";
		$SYNC_OPTIONS_MENU['FROM_ZASOBY_TO_ZASOBY']="from LOCAL to REMOTE TODO importuje zasoby oraz procesy z oznaczeniem where TAGS=%$SYSTEM_PROFILE_STRING_IMPORT_EXPORT% ,
			 z zasobu LOCAL do zasobu REMOTE ( zasoby powiazuje rekursywnie - zaimportowane zasoby maja oznaczenie LOCAL oraz jego ID w polach DESC )
			 draft dzialania tego algorytmu jest w sprawie BIALL_NET 1412 / 2012-10-06.MAPA_PROCESU.Mapy_procesow_biallnet_system_oraz_procesy5.graffle / Schemat Structure_zasob_sync(procesy)
			 uruchamia sie funkcja FROM_ZASOBY_TO_ZASOBY(\$CONNLOCAL,\$CONNREMOTE,\$SYSTEM_PROFILE_STRING_IMPORT_EXPORT)";

		$SYNC_OPTIONS_MENU['MAKE_SE_AND_HIST_FIELDS_FOR_TABLE']="dodaje do okreslonych tabel kolumny A_RECORD_CREATE_DATE itp oraz tworzy tabele historyczna";
		$SYNC_OPTIONS_MENU['CLEAR_IMPORTED_ZASOBY_REMOTE']="kasuje zaimportowane fragmenty procesow z funkcji FROM_ZASOBY_TO_ZASOBY";
		$SYNC_OPTIONS_MENU['IMPORT_SORT_DESC_INFO']="importuje parametry sortowania oraz opisy zasobow";
		$SYNC_OPTIONS_MENU['CLEAR_TREE_DUBLES_AND_MOVE_WSK']="czysci drzewo zasobow z dubli i przesuwa wskazniki";




		echo "\n<tr><td>Opcja glowna funkcji </td><td><select name=SYNC_OPTIONS>";
				foreach ($SYNC_OPTIONS_MENU as $CNF_ZASOB_IND=>$CNF_ZASOB_VAL) {
		echo "\n <option value='".$CNF_ZASOB_IND."'  ";
			if($SYNC_OPTIONS==$CNF_ZASOB_IND) echo " selected ";
		echo ">".$CNF_ZASOB_IND." ".$CNF_ZASOB_VAL."</option>";
   		  }
		echo "</select></td></tr>";
		echo "<tr><td>Podaj numer zasobu do wstawiania komorek z bazy danych do jej synchronizacji \$DATABASE_ROOT_ZASOB_ID - do tego numeru system bedzie dopisywac kolejne zasoby TABEL,KOMOREK,CECH. Podaj numer zasobu [ID] o typie BAZA_DANYCH </td>";
		echo "\n<td><input type=text name=DATABASE_ROOT_ZASOB_ID id=DATABASE_ROOT_ZASOB_ID value='".$DATABASE_ROOT_ZASOB_ID."'></input></td></tr>";		
		echo "<tr><td>Podaj filtr/klucz do importu procesow z bazy LOCAL do bazy REMOTE \$SYSTEM_PROFILE_STRING_IMPORT_EXPORT - Te dane beda wyszukane po ADM_COMPANY , system dowiaze brakujace zasoby, przemapuje nowe ID i ustali ich powiazania w oparciu o tabele CRM_IMPORT_TRANSLATE </td>";
		echo "\n<td><input type=text name=SYSTEM_PROFILE_STRING_IMPORT_EXPORT value='".$SYSTEM_PROFILE_STRING_IMPORT_EXPORT."'></input></td></tr>";
		echo "\n<tr><td>Poziom debugu - ustaw na 6 aby mocno debugowac, na 1 aby slabo</td><td><input type=text name=DEBUG_LEVEL value='".$DEBUG_LEVEL."'></input></td></tr>";

		echo "<tr><td>Potwierdzenie dokonania zapisu na tabeli REMOTE</td><td><select name=CONFIRM_SQL_UPDATE>
			<option value=\"\"></option><option value=1>WYSLIJ DO BAZY</option><option value=REPLACE>WYSLIJ I NADPISZ STARE IMPORTY DO BAZY</option></td></tr></tr>";
		echo "<tr><td colspan=3><input type=submit name=submit value=OK></td></td>";
		echo "</table>";		

	echo "</form><br>\n";
	echo "<a href=?FUNCTION_INIT=SQIX_STRUCTURE_DB_SYNC>odswiez</a>";
	echo "<img src=icon/superedit-SQIX_STRUCTURE_DB_SYNC.png border=0 width=100%><br> \n";
		
		

		if(empty($_REQUEST['submit'])||empty($SYNC_OPTIONS) ) die1();
	}


// mozemy podac lokalna baze danych do weryfikacji oraz zdalna baze danych do weryfikacji
$config_base_structure=".config_base_structure.php";
//$CONFIRM_SQL_UPDATE='update';
//$SYNC_OPTIONS='FROM_ZASOBY_TO_ZASOBY'; //CLEAR_IMPORTED_ZASOBY_REMOTE //FROM_ZASOBY_TO_ZASOBY

						 $CECHY_POSZUKIWANE['FIELDS']['Field']='FIELD_PROP_Field';
						 $CECHY_POSZUKIWANE['FIELDS']['Type']='FIELD_PROP_Type';
						 $CECHY_POSZUKIWANE['FIELDS']['Null']='FIELD_PROP_Null';
						 $CECHY_POSZUKIWANE['FIELDS']['Default']='FIELD_PROP_Default';
						 $CECHY_POSZUKIWANE['FIELDS']['Extra']='FIELD_PROP_Extra';
						 $CECHY_POSZUKIWANE['INDEX']['Non_unique']='TAB_PR_Non_unique';
						 $CECHY_POSZUKIWANE['INDEX']['Key_name']='TAB_PR_Key_name';
						 $CECHY_POSZUKIWANE['INDEX']['Column_name']='TAB_PR_Column_name';
						 
						 
						 

//! set tables used to generate main structure
$TABLES_STRUCTURE_arr['MAIN'] = array();

$TABLES_STRUCTURE_DATA_arr['MAIN'] = array();

 
$TABLES_STRUCTURE_arr['BiAudit'] = array(
	'BI_audit_ALL',
	'BI_audit_ALL_ref',
	'BI_audit_ALL_ref_RELATIONS',
	'BI_audit_CEIDG',
	'BI_audit_CEIDG_pelnomocnicy',
	'BI_audit_CEIDG_powiazania',
	'BI_audit_ENERGA_FAKTURY',
	'BI_audit_ENERGA_FAKTURY_HIST',
	'BI_audit_ENERGA_KONTRAHENCI_group',
	'BI_audit_ENERGA_KONTRAHENCI_group_HIST',
	'BI_audit_ENERGA_PRACOWNICY',
	'BI_audit_ENERGA_PRACOWNICY_adresy',
	'BI_audit_ENERGA_PRACOWNICY_group',
	'BI_audit_ENERGA_PRACOWNICY_group_HIST',
	'BI_audit_ENERGA_PRACOWNICY_HIST',
	'BI_audit_ENERGA_RUM_KONTRAHENCI',
	'BI_audit_ENERGA_RUM_KONTRAHENCI_HIST',
	'BI_audit_ENERGA_RUM_KONTRAHENCI_POWIAZANIA',
	'BI_audit_ENERGA_RUM_KONTRAHENCI_POWIAZANIA_HIST',
	'BI_audit_ENERGA_RUM_KONTRAHENCI_POWIAZANIA_row',
	'BI_audit_ENERGA_RUM_KONTRAHENCI_POWIAZANIA_row_object',
	'BI_audit_ENERGA_RUM_UMOWY',
	'BI_audit_ENERGA_RUM_UMOWY_HIST',
	'BI_audit_KRS',
	'BI_audit_KRS_address',
	'BI_audit_KRS_company',
	'BI_audit_KRS_MSIG',
	'BI_audit_KRS_MSIG_HIST',
	'BI_audit_KRS_MSIG_poz',
	'BI_audit_KRS_person',
	'BI_audit_KRS_PKD',
	'BI_audit_KRS_PKD_HIST',
	'BI_audit_KW_requested',
	'BI_audit_KW_requested_HIST',
	'BI_audit_KW_requested_person',
	'BI_audit_MSIG',
	'BI_audit_MSIG_address',
	'BI_audit_MSIG_company',
	'BI_audit_MSIG_name',
	'BI_audit_MSIG_person',
	'BI_audit_MSIG_PKD',
	'BI_audit_MSIG_PKD_HIST',
	'BI_audit_operational_raport_note',
	'BI_audit_operational_raport_note_HIST',
	'BI_audit_taxpayer',
);

//$TABLES_STRUCTURE_DATA_arr['BiAudit'] = array('BI_audit_ALL','BI_audit_ALL_ref','BI_audit_ALL_ref_RELATIONS','BI_audit_CEIDG','BI_audit_CEIDG_pelnomocnicy','BI_audit_CEIDG_powiazania','BI_audit_KRS','BI_audit_KRS_company','BI_audit_KRS_person','CRM__#REF_TABLE__11','CRM__#REF_TABLE__12','CRM__#REF_TABLE__18','CRM__#REF_TABLE__19');


$TABLES_STRUCTURE = array();
$TABLES_STRUCTURE_DATA = array();
foreach ($TABLES_STRUCTURE_arr as $item) $TABLES_STRUCTURE = array_merge($TABLES_STRUCTURE, $item);
foreach ($TABLES_STRUCTURE_DATA_arr as $item) $TABLES_STRUCTURE_DATA = array_merge($TABLES_STRUCTURE_DATA, $item);



DEBUG_S(-3,'Lacze z bazami param: REMOTE_DB_ZASOB_ID',array($REMOTE_DB_ZASOB_ID,$CNF_ZASOB[$REMOTE_DB_ZASOB_ID]['INTERFACE_ADDR'],$CNF_ZASOB[$REMOTE_DB_ZASOB_ID]['SQL_USER'],$CNF_ZASOB[$REMOTE_DB_ZASOB_ID]['SQL_DATABASE']),__FILE__,__FUNCTION__,__LINE__ );
$CONNREMOTE = DB::getDB($REMOTE_DB_ZASOB_ID);
$CONNREMOTE->query('set global max_allowed_packet=1000000000');
/*				if(!isset($CNF_ZASOB[$REMOTE_DB_ZASOB_ID])&&($SYNC_OPTIONS!='CREATE_ZASOBY_DATABASE_DESC')) die1('Nie zdefiniowano w konfigu CONNREMOTE bazy '.$REMOTE_DB_ZASOB_ID.' uzyj opcji CREATE_ZASOBY_DATABASE_DESC aby stworzyc te pola i wprowadz zmienna DATABASE_ROOT_ZASOB_ID do konfiga!');
				$CONNREMOTE=mysql_connect($CNF_ZASOB[$REMOTE_DB_ZASOB_ID]['INTERFACE_ADDR'], 	$CNF_ZASOB[$REMOTE_DB_ZASOB_ID]['SQL_USER'], $CNF_ZASOB[$REMOTE_DB_ZASOB_ID]['SQL_USER_PASS'])
				or die1('nie moge polaczyc z '.$CNF_ZASOB[$REMOTE_DB_ZASOB_ID]['INTERFACE_ADDR']);
     		    mysql_select_db($CNF_ZASOB[$REMOTE_DB_ZASOB_ID]['SQL_DATABASE'],$CONNREMOTE);	
				if (isset($CNF_ZASOB[$REMOTE_DB_ZASOB_ID]['SQL_NAMES'])) $res=mysql_query("SET NAMES '{$CNF_ZASOB[$REMOTE_DB_ZASOB_ID]['SQL_NAMES']}';",$CONNREMOTE);
				$res=mysql_query("SHOW VARIABLES LIKE 'character\_set\_%';",$CONNREMOTE);
				while($h=mysql_fetch_object($res)) {
					$kodowania_remote[$h->Variable_name]=$h->Value;
				}
				DEBUG_S(-2,'Kodowania tej bazy remote',$kodowania_remote,__FILE__,__FUNCTION__,__LINE__);
				//echo "<pre> ".print_r($kodowania_remote)." </pre>";
*/
DEBUG_S(-3,'Lacze z bazami param: LOCAL_DB_ZASOB_ID',array($LOCAL_DB_ZASOB_ID,$CNF_ZASOB[$LOCAL_DB_ZASOB_ID]['INTERFACE_ADDR'], 	$CNF_ZASOB[$LOCAL_DB_ZASOB_ID]['SQL_USER'], $CNF_ZASOB[$LOCAL_DB_ZASOB_ID]['SQL_DATABASE']),__FILE__,__FUNCTION__,__LINE__ );
$CONNLOCAL = DB::getDB($LOCAL_DB_ZASOB_ID);
$CONNLOCAL->query('set global max_allowed_packet=1000000000');

//DEBUG_S(-3,'LOCAL_DB_ZASOB_ID/REMOTE',array($LOCAL_DB_ZASOB_ID,$REMOTE_DB_ZASOB_ID),__FILE__,__FUNCTION__,__LINE__);
//DEBUG_S(-3,'LOCAL_DB_ZASOB_ID/REMOTE',$CONNLOCAL,__FILE__,__FUNCTION__,__LINE__);

/*
				if(!isset($CNF_ZASOB[$LOCAL_DB_ZASOB_ID])&&($SYNC_OPTIONS!='CREATE_ZASOBY_DATABASE_DESC')) die1('Nie zdefiniowano w konfigu CONNREMOTE bazy '.$CONNLOCAL);
				$CONNLOCAL=mysql_connect($CNF_ZASOB[$LOCAL_DB_ZASOB_ID]['INTERFACE_ADDR'], 	$CNF_ZASOB[$LOCAL_DB_ZASOB_ID]['SQL_USER'], $CNF_ZASOB[$LOCAL_DB_ZASOB_ID]['SQL_USER_PASS'])
				or die1('nie moge polaczyc z '.$CNF_ZASOB[$LOCAL_DB_ZASOB_ID]['INTERFACE_ADDR']);
     		    mysql_select_db($CNF_ZASOB[$LOCAL_DB_ZASOB_ID]['SQL_DATABASE'],$CONNLOCAL);	
				if (isset($CNF_ZASOB[$LOCAL_DB_ZASOB_ID]['SQL_NAMES'])) $res=mysql_query("SET NAMES '{$CNF_ZASOB[$LOCAL_DB_ZASOB_ID]['SQL_NAMES']}';",$CONNLOCAL);
				$res=mysql_query("SHOW VARIABLES LIKE 'character\_set\_%';",$CONNLOCAL);
				while($h=mysql_fetch_object($res)) {
					$kodowania_local[$h->Variable_name]=$h->Value;
				}
				DEBUG_S(-2,'Kodowania tej bazy local',$kodowania_local,__FILE__,__FUNCTION__,__LINE__);
				//echo "<pre> ".print_r($kodowania_local)." </pre>";
*/
 
 
   		echo "<pre>\n";
   		echo "<hr>Odpalilem SQIX_STRUCTURE_DB_SYNC";
   
   echo "\n Lacze sie z baza lokalna :".$LOCAL_DB_ZASOB_ID;
   echo "\n Lacze sie z baza zdalna  :".$REMOTE_DB_ZASOB_ID;
   echo "\n Funkcja   :".$SYNC_OPTIONS;
   if(isset($_SESSION['CONFIG']['sql_character_set'])) {
	//   mysql_query("SET character_set_results = '".$_SESSION['CONFIG']['sql_character_set']."', character_set_client = '".$_SESSION['CONFIG']['sql_character_set']."', character_set_connection = '".$_SESSION['CONFIG']['sql_character_set']."', character_set_database = '".$_SESSION['CONFIG']['sql_character_set']."', character_set_server = '".$_SESSION['CONFIG']['sql_character_set']."'", $CONNLOCAL);
//	  mysql_query("SET character_set_results = '".$_SESSION['CONFIG']['sql_character_set']."', character_set_client = '".$_SESSION['CONFIG']['sql_character_set']."', character_set_connection = '".$_SESSION['CONFIG']['sql_character_set']."', character_set_database = '".$_SESSION['CONFIG']['sql_character_set']."', character_set_server = '".$_SESSION['CONFIG']['sql_character_set']."'", $CONNREMOTE);
//  mysql_query("SET character_set_results = 'latin2', character_set_client = 'latin2', character_set_connection = 'latin2', character_set_database = 'latin2', character_set_server = 'latin2'", $CONNREMOTE);
  //  mysql_set_charset('latin2',$CONNREMOTE);
//	mysql_query("SET NAMES 'utf-8'",$CONNREMOTE);
   }
   
   
  // print_r($CNF_ZASOB[$REMOTE_DB_ZASOB_ID]);
  function insert_converted($VAL) {
	// ! TODO @2013-02-18 funkcja ma za zadanie w odpowiedni sposob przekonwertowac zapisane dane
  	global $kodowania_local,$kodowania_remote;
  	
/*		$VALX=explode(" ",$VAL);
		foreach($VALX as $VALS) {
		$hex='';
	    for ($i=0; $i < strlen($VALS); $i++)
    		{
        		$hex .=" ".dechex(ord($VALS[$i]));
		    }
		 echo "\n<br>".$VALS."==".$hex ;
	}
   	// if($kodowania_local['character_set_server']<>$kodowania_remote['character_set_server']) {
	//       $VAL = iconv('UTF-8', 'ISO-8859-2', $VAL);
	//       $VAL = iconv($kodowania_remote['character_set_server'], $kodowania_local['character_set_server'], $VAL);

       //DEBUG_S(-3,'Kodowanie jest inne, wiec bedziemy konwertowac',array($kodowania_local,$kodowania_remote),__FILE__,__FUNCTION__,__LINE__);

   	 //}
   	 */
		return $VAL;
  	
  }
  

  
  // ! FROM_ZASOBY_TO_ZASOBY
  
  		//funkcja do usuniecia zasobow ze zdublowanymi nazwami, najlepiej tych, ktore nie maja uzytych procesow
  
  
  
  
   	   // ! CREATE_ZASOBY_STRUCTURES_CONFIG
       if($SYNC_OPTIONS=='CREATE_ZASOBY_STRUCTURES_CONFIG') {//budowa struktur w bazie
       
       		$TABLES_IMPORT=$CONNREMOTE->STRUCTURE_GENERATE($TABLES_STRUCTURE,null,$TABLES_STRUCTURE_DATA);
	   	//	$CONNREMOTE->STRUCTURE_GENERATE_to_xsd($TABLES_IMPORT,$CONNREMOTE,'/tmp/schema'); //Generujemy XSD dla struktur

//       		$TABLES_IMPORT=STRUCTURE_GENERATE($TABLES_STRUCTURE,$CONNREMOTE,$TABLES_STRUCTURE_DATA);
                    
           // $TABLES_STRUCTURE_DATA
   			$RETURN=serialize($TABLES_IMPORT);
   			if (is_writable('config/.config_base_structure.php')) {

   			$fp = fopen('config/.config_base_structure.php', 'w');
   			fwrite($fp, $RETURN);
			fclose($fp);
			DEBUG_S(-3,'Zapisano aktualna strukture danych do config/.config_base_structure.php','',__FILE__,__FUNCTION__,__LINE__);
   			//print_r($TABLES_IMPORT);
   			//print_r($TABLES_IMPORT);
   			} else {
   			  echo "\n\n\n config/.config_base_structure.php - nie jest do zapisu - zatem Zmienna do przekopiowania do konfiga config/".$config_base_structure."  : \n";
	   			echo $RETURN;
   				echo "\n";

   			 }
	
         
         
         
       				// ! SYNC_ZASOBY_STRUCTURES_FROM_CONFIG
       }   else    if($SYNC_OPTIONS=='SYNC_ZASOBY_STRUCTURES_FROM_CONFIG' or $SYNC_OPTIONS=='SYNC_ZASOBY_STRUCTURES_FROM_CONFIG_WITHOUT_PROCEDURES_AND_VIEWS') {//budowa struktur w bazie
					if(!file_exists(APP_PATH_ROOT."/config/".$config_base_structure)) die1("Brak konfiga w ".APP_PATH_ROOT."/config/".$config_base_structure." , wygeneruj go za pomoca opcji CREATE_ZASOBY_STRUCTURES_CONFIG");

					$handle = fopen(APP_PATH_ROOT."/config/".$config_base_structure, "r");
					$config_base_structure_serialized = fread($handle, filesize(APP_PATH_ROOT."/config/".$config_base_structure));
					fclose($handle);
					//echo $config_base_structure_serialized;
					$config_base_structure_unserialized=unserialize($config_base_structure_serialized);
					//print_r($config_base_structure_unserialized['CRM_AUTH_PROFILE']);
					if($SYNC_OPTIONS=='SYNC_ZASOBY_STRUCTURES_FROM_CONFIG_WITHOUT_PROCEDURES_AND_VIEWS') $SKIP_OPTIONS=array('SKIP-PROCEDURE','SKIP-VIEW');
					
					DEBUG_S(-3,'SKIP_OPTIONS,config_base_structure_unserialized',array($SKIP_OPTIONS,$config_base_structure_unserialized),__FILE__, __FUNCTION__, __LINE__) ;
					$CONNREMOTE->STRUCTURE_GENERATE_PARSE($config_base_structure_unserialized,$SKIP_OPTIONS); //@2014-08-14 TEST IT

					
					/*
	
						foreach($config_base_structure_unserialized as $TABLE=>$ARR_TABLE) { //dla kazdej tabeli 
						set_time_limit(36000);
						//! if($TABLE<>'_CRM_PROCES_USER_STATS_wiev') continue; //trigger development
						//! try to sync __SCHEMA_FUNCTIONS__ARRAY__
						if($TABLE=='__SCHEMA_FUNCTIONS__ARRAY__') {	
							DEBUG_S(-3,'Try to synchronize functions and procedures',$ARR_TABLE,__FILE__,__FUNCTION__,__LINE__);
	
														//BEGIN PROCEDURE
														$sql=" SHOW PROCEDURE STATUS; ;" ; //listujemy nasze procedury
										       			DEBUG_S(-3,'Looking for PROCEDURE ',$sql,__FILE__,__FUNCTION__,__LINE__);
										       				$result=$CONNREMOTE->query($sql) or die1('\nProblem z '.$sql);
									       			   	     while($h=mysql_fetch_object($result)) {		       				
			 								   			     if($h->Db<>$CONNREMOTE->getDatabaseName()) continue;
	
									       				     set_time_limit(36000);       				
		 							       					 $sql_="show create PROCEDURE {$h->Name} ;" ;
		 								   					 //echo $sql_;
		 								   					 $result_=$CONNREMOTE->query($sql_) or die1('\nProblem z '.$sql_);	
		 								   					 	while($h_=mysql_fetch_object($result_)) {			       					 
			 								   					 $FIELDS_CHECKED['FOUNDS'][$h->Name]=$h_;
		 							       					     
		 							       					     if(!isset($ARR_TABLE['PROCEDURE'][$h->Name])) {
		 							       					       DEBUG_S(-3,'We have some more functions - we will not delete them:'.$h->Name,null,__FILE__,__FUNCTION__,__LINE__);
		 							       					       //$FIELDS_CHECKED['TO_DELETE'][$h->Name]=$h_;
		 							       					       }
			 								   					 }
		 							       					   
									       				    }
										       				DEBUG_S(-3,'Try to unserialize PROCEDURE and install to db:',$ARR_TABLE['PROCEDURE'],__FILE__,__FUNCTION__,__LINE__);
									       				
									       				foreach($ARR_TABLE['PROCEDURE'] as $TRIGGER_INDEX=>$TRIGGER_OBJECT) {
											   				if(!isset($FIELDS_CHECKED['FOUNDS'][$TRIGGER_INDEX])) { $FIELDS_CHECKED['TO_CREATE'][$TRIGGER_INDEX]=$TRIGGER_OBJECT;
											   				DEBUG_S(-3,'We have object to create '.$TRIGGER_INDEX,$TRIGGER_OBJECT,__FILE__,__FUNCTION__,__LINE__);
											   				}
									       				}
	
	
										   				//staramy sie zaktualizowac stare triggery, pod warunkiem, ze sie roznia
									       				foreach($FIELDS_CHECKED['FOUNDS'] as $TRIGGER_INDEX=>$TRIGGER_OBJECT) {
										       				DEBUG_S(-3,'OBJ/OBJ for '.$TRIGGER_INDEX,array($TRIGGER_OBJECT->{'Create Procedure'},$ARR_TABLE['PROCEDURE'][$TRIGGER_INDEX]->{'Create Procedure'}),__FILE__, __FUNCTION__, __LINE__);
										       				if(isset($ARR_TABLE['PROCEDURE'][$TRIGGER_INDEX])) //we first try to find if this trigger exists or delete it
										       				if($TRIGGER_OBJECT->{'Create Procedure'}<>$ARR_TABLE['PROCEDURE'][$TRIGGER_INDEX]->{'Create Procedure'} )  { 
										       					DEBUG_S(-3,"Data are different ({$TRIGGER_INDEX}). We add object to be created as new.",__FILE__, __FUNCTION__, __LINE__);
											   					$FIELDS_CHECKED['TO_CREATE'][$TRIGGER_INDEX]=$ARR_TABLE['PROCEDURE'][$TRIGGER_INDEX];
											   					$FIELDS_CHECKED['TO_DELETE'][$TRIGGER_INDEX]=true;
	
											   				}
									       				}
									       				
									       				
									       				if(isset($FIELDS_CHECKED['TO_DELETE']))  {
									       					DEBUG_S(-3,'We have some data to delete',$FIELDS_CHECKED['TO_DELETE'],__FILE__,__FUNCTION__,__LINE__);
										   					foreach($FIELDS_CHECKED['TO_DELETE'] as $TRIGGER_INDEX=>$TRIGGER_OBJECT ) {
											   					$sql="DROP PROCEDURE IF EXISTS `{$TRIGGER_INDEX}`; ";
											   				    DEBUG_S(-3,' sql to delete  '.$TRIGGER_INDEX,$sql,__FILE__,__FUNCTION__,__LINE__);
											   				    if(!empty($CONFIRM_SQL_UPDATE))	$result=$CONNREMOTE->query($sql) or DEBUG_S(-3,'Problem ze SQL:',$sql,__FILE__, __FUNCTION__, __LINE__)  or die1(); 
	
										   					}
									       				}
									       				
									       				
									       				//tworzymy brakujace procedury
									       				foreach ($FIELDS_CHECKED['TO_CREATE'] as $TRIGGER_INDEX=>$TRIGGER_OBJECT) {
										       				$sql=$TRIGGER_OBJECT->{'Create Procedure'};
										       				DEBUG_S(-3,'Try to add new  '.$TRIGGER_INDEX,$sql,__FILE__,__FUNCTION__,__LINE__);
										       				if(!empty($CONFIRM_SQL_UPDATE))	$result=$CONNREMOTE->query($sql) or DEBUG_S(-3,'Problem ze SQL:',$sql,__FILE__, __FUNCTION__, __LINE__)  or die1(); 
										       				
									       				}
										   				unset($FIELDS_CHECKED);
										   				//EOF PROCEDURE
										   				
										   				
										   				//BEGIN FUNCTION
														$sql=" SHOW FUNCTION STATUS ;" ; //listujemy nasze procedury
										       			DEBUG_S(-3,'Looking for FUNCTION ',$sql,__FILE__,__FUNCTION__,__LINE__);
										       				$result=$CONNREMOTE->query($sql) or die1('\nProblem z '.$sql);
									       			   	     while($h=mysql_fetch_object($result)) {		       				
									       				     set_time_limit(36000);       				
		 							       					 $sql_="show create FUNCTION {$h->Name} ;" ;
		 								   					 //echo $sql_;
		 								   					 $result_=$CONNREMOTE->query($sql_) or die1('\nProblem z '.$sql_);	
		 								   					 	while($h_=mysql_fetch_object($result_)) {			       					 
			 								   					 $FIELDS_CHECKED['FOUNDS'][$h->Name]=$h_;
		 							       					       if(!isset($ARR_TABLE['FUNCTION'][$h->Name])) {
		 							       					          DEBUG_S(-3,'We have some more functions - we will not delete them:'.$h->Name,null,__FILE__,__FUNCTION__,__LINE__);
		 							       					         // $FIELDS_CHECKED['TO_DELETE'][$h->Name]=$h_;
		 							       					       }
			 								   					 }
		 							       					   
									       				    }
										       				DEBUG_S(-3,'Try to unserialize FUNCTION and install to db:',$ARR_TABLE['FUNCTION'],__FILE__,__FUNCTION__,__LINE__);
									       				
									       				foreach($ARR_TABLE['FUNCTION'] as $TRIGGER_INDEX=>$TRIGGER_OBJECT) {
											   				if(!isset($FIELDS_CHECKED['FOUNDS'][$TRIGGER_INDEX])) { $FIELDS_CHECKED['TO_CREATE'][$TRIGGER_INDEX]=$TRIGGER_OBJECT;
											   				DEBUG_S(-3,'We have object to create '.$TRIGGER_INDEX,$TRIGGER_OBJECT,__FILE__,__FUNCTION__,__LINE__);
											   				}
									       				}
	
	
										   				//staramy sie zaktualizowac stare triggery, pod warunkiem, ze sie roznia
									       				foreach($FIELDS_CHECKED['FOUNDS'] as $TRIGGER_INDEX=>$TRIGGER_OBJECT) {
										       				DEBUG_S(-3,'OBJ/OBJ for '.$TRIGGER_INDEX,array($TRIGGER_OBJECT->{'Create Function'},$ARR_TABLE['FUNCTION'][$TRIGGER_INDEX]->{'Create Function'}),__FILE__, __FUNCTION__, __LINE__);
										       				if(isset($ARR_TABLE['FUNCTION'][$TRIGGER_INDEX])) //we first try to find if this trigger exists or delete it
										       				if($TRIGGER_OBJECT->{'Create Function'}<>$ARR_TABLE['FUNCTION'][$TRIGGER_INDEX]->{'Create Function'} )  { 
										       					DEBUG_S(-3,"Data are different ({$TRIGGER_INDEX}). We add object to be created as new.",__FILE__, __FUNCTION__, __LINE__);
											   					$FIELDS_CHECKED['TO_CREATE'][$TRIGGER_INDEX]=$ARR_TABLE['FUNCTION'][$TRIGGER_INDEX];
											   					$FIELDS_CHECKED['TO_DELETE'][$TRIGGER_INDEX]=true;
	
											   				}
									       				}
									       				
									       				
									       				if(isset($FIELDS_CHECKED['TO_DELETE']))  {
									       					DEBUG_S(-3,'We have some data to delete',$FIELDS_CHECKED['TO_DELETE'],__FILE__,__FUNCTION__,__LINE__);
										   					foreach($FIELDS_CHECKED['TO_DELETE'] as $TRIGGER_INDEX=>$TRIGGER_OBJECT ) {
											   					$sql="DROP FUNCTION IF EXISTS `{$TRIGGER_INDEX}`; ";
											   				    DEBUG_S(-3,' sql to delete  '.$TRIGGER_INDEX,$sql,__FILE__,__FUNCTION__,__LINE__);
											   				    if(!empty($CONFIRM_SQL_UPDATE))	$result=$CONNREMOTE->query($sql) or DEBUG_S(-3,'Problem ze SQL:',$sql,__FILE__, __FUNCTION__, __LINE__)  or die1(); 
	
										   					}
									       				}
									       				
									       				
									       				//tworzymy brakujace procedury
									       				foreach ($FIELDS_CHECKED['TO_CREATE'] as $TRIGGER_INDEX=>$TRIGGER_OBJECT) {
										       				$sql=$TRIGGER_OBJECT->{'Create Function'};
										       				DEBUG_S(-3,'Try to add new  '.$TRIGGER_INDEX,$sql,__FILE__,__FUNCTION__,__LINE__);
										       				if(!empty($CONFIRM_SQL_UPDATE))	$result=$CONNREMOTE->query($sql) or DEBUG_S(-3,'Problem ze SQL:',$sql,__FILE__, __FUNCTION__, __LINE__)  or die1(); 
										       				
									       				}
										   				unset($FIELDS_CHECKED);
										   				//EOF FUNCTION
										   				
										   				//die1('app in devel');
	
	
	
	
							 continue; //no go to another table in loop
						} //eof 
						
							//! detect if src table is TABLE or VIEW
						  
						//	foreach($TABLES as $TABLE ){
	       										$sql="show full tables like   '".$TABLE."' ;" ;
	
												DEBUG_S(-3,'SQL:'.$CONNREMOTE->getDatabaseName(),$sql,__FILE__, __FUNCTION__, __LINE__) ;
	
	       										$result=$CONNREMOTE->query($sql) or die1('\nProblem z '.$sql);       				
	       										while($h=mysql_fetch_object($result))  {
		       										$FIELDS_CHECKED['Table_type']=$h->{'Table_type'};
	       										}
	       										    			
	       										    				
	       										if(mysql_num_rows($result)==0) {
	       										// nie ma tabeli - trzeba zapisac
			       									if($ARR_TABLE['Table_type']=='BASE TABLE') {
			       										//DEBUG_S(-3,"\n BRAK TABELI  dodajemy : ".$TABLE."!!!",null,__FILE__,__FUNCTION__,__LINE__);
			       									
			       										 $sql="create table ".$TABLE." ( ".$ARR_TABLE['FIELDS'][0]->Field." ".$ARR_TABLE['FIELDS'][0]->Type ; //  ID int(11) NOT NULL AUTO_INCREMENT,
															 if($ARR_TABLE['FIELDS'][0]->Null=='NO') $sql.=" not null "; else $sql.=" null ";
															 //if($ARR_TABLE['FIELDS'][0]->Extra=='auto_increment') $sql.=" AUTO_INCREMENT "; else $sql.="  ";
															$sql.=" )  DEFAULT CHARSET=latin2  ";
															 DEBUG_S(-3,"Brak tabeli: ".$TABLE." dodajemy sql:",$sql,__FILE__,__FUNCTION__,__LINE__) ;
															if(!empty($CONFIRM_SQL_UPDATE)) $CONNREMOTE->query($sql) or die1('\nProblem z CREATE '.$sql);
			
															 if($TABLE=='CRM_LISTA_ZASOBOW') {
															 		$sql=" alter table `".$TABLE."` AUTO_INCREMENT=1000 ";
															 		if(!empty($CONFIRM_SQL_UPDATE)) $CONNREMOTE->query($sql) or die1('\nProblem z AUTO INCREMENT '.$sql);
			
															 }
			       									} else if($ARR_TABLE['Table_type']=='VIEW') {
			       										$sql=$ARR_TABLE['VIEW']->{'Create View'};
				       									DEBUG_S(-3,"Brak widoku: ".$TABLE." dodajemy sql:",$sql,__FILE__,__FUNCTION__,__LINE__) ;
				       									if(!empty($CONFIRM_SQL_UPDATE)) $CONNREMOTE->query($sql) or die1('\nProblem ze '.$sql);
			       									}
			       										
	       										
	       										} else {
		       										//try to detect if types are the same
		       										if($ARR_TABLE['Table_type']<>$FIELDS_CHECKED['Table_type']) die1('Todo: ERROR  VIEW/TABLE different types ');
		       										if($ARR_TABLE['Table_type']=='VIEW') {
			       										if(isset($ARR_TABLE['VIEW'])) {
				       										
						       										
						       									$sql_="show create view `{$TABLE}` ;" ;
							   									echo $sql_;
							   									$result_=$CONNREMOTE->query($sql_) or die1('\nProblem z '.$sql_);	
							   									while($h_=mysql_fetch_object($result_)) {			       					 
								   									DEBUG_S(-3,"//! get current view info ".$TABLE." sql/res",array($sql_,$h_),__FILE__, __FUNCTION__, __LINE__);
								   									$FIELDS_CHECKED['VIEW']=$h_; 
								   								}
								   								//ereg_replace(, , )
										   					    if(strtolower($FIELDS_CHECKED['VIEW']->{'Create View'})<>strtolower($ARR_TABLE['VIEW']->{'Create View'})) {
											   					    $sql="drop view `{$TABLE}`";
											   					    if(!empty($CONFIRM_SQL_UPDATE)) $CONNREMOTE->query($sql) or die1('\nProblem ze '.$sql);
											   					    $sql_=$ARR_TABLE['VIEW']->{'Create View'};
											   					    DEBUG_S(-3,"//! Views are different for ".$TABLE." . Dropping old view and adding  new  (old/new/sql/sql):",array(strtolower($FIELDS_CHECKED['VIEW']->{'Create View'}),$ARR_TABLE['VIEW']->{'Create View'},$sql,$sql_,$h_),__FILE__, __FUNCTION__, __LINE__);
											   					    if(!empty($CONFIRM_SQL_UPDATE)) $CONNREMOTE->query($sql_) or die1('\nProblem ze '.$sql_);
	
										   					    }
						       										
				       										
				       										
			       										}
			       										
			       										
		       										}
		       										
	       										}
	       										
	       										//always create
	       										if($ARR_TABLE['Table_type']=='BASE TABLE') {
	       										set_time_limit(36000);
									       				$sql=" describe  `".$TABLE."` ;" ;
														DEBUG_S(-3,'SQL:describe '.$TABLE,$sql,__FILE__, __FUNCTION__, __LINE__) ;
	       										       	$result=$CONNREMOTE->query($sql) or die1('\nProblem z '.$sql);
	       										       	$FIELDS_CHECKED=""; unset($FIELDS_CHECKED);
	       										       	foreach($ARR_TABLE['FIELDS'] as $TSTIND=>$TST_VAL) { //tu robie tabelke do odhaczania z niej zmiennych
									       					$FIELDS_CHECKED['FIELD_IN_CONFIG_TO_BE_PASSED'][$TST_VAL->Field]=1;
									       					$FIELDS_CHECKED['FIELD_IN_CONFIG_THAT_EXISTS'][$TST_VAL->Field]=1;
									       				}
									       				DEBUG_S(-3,'FIELDS_CHECKED',$FIELDS_CHECKED,__FILE__, __FUNCTION__, __LINE__) ;
									       				$var_passed=false;
									       				while($h=mysql_fetch_object($result)) {		       				
									       					//tu sprawdzamy czy sa wszystkie kolumny i maja takie same typy
									       					$FIELDS_CHECKED['FIELD_FROM_DB'][$h->Field]=1;
									       						if(!isset($FIELDS_CHECKED['FIELD_IN_CONFIG_THAT_EXISTS'][$h->Field])) {
																	DEBUG_S(-3,'Za duzo o komorke '.$h->Field,$FIELDS_CHECKED,__FILE__, __FUNCTION__, __LINE__) ;
																	$FIELDS_CHECKED['FIELD_IN_CONFIG_THAT_NOT_EXISTS'][$h->Field]=1;
															 	}
									       					foreach($ARR_TABLE['FIELDS'] as $TSTIND=>$TST_VAL) { //tu sprawdzam czy kolumna jest i jaka
									       					 // echo "\n Tst ".$TST_VAL->Field." ==? ".$h->Field;
		
									       					  if($TST_VAL->Field==$h->Field) {
									       					  	 $FIELDS_CHECKED['FIELD_FOUND_IN_REMOTE_DB'][$h->Field]=1;
									       					  	 if(isset($FIELDS_CHECKED['FIELD_IN_CONFIG_TO_BE_PASSED'][$h->Field])) //jezeli byla komorka ramowa
																	 unset($FIELDS_CHECKED['FIELD_IN_CONFIG_TO_BE_PASSED'][$h->Field]);
									       					  	 }
									       					}
															
									       					//$TABLES_IMPORT[$TABLE]['FIELDS']=$h;
									       					
									       					
									       					
									       				}
									       				
									       				if(!empty($FIELDS_CHECKED['FIELD_IN_CONFIG_TO_BE_PASSED'])) DEBUG_S(-3,'Brakuje komorek dla '.$TABLE." ",array($FIELDS_CHECKED['FIELD_IN_CONFIG_TO_BE_PASSED']),__FILE__, __FUNCTION__, __LINE__);													
														DEBUG_S(-3,'FIELDS_CHECKED',$FIELDS_CHECKED,__FILE__, __FUNCTION__, __LINE__) ;
									       				//dodajemy brakujace komorki
									       				if(count($FIELDS_CHECKED['FIELD_IN_CONFIG_TO_BE_PASSED'])>0) {
									       						foreach($FIELDS_CHECKED['FIELD_IN_CONFIG_TO_BE_PASSED'] as $FIELD_TO_ADD=>$VAL ){
									       					set_time_limit(36000);
									       								//echo "\n Trying to add column: ".$FIELD_TO_ADD;
									       										if(isset($INDEX_OF_CONFIG_TABLE)) unset($INDEX_OF_CONFIG_TABLE);
									       								foreach($ARR_TABLE['FIELDS'] as $TSTIND=>$TST_VAL) { //trzeba znalezc numer ID indeksu brakujacej komorki
									       										if($TST_VAL->Field==$FIELD_TO_ADD) $INDEX_OF_CONFIG_TABLE=$TSTIND;
									       								}
									       								
									       								// $sql="create table ".$TABLE." ( ".$ARR_TABLE['FIELDS'][0]->Field." ".$ARR_TABLE['FIELDS'][0]->Type ; //  ID int(11) NOT NULL AUTO_INCREMENT,
																	 //if($ARR_TABLE['FIELDS'][0]->Extra=='auto_increment') $sql.=" AUTO_INCREMENT "; else $sql.="  ";
									       								$sql="alter table `".$TABLE."` add `".$FIELD_TO_ADD."` ".$ARR_TABLE['FIELDS'][$INDEX_OF_CONFIG_TABLE]->Type." ";
									       								if(($ARR_TABLE['FIELDS'][$INDEX_OF_CONFIG_TABLE]->Default)) {
									       								   if(($ARR_TABLE['FIELDS'][$INDEX_OF_CONFIG_TABLE]->Default=='NULL')||($ARR_TABLE['FIELDS'][$INDEX_OF_CONFIG_TABLE]->Default=='CURRENT_TIMESTAMP'))
									       									 $sql.=" DEFAULT ".$ARR_TABLE['FIELDS'][$INDEX_OF_CONFIG_TABLE]->Default." ";//   (".$INDEX_OF_CONFIG_TABLE.")";
									       									else $sql.=" DEFAULT '".$ARR_TABLE['FIELDS'][$INDEX_OF_CONFIG_TABLE]->Default."' ";//   (".$INDEX_OF_CONFIG_TABLE.")";
									       									 }
									       							    if($ARR_TABLE['FIELDS'][$INDEX_OF_CONFIG_TABLE]->Null=='NO') $sql.=" not null "; else $sql.=" null ";
									       							    $sql.=" ;";
									       								echo "\n ".$sql;
									       								if(!empty($CONFIRM_SQL_UPDATE)) $CONNREMOTE->query($sql) or  DEBUG_S(-3,'Problem z sql',$sql,__FILE__, __FUNCTION__, __LINE__)  or die1();
	
									       								
									       						}
									       				} //eof dodajemy brakujace komorki
									       				
									       				
									       				//Sprawdzamy czy sa zgodne typy komorek...
									       				$sql=" describe  `".$TABLE."` ;" ;
									       				DEBUG_S(-3,'describe '.$TABLE,$sql,__FILE__, __FUNCTION__, __LINE__) ;
									       				$result=$CONNREMOTE->query($sql) or die1('\nProblem z '.$sql);
									       				while($h=mysql_fetch_object($result)) {		       				
									       				set_time_limit(36000);       				
															$FIELDS_CHECKED['FIELD_FOUND_IN_REMOTE_DB_PROFILE'][$h->Field]=$h;
	
									       				}		
									       				DEBUG_S(-3,'FIELDS_CHECKED',$FIELDS_CHECKED,__FILE__, __FUNCTION__, __LINE__) ;
	
									       						foreach($FIELDS_CHECKED['FIELD_FOUND_IN_REMOTE_DB_PROFILE'] as $FIELD_TO_CHK=>$VAL) {
									       									if(isset($INDEX_OF_CONFIG_TABLE)) unset($INDEX_OF_CONFIG_TABLE);
									       								foreach($ARR_TABLE['FIELDS'] as $TSTIND=>$TST_VAL) { //trzeba znalezc numer ID indeksu brakujacej komorki
									       									if($TST_VAL->Field==$FIELD_TO_CHK) $INDEX_OF_CONFIG_TABLE=$TSTIND;
									       								}
									       								if(isset($FIELDS_CHECKED['FIELD_IN_CONFIG_THAT_NOT_EXISTS'][$FIELD_TO_CHK])) continue; //jezeli komorki nie ma i jest tylko lokalnie - ignorujemy!
									       								// to jakis glupi warunek ?
									       								if(!isset($INDEX_OF_CONFIG_TABLE)) die1('Nie znaleziono indeksu w konfiguracji dla '.$TABLE.' i komorki '.$FIELD_TO_CHK);
									       							//	echo "\nsprawdzamy wszystkie wlasciwosci dla db ".$TABLE." ".$FIELD_TO_CHK." col ".$INDEX_OF_CONFIG_TABLE;
																		$CHK_TYPES_ARS=array('Type','Null','Default');
																		$sql="";
																	//	 echo "\n if ".$VAL->Type." =? ".$ARR_TABLE['FIELDS'][$INDEX_OF_CONFIG_TABLE]->Type ;
																		if($VAL->Type!=$ARR_TABLE['FIELDS'][$INDEX_OF_CONFIG_TABLE]->Type) {
																		 //!  aktualizujemy typy
																		 	  $sql=" alter table `".$TABLE."` CHANGE `".$FIELD_TO_CHK."` `".$FIELD_TO_CHK."` ".$ARR_TABLE['FIELDS'][$INDEX_OF_CONFIG_TABLE]->Type." ; ";
	
																		      if(strstr($ARR_TABLE['FIELDS'][$INDEX_OF_CONFIG_TABLE]->Type, 'char(')&& strstr($VAL->Type, 'char(')){
																			      $src_char_len=ereg_replace('[^0-9]', '',$ARR_TABLE['FIELDS'][$INDEX_OF_CONFIG_TABLE]->Type ); 
																			      $dst_char_len=ereg_replace('[^0-9]', '',$VAL->Type );
	
																			      if($src_char_len>$dst_char_len) {  
																			      	  DEBUG_S(-3,'Aktualizacja rozszerzajaca zakres pola CHAR : CUR_CHAR_LEN ='.$src_char_len." and dest=".$dst_char_len ,$sql,__FILE__, __FUNCTION__, __LINE__);
																					  if(!empty($CONFIRM_SQL_UPDATE))	$result=$CONNREMOTE->query($sql) or DEBUG_S(-3,'Problem ze SQL:',$sql,__FILE__, __FUNCTION__, __LINE__)  or die1('\nProblem z '.$sql);
	
																			      } else {
																				         DEBUG_S(-3,'celowe pominiecie - aktualizacja moze skasowac dane w bazie!!! :',$sql,__FILE__, __FUNCTION__, __LINE__);
																						// die1();  
																			      }
																		      } else if(strstr($VAL->Type, 'enum(') && strstr($ARR_TABLE['FIELDS'][$INDEX_OF_CONFIG_TABLE]->Type, 'enum('  )) { //jezeli zmienia sie ENUM na inne ENUM
																		      
																			  	  preg_match('/^enum\((.*)\)$/', $ARR_TABLE['FIELDS'][$INDEX_OF_CONFIG_TABLE]->Type, $src_char_len);
																				  preg_match('/^enum\((.*)\)$/', $VAL->Type, $dst_char_len);
																				  
																				  $src_char_len=explode(',', $src_char_len[1]);$dst_char_len=explode(',', $dst_char_len[1]);
																				  foreach($src_char_len as $var) {
																					  if( !in_array($var, $dst_char_len)) $dst_char_len[]=$var;
																					  
																				  } 
																				  $dst_char_len="enum(".implode(",", $dst_char_len).")";
	 																	 	      $sql=" alter table `".$TABLE."` CHANGE `".$FIELD_TO_CHK."` `".$FIELD_TO_CHK."` ".$dst_char_len." ; ";
	
																		          DEBUG_S(-3,'Uzupelniamy strukture o ewentualnie brakujace elementy (sql,wynik polaczenia,import.strukt.,akt_strukt.)',array($sql,$dst_char_len,$ARR_TABLE['FIELDS'][$INDEX_OF_CONFIG_TABLE]->Type,$VAL->Type),__FILE__, __FUNCTION__, __LINE__);
																			   	  
																			   	  if(!empty($CONFIRM_SQL_UPDATE))	$result=$CONNREMOTE->query($sql) or DEBUG_S(-3,'Problem ze SQL:',$sql,__FILE__, __FUNCTION__, __LINE__)  or die1('\nProblem z '.$sql);
																		      
																		      } else if(strstr($VAL->Type, 'set(') && strstr($ARR_TABLE['FIELDS'][$INDEX_OF_CONFIG_TABLE]->Type, 'set('  )) { //jezeli zmienia sie ENUM na inne ENUM
																		      
																			  	  preg_match('/^set\((.*)\)$/', $ARR_TABLE['FIELDS'][$INDEX_OF_CONFIG_TABLE]->Type, $src_char_len);
																				  preg_match('/^set\((.*)\)$/', $VAL->Type, $dst_char_len);
																				  
																				  $src_char_len=explode(',', $src_char_len[1]);$dst_char_len=explode(',', $dst_char_len[1]);
																				  foreach($src_char_len as $var) {
																					  if( !in_array($var, $dst_char_len)) $dst_char_len[]=$var;
																					  
																				  } 
																				  $dst_char_len="set(".implode(",", $dst_char_len).")";
	 																	 	      $sql=" alter table `".$TABLE."` CHANGE `".$FIELD_TO_CHK."` `".$FIELD_TO_CHK."` ".$dst_char_len." ; ";
	
																		          DEBUG_S(-3,'Uzupelniamy strukture o ewentualnie brakujace elementy (sql,wynik polaczenia,import.strukt.,akt_strukt.)',array($sql,$dst_char_len,$ARR_TABLE['FIELDS'][$INDEX_OF_CONFIG_TABLE]->Type,$VAL->Type),__FILE__, __FUNCTION__, __LINE__);
																			   	  if(!empty($CONFIRM_SQL_UPDATE))	$result=$CONNREMOTE->query($sql) or DEBUG_S(-3,'Problem ze SQL:',$sql,__FILE__, __FUNCTION__, __LINE__)  or die1('\nProblem z '.$sql);
																		      
																		      } else if(strstr($VAL->Type, 'int(') && strstr($ARR_TABLE['FIELDS'][$INDEX_OF_CONFIG_TABLE]->Type, 'int('  )) {
																		          preg_match('/^int\((.*)\)$/', $ARR_TABLE['FIELDS'][$INDEX_OF_CONFIG_TABLE]->Type, $src_char_len);
																				  preg_match('/^int\((.*)\)$/', $VAL->Type, $dst_char_len);
																				  if($src_char_len[1]>$dst_char_len[1]) {
																				      $sql=" alter table `".$TABLE."` CHANGE `".$FIELD_TO_CHK."` `".$FIELD_TO_CHK."` ".$ARR_TABLE['FIELDS'][$INDEX_OF_CONFIG_TABLE]->Type." ; ";
																					  DEBUG_S(-3,'Aktualizacja rozszerzajaca zakres pola INT ma byc ='.$src_char_len[1]." byla dest=".$dst_char_len[1] ,$sql,__FILE__, __FUNCTION__, __LINE__);
																					 // if(!empty($CONFIRM_SQL_UPDATE))	$result=$CONNREMOTE->query($sql) or DEBUG_S(-3,'Problem ze SQL:',$sql,__FILE__, __FUNCTION__, __LINE__)  or die1('\nProblem z '.$sql);
																				  } else {
																					  DEBUG_S(-3,'Pominieta Aktualizacja zawiezajaca zakres pola INT ma byc ='.$src_char_len[1]." byla dest=".$dst_char_len[1] ,$sql,__FILE__, __FUNCTION__, __LINE__);
																				  }
																		      
																		      } else if( ( strstr($VAL->Type, 'char(') || strstr($VAL->Type, 'varchar(')  ) && strstr($ARR_TABLE['FIELDS'][$INDEX_OF_CONFIG_TABLE]->Type, 'text'  )
																		      			|| ( strstr($VAL->Type, 'bigint(')  ) && strstr($ARR_TABLE['FIELDS'][$INDEX_OF_CONFIG_TABLE]->Type, 'longblob'  )
																		      			|| ( strstr($VAL->Type, 'mediumtext')  ) && strstr($ARR_TABLE['FIELDS'][$INDEX_OF_CONFIG_TABLE]->Type, 'longblob'  )
																		      			|| ( strstr($VAL->Type, 'decimal(42')  ) && strstr($ARR_TABLE['FIELDS'][$INDEX_OF_CONFIG_TABLE]->Type, 'decimal(41'  )
																		      			|| ( strstr($VAL->Type, 'decimal(43')  ) && strstr($ARR_TABLE['FIELDS'][$INDEX_OF_CONFIG_TABLE]->Type, 'decimal(41'  )
	
																		      			) {
																		          
																				      $sql=" alter table `".$TABLE."` CHANGE `".$FIELD_TO_CHK."` `".$FIELD_TO_CHK."` ".$ARR_TABLE['FIELDS'][$INDEX_OF_CONFIG_TABLE]->Type." ; ";
																					  DEBUG_S(-3,'Aktualizacja rozszerzajaca zakres pola varchar/char() do text()',$sql,__FILE__, __FUNCTION__, __LINE__);
																					  if(!empty($CONFIRM_SQL_UPDATE))	$result=$CONNREMOTE->query($sql) or DEBUG_S(-3,'Problem ze SQL:',$sql,__FILE__, __FUNCTION__, __LINE__)  or die1('\nProblem z '.$sql);
																					 // DEBUG_S(-3,'Pominieta Aktualizacja zawiezajaca zakres pola INT ma byc ='.$src_char_len[1]." byla dest=".$dst_char_len[1] ,$sql,__FILE__, __FUNCTION__, __LINE__);
																				  
																		      
																		      } else {
																			  	  DEBUG_S(-3,'Celowe zabicie z uwagi na niebezpieczenstwo zmiany typu: sql/old/new',array($sql,$VAL->Type,$ARR_TABLE['FIELDS'][$INDEX_OF_CONFIG_TABLE]->Type),__FILE__, __FUNCTION__, __LINE__);
																			  	  die1();
																			   	  if(!empty($CONFIRM_SQL_UPDATE))	$result=$CONNREMOTE->query($sql) or DEBUG_S(-3,'Problem ze SQL:',$sql,__FILE__, __FUNCTION__, __LINE__)  or die1('\nProblem z '.$sql);
																			    }
																		    }
																		if($VAL->Null!=$ARR_TABLE['FIELDS'][$INDEX_OF_CONFIG_TABLE]->Null) 
																		  	if($ARR_TABLE['FIELDS'][$INDEX_OF_CONFIG_TABLE]->Null=='YES') { 
																			  $sql=" alter table `".$TABLE."` CHANGE `".$FIELD_TO_CHK."` `".$FIELD_TO_CHK."` ".$ARR_TABLE['FIELDS'][$INDEX_OF_CONFIG_TABLE]->Type." NULL ; ";
																			    if(!empty($CONFIRM_SQL_UPDATE))	$result=$CONNREMOTE->query($sql) or DEBUG_S(-3,'Problem ze SQL ',$sql,__FILE__, __FUNCTION__, __LINE__) or DIE();
																			  } else  { 
																		     	$sql=" alter table `".$TABLE."` CHANGE `".$FIELD_TO_CHK."` `".$FIELD_TO_CHK."` ".$ARR_TABLE['FIELDS'][$INDEX_OF_CONFIG_TABLE]->Type." NOT NULL ; ";
																		     	if(!empty($CONFIRM_SQL_UPDATE))	$result=$CONNREMOTE->query($sql) or DEBUG_S(-3,'Problem ze SQL ',$sql,__FILE__, __FUNCTION__, __LINE__) or DIE();
	
																		       }
																		if($VAL->Default!=$ARR_TABLE['FIELDS'][$INDEX_OF_CONFIG_TABLE]->Default) {
																			if($ARR_TABLE['FIELDS'][$INDEX_OF_CONFIG_TABLE]->Default=='CURRENT_TIMESTAMP')
													 						 $sql=" alter table `".$TABLE."` CHANGE `".$FIELD_TO_CHK."` `".$FIELD_TO_CHK."`  ".$ARR_TABLE['FIELDS'][$INDEX_OF_CONFIG_TABLE]->Type."  DEFAULT ".str_replace("'","",$ARR_TABLE['FIELDS'][$INDEX_OF_CONFIG_TABLE]->Default)."  ; ";
													 						else if(empty($ARR_TABLE['FIELDS'][$INDEX_OF_CONFIG_TABLE]->Default))
													 						 $sql=" alter table `".$TABLE."` CHANGE `".$FIELD_TO_CHK."` `".$FIELD_TO_CHK."`  ".$ARR_TABLE['FIELDS'][$INDEX_OF_CONFIG_TABLE]->Type." ; ";
													 						 else $sql=" alter table `".$TABLE."` CHANGE `".$FIELD_TO_CHK."` `".$FIELD_TO_CHK."`  ".$ARR_TABLE['FIELDS'][$INDEX_OF_CONFIG_TABLE]->Type."  DEFAULT '".$ARR_TABLE['FIELDS'][$INDEX_OF_CONFIG_TABLE]->Default."'  ; ";
																			if(!empty($CONFIRM_SQL_UPDATE))	$result=$CONNREMOTE->query($sql) or  DEBUG_S(-3,'Problem ze SQL ',$sql,__FILE__, __FUNCTION__, __LINE__) or DIE();
																			
																		}
																		//autoincrement:
																		if(($VAL->Extra!=$ARR_TABLE['FIELDS'][$INDEX_OF_CONFIG_TABLE]->Extra)&&$ARR_TABLE['FIELDS'][$INDEX_OF_CONFIG_TABLE]->Extra=='auto_increment' ) {
																			//sprawdzmy czy nie ma w tabeli klucza z PRIMARY z ID
																			$sql="show keys from  `".$TABLE."`";
																			$result=$CONNREMOTE->query($sql) or DEBUG_S(-3,'Problem ze SQL ',$sql,__FILE__, __FUNCTION__, __LINE__) or DIE();
																			 $TEST_IF_HAS_PRIMARY=false;
																			 while($tst=mysql_fetch_object($result)) { //dla kazdego klucza
																			   if($tst->Column_name==$FIELD_TO_CHK) //sprawdz czy jest klucz do tej kolumny
																			    if($tst->Key_name=='PRIMARY') $TEST_IF_HAS_PRIMARY=true; //jezeli jest primary, to flagujemy
																			 }
																			
																			if($TEST_IF_HAS_PRIMARY==false) { //bedziemy dodawac primary key 
																			  $sql="ALTER TABLE  `".$TABLE."` ADD PRIMARY KEY (  `".$FIELD_TO_CHK."` )";
																			  $result=$CONNREMOTE->query($sql) or DEBUG_S(-3,'Problem ze SQL ',$sql,__FILE__, __FUNCTION__, __LINE__) or DIE();
																			 } 
																			$sql=" alter table `".$TABLE."` CHANGE `".$FIELD_TO_CHK."` `".$FIELD_TO_CHK."`  ".$ARR_TABLE['FIELDS'][$INDEX_OF_CONFIG_TABLE]->Type."    ".$ARR_TABLE['FIELDS'][$INDEX_OF_CONFIG_TABLE]->Extra." ; ";
																			echo "\n SQL auto_increment ".$sql ;
																			if(!empty($CONFIRM_SQL_UPDATE))	$result=$CONNREMOTE->query($sql) or DEBUG_S(-3,'Problem ze SQL ',$sql,__FILE__, __FUNCTION__, __LINE__) or DIE();
																			
																		}
									       								//foreach($ARR_TABLE['FIELDS'][$INDEX_OF_CONFIG_TABLE] as $TST_FIELD_IND=>$TST_FIELD_VAL) {
									       								//   echo "\n TST2 ".$TST_FIELD_IND." ?= ".$FIELDS_CHECKED['FIELD_FOUND_IN_REMOTE_DB_PROFILE'][$TST_FIELD_IND]->$TST_FIELD_IND;
									       								//}
									       								
	
									       						}
									       				//print_r($FIELDS_CHECKED);
									       				
									       			    $sql=" show index from  `".$TABLE."` ;" ;
									       			    echo "\n ".$sql;
	       										       	$result=$CONNREMOTE->query($sql) or die1('\nProblem z '.$sql);
									       				while($h=mysql_fetch_object($result)) {		       				
									       				set_time_limit(36000);       				
									       					$FIELDS_CHECKED['INDEX_FOUND_IN_TABLES'][$h->Key_name]=$h;
									       				}
														foreach($ARR_TABLE['INDEX'] as $FOUND_INDEX_NAME=>$FOUND_INDEX_ARR){
															$FIELDS_CHECKED['INDEX_TO_BE_FOUND_IN_TABLES'][$FOUND_INDEX_NAME]=$FOUND_INDEX_ARR;
														}
									       				DEBUG_S(-3,'Znaleziono indeksy w tabeli '.$TABLE." FOUND/TO_BE_FOUND",array($FIELDS_CHECKED['INDEX_FOUND_IN_TABLES'],$FIELDS_CHECKED['INDEX_TO_BE_FOUND_IN_TABLES']),__FILE__, __FUNCTION__, __LINE__);													
														//teraz wygaszam znalezione indeksy
														foreach($ARR_TABLE['INDEX'] as $FOUND_INDEX_NAME=>$FOUND_INDEX_ARR){
															echo "\n If jest ".$FOUND_INDEX_NAME;
																if(isset($FIELDS_CHECKED['INDEX_FOUND_IN_TABLES'][$FOUND_INDEX_NAME])) 
														           unset($FIELDS_CHECKED['INDEX_TO_BE_FOUND_IN_TABLES'][$FOUND_INDEX_NAME]);
									       				}
														//print_r($FIELDS_CHECKED['INDEX_TO_BE_FOUND_IN_TABLES']);
														//brakujace klucze dodajemy
														foreach($FIELDS_CHECKED['INDEX_TO_BE_FOUND_IN_TABLES'] as $FOUND_INDEX_NAME=>$FOUND_INDEX_ARR) {
															if($FOUND_INDEX_NAME=='PRIMARY') {
																$FOUND_INDEX_ARR->Column_name=str_replace('`','',$FOUND_INDEX_ARR->Column_name);
															    $sql="ALTER TABLE  `".$TABLE."` ADD PRIMARY KEY (  `".$FOUND_INDEX_ARR->Column_name."` ) ;";
															    echo "\n 927: ".$sql;
															    if(!empty($CONFIRM_SQL_UPDATE))	$result=$CONNREMOTE->query($sql) or  print_r($FIELDS_CHECKED) &&  die1('\nProblem z '.$sql);
															    $sql="ALTER TABLE  `".$TABLE."` CHANGE  `".$FOUND_INDEX_ARR->Column_name."`  `".$FOUND_INDEX_ARR->Column_name."` ".$FIELDS_CHECKED['FIELD_FOUND_IN_REMOTE_DB_PROFILE'][$FOUND_INDEX_ARR->Column_name]->Type." AUTO_INCREMENT ; ";
															    echo "\n ".$sql;
															    if(!empty($CONFIRM_SQL_UPDATE))	$result=$CONNREMOTE->query($sql) or  print_r($FIELDS_CHECKED) &&  die1('\nProblem z '.$sql);
	
															    if(!empty($CONFIRM_SQL_UPDATE))	$result=$CONNREMOTE->query($sql) or  print_r($FIELDS_CHECKED) &&  die1('\nProblem z '.$sql);
															 } else if($FOUND_INDEX_ARR->Non_unique==1) {
															    $sql="ALTER TABLE  `".$TABLE."` ADD KEY `".$FOUND_INDEX_ARR->Key_name."`  (  ".$FOUND_INDEX_ARR->Column_name." ) ;" ;
															    echo "\n ".$sql; 
															    if(!empty($CONFIRM_SQL_UPDATE))	$result=$CONNREMOTE->query($sql) or DEBUG_S(-3,'Problem ze SQL:',$sql,__FILE__, __FUNCTION__, __LINE__)  or die1();
															 } else {
															 set_time_limit(36000);
															 	//@2013-01-17 poprawka do kluczy bledu w stylu  ALTER TABLE  `IN7_PRODUKTY_CECHY` ADD UNIQUE `UNIK_CECHY_PRODUKTU`  (  CECHA_ID, PRODUKT_ID , DESC  ) ;
																$CORRECT_INDEX_FOUNDKEY="";
																if(!strstr($FOUND_INDEX_ARR->Column_name,'`')) {
																	$explode=explode(' ',$FOUND_INDEX_ARR->Column_name);
																	foreach($explode as $exploded) {
																		$exploded=str_replace(',','',$exploded); //wywalenie przecinkow
																		if((!strstr($exploded,' '))&&(strlen($exploded)>1))
																		if($CORRECT_INDEX_FOUNDKEY) $CORRECT_INDEX_FOUNDKEY.=" , `".$exploded."` ";
																		else $CORRECT_INDEX_FOUNDKEY.=" `".$exploded."` ";
																	}
																} else $CORRECT_INDEX_FOUNDKEY=$FOUND_INDEX_ARR->Column_name;
	//															$CORRECT_INDEX_FOUNDKEY=$FOUND_INDEX_ARR->Column_name;
															    $sql="ALTER TABLE  `".$TABLE."` ADD UNIQUE `".$FOUND_INDEX_ARR->Key_name."`  (  ".$CORRECT_INDEX_FOUNDKEY." ) ;" ;
															    echo "\n ".$sql; 
	
															    if(!empty($CONFIRM_SQL_UPDATE))	$result=$CONNREMOTE->query($sql) or DEBUG_S(-3,'Problem ze SQL:',$sql,__FILE__, __FUNCTION__, __LINE__)  or die1(); 
															 }
														} 
														flush();
														
									       				//print_r($FIELDS_CHECKED);
									       				unset($FIELDS_CHECKED);
									       				$sql=" show triggers like '".$TABLE."' ;" ; //listujemy nasze triggery z tej tabeli
										       			DEBUG_S(-3,'Looking for triggers in '.$TABLE,$sql,__FILE__,__FUNCTION__,__LINE__);
										       				$result=$CONNREMOTE->query($sql) or die1('\nProblem z '.$sql);
									       			   	     while($h=mysql_fetch_object($result)) {		       				
									       				     set_time_limit(36000);       				
		 							       					 $sql_="show create trigger {$h->Trigger} ;" ;
		 								   					 //echo $sql_;
		 								   					 $result_=$CONNREMOTE->query($sql_) or die1('\nProblem z '.$sql_);	
		 								   					 	while($h_=mysql_fetch_object($result_)) {			       					 
			 								   					 $FIELDS_CHECKED['TRIGGER_FOUNDS'][$h->Trigger]=$h_;
		 							       					     if(!isset($ARR_TABLE['TRIGGERS'][$h->Trigger]))  $FIELDS_CHECKED['TRIGGER_TO_DELETE'][$h->Trigger]=$h_;
			 								   					 }
		 							       					   
									       				    }
										       				DEBUG_S(-3,'Try to unserialize trigger and install to db:',$ARR_TABLE['TRIGGERS'],__FILE__,__FUNCTION__,__LINE__);
									       				//! try to synchronize triggers $TABLE=>$ARR_TABLE
									       				foreach($ARR_TABLE['TRIGGERS'] as $TRIGGER_INDEX=>$TRIGGER_OBJECT) {
											   				if(!isset($FIELDS_CHECKED['TRIGGER_FOUNDS'][$TRIGGER_INDEX]))  $FIELDS_CHECKED['TRIGGER_TO_CREATE'][$TRIGGER_INDEX]=$TRIGGER_OBJECT;
									       				}
									       				
									       				//staramy sie zaktualizowac stare triggery, pod warunkiem, ze sie roznia
									       				foreach($FIELDS_CHECKED['TRIGGER_FOUNDS'] as $TRIGGER_INDEX=>$TRIGGER_OBJECT) {
										       				DEBUG_S(-3,'TRIGGER_OBJECT/$TRIGGER_OBJECT for '.$TRIGGER_INDEX,array($TRIGGER_OBJECT,$ARR_TABLE['TRIGGERS'][$TRIGGER_INDEX]),__FILE__, __FUNCTION__, __LINE__);
										       				if(isset($ARR_TABLE['TRIGGERS'][$TRIGGER_INDEX])) //we first try to find if this trigger exists or delete it
										       				if($TRIGGER_OBJECT->{'SQL Original Statement'}<>$ARR_TABLE['TRIGGERS'][$TRIGGER_INDEX]->{'SQL Original Statement'} )  { 
										       					DEBUG_S(-3,"Triggers are different ({$TRIGGER_INDEX}). We add object to be created as new.",__FILE__, __FUNCTION__, __LINE__);
											   					$FIELDS_CHECKED['TRIGGER_TO_CREATE'][$TRIGGER_INDEX]=$ARR_TABLE['TRIGGERS'][$TRIGGER_INDEX];
											   					$FIELDS_CHECKED['TRIGGER_TO_DELETE'][$TRIGGER_INDEX]=true;
	
											   				}
									       				}
									       				
									       				
									       				if(isset($FIELDS_CHECKED['TRIGGER_TO_DELETE']))  {
									       					DEBUG_S(-3,'We have some triggers to delete',$FIELDS_CHECKED['TRIGGER_TO_DELETE'],__FILE__,__FUNCTION__,__LINE__);
										   					foreach($FIELDS_CHECKED['TRIGGER_TO_DELETE'] as $TRIGGER_INDEX=>$TRIGGER_OBJECT ) {
											   					$sql="DROP TRIGGER IF EXISTS `{$TRIGGER_INDEX}`; ";
											   				    DEBUG_S(-3,' sql to delete trigger '.$TRIGGER_INDEX,$sql,__FILE__,__FUNCTION__,__LINE__);
											   				    if(!empty($CONFIRM_SQL_UPDATE))	$result=$CONNREMOTE->query($sql) or DEBUG_S(-3,'Problem ze SQL:',$sql,__FILE__, __FUNCTION__, __LINE__)  or die1(); 
	
										   					}
									       				}
									       				
									       				
									       				//tworzymy brakujace procedury
									       				foreach ($FIELDS_CHECKED['TRIGGER_TO_CREATE'] as $TRIGGER_INDEX=>$TRIGGER_OBJECT) {
										       				//$sql="DROP TRIGGER IF EXISTS `{$TRIGGER_INDEX}`; ";
										       				//DEBUG_S(-3,'Delete old trigger '.$TRIGGER_INDEX,$sql,__FILE__,__FUNCTION__,__LINE__);
										       				//if(!empty($CONFIRM_SQL_UPDATE))	$result=$CONNREMOTE->query($sql) or DEBUG_S(-3,'Problem ze SQL:',array($sql,mysql_error() ),__FILE__, __FUNCTION__, __LINE__)  or die1(); 
											   				//if(!empty($CONFIRM_SQL_UPDATE))	$result=$CONNREMOTE->query("show create trigger {$TRIGGER_INDEX}") or DEBUG_S(-3,'Problem ze SQL:'.mysql_error(),$sql,__FILE__, __FUNCTION__, __LINE__)  or die1(); 		
										       				$sql=$TRIGGER_OBJECT->{'SQL Original Statement'};
										       				DEBUG_S(-3,'Try to add new trigger '.$TRIGGER_INDEX,$sql,__FILE__,__FUNCTION__,__LINE__);
										       				if(!empty($CONFIRM_SQL_UPDATE))	$result=$CONNREMOTE->query($sql) or DEBUG_S(-3,'Problem ze SQL:',$sql,__FILE__, __FUNCTION__, __LINE__)  or die1(); 
										       				
									       				}
									       				
									       			
									       				
	       										}
	       										
	       										
	       				//tu bedziemy dodawac wartosci insert : 
	       				$sql="select count(*) as ilosc from `".$TABLE."` ;" ;
	
						DEBUG_S(-3,'SQL: licze czy cos jest w tabeli ',$sql,__FILE__, __FUNCTION__, __LINE__) ;
	
	       				$result=$CONNREMOTE->query($sql) or die1('\nProblem z '.$sql);   
	       				$ilosc=0;
	       						//while($h=mysql_fetch_object($result)) {
	       						//	$ilosc=$h->ilosc;
	       						//} 				
	       						//if($ilosc>0) {
	       						//	DEBUG_S(-2,'Nie trzeba dodawac rekordow - juz jakies sa w tabeli: ilosc : ',$ilosc,__FILE__,__FUNCTION__,__LINE__);
	       						//	continue ; 
	       						//} else {
	       						    if(!empty($ARR_TABLE['VALUES']))
		       						foreach($ARR_TABLE['VALUES'] as $ROW) {
										$sql="insert ignore into `".$TABLE."` values ( ";
										$vals="";
										foreach($ROW as $FIELD=>$VAL) {
											if(!$vals) $vals.="'".$VAL."'" ; else $vals.=" , '".$VAL."' ";
										}
										$sql.=$vals." ) ;";
										if(!empty($CONFIRM_SQL_UPDATE))	 $CONNREMOTE->query($sql) or die1('\nProblem z '.$sql);   
										DEBUG_S(-3,'Dodanie rekordu do tabeli ',$sql,__FILE__,__FUNCTION__,__LINE__);
										
										
		       						}
		       					//}						
	       										
	        			}

					*/	
					
					//}
			


       } 
				
   		
      		echo "</pre>\n";

   unset($_SESSION['DEBUG']);
   
   }
		
		
echo "<HR>EOF";



?>