Revision fc47e483
Von Holger Lindemann vor mehr als 15 Jahren hinzugefügt
| lxo-import/db.php | ||
|---|---|---|
|
var $showErr = false; // Browserausgabe
|
||
|
var $debug = false; // 1 = SQL-Ausgabe, 2 = zusätzlich Ergebnis
|
||
|
var $log = true; // Alle Abfragen mitloggen
|
||
|
var $errfile = "/tmp/lxcrm.err";
|
||
|
var $logfile = "/tmp/lxcrm.log";
|
||
|
var $path = "/tmp/";
|
||
|
var $lfh = false;
|
||
|
|
||
|
function dbFehler($sql,$err) {
|
||
|
$efh=fopen($this->errfile,"a");
|
||
|
fputs($efh,date("Y-m-d H:i:s ->"));
|
||
|
fputs($efh,$sql."\n");
|
||
|
fputs($efh,$err."\n");
|
||
|
fputs($efh,print_r($this->rc,true));
|
||
|
fputs($efh,"\n");
|
||
|
fclose($efh);
|
||
|
if ($this->showErr)
|
||
|
echo "</td></tr></table><font color='red'>$sql : $err</font><br>";
|
||
|
}
|
||
|
function dbFehler($sql,$err) {
|
||
|
$efh=fopen($this->path."lxcrm".date("w").".err","a");
|
||
|
fputs($efh,date("Y-m-d H:i:s ->"));
|
||
|
fputs($efh,$sql."\n");
|
||
|
fputs($efh,$err."\n");
|
||
|
fputs($efh,print_r($this->rc,true));
|
||
|
fputs($efh,"\n");
|
||
|
fclose($efh);
|
||
|
if ($this->showErr)
|
||
|
echo "</td></tr></table><font color='red'>$sql : $err</font><br>";
|
||
|
}
|
||
|
|
||
|
function showDebug($sql) {
|
||
|
echo $sql."<br>";
|
||
|
if ($this->debug==2) {
|
||
|
echo "<pre>";
|
||
|
print_r($this->rc);
|
||
|
echo "</pre>";
|
||
|
};
|
||
|
}
|
||
|
function showDebug($sql) {
|
||
|
echo $sql."<br>";
|
||
|
if ($this->debug==2) {
|
||
|
echo "<pre>";
|
||
|
print_r($this->rc);
|
||
|
echo "</pre>";
|
||
|
};
|
||
|
}
|
||
|
|
||
|
function writeLog($txt) {
|
||
|
if ($this->lfh===false)
|
||
|
$this->lfh=fopen($this->logfile,"a");
|
||
|
fputs($this->lfh,date("Y-m-d H:i:s ->"));
|
||
|
fputs($this->lfh,$txt."\n");
|
||
|
fputs($this->lfh,print_r($this->rc,true));
|
||
|
fputs($this->lfh,"\n");
|
||
|
}
|
||
|
function writeLog($txt) {
|
||
|
if ($this->lfh===false)
|
||
|
$this->lfh=fopen($this->path."lxcrm".date("w").".log","a");
|
||
|
fputs($this->lfh,date("Y-m-d H:i:s ->"));
|
||
|
fputs($this->lfh,$txt."\n");
|
||
|
fputs($this->lfh,print_r($this->rc,true));
|
||
|
fputs($this->lfh,"\n");
|
||
|
}
|
||
|
|
||
|
function closeLogfile() {
|
||
|
fclose($this->lfh);
|
||
|
}
|
||
|
|
||
|
function myDB($host,$user,$pwd,$db,$port,$showErr=false) {
|
||
|
$dsn = array(
|
||
|
function closeLogfile() {
|
||
|
fclose($this->lfh);
|
||
|
}
|
||
|
|
||
|
function myDB($host,$user,$pwd,$db,$port,$showErr=false) {
|
||
|
$dsn = array(
|
||
|
'phptype' => 'pgsql',
|
||
|
'username' => $user,
|
||
|
'password' => $pwd,
|
||
| ... | ... | |
|
'database' => $db,
|
||
|
'port' => $port
|
||
|
);
|
||
|
$this->showErr=$showErr;
|
||
|
$this->db=DB::connect($dsn);
|
||
|
if (!$this->db || DB::isError($this->db)) {
|
||
|
if ($this->log) $this->writeLog("Connect $dns");
|
||
|
$this->dbFehler("Connect ".print_r($dsn,true),$this->db->getMessage());
|
||
|
die ($this->db->getMessage());
|
||
|
}
|
||
|
if ($this->log) $this->writeLog("Connect: ok ");
|
||
|
return $this->db;
|
||
|
}
|
||
|
$this->showErr=$showErr;
|
||
|
$this->db=DB::connect($dsn);
|
||
|
if (!$this->db || DB::isError($this->db)) {
|
||
|
if ($this->log) $this->writeLog("Connect $dns");
|
||
|
$this->dbFehler("Connect ".print_r($dsn,true),$this->db->getMessage());
|
||
|
die ($this->db->getMessage());
|
||
|
}
|
||
|
if ($this->log) $this->writeLog("Connect: ok ");
|
||
|
return $this->db;
|
||
|
}
|
||
|
|
||
|
function query($sql) {
|
||
|
$this->rc=@$this->db->query($sql);
|
||
|
if ($this->debug) $this->showDebug($sql);
|
||
|
if ($this->log) $this->writeLog($sql);
|
||
|
if(DB::isError($this->rc)) {
|
||
|
$this->dbFehler($sql,$this->rc->getMessage());
|
||
|
$this->rollback();
|
||
|
return false;
|
||
|
} else {
|
||
|
return $this->rc;
|
||
|
}
|
||
|
}
|
||
|
function query($sql) {
|
||
|
$this->rc=@$this->db->query($sql);
|
||
|
if ($this->debug) $this->showDebug($sql);
|
||
|
if ($this->log) $this->writeLog($sql);
|
||
|
if(DB::isError($this->rc)) {
|
||
|
$this->dbFehler($sql,$this->rc->getMessage());
|
||
|
$this->rollback();
|
||
|
return false;
|
||
|
} else {
|
||
|
return $this->rc;
|
||
|
}
|
||
|
}
|
||
|
|
||
|
function begin() {
|
||
|
$this->query("BEGIN");
|
||
|
}
|
||
|
function commit() {
|
||
|
$this->query("COMMIT");
|
||
|
}
|
||
|
function rollback() {
|
||
|
$this->query("ROLLBACK");
|
||
|
}
|
||
|
function begin() {
|
||
|
$this->query("BEGIN");
|
||
|
}
|
||
|
function commit() {
|
||
|
$this->query("COMMIT");
|
||
|
}
|
||
|
function rollback() {
|
||
|
$this->query("ROLLBACK");
|
||
|
}
|
||
|
|
||
|
function getAll($sql) {
|
||
|
$this->rc=$this->db->getAll($sql,DB_FETCHMODE_ASSOC);
|
||
|
if ($this->debug) $this->showDebug($sql);
|
||
|
if ($this->log) $this->writeLog($sql);
|
||
|
if(DB::isError($this->rc)) {
|
||
|
$this->dbFehler($sql,$this->rc->getMessage());
|
||
|
return false;
|
||
|
} else {
|
||
|
return $this->rc;
|
||
|
}
|
||
|
}
|
||
|
function getAll($sql) {
|
||
|
$this->rc=$this->db->getAll($sql,DB_FETCHMODE_ASSOC);
|
||
|
if ($this->debug) $this->showDebug($sql);
|
||
|
if ($this->log) $this->writeLog($sql);
|
||
|
if(DB::isError($this->rc)) {
|
||
|
$this->dbFehler($sql,$this->rc->getMessage());
|
||
|
return false;
|
||
|
} else {
|
||
|
return $this->rc;
|
||
|
}
|
||
|
}
|
||
|
|
||
|
function saveData($txt) {
|
||
|
if (get_magic_quotes_gpc()) {
|
||
|
return $txt;
|
||
|
} else {
|
||
|
return DB::quoteSmart($string);
|
||
|
}
|
||
|
}
|
||
|
function saveData($txt) {
|
||
|
if (get_magic_quotes_gpc()) {
|
||
|
return $txt;
|
||
|
} else {
|
||
|
return DB::quoteSmart($string);
|
||
|
}
|
||
|
}
|
||
|
|
||
|
function chkcol($tbl) {
|
||
|
function execute($statement, $data){
|
||
|
$sth = $this->db->prepare($statement); //Prepare
|
||
|
/*if (PEAR::isError($sth)) {
|
||
|
$this->dbFehler($statement,$sth->getMessage());
|
||
|
$this->rollback();
|
||
|
return false;
|
||
|
}*/
|
||
|
$rc = $this->db->execute($sth,$data);
|
||
|
if(PEAR::isError($rc)) {
|
||
|
$this->dbFehler(print_r($data,true),$rc->getMessage()."\n".print_r($rc,true));
|
||
|
$this->rollback();
|
||
|
return false;
|
||
|
}
|
||
|
$this->db->commit();
|
||
|
return true;
|
||
|
}
|
||
|
|
||
|
function chkcol($tbl) {
|
||
|
// gibt es die Spalte import schon?
|
||
|
$rc=$this->db->query("select import from $tbl limit 1");
|
||
|
if(DB::isError($rc)) {
|
||
|
$rc=$this->db->query("alter table $tbl add column import int4");
|
||
|
if(DB::isError($rc)) { return false; }
|
||
|
else { return true; }
|
||
|
} else { return true; };
|
||
|
}
|
||
|
$rc=$this->db->query("select import from $tbl limit 1");
|
||
|
if(DB::isError($rc)) {
|
||
|
$rc=$this->db->query("alter table $tbl add column import int4");
|
||
|
if(DB::isError($rc)) { return false; }
|
||
|
else { return true; }
|
||
|
} else { return true; };
|
||
|
}
|
||
|
|
||
|
|
||
|
}
|
||
Auch abrufbar als: Unified diff
Code überarbeitet
Beispielimportdateien zugefügt