|
|
@@ -0,0 +1,998 @@
|
|
|
+<?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 ktrego system bedize
|
|
|
+ // rysowal tabele i komorki w drzewie zasobw ( 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(5,'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";
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+?>
|
