se/SE/se-lib/Core/Database/Mysql.php

<?php


require_once dirname(__FILE__) . '/../../' . 'Lib.php';


Lib::loadClass('Core_Database');
Lib::loadClass('DBG');


class Core_Database_Mysql extends Core_Database {

	function __construct($host, $user, $password, $database, $names = '', $params = array()) {
		parent::__construct($host, $user, $password, $database, $names, $params);

		$this->_conn = @mysql_pconnect($host, $user, $password);
		if (!is_resource($this->_conn)) {
			$this->_set_error('CREATE CONNECTION FAILED');
			return;
		}
		if (false === mysql_select_db($database, $this->_conn)) {
			$this->_set_error('SELECT DATABASE FAILED');
			return;
		}

		if ($names != '') {
			$this->query(" SET NAMES '$names' ");
		}
	}

	function getConnection() {
		return $this->_conn;
	}

	function getVersion($version) {
		if (!$this->_version) {
			$sql = "SHOW VARIABLES LIKE 'version';";
			$res = $this->query($sql);
			if ($r = $this->fetch($res)) {
				// [Variable_name] => version, [Value] => 4.0.26-log
				$this->_version = $r->Value;
			}
		}
		return $this->_version;
	}

	/**
	 * Wykonuje podane zapytanie i zwraca wynik mysql_query().
	 */
	function query( $query, $msg = 'Query ERROR.' ) {
		$null = null;
		if (!$this->_conn) { return $null; }
		DBG::_('DBG_SQL', '>4', 'sql', $query, __CLASS__, __FUNCTION__, __LINE__);
		$res = mysql_query($query, $this->_conn);
		if (!$res) {
			DBG::_('DBG_SQL', '>1', 'SQL QUERY FAILED:', mysql_error($this->_conn), __CLASS__, __FUNCTION__, __LINE__);
			$this->_set_error('SQL QUERY FAILED: '.mysql_error($this->_conn));
			return $null;
		}
		return $res;
	}

	function fetch( $res ) {
		$ret = null;
		if ($res) $ret = mysql_fetch_object( $res );
		return $ret;
	}

	function fetch_row( $res ) {
		$ret = null;
		if ($res) $ret = mysql_fetch_row( $res );
		return $ret;
	}

	function fetch_assoc( $res ) {
		$ret = null;
		if ($res) $ret = mysql_fetch_assoc( $res );
		return $ret;
	}

	function fetch_array($res) {
		$ret = null;
		if ($res) $ret = mysql_fetch_array($res);
		return $ret;
	}

	function count( $res ) {
		return mysql_num_rows( $res );
	}

	function num_rows( $res ) {
		return mysql_num_rows( $res );
	}

	function insert_id() {
		return mysql_insert_id( $this->_conn );
	}
	function show_tables($table=null) {
		if(!empty($table)) $sql="show tables like '".$table."'";
		else $sql="show tables";
		$res = $this->query($sql);
		return $res;
	}

	function describe_table($table) {
		$sql='SHOW FIELDS FROM `'.$table.'`';
		$res = $this->query($sql);
		return $res;
	}

	function describe_table_value($table) {

		$res = self::describe_table($table);
		while($h=self::fetch($res)) {
			$result[$h->Field]=$h;
		}
		return $result;
	}

	function show_index($table,$only_primary_flag=false) {
		$sql="show index from `".$table."`";
		if($only_primary_flag) $sql.=" WHERE  `Key_name` =  'PRIMARY' ";

		$res=self::query($sql);
		return $res;

	}

	function show_index_value($table) {
		$res=self::show_index($table,true);
		while($h=self::fetch($res)) {
			return $h->Column_name;
		}
	}


	function get_by_data_column($table,$date_column,$timestamp,$now,$remote_key) {
		$structure=self::describe_table_value($table);
		if(strlen($timestamp)==0) $timestamp='0';
		//DEBUG_S(-3,'Struct',$structure,__FILE__,__FUNCTION__,__LINE__);


		$col=self::GET_DB_OBJ_cols($table);
		$sql='select '.implode(',', $col).' from `'.$table.'` where  COALESCE(unix_timestamp(`'.$date_column.'`), 0) >  '.$timestamp.'  and  COALESCE(unix_timestamp(`'.$date_column.'`), 0) < '.$now.' ';
//		$sql='select '.implode(',', $col).' from `'.$table.'` where  unix_timestamp(`'.$date_column.'`) >  '.$timestamp.' '; //TODO trzeba zmienic jak piotr zmieni ze A_RECORD_UPDATE_DATE sa trzymane w UTC

			//if(empty($timestamp))
			$sql.=' or `'.$date_column.'` is null';
			$sql.=' or `'.$remote_key.'` is null';

		DEBUG_S(-3,'biore dane ',$sql,__FILE__,__FUNCTION__,__LINE__);
		$res=self::query($sql) or die1($sql);
		return $res;
	}




	function get_current_time() {
		$sql=" select unix_timestamp(UTC_TIMESTAMP) as time ";
		$res=self::query($sql);
		while($h=self::fetch($res)) {
			return $h->time;
		}
	}



