query($sql);
$_SESSION['db']->commit();
echo "Versionsnummer gesetzt
";
if (is_file("update/update$VERSION.txt")) {
echo "Wichtig!
";
echo readfile("update/update$VERSION.txt");
}
}
};
if (!function_exists('sorttodo')) {
function sorttodo($todo) {
$todonew = array();
foreach ($todo as $sql) {
$file = file_get_contents("update/".$sql);
if (preg_match("/@depends: ([^\n;]+)/",$file,$hit)) {
if (in_array("crm_".$hit[1].".sql",$todo) && !in_array("crm_".$hit[1].".sql",$todonew)) {
$todonew[] = "crm_".$hit[1].".sql";
}
}
if (!in_array($sql,$todonew)) $todonew[] = $sql;
}
return $todonew;
}
}
$sql = "SELECT tag || '.sql' as tag from schema_info where tag like 'crm_%' order by tag";
$rs = $_SESSION["db"]->getAll($sql);
if ( !$rs ) { $isnow = array(); }
else { foreach ( $rs as $row ) { $isnow[] = $row["tag"];} };
chdir("update");
$update = glob("crm_*.sql");
chdir("..");
$code = false;
$ok = true;
if ( !is_array($update) ) $update = array();
$todo = array_diff($update,$isnow);
if ( $todo ) {
$todonew = sorttodo($todo);
echo "
";
while ( array_diff($todo,$todonew) ) {
$todo = $todonew;
$todonew = sorttodo($todo);
}
$todo = $todonew;
$rc = $_SESSION['db']->begin();
foreach ( $todo as $upd ) {
$f = fopen("update/".$upd,"r");
while (!feof($f) ) {
if ( empty($zeile)) { $zeile=trim(fgets($f,1000) ); continue; };
if ( preg_match("/^-- @([^:]+):(.+)/",$zeile,$treffer) ) {
$tmp = $treffer[1];
if ( $tmp == "php" ) {
$query = "";
$code = true;
} else if ( $tmp == "exec" ) {
$code = false;
$rc = eval($query);
$query = "";
if ( $rc < 0 ) {
echo "Probleme beim Update, alle Änderungen werden zurück genommen";
$_SESSION['db']->rollback();
exit(1);
}
} else {
${$tmp} = $treffer[2];
echo $tmp.":".${$tmp}."
"; flush();
}
$zeile = trim(fgets($f,1000));
continue;
};
if ( preg_match("/^--/",$zeile) ) { $zeile = trim(fgets($f,1000)); continue; };
if ( !preg_match("/;$/",$zeile) or $code ) {
if ( !preg_match("#\\s?//#",$zeile) ) $query .= $zeile;
$zeile = trim(fgets($f,1000));
} else {
$query .= substr($zeile,0,-1);
$rc = $_SESSION["db"]->query($query, True);
if ( !$rc ) {
echo "Probleme beim Update, alle Änderungen werden zurück genommen";
$_SESSION['db']->rollback();
exit(1);
}
$zeile = trim(fgets($f,1000));
$query = "";
}
}
$sql = "insert into schema_info (tag,login) values ('crm_%s','%s')";
$rc = $_SESSION["db"]->query(sprintf($sql,trim($tag),$_SESSION["login"]));
if ( !$rc ) {
$ok = false;
$_SESSION['db']->rollback();
exit(2);
}
}
if ( $ok ) {
updatever($VERSION);
echo "update ok
";
}
} else {
if ( isset($dbver) and $dbver <> $_SESSION['VERSION'] ) updatever($_SESSION['VERSION']);
if ( !$LOGIN ) echo "System uptodate
";//wofür ist $LOGIN gedacht??
};
if ( !$LOGIN ) {
$sql = "select tag,login,itime from schema_info where tag ilike 'crm_%' order by itime";
$liste = $_SESSION["db"]->getAll($sql);
echo "
\n";
$zeile = "| %s | %s | %s |
\n";
if ( $liste ) foreach ( $liste as $line ) {
echo sprintf($zeile,$line["tag"],$line["login"],$line["itime"]);
};
echo "
";
echo '
';
}
?>