$table_name => ".$this->write_array($schema,1)."\n"; + $this->schema_proc->CreateTable($table_name,$schema); + } + // make the schemas availible for the db-class + $GLOBALS['phpgw_info']['apps']['all-apps']['table_defs'] = &$this->schemas; + continue; + } + if (substr($line,0,7) == 'table: ') + { + $table = substr($line,7); + + $cols = $this->csv_split($line=fgets($f)); ++$n; + + if (feof($f)) break; + continue; + } + if ($table) // do we already reached the data part + { + $data = $this->csv_split($line,$cols); + + if (count($data) == count($cols)) + { + $this->db->insert($table,$data,False,__LINE__,__FILE__,'all-apps',true); + } + else + { + echo '
'.lang("Line %1: '%2'
csv data does not match column-count of table %3 ==> ignored",$n,$line,$table)."
'.print_r($data,true)."\n"; + } + } + } + // updated the sequences, if the DB uses them + foreach($this->schemas as $table => $schema) + { + foreach($schema['fd'] as $column => $definition) + { + if ($definition['type'] == 'auto') + { + $this->schema_proc->UpdateSequence($table,$column); + break; // max. one per table + } + } + } + $this->db->transaction_commit(); + } + + /** + * Split one line of a csv file into an array and does all unescaping + * @internal + */ + function csv_split($line,$keys=False) + { + $fields = explode(',',trim($line)); + + $str_pending = False; + $n = 0; + foreach($fields as $i => $field) + { + if ($str_pending !== False) + { + $field = $str_pending.','.$field; + $str_pending = False; + } + $key = $keys ? $keys[$n] : $n; + + if ($field[0] == '"') + { + if (substr($field,-1) !== '"' || $field === '"') + { + $str_pending = $field; + continue; + } + // count the number of backslashes before the finishing double-quote + // it's not escaped if the number is even (incl. zero) + for($anz_bslash = 0, $i = strlen($field)-2; $i >= 0 && $field[$i] == '\\'; --$i,++$anz_bslash); + + if ($anz_bslash & 1) // ending double quote is escaped and does not end the string + { + $str_pending = $field; + continue; + } + $arr[$key] = str_replace($this->backslash_token,'\\',str_replace(array('\\\\','\\n','\\r','\\"'),array($this->backslash_token,"\n","\r",'"'),substr($field,1,-1))); + } + else + { + $arr[$key] = $field == 'NULL' ? NULL : $field; + } + ++$n; + } + return $arr; + } + + /** + * @internal + */ + function escape_data(&$data,$col,$defs) + { + if (is_null($data)) + { + $data = 'NULL'; + } + else + { + switch($defs[$col]['type']) + { + case 'int': + case 'auto': + case 'decimal': + case 'date': + case 'timestamp': + break; + default: + $data = '"'.str_replace(array('\\',"\n","\r",'"'),array('\\\\','\\n','\\r','\\"'),$data).'"'; + break; + } + } + } + + /** + * Backup all data in the form of a (compressed) csv file + * + * @param f resource file opened with fopen for writing + */ + function backup($f) + { + @set_time_limit(0); + + fwrite($f,"eGroupWare backup from ".date('Y-m-d H:i:s')."\n"); + + fwrite($f,"\ncharset: ".$GLOBALS['phpgw']->translation->charset()."\n\n"); + + $this->schema_backup($f); // add the schema in a human readable form too + + /* not needed, already done by schema_backup + foreach($this->adodb->MetaTables('TABLES') as $table) + { + if ($this->db->Type == 'sapdb' || $this->db->Type == 'maxdb') + { + $table = strtolower($table); + } + if (!($this->schemas[$table] = $this->schema_proc->GetTableDefinition($table))) + { + unset($this->schemas[$table]); + } + } + */ + fwrite($f,"\nschema: ".serialize($this->schemas)."\n"); + + foreach($this->schemas as $table => $schema) + { + if (in_array($table,$this->exclude_tables)) continue; // dont backup + + $first_row = true; + $this->db->select($table,'*',false,__LINE__,__FILE__); + while(($row = $this->db->row(true))) + { + if ($first_row) + { + fwrite($f,"\ntable: $table\n".implode(',',array_keys($row))."\n"); + $first_row = false; + } + array_walk($row,array('db_backup','escape_data'),$schema['fd']); + fwrite($f,implode(',',$row)."\n"); + } + } + return true; + } + + /** + * Backup all schemas in the form of a setup/tables_current.inc.php file + * + * @param f resource/boolean + */ + function schema_backup($f=False) + { + foreach($this->adodb->MetaTables('TABLES') as $table) + { + if ($this->system_tables && preg_match($this->system_tables,$table) || + $this->egw_tables && !preg_match($this->egw_tables,$table)) + { + continue; + } + if ($this->db->Type == 'sapdb' || $this->db->Type == 'maxdb') + { + $table = strtolower($table); + } + if (!($this->schemas[$table] = $this->schema_proc->GetTableDefinition($table))) + { + unset($this->schemas[$table]); + } + if (($this->db->Type == 'sapdb' || $this->db->Type == 'maxdb') && $table == 'phpgw_anglemail') + { + // sapdb does not differ between text and blob + $this->schemas[$table]['fd']['content']['type'] = 'blob'; + } + } + $def = "\t\$phpgw_baseline = "; + $def .= $this->write_array($this->schemas,1); + $def .= ";\n"; + + if ($f) + { + fwrite($f,$def); + } + else + { + if (!is_object($this->browser)) + { + $this->browser = CreateObject('phpgwapi.browser'); + } + $this->browser->content_header('schema-backup-'.date('YmdHi').'.inc.php','text/plain',strlen($def)); + echo " $val) + { + if (!is_int($key)) + { + $def .= "'$key' => "; + } + if (is_array($val)) + { + $def .= $this->write_array($val,$parent == 'fd' ? 0 : $depth,$key); + } + else + { + if (!$only_vals && $key === 'nullable') + { + $def .= $val ? 'True' : 'False'; + } + else + { + $def .= "'$val'"; + } + } + if ($n < count($arr)-1) + { + $def .= ",$tabs".($tabs ? "\t" : ''); + } + ++$n; + } + $def .= "$tabs)"; + + return $def; + } + } +/* + $phpgw_info = array('flags' => array( + 'currentapp' => 'admin', + 'noheader' => true, + 'nonavbar' => true, + )); + include '../../header.inc.php'; + + $db_backup = new db_backup(); + + //ini_set('mbstring.internal_encoding','iso-8859-1'); + //$str = '"c00cebe55f292105174b89133e5fc62a","ralf@pole","127.0.0.1",1091089152,1091089230,501'; + //$str = '306266,"hansjorg","7722959c3ad772bcc6ac608bced3d9f4","Hansjörg","Helms",NULL,NULL,NULL,"A",-1,"u",NULL,0'."\n"; + //$str = '306266,"hansjorg","7722959c3ad772bcc6ac608bced3d9f4","Hansjörg \\"Hansi\\"","Helms, Hansjörg\\\\",NULL,NULL,NULL,"A",-1,"u",NULL,0'."\n"; + //$str = '"en","calendar","are you sure\\\\nyou want to\\\\ndelete this entry ?\\\\n\\\\nthis will delete\\\\nthis entry for all users.","Are you sure\\\\nyou want to\\\\ndelete this entry ?\\\\n\\\\nThis will delete\\\\nthis entry for all users."'; + //echo "'$str'=
".print_r($db_backup->csv_split($str),true)."\n"; + //exit; + + if ($_GET['backup']) + { + $name = is_numeric($_GET['backup']) ? '/tmp/db_backup' : $_GET['backup']; + + if (!($f = fopen($file = "compress.bzip2://$name.bz2",'wb')) && + !($f = fopen($file = "compress.zlib://$name.gz",'wb')) && + !($f = fopen($file = "zlib:$name.gz",'wb')) && // php < 4.3 + !($f = fopen($file = $name,'wb'))) + { + die("Cant open $name for writing"); + } + $db_backup->backup($f); + fclose($f); + + echo "
";
+ fpassthru(fopen($file,'r'));
+ }
+ elseif ($_GET['restore'])
+ {
+ $name = is_numeric($_GET['restore']) ? '/tmp/db_backup' : $_GET['restore'];
+
+ if (!($f = fopen($file = "compress.bzip2://$name.bz2",'r')))
+ {
+ die("Cant open $name for reading");
+ }
+ $db_backup->restore($f);
+ fclose($f);
+ echo "DB restored from dump";
+ }
+ else
+ {
+ $db_backup->schema_backup();
+ }
+*/
\ No newline at end of file