	function STRUCTURE_GENERATE($TABLES,$null=null,$TABLES_STRUCTURE_DATA,$flags=array()){
   				DEBUG_S(-3,'flags',$flags,__FILE__,__FUNCTION__,__LINE__);
   				//global $this;
   				//! try to create info for functions and procedures -> ['__SCHEMA_FUNCTIONS__ARRAY__']
   				$sql="show function status where Db='".$this->getDatabaseName()."';";
   					DEBUG_S(-3,'sql function detail :: ',$sql_,__FILE__,__FUNCTION__,__LINE__)	 ;
   				$result=$this->query($sql) or die1('\nProblem z '.$sql);
   				while($h=mysql_fetch_object($result)) {
   					$sql_="show create function `{$h->Name}`" ;
   					DEBUG_S(-3,'sql function detail :: ',$sql_,__FILE__,__FUNCTION__,__LINE__)	 ;
   					$result_=$this->query($sql_) or die1('\nProblem z '.$sql);
   					while($h_=mysql_fetch_object($result_)) {
   					$TABLES_IMPORT['__SCHEMA_FUNCTIONS__ARRAY__']['FUNCTION'][$h->Name]=$h_;
   					}
	   			}


	   			$sql="show PROCEDURE status where Db='".$this->getDatabaseName()."';";
   			   	DEBUG_S(-3,'sql function detail :: ',$sql_,__FILE__,__FUNCTION__,__LINE__)	 ;
   				$result=$this->query($sql) or die1('\nProblem z '.$sql);
   				while($h=mysql_fetch_object($result)) {
   					$sql_="show create PROCEDURE `{$h->Name}`" ;
   					DEBUG_S(-3,'sql PROCEDURE detail :: ',$sql_,__FILE__,__FUNCTION__,__LINE__)	 ;
   					$result_=$this->query($sql_) or die1('\nProblem z '.$sql);
   					while($h_=mysql_fetch_object($result_)) {
   					$TABLES_IMPORT['__SCHEMA_FUNCTIONS__ARRAY__']['PROCEDURE'][$h->Name]=$h_;
   					}
	   			}
	   				DEBUG_S(-3,'struktury funkcji: __SCHEMA_FUNCTIONS__ARRAY__ ',array($TABLES_IMPORT['__SCHEMA_FUNCTIONS__ARRAY__'],$TABLES),__FILE__,__FUNCTION__,__LINE__)	 ;
   				//die1('stop function during dev.');

		       		foreach($TABLES as $TABLE ){

		       				$sql="show tables like   '".$TABLE."' ;" ;
		       				DEBUG_S(-3,'//! Listing possible tables to write to config',$sql,__FILE__,__FUNCTION__,__LINE__);
		       				$result=$this->query($sql) or die1('\nProblem z '.$sql);
		       				if(mysql_num_rows($result)==0) {
		       				// nie ma tabeli - trzeba zapisac
		       				DEBUG_S(-3," BRAK TABELI ".$TABLE,null,__FILE__,__FUNCTION__,__LINE__);
		       				//die1();
		       				if(isset($TABLES_IMPORT[$TABLE])) {
			       				DEBUG_S(-3," Table already imported - problem in twice declared table ".$TABLE,null,__FILE__,__FUNCTION__,__LINE__);
			       				die1();
		       				}
		       				} else {


		       						$sql="show full tables like   '".$TABLE."' ;" ;
			   						$result=$this->query($sql) or die1('\n214:Problem z '.$sql);
			   						while($h=mysql_fetch_object($result)) {
				   						$TABLES_IMPORT[$TABLE]['Table_type']=$h->{'Table_type'};
				       					DEBUG_S(-3,'//! Reading to conf if table is WIEV or not :sql/result',array($sql,$h->{'Table_type'}),__FILE__,__FUNCTION__,__LINE__);
					   				}

					   				$FLAG_CONTABLE=false;

					   				if( ($TABLES_IMPORT[$TABLE]['Table_type']=='BASE TABLE')
					   					|| ( in_array('with_view', $flags) && $TABLES_IMPORT[$TABLE]['Table_type']=='VIEW' )
					   				) {
				       						$FLAG_CONTABLE=true;
						       				$sql=" describe  `".$TABLE."` ;" ;
						       				//echo "\n ".$sql;
				       				       	$result=$this->query($sql) or die1('\nProblem z '.$sql);
						       				while($h=mysql_fetch_object($result)) {
						       					$TABLES_IMPORT[$TABLE]['FIELDS'][]=$h;
						       				}
						       			    $sql=" show index from  `".$TABLE."` ;" ;
				       				       	$result=$this->query($sql) or die1('\nProblem z '.$sql);
											$TMP_KEYNAME=array();
						       						while($h=mysql_fetch_object($result)) {
							       						if(isset($h->Column_name)) { $h->Column_name="`".$h->Column_name."`";
														if(!isset($TMP_KEYNAME[$h->Key_name])) $TMP_KEYNAME[$h->Key_name]=$h->Column_name;
														else $TMP_KEYNAME[$h->Key_name].=",".$h->Column_name;
														}
														//if(isset($TABLES_IMPORT[$TABLE]['INDEX'][$h->Key_name])) {
														//   $TABLES_IMPORT[$TABLE]['INDEX'][$h->Key_name]->Column_name.=", ".$h->Column_name." ";
														//} else {
														//}
														$TABLES_IMPORT[$TABLE]['INDEX'][$h->Key_name]=$h;
														$TABLES_IMPORT[$TABLE]['INDEX'][$h->Key_name]->Column_name=$TMP_KEYNAME[$h->Key_name];
													}
						       				if(in_array($TABLE,$TABLES_STRUCTURE_DATA)) { //bedziemy dodawac dane tej tabeli
						       					 $sql=" select  * from  `".$TABLE."` ;" ;
				       				       		 $result=$this->query($sql) or die1('\nProblem z '.$sql);
				       				       		 while($h=mysql_fetch_object($result)) {
						       					 	$TABLES_IMPORT[$TABLE]['VALUES'][]=$h;
						       					 }
						       				}

						       				DEBUG_S(-3,"Dane tabeli KOMORKI ".$TABLE." ",$TABLES_IMPORT[$TABLE]['FIELDS'],__FILE__, __FUNCTION__, __LINE__);
						       				DEBUG_S(-3,"Dane tabeli INDEKSY ".$TABLE." ",$TABLES_IMPORT[$TABLE]['INDEX'],__FILE__, __FUNCTION__, __LINE__);
						       				if(isset($TABLES_IMPORT[$TABLE]['VALUES'])) DEBUG_S(-3,"Dane tabeli VALUES ".$TABLE." ",$TABLES_IMPORT[$TABLE]['VALUES'],__FILE__, __FUNCTION__, __LINE__);

							   				//! reading triggers to conf -> $TABLES_IMPORT[$TABLE]['TRIGGERS']
							   			    $sql=" show triggers like '".$TABLE."' ;" ;
				       				       	$result=$this->query($sql) or die1('\nProblem z '.$sql);
						       				while($h=mysql_fetch_object($result)) {
						       					 $sql_="show create trigger {$h->Trigger} ;" ;
							   					 echo $sql_;
		    		       				         $result_=$this->query($sql_) or die1('\nProblem z '.$sql_);
		    		       				         while($h_=mysql_fetch_object($result_)) {
							   					  DEBUG_S(-3,"Dane tabeli h_ ".$TABLE." ",$h_,__FILE__, __FUNCTION__, __LINE__);
						       					  $TABLES_IMPORT[$TABLE]['TRIGGERS'][$h->Trigger]=$h_;
						       					 }
								   			}
								   			if(isset($TABLES_IMPORT[$TABLE]['TRIGGERS'])) DEBUG_S(-3,"Dane tabeli TRIGGERS ".$TABLE." ",$TABLES_IMPORT[$TABLE]['TRIGGERS'],__FILE__, __FUNCTION__, __LINE__);

						       			}
						       			if(($TABLES_IMPORT[$TABLE]['Table_type']=='VIEW')) {
								   			 $FLAG_CONTABLE=true;
							       			 $sql_="show create view `{$TABLE}` ;" ;
							   					 //echo $sql_;
		    		       				         $result_=$this->query($sql_) or die1('\nProblem z '.$sql_);
		    		       				         while($h_=mysql_fetch_object($result_)) {
							   					  DEBUG_S(-3,"//! trying to fetch create view fom".$TABLE." sql/res",array($sql_,$h_),__FILE__, __FUNCTION__, __LINE__);
						       					  $TABLES_IMPORT[$TABLE]['VIEW']=$h_;
						       					 }

						       			} if(!$FLAG_CONTABLE) {
						       			  DEBUG_S(-3,"Unknown table type ! ".$TABLE." ".$TABLES_IMPORT[$TABLE]['Table_type'],$TABLES_IMPORT[$TABLE],__FILE__, __FUNCTION__, __LINE__);
						       			  die1();
						       			}

						   			}
		            }
		            //print_r($TABLES_IMPORT);


					if(!function_exists('func_sort_tables_import')) {
		            function func_sort_tables_import($a,$b){
		               if($a['Table_type']==$b['Table_type']) return 0;
		               else if($a['Table_type']=='VIEW') return 1;
		               else return -1;
                            }
                     }
                           uasort($TABLES_IMPORT,'func_sort_tables_import');

		           DEBUG_S(-3,'Wygenerowane struktury (TABLES_IMPORT)',$TABLES_IMPORT,__FILE__,__FUNCTION__,__LINE__);
		           return($TABLES_IMPORT);
         	}




