File Source for functions

<?php
/**
* MYSQL update functions
*
* @project Open CSP-Management
* @package dbms
*
* @author Peter Krebs (pk)<p.krebs@amicas.at>
* @license http://opensource.org/licenses/gpl-license.php GNU Public License
*
***/
function DB_UPDATE_backup() {
include __OCSP_PROJECTPATH__."config" . _OCSP_DIRSEP_ . "mySQL.conf";
$cmd="mysqldump ".$DBCONF['ADMIN']['USR']." ".$DBCONF['ADMIN']['PWD'];
$cmd.=" ".$DBCONF['DATABASE']." >".$GLOBALS['PROJECT']['BACKUPPATH'].time().".mysqldump";
require_once __OCSP_PHPINCPATH__."common" . _OCSP_DIRSEP_ . "pcf_directory.phpinc";
pcf_checkDir($GLOBALS['PROJECT']['BACKUPPATH'],TRUE);
// echo "<pre>$cmd</pre>";
system($cmd);
}
/**
* backups a table with serialized arrays
*
* @param string $table
*
* @return boolean
*
* @since pk-05-06-16
*
***/
function DB_UPDATE_backupTable($table) {
if (empty($table)) return FALSE;
$query="SELECT * FROM $table";
if ($cursor=OCSP_OBJ::defaultReadDBObj()->query($query)) {
$bakFileName= OCSP_CONF::getInstance('OCSP')->getValue('BACKUPPATH').$table.".bak";
require_once __OCSP_PHPINCPATH__."common/pcf_directory.phpinc";
if (!pcf_checkDir(OCSP_CONF::getInstance('OCSP')->getValue('BACKUPPATH'),True)) return False;
if ($hBF=fopen($bakFileName,"w")) {
fputs($hBF,"<?php \n\n");
fputs($hBF,"/* Backup of $table created on: ".date("r",time())." */\n");
fputs($hBF,"\$timeStamp=".time().";\n");
$i=1;
while($row=$cursor->fetchArrayFld()) {
fputs($hBF,"\$row[".$i++."]=unserialize(base64_decode(\"".base64_encode(serialize($row))."\"));\n");
}
fputs($hBF,"\n?>");
fclose($hBF);
} else {
return FALSE;
}
} else {
return FALSE;
}
}
function DB_UPDATE_execCmd($cmd) {
require_once dirname(dirname(__FILE__))."/OCSP_DB_mySQL.phpclass";
$DB=new OCSP_DB_mySQL();
$DB->connect(__OCSP_PROJECTPATH__ ."config/mySQL.conf",FALSE,TRUE);
try {
if (!$DB->executeCmd($cmd)) {
echo $DB->errorMsg();
}
} catch (Exception $e) {
echo $e->getMessage();
}
$DB->disconnect();
}
/**
* stores the new version of table in the database
* and clears $GLOBALS['PROJECT']['OBJCACHEPATH']
*
* @param array $tblArray data to store to T_SYS_TABLES
* @param boolean $debug
*
* @version pk-06-05-24 (clear cache added)
*
***/
function DB_UPDATE_setVersion($tblArray,$debug=FALSE) {
echo "UPDATING Table: ".$tblArray['TBL_NAME']." to Version: ".$tblArray['TBL_VERSION']."";
if ($debug) echo "<pre>".print_r($tblArray,TRUE)."</pre>";
if (!array_key_exists("TBL_LASTCHANGE",$tblArray)) {
if (!OCSP_OBJ::defaultReadDBObj()->quickQuery("SELECT TBL_LASTCHANGE FROM T_SYS_TABLES")) {
DB_UPDATE_execCmd("ALTER TABLE T_SYS_TABLES ADD TBL_LASTCHANGE TIMESTAMP NOT NULL");
}
}
$tblArray['TBL_LASTCHANGE']="NULL";
$tblArray['TBL_NAME']="'".$tblArray['TBL_NAME']."'";
$cmd="REPLACE INTO T_SYS_TABLES (";
$values=" VALUES(";
$sep="";
if ($debug) echo "<pre>".print_r($tblArray,TRUE)."</pre>";
foreach($tblArray as $fld=>$val) {
$cmd .=$sep.$fld;
$values.=$sep.$val;
$sep=",";
}
$cmd.=")".$values.")";
if ($debug) echo "<pre>$cmd</pre>";
DB_UPDATE_execCmd($cmd);
require_once __OCSP_PHPINCPATH__."common/pcf_directory.phpinc";
if ($a_cachefiles=pcf_getDirList(OCSP_OBJ::getConf('OBJCACHEPATH'),"!D",$debug)) {
foreach($a_cachefiles as $s_file) {
unlink(OCSP_OBJ::getConf('OBJCACHEPATH')."/".$s_file);
}
}
}
/**
* executs a sql script file
*
* @param string $file path tho file
* @param bool $debug
*
***/
function DB_UPDATE_execScript($file,$debug=FALSE) {
if ($debug) echo "DB_UPDATE_execScript($file,$debug)";
if (file_exists($file)) {
if ($fp = fopen($file, 'rb')) {
$content = fread($fp, filesize($file));
fclose($fp);
} else {
return FALSE;
}
$clen=strlen($content);
$isComment=FALSE; // # found and not eol reached
$strOpen=""; // empty if we are not in a string or the string start char " or '
$cmd=""; // the sql cmd to execute
for ($i = 0; $i < $clen; ++$i) {
$char = $content[$i];
if ((empty($strOpen)) && ($char=="#")) {
$isComment=TRUE;
} else if (($isComment) && ($char=="\n")) {
$isComment=FALSE;
} else if ((empty($strOpen)) && ($char==";")) {
$cmd=trim($cmd);
if ($debug) { echo "<pre style='font-size=10px;'>".htmlspecialchars($cmd)."</pre><hr>"; }
DB_UPDATE_execCmd($cmd);
$cmd="";
} else if (!$isComment) {
$cmd.=$char;
if (!empty($strOpen)) {
if ($char==$strOpen) $strOpen=""; // end of a string value
} else {
if (($char=="\"") || ($char=="'")) $strOpen=$char; // beginn of a string value
}
}
}
return TRUE;
}
return FALSE;
}
/**
* checks a form and adds fields if not in the form
*
* @param string $frmObj_b64 base64_encoded serialized object
* @param boolean $debug
*
* @returns boolean
*
* @since pk-05-11-24
*
***/
function DB_UPDATE_checkForm($frmObj_b64,$debug=FALSE) {
if (!empty($frmObj_b64)) {
require_once $GLOBALS['OCSP']['PHPFORMPATH']."forms.phpinc";
DBMS_field_IncludeAllSrc($debug);
$o_frmObj=unserialize(base64_decode($frmObj_b64));
if ($o_frmObj->getName()) {
if ($o_oriForm=DBMS_form_loadName($o_frmObj->getName())) {
echo "form ".$o_frmObj->getName()." found";
foreach($o_frmObj->frmFields as $key => $fldObj) {
if (!isset($o_oriForm->frmFields[$key])) {
$fldObj->setFrmId($o_oriForm->getId());
$o_oriForm->frmFields[$key]=$fldObj;
echo "Field: $key added";
}
}
try {
$o_oriForm->storeToDb();
} catch(Exception $e) {
echo $e->getMessage();
}
return TRUE;
} else {
$o_frmObj->frmId=0;
$o_frmObj->storeToDb();
echo "form ".$o_frmObj->getName()." angelegt";
return TRUE;
}
}
}
}
?>

Source for file functions_mySQL.phpinc