	function set_last_sync_date($table,$now,$remote_db_id,$local_db_id,$timestamp_column='A_RECORD_UPDATE_DATE') {
		$sql="insert  into _SYNC_DATABASE_TABLE_STATE ( TABLE_NAME, LAST_SYNCED , DATABASE_SYNCED_ID , DATABASE_LOCAL_ID )
		values ('".$table."' , from_unixtime('".$now."') , '".$remote_db_id."' , '".$local_db_id."')";
		DEBUG_S(-3,'update sync date',$sql,__FILE__,__FUNCTION__,__LINE__);
		self::query($sql) or die('310Problem z '.$sql);
		$sql="update  _SYNC_DATABASE_TABLE_STATE set  LAST_SYNCED=from_unixtime('".$now."') where TABLE_NAME='".$table."'
			and DATABASE_SYNCED_ID='".$remote_db_id."' and DATABASE_LOCAL_ID='".$local_db_id."' ";

		$sql_c="update `".$table."` set `".$timestamp_column."`=from_unixtime('".$now."') where `".$timestamp_column."` is null ";
	    self::query($sql_c) or die('315Problem z '.$sql_c);
		DEBUG_S(-3,'update sync date',array($sql,$sql_c),__FILE__,__FUNCTION__,__LINE__);
	}

	function get_last_sync_date($table,$remote_db_id,$local_db_id) {
		$sql="select TABLE_NAME, unix_timestamp(LAST_SYNCED) as LAST_SYNCED from _SYNC_DATABASE_TABLE_STATE
		where DATABASE_SYNCED_ID='".$remote_db_id."' and DATABASE_LOCAL_ID='".$local_db_id."' and TABLE_NAME='".$table."'
		order by ID desc limit 1
		";
		$res=DB::query($sql);
		DEBUG_S(-3,'Get date',$sql,__FILE__,__FUNCTION__,__LINE__);
		while($h=DB::fetch($res)) {
			return $h->LAST_SYNCED;

		}
		return 0;
	}



	function SHOW_TABLE_STATUS_LIKE($table) {
		$records=$this->query("SHOW TABLE STATUS LIKE '".$table."'");
		if ($record = $this->fetch_assoc($records)) {
//		DEBUG_S(-3,'SHOW_TABLE_STATUS_LIKE',$record,__FILE__,__FUNCTION__,__LINE__);
		return $record;
		}

	}

	function affected_rows($needed_in_psql_only=null) {
		return mysql_affected_rows( $this->_conn );
	}

	function _( $str ) {
		return mysql_real_escape_string( $str, $this->_conn );
	}

	function error() {
		return "#".mysql_errno($this->_conn).": ".mysql_error($this->_conn);
	}

	function errno() {
		return mysql_errno($this->_conn);
	}

	function get_by_id( $table, $id ) {
		$null = null;
		$sql = "select p.*
			from `".$table."` as p
			where p.`ID`='".$id."'
		";
		$res = $this->query( $sql );
		if ($r = $this->fetch( $res )) {
			return $r;
		}
		return $null;
	}


	function get_searched_obj($table,$obj_filter,$obj_get=null,$obj_group=null,$obj_order=null) {
		foreach($obj_filter as $k=>$v) {
			$where[]='`'.$k.'` like \''.$v.'\'';
		}

		if(!empty($obj_get)) {
			foreach($obj_get as $k=>$v) {
				$what[]="`".$k."`";
			}
		}

		if(!empty($obj_group)) {
			foreach($obj_group as $k=>$v) {
				$group[]="`".$k."`";
			}
		}
		if(!empty($obj_order)) {
			foreach($obj_order as $k=>$v) {
				if($v=='DESC') $order[]="`".$k."` DESC ";
				else $order[]="`".$k."`";
			}
		}
		if(!empty($order)) $order_by=" order by ".implode(',', $order); else $order_by="  ";
		if(!empty($what)) $select=implode(',', $what); else $select=" * ";
		if(!empty($group)) $group_by=" group by ".implode(',', $group); else $group_by="";
		$sql="select ".$select." from `".$table."` where ".implode(' and ', $where)." ".$group_by." ".$order_by;
	//	DEBUG_S(-3,'Select',$sql,__FILE__,__FUNCTION__,__LINE__);
		$result=$this->query($sql);
		return $result;
	}


	/** Returns formated array to parse it to SQL (especialy to get GIS data to keep as WKT)
	  *
	  */

	function GET_DB_OBJ_cols($table) {
				$structure=self::describe_table_value($table);
				foreach($structure as $Field=>$Struct) {
						//echo $Struct->Type;
						if(strstr($Struct->Type,"multipoint"))  $col[]=' AsWKT(`'.$Field.'`) as "'.$Field.'"';
						else if(strstr($Struct->Type,"linestring")) $col[]=' AsWKT(`'.$Field.'`) as "'.$Field.'"';
						else if(strstr($Struct->Type,"multilinestring")) $col[]=' AsWKT(`'.$Field.'`) as "'.$Field.'"';
						else if(strstr($Struct->Type,"polygon")) $col[]=' AsWKT(`'.$Field.'`) as "'.$Field.'"';
						else if(strstr($Struct->Type,"multipolygon")) $col[]=' AsWKT(`'.$Field.'`) as "'.$Field.'"';
						else if(strstr($Struct->Type,"point")) $col[]=' AsWKT(`'.$Field.'`) as "'.$Field.'"';

						else $col[]='`'.$Field.'`';
				}
				return $col;
	}
	/** Use it before pasting obj to UPDATE_OBJ or ADD_NEW_OBJ to maintain GIS data especially
	 *
	 */

	function MAKE_DB_OBJ($table,$obj,$dieonerror=null) {
		$structure=self::describe_table_value($table); //todo to cache optimize
		foreach(get_object_vars($obj) as $k=>$v) {
			if(($structure[$k]->Type=='multipoint')||($structure[$k]->Type=='point')||($structure[$k]->Type=='linestring')||($structure[$k]->Type=='polygon')||($structure[$k]->Type=='multipolygon')||($structure[$k]->Type=='multilinestring')) {
				if(empty($v)) {
					unset($k);
					unset($v);
					continue;
				}
				else $v = "GeomFromText('".$v."')";
			}
		$obj_ret->$k=$v;
		}
		return $obj_ret;
	}

	/**
	 * @returns int
	 *   1 - changed but without add hist
	 *   2 - changed and add hist
	 *   0 - nothing to change
	 *   -1 - sql errors
	 *   -2 - error id not exists in DB
	 *   -3 - error ID not set
	 *
	 * TODO: sprawdzac czy w hist mozna odczytac aktualny stan, jesli nie to dodac caly rekord do HIST, jako 'procesy-fix-hist-data'
	 */
	public function UPDATE_OBJ($table, $sql_obj,$timestamp=null,$skip_author=null) {
		$structure=self::describe_table_value($table); //todo to cache optimize
		$primary=self::show_index_value($table); //todo to cache optimize

		$primaryKey = V::geti($primary, '', $sql_obj);
		if ($primaryKey <= 0) {
			$this->_set_error("Missing primary key '{$primary}' in table '{$table}'!");
			return -3;
		}

		// check if record $primaryKey exists
		if (($curr_obj = $this->get_by_id( $table, $primaryKey )) == null) {
			$this->_set_error("Record '{$primaryKey}' not exists in table '{$table}'!");
			return -2;
		}

		// check if enything changed
		$changed = false;
		foreach (get_object_vars($sql_obj) as $k => $v) {
			if (strtolower($k) == strtolower($primary)) continue;
			if ($v == $curr_obj->$k) {// === ?
				unset($sql_obj->$k);
			} else {
				$changed = true;
			}
		}
		if ($changed == false) {
			return 0;// record not changed
		}

		$sql_arr = array();
		// TODO: add admin columns if exists in table - search in session
		$admin_col = array();
		$admin_col[] = 'A_RECORD_CREATE_DATE';
		$admin_col[] = 'A_RECORD_CREATE_AUTHOR';
		// ...
		$sql_obj->A_RECORD_UPDATE_DATE = date('Y-m-d-H:i');
// OFF - BUG w _HIST		$sql_obj->A_RECORD_UPDATE_DATE = "FROM_UNIXTIME(".$this->get_current_time().")";

		$sql_obj->A_RECORD_UPDATE_AUTHOR = User::getName();
		foreach (get_object_vars($sql_obj) as $k => $v) {
		   if(!empty($skip_author)) {
			   if($k=='A_RECORD_UPDATE_AUTHOR') continue;
			   if($k=='A_RECORD_UPDATE_DATE') continue;
		   }


			if (strtoupper($v) == 'NOW()') {
				$v = 'NOW()';
			} else if (strtoupper($v) == 'NULL') {
				$v = 'NULL';
			} else if (substr($v, 0, strlen('GeomFromText')) == 'GeomFromText') {

			} else {
				$v = $this->_($v);
				$v = "'{$v}'";
			}
			$sql_arr [] = "`{$k}`={$v}";
		}
		$sql = "update `{$table}` set ".implode(",", $sql_arr)." where `ID`='{$primaryKey}' limit 1; ";
		$this->query($sql);

		$returnError = false;
		$skipDbErrorAddHist = false;
		if ($this->has_errors()) {
			$returnError = true;
			if (1146 == $this->errno()) {
				$skipDbErrorAddHist = true;
			}
		}

		$returnCode = 0;
		$affected = $this->affected_rows();
		if ($affected || $skipDbErrorAddHist) {
			$returnCode = 1;
			$sql_obj->ID_USERS2 = $primaryKey;
			foreach (get_object_vars($sql_obj) as $k => $v) {
				if (strtolower($k) == strtolower($primary)) unset($sql_obj->$k);
			}
			$new_id = $this->ADD_NEW_OBJ("{$table}_HIST", $sql_obj);
			if ($new_id) {
				$returnCode += 1;
			}
		}
		if ($returnError) {
			return -1;
		}
		return $returnCode;
	}

	function ADD_NEW_OBJ( $table, $sql_obj,$dieonerror=null ) {

		//TODO to optimize:
		$structure=self::describe_table_value($table);
		$primary=self::show_index_value($table);
		$sql_arr = array();
		// TODO: add admin columns if exists in table - search in session
		$admin_col = array();
		$admin_col []= 'ID';
		$admin_col []= 'A_RECORD_CREATE_DATE';
		$admin_col []= 'A_RECORD_CREATE_AUTHOR';
		$admin_col []= 'A_RECORD_UPDATE_DATE';
		$admin_col []= 'A_RECORD_UPDATE_AUTHOR';
		// ...
		$sql_arr["`ID`"] = "NULL";// add default value for ID, NULL in all inserts
		if (substr($table, 0, -5) == '_HIST') {
			$sql_obj->A_RECORD_UPDATE_DATE = date('Y-m-d-H:i');
			$sql_obj->A_RECORD_UPDATE_AUTHOR = User::getName();
		} else {
			$sql_obj->A_RECORD_CREATE_DATE = date('Y-m-d-H:i');
			$sql_obj->A_RECORD_CREATE_AUTHOR = User::getName();
		}

		foreach (get_object_vars($sql_obj) as $k => $v) {
			if($k==$primary) $v='0';
			else if (strtoupper($v) == 'NOW()') {
				$v = 'NOW()';
			} else if (strtoupper($v) == 'NULL' && substr($table, -5) != '_HIST') {
				$v = 'NULL';
			} else if (substr($v, 0, strlen('GeomFromText')) == 'GeomFromText') {

			} else {
				$v = $this->_($v);
				$v = "'{$v}'";
			}
			$sql_arr ["`{$k}`"] = $v;
		}
		$sql = "insert into `{$table}` (".implode(",", array_keys($sql_arr)).") values (".implode(",", array_values($sql_arr))."); ";
		//error_log($sql);
		$this->query($sql);

		if ($this->has_errors()) {
			if(!empty($dieonerror)) {
			  echo'<pre style="max-height:200px;overflow:auto;border:1px solid red;text-align:left;">db errors: (' . __CLASS__ . '::' . __FUNCTION__ . ':' . __LINE__ . '): ';print_r($this->get_errors());echo'</pre>';
			  DEBUG_S(-3,'Bledne zapytanie sql',$sql,__FILE__,__FUNCTION__,__LINE__);
			}
		}

		$ret_id = $this->insert_id();
		if (substr($table, -5) == '_HIST') {
			return $ret_id;
		}
		if ($ret_id) {
			$sql_obj->ID_USERS2 = $ret_id;
			unset($sql_obj->ID);
			$new_id_hist = $this->ADD_NEW_OBJ($table . '_HIST', $sql_obj);
			// error jesli nie udalo sie dodac rekordu do tabeli _HIST
		}
		return $ret_id;
	}

	function add_index($tbl,$column) {
		$sql="alter table `".$tbl."` add index(`".$column."`) ; ";
		self::query($sql);

	}

	function STRUCTURE_GENERATE_PARSE($config_base_structure_unserialized,$options=array()) {

					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__') {
						if(in_array('SKIP-PROCEDURE', $options)) {
							DEBUG_S(-3,'SKIP-PROCEDURES option',null,__FILE__,__FUNCTION__,__LINE__);
							continue;
						}


														//BEGIN PROCEDURE
						DEBUG_S(-3,'Try to synchronize functions and procedures',$ARR_TABLE,__FILE__,__FUNCTION__,__LINE__);

													$sql=" SHOW PROCEDURE STATUS; ;" ; //listujemy nasze procedury
									       			DEBUG_S(-3,'Looking for PROCEDURE ',$sql,__FILE__,__FUNCTION__,__LINE__);
									       				$result=$this->query($sql) or die1('\nProblem z '.$sql);
								       			   	     while($h=mysql_fetch_object($result)) {
		 								   			     if($h->Db<>$this->getDatabaseName()) continue;

								       				     set_time_limit(36000);
	 							       					 $sql_="show create PROCEDURE {$h->Name} ;" ;
	 								   					 //echo $sql_;
	 								   					 $result_=$this->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__);
										   				    	$result=$this->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__);
									       					$result=$this->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=$this->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_=$this->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__);
										   				    	$result=$this->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__);
									       					$result=$this->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:'.$this->getDatabaseName(),$sql,__FILE__, __FUNCTION__, __LINE__) ;

       										$result=$this->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.=" ) ENGINE=MyISAM DEFAULT CHARSET=latin2 ";
														 DEBUG_S(-3,"Brak tabeli: ".$TABLE." dodajemy sql:",$sql,__FILE__,__FUNCTION__,__LINE__) ;
														 $this->query($sql) or die1('\nProblem z CREATE '.$sql);

														 if($TABLE=='CRM_LISTA_ZASOBOW') {
														 		$sql=" alter table `".$TABLE."` AUTO_INCREMENT=1000 ";
														 		 $this->query($sql) or die1('\nProblem z AUTO INCREMENT '.$sql);

														 }
		       									} else if($ARR_TABLE['Table_type']=='VIEW') {

		       										if(in_array('SKIP-VIEW', $options)) {
		       										DEBUG_S(-3,"SKIP-VIEW Brak widoku: ".$TABLE." :",null,__FILE__,__FUNCTION__,__LINE__) ;
		       										} else {
		       										$sql=$ARR_TABLE['VIEW']->{'Create View'};
			       									DEBUG_S(-3,"Brak widoku: ".$TABLE." dodajemy sql:",$sql,__FILE__,__FUNCTION__,__LINE__) ;
			       									 $this->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'])) {

					       								if(in_array('SKIP-VIEW', $options)) {
						   								DEBUG_S(-3,"SKIP-VIEW option set - for ".$TABLE." :",null,__FILE__,__FUNCTION__,__LINE__) ;
		       											} else {
					       									$sql_="show create view `{$TABLE}` ;" ;
						   									echo $sql_;
						   									$result_=$this->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}`";
										   					     $this->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__);
										   					     $this->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=$this->query($sql) or die1('\nProblem z '.$sql);
       										       	$FIELDS_CHECKED=""; unset($FIELDS_CHECKED);
	   											   	$PRIMARY_FIELD=self::show_index_value($TABLE);

       										       	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(in_array('SKIP-PRIMARY-KEY', $options) && ($PRIMARY_FIELD==$INDEX_OF_CONFIG_TABLE))  {
								       							    	$sql.=" null ";
								       							    } else {
								       							    if($ARR_TABLE['FIELDS'][$INDEX_OF_CONFIG_TABLE]->Null=='NO') $sql.=" not null "; else $sql.=" null ";
								       							    }
								       							    $sql.=" ;";
								       								DEBUG_S(-3,'add field',$sql,__FILE__,__FUNCTION__,__LINE__);
								       								 $this->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=$this->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="";
																	// $val1=utf8_encode($VAL->Type);
																	// $val2=utf8_encode($ARR_TABLE['FIELDS'][$INDEX_OF_CONFIG_TABLE]->Type);
																	// echo "\n<br> if(".(trim($VAL->Type)==trim($ARR_TABLE['FIELDS'][$INDEX_OF_CONFIG_TABLE]->Type))." vs ".($VAL->Type==$ARR_TABLE['FIELDS'][$INDEX_OF_CONFIG_TABLE]->Type).") ".var_dump($VAL->Type)." =? ".var_dump($ARR_TABLE['FIELDS'][$INDEX_OF_CONFIG_TABLE]->Type)." ".gettype($VAL->Type)." ".gettype($ARR_TABLE['FIELDS'][$INDEX_OF_CONFIG_TABLE]->Type) ;

																	if((trim($VAL->Type)!=trim($ARR_TABLE['FIELDS'][$INDEX_OF_CONFIG_TABLE]->Type)) ) {

																	 //!  aktualizujemy typy
																	 	  DEBUG_S(-3,'VAL Type ('.$VAL->Type.')!= ARR_TABLE ('.$ARR_TABLE['FIELDS'][$INDEX_OF_CONFIG_TABLE]->Type.') ',array($VAL->Type,$ARR_TABLE['FIELDS'][$INDEX_OF_CONFIG_TABLE]->Type),__FILE__,__FUNCTION__,__LINE__);
																	 	  var_dump($VAL->Type);var_dump($ARR_TABLE['FIELDS'][$INDEX_OF_CONFIG_TABLE]->Type);
																	 	  $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__);
																				  	$result=$this->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." ; ";
 																	 		 	 $sql=str_replace("',)", "')", $sql); //Todo @2014-11 jakis chory blad implode 'WAIT',) ;
																	          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__);

																		   	  	$result=$this->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__);
																		   	  	$result=$this->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__);
																				  	$result=$this->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] ,array($sql,$src_char_len,$dst_char_len,$ARR_TABLE['FIELDS'][$INDEX_OF_CONFIG_TABLE]->Type),__FILE__, __FUNCTION__, __LINE__);
																			  }

																	     } else if(strstr($VAL->Type, 'double(') && strstr($ARR_TABLE['FIELDS'][$INDEX_OF_CONFIG_TABLE]->Type, 'double('  )) {

																	          preg_match('/^double\((.*),[0-9]+\)$/', $ARR_TABLE['FIELDS'][$INDEX_OF_CONFIG_TABLE]->Type, $src_char_len);
																			  preg_match('/^double\((.*),[0-9]+\)$/', $VAL->Type, $dst_char_len);
																			  preg_match('/^double\([0-9]+,(.*)\)$/', $ARR_TABLE['FIELDS'][$INDEX_OF_CONFIG_TABLE]->Type, $src_char_len_com);
																			  preg_match('/^double\([0-9]+,(.*)\)$/', $VAL->Type, $dst_char_len_com);

																			  if($src_char_len[1]>$dst_char_len[1] and $src_char_len_com[1]>=$dst_char_len_com[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 Double ma byc ='.$src_char_len[1]." byla dest=".$dst_char_len[1] ,$sql,__FILE__, __FUNCTION__, __LINE__);
																				 	$result=$this->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 Double ma byc ='.$src_char_len[1]." byla dest=".$dst_char_len[1] ,array($sql,$src_char_len,$dst_char_len,$ARR_TABLE['FIELDS'][$INDEX_OF_CONFIG_TABLE]->Type),__FILE__, __FUNCTION__, __LINE__);
																			  }



																	      } else if(strstr($VAL->Type, 'geometry') && (    strstr($ARR_TABLE['FIELDS'][$INDEX_OF_CONFIG_TABLE]->Type, 'polygon'  ) or   strstr($ARR_TABLE['FIELDS'][$INDEX_OF_CONFIG_TABLE]->Type, 'point'  )    or strstr($ARR_TABLE['FIELDS'][$INDEX_OF_CONFIG_TABLE]->Type, 'linestring'  )   )       ) {

																	       $sql=" alter table `".$TABLE."` CHANGE `".$FIELD_TO_CHK."` `".$FIELD_TO_CHK."` ".$ARR_TABLE['FIELDS'][$INDEX_OF_CONFIG_TABLE]->Type." ; ";
																		   DEBUG_S(-3,'Aktualizacja zmieniajaca zakres pola geometrycznego' ,$sql,__FILE__, __FUNCTION__, __LINE__);
																		   $result=$this->query($sql) or DEBUG_S(-3,'Problem ze SQL:',$sql,__FILE__, __FUNCTION__, __LINE__)  or die1('\nProblem z '.$sql);

																	      }  else if(strstr($ARR_TABLE['FIELDS'][$INDEX_OF_CONFIG_TABLE]->Type, 'geometry') && (    strstr($VAL->Type, 'polygon'  ) or   strstr($VAL->Type, 'point'  )    or strstr($VAL->Type, 'linestring'  )   )       ) {

																	       $sql=" alter table `".$TABLE."` CHANGE `".$FIELD_TO_CHK."` `".$FIELD_TO_CHK."` ".$ARR_TABLE['FIELDS'][$INDEX_OF_CONFIG_TABLE]->Type." ; ";
																		   DEBUG_S(-3,'Aktualizacja zmieniajaca zakres pola geometrycznego pominieta' ,$sql,__FILE__, __FUNCTION__, __LINE__);
																		  // $result=$this->query($sql) or DEBUG_S(-3,'Problem ze SQL:',$sql,__FILE__, __FUNCTION__, __LINE__)  or die1('\nProblem z '.$sql);

																	      } 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'  )
																	      			|| ( strstr($VAL->Type, 'multipoint')  ) && strstr($ARR_TABLE['FIELDS'][$INDEX_OF_CONFIG_TABLE]->Type, 'multipoint'  )
																	      			|| ( strstr($VAL->Type, 'point')  ) && strstr($ARR_TABLE['FIELDS'][$INDEX_OF_CONFIG_TABLE]->Type, 'point'  )
																		  			|| ( strstr($VAL->Type, 'date')  ) && strstr($ARR_TABLE['FIELDS'][$INDEX_OF_CONFIG_TABLE]->Type, 'char' )
																		  			|| ( strstr($VAL->Type, 'date')  ) && strstr('varchar',$ARR_TABLE['FIELDS'][$INDEX_OF_CONFIG_TABLE]->Type )
																		  			|| ( strstr($VAL->Type, 'datetime')  ) && strstr($ARR_TABLE['FIELDS'][$INDEX_OF_CONFIG_TABLE]->Type, 'char' )
																		  			|| ( strstr($VAL->Type, 'datetime')  ) && strstr('varchar' ,$ARR_TABLE['FIELDS'][$INDEX_OF_CONFIG_TABLE]->Type)
																		  			|| ( strstr($VAL->Type, 'datetime')  ) && strstr($ARR_TABLE['FIELDS'][$INDEX_OF_CONFIG_TABLE]->Type, 'date' )

																	      			) {

																			      $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__);
																				  	$result=$this->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();
																		   	  	$result=$this->query($sql) or DEBUG_S(-3,'Problem ze SQL:',$sql,__FILE__, __FUNCTION__, __LINE__)  or die1('\nProblem z '.$sql);
																		    }
																	    }

																	if(trim($VAL->Null)!=trim($ARR_TABLE['FIELDS'][$INDEX_OF_CONFIG_TABLE]->Null)) {
																	  if(!in_array('SKIP-PRIMARY-KEY', $options)) {
																			 DEBUG_S(-3,'SKIP-PRIMARY-KEY option',null,__FILE__,__FUNCTION__,__LINE__);


																	 // echo "<br>".$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  ";
																		    	DEBUG_S(-3,'Alter',$sql,__FILE__,__FUNCTION__,__LINE__);
																		    	$result=$this->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  ";
																	     		DEBUG_S(-3,'Alter '.$FIELD_TO_CHK,array($sql,$ARR_TABLE['FIELDS'][$INDEX_OF_CONFIG_TABLE]),__FILE__,__FUNCTION__,__LINE__);
																	     		$result=$this->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."'  ; ";
																			$result=$this->query($sql) or  DEBUG_S(-3,'Problem ze SQL ',$sql,__FILE__, __FUNCTION__, __LINE__) or DIE();

																	}
																	//autoincrement:

																	if(in_array('SKIP-PRIMARY-KEY', $options)) {
																		DEBUG_S(-3,'SKIP-PRIMARY-KEY option',null,__FILE__,__FUNCTION__,__LINE__);

																	} else 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=$this->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=$this->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 ;
																			$result=$this->query($sql) or DEBUG_S(-3,'Problem ze SQL ',$sql,__FILE__, __FUNCTION__, __LINE__) or DIE('die927');

																	}
								       								//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=$this->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') {
															if(in_array('SKIP-PRIMARY-KEY', $options)) {
																		DEBUG_S(-3,'SKIP-PRIMARY-KEY option',null,__FILE__,__FUNCTION__,__LINE__);
															} else {
															$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;
														    	$result=$this->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;
														    	$result=$this->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;
														    	$result=$this->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;

														    	$result=$this->query($sql) or DEBUG_S(-3,'Problem ze SQL:',$sql,__FILE__, __FUNCTION__, __LINE__)  or die1();
														 }
													}
													flush();

								       				//print_r($FIELDS_CHECKED);
								       				unset($FIELDS_CHECKED);
								       				if(in_array('SKIP-PROCEDURE', $options)) {
										   				DEBUG_S(-3,'SKIP-PROCEDURES option',null,__FILE__,__FUNCTION__,__LINE__);

												   		} else {
								       				$sql=" show triggers like '".$TABLE."' ;" ; //listujemy nasze triggery z tej tabeli
									       			DEBUG_S(-3,'Looking for triggers in '.$TABLE,$sql,__FILE__,__FUNCTION__,__LINE__);
									       				$result=$this->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_=$this->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__);
										   				    	$result=$this->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) {
										       				if(in_array('SKIP-FUNCTION', $options)) {
												   				DEBUG_S(-3,'SKIP-FUNCTION option',null,__FILE__,__FUNCTION__,__LINE__);
												   				continue;
												   			}
									       				//$sql="DROP TRIGGER IF EXISTS `{$TRIGGER_INDEX}`; ";
									       				//DEBUG_S(-3,'Delete old trigger '.$TRIGGER_INDEX,$sql,__FILE__,__FUNCTION__,__LINE__);
									       				//	$result=$this->query($sql) or DEBUG_S(-3,'Problem ze SQL:',array($sql,mysql_error() ),__FILE__, __FUNCTION__, __LINE__)  or die1();
										   				//	$result=$this->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__);
									       					$result=$this->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=$this->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." ) ;";
										 $this->query($sql) or die1('\nProblem z '.$sql);
									DEBUG_S(-3,'Dodanie rekordu do tabeli ',$sql,__FILE__,__FUNCTION__,__LINE__);


	       						}
	       					//}

        			}


	}

	function MAKE_SE_AND_HIST_FIELDS_FOR_TABLE($table){
	   		$sql="show tables like '".$table."';";
	   		DEBUG_S(-3,'SQL',$sql,__FILE__,__FUNCTION__,__LINE__);
	   			$USERS_COLUMN_INIT2['REQUEST_COLUMN']=array(
						'ID'=>'int(11) primary key not null auto_increment',
						'A_RECORD_CREATE_DATE'=>'datetime','A_RECORD_CREATE_AUTHOR'=>'varchar(100)','SYNC_SQIX_STATUS'=>'varchar(100) not null',
						'A_RECORD_UPDATE_DATE'=>'datetime','A_RECORD_UPDATE_AUTHOR'=>'varchar(100) not null',
						'L_APPOITMENT_DATE'=>'varchar(30) not null',
						'L_APPOITMENT_USER'=>"varchar(100) not null",
						'L_APPOITMENT_PERIOD'=>"varchar(4) not null",
						'L_APPOITMENT_INFO'=>"varchar(255) not null",
						'L_APPOITMENT_TYPE'=>"enum('', 'ARRANGED', 'TO_ARRANGE', 'CANCELLED', 'TO_CANCEL', 'RELATE', 'WAIT')",
						'A_STATUS'=>"enum('WAITING', 'NORMAL', 'MONITOR', 'WARNING', 'OFF_SOFT', 'OFF_HARD', 'DELETED') default 'WAITING'",
						'A_STATUS_INFO'=>"varchar(255) not null",
						'A_ADM_COMPANY'=>'varchar(100) not null','A_CLASSIFIED'=>'varchar(100) not null'

						);


			DEBUG_S(-3,'zapytanie',$sql,__FILE__,__FUNCTION__,__LINE__);
       		$result=self::query($sql) or die1(' Problem ze sql '.$sql);

       			while($h=self::fetch_array($result)) {

       				$sql="create  table IF NOT EXISTS `".$h[0]."_HIST` (`ID` INT( 11 ) NOT NULL AUTO_INCREMENT ,
       					  `ID_USERS2` INT( 11 ) NOT NULL ,
       					  `_action_time`  TIMESTAMP NOT NULL,
       					  `_action_type` varchar(16),
       					  PRIMARY KEY (  `ID` ) , INDEX (  `ID_USERS2` ) ) ENGINE=MyISAM ";
       				DEBUG_S(-3,'create table hist '.$h[0],array($sql),__FILE__,__FUNCTION__,__LINE__);
       				 self::query($sql) or die1(' Problem ze sql '.$sql);

					//kolumny z bazy istniejace
						$sql_="describe  `".$h[0]."`";
					    $result_=self::query($sql_) or die1(' Problem ze sql '.$sql_);
						while($h_=self::fetch($result_)) {


							DEBUG_S(-3,'dane z tabeli',$h_,__FILE__,__FUNCTION__,__LINE__);
							 $sql="\n alter ignore table `".$h[0]."_HIST` add ".$h_->Field." varchar(255) default 'N/S;'  ; " ;
							 self::query($sql) or DEBUG_S(-3,' Problem ze sql '.$sql,array($sql),__FILE__,__FUNCTION__,__LINE__);

						}



					foreach($USERS_COLUMN_INIT2['REQUEST_COLUMN'] as $tst_column=>$tst_type) {
						 $sql="\n alter ignore table `".$h[0]."` add ".$tst_column." ".$tst_type."  ; " ;
	       				 self::query($sql) or DEBUG_S(-3,' Problem ze sql '.$sql,array($sql),__FILE__,__FUNCTION__,__LINE__);
	       				 $sql="\n alter ignore table `".$h[0]."_HIST` add ".$tst_column." varchar(255) default 'N/S;'  ; " ;
	       				 self::query($sql) or DEBUG_S(-3,' Problem ze sql '.$sql,array($sql),__FILE__,__FUNCTION__,__LINE__);

	}

       			    $sql="\n alter ignore table `".$h[0]."_HIST` add `_action_time` TIMESTAMP NOT NULL  after `ID_USERS2` ; " ;
       				 self::query($sql) or DEBUG_S(-3,' Problem ze sql '.$sql,array($sql),__FILE__,__FUNCTION__,__LINE__);
       			     $sql="\n alter ignore table `".$h[0]."_HIST` add `_action_type` varchar(16)  after `_action_time` ; " ;
	       		     self::query($sql) or DEBUG_S(-3,' Problem ze sql '.$sql,array($sql),__FILE__,__FUNCTION__,__LINE__);


       			}
	   	//! IMPORT_SORT_DESC_INFO
	   }


}