Better postgresql compatibility

This commit is contained in:
Laurent Destailleur 2010-08-14 02:44:07 +00:00
parent 5f1310a325
commit 98a4430d5f
25 changed files with 174 additions and 155 deletions

View File

@ -60,17 +60,25 @@ $user->getrights();
$sql = "SELECT rowid FROM ".MAIN_DB_PREFIX."product"; $productsid = array(); $sql = "SELECT rowid FROM ".MAIN_DB_PREFIX."product"; $productsid = array();
if ($db->query($sql)) { $resql=$db->query($sql);
$num = $db->num_rows(); $i = 0; if ($resql) {
while ($i < $num) { $row = $db->fetch_row($i); $productsid[$i] = $row[0]; $i++; } } $num = $db->num_rows($resql); $i = 0;
while ($i < $num) { $row = $db->fetch_row($resql); $productsid[$i] = $row[0]; $i++; }
}
$sql = "SELECT rowid FROM ".MAIN_DB_PREFIX."societe"; $societesid = array(); $sql = "SELECT rowid FROM ".MAIN_DB_PREFIX."societe"; $societesid = array();
if ($db->query($sql)) { $num = $db->num_rows(); $i = 0; $resql=$db->query($sql);
while ($i < $num) { $row = $db->fetch_row($i); $societesid[$i] = $row[0]; $i++; } } else { print "err"; } if ($resql) {
$num = $db->num_rows($resql); $i = 0;
while ($i < $num) { $row = $db->fetch_row($resql); $societesid[$i] = $row[0]; $i++; }
} else { print "err"; }
$sql = "SELECT rowid FROM ".MAIN_DB_PREFIX."commande"; $commandesid = array(); $sql = "SELECT rowid FROM ".MAIN_DB_PREFIX."commande"; $commandesid = array();
if ($db->query($sql)) { $num = $db->num_rows(); $i = 0; $resql=$db->query($sql);
while ($i < $num) { $row = $db->fetch_row($i); $commandesid[$i] = $row[0]; $i++; } } else { print "err"; } if ($resql) {
$num = $db->num_rows($resql); $i = 0;
while ($i < $num) { $row = $db->fetch_row($resql); $commandesid[$i] = $row[0]; $i++; }
} else { print "err"; }
print "Generates ".GEN_NUMBER_PRODUIT." products\n"; print "Generates ".GEN_NUMBER_PRODUIT." products\n";

View File

@ -63,17 +63,25 @@ $user->getrights();
$sql = "SELECT rowid FROM ".MAIN_DB_PREFIX."product"; $productsid = array(); $sql = "SELECT rowid FROM ".MAIN_DB_PREFIX."product"; $productsid = array();
if ($db->query($sql)) { $resql=$db->query($sql);
$num = $db->num_rows(); $i = 0; if ($resql) {
while ($i < $num) { $row = $db->fetch_row($i); $productsid[$i] = $row[0]; $i++; } } $num = $db->num_rows($resql); $i = 0;
while ($i < $num) { $row = $db->fetch_row($resql); $productsid[$i] = $row[0]; $i++; }
}
$sql = "SELECT rowid FROM ".MAIN_DB_PREFIX."societe"; $societesid = array(); $sql = "SELECT rowid FROM ".MAIN_DB_PREFIX."societe"; $societesid = array();
if ($db->query($sql)) { $num = $db->num_rows(); $i = 0; $resql=$db->query($sql);
while ($i < $num) { $row = $db->fetch_row($i); $societesid[$i] = $row[0]; $i++; } } else { print "err"; } if ($resql) {
$num = $db->num_rows($resql); $i = 0;
while ($i < $num) { $row = $db->fetch_row($resql); $societesid[$i] = $row[0]; $i++; }
} else { print "err"; }
$sql = "SELECT rowid FROM ".MAIN_DB_PREFIX."commande"; $commandesid = array(); $sql = "SELECT rowid FROM ".MAIN_DB_PREFIX."commande"; $commandesid = array();
if ($db->query($sql)) { $num = $db->num_rows(); $i = 0; $resql=$db->query($sql);
while ($i < $num) { $row = $db->fetch_row($i); $commandesid[$i] = $row[0]; $i++; } } else { print "err"; } if ($resql) {
$num = $db->num_rows($resql); $i = 0;
while ($i < $num) { $row = $db->fetch_row($resql); $commandesid[$i] = $row[0]; $i++; }
} else { print "err"; }

View File

@ -1534,16 +1534,16 @@ class Adherent extends CommonObject
if ($result) if ($result)
{ {
if ($mydb->num_rows()) if ($mydb->num_rows($result))
{ {
# nous avons au moins une reponse # nous avons au moins une reponse
$mydb->close(); $mydb->close($result);
return 1; return 1;
} }
else else
{ {
# nous n'avons pas de reponse => n'existe pas # nous n'avons pas de reponse => n'existe pas
$mydb->close(); $mydb->close($result);
return 0; return 0;
} }
} }

View File

@ -108,12 +108,12 @@ else
$result = $db->query($sql); $result = $db->query($sql);
if ($result) if ($result)
{ {
$num = $db->num_rows(); $num = $db->num_rows($result);
$var=True; $var=True;
$i=0; $i=0;
while ($i < $num) while ($i < $num)
{ {
$row = $db->fetch_row($i); $row = $db->fetch_row($result);
$var=!$var; $var=!$var;
print "<tr $bc[$var]>"; print "<tr $bc[$var]>";

View File

@ -99,14 +99,13 @@ class BoutiqueCommande
$sql .= " FROM ".$conf->global->OSC_DB_NAME.".".$conf->global->OSC_DB_TABLE_PREFIX."orders_total WHERE orders_id = $id"; $sql .= " FROM ".$conf->global->OSC_DB_NAME.".".$conf->global->OSC_DB_TABLE_PREFIX."orders_total WHERE orders_id = $id";
$result = $this->db->query($sql); $result = $this->db->query($sql);
if ( $result ) if ( $result )
{ {
$num = $this->db->num_rows(); $num = $this->db->num_rows($result);
while ($i < $num) while ($i < $num)
{ {
$array = $this->db->fetch_array($i); $array = $this->db->fetch_array($result);
if ($array["class"] == 'ot_total') if ($array["class"] == 'ot_total')
{ {
$this->total_ot_total = $array["value"]; $this->total_ot_total = $array["value"];

View File

@ -104,7 +104,7 @@ $sql.= " ORDER BY label";
$result = $db->query($sql); $result = $db->query($sql);
if ($result) if ($result)
{ {
$num = $db->num_rows(); $num = $db->num_rows($result);
$i = 0; $total = 0; $i = 0; $total = 0;
$var=True; $var=True;
@ -119,7 +119,7 @@ if ($result)
print "</tr>"; print "</tr>";
$i++; $i++;
} }
$db->free(); $db->free($result);
} }
/* /*

View File

@ -47,7 +47,7 @@ $result = $db->query($sql);
if ($result) if ($result)
{ {
$num = $db->num_rows(); $num = $db->num_rows($result);
$i = 0; $i = 0;
while ($i < $num) while ($i < $num)
{ {

View File

@ -147,9 +147,10 @@ class BonPrelevement extends CommonObject
$sql.= " AND code_guichet ='".$code_guichet."'"; $sql.= " AND code_guichet ='".$code_guichet."'";
$sql.= " AND number ='".$number."'"; $sql.= " AND number ='".$number."'";
if ($this->db->query($sql)) $resql=$this->db->query($sql);
if ($resql)
{ {
$num = $this->db->num_rows(); $num = $this->db->num_rows($resql);
} }
else else
{ {

View File

@ -55,7 +55,7 @@ function propals ($db, $year, $month)
$sql .= " ORDER BY p.fk_statut"; $sql .= " ORDER BY p.fk_statut";
$result = $db->query($sql); $result = $db->query($sql);
$num = $db->num_rows(); $num = $db->num_rows($result);
$i = 0; $i = 0;
print "<table class=\"noborder\" width=\"100%\" cellspacing=\"0\" cellpadding=\"4\">"; print "<table class=\"noborder\" width=\"100%\" cellspacing=\"0\" cellpadding=\"4\">";
print "<tr class=\"liste_titre\"><td colspan=\"5\"><b>Propal</b></td></tr>"; print "<tr class=\"liste_titre\"><td colspan=\"5\"><b>Propal</b></td></tr>";
@ -131,7 +131,7 @@ function factures ($db, $year, $month, $paye)
$result = $db->query($sql); $result = $db->query($sql);
if ($result) if ($result)
{ {
$num = $db->num_rows(); $num = $db->num_rows($result);
if ($num > 0) if ($num > 0)
{ {
$i = 0; $i = 0;
@ -192,7 +192,7 @@ function pt ($db, $sql, $year)
$result = $db->query($sql); $result = $db->query($sql);
if ($result) { if ($result) {
$num = $db->num_rows(); $num = $db->num_rows($result);
$i = 0; $total = 0 ; $i = 0; $total = 0 ;
print '<table class="border" width="100%" cellspacing="0" cellpadding="3">'; print '<table class="border" width="100%" cellspacing="0" cellpadding="3">';
print "<tr class=\"liste_titre\">"; print "<tr class=\"liste_titre\">";

View File

@ -42,7 +42,7 @@ function pt ($db, $sql, $title) {
$result = $db->query($sql); $result = $db->query($sql);
if ($result) if ($result)
{ {
$num = $db->num_rows(); $num = $db->num_rows($result);
$i = 0; $total = 0 ; $i = 0; $total = 0 ;
$var=True; $var=True;

View File

@ -34,7 +34,7 @@ function pt ($db, $sql, $date) {
$result = $db->query($sql); $result = $db->query($sql);
if ($result) { if ($result) {
$num = $db->num_rows(); $num = $db->num_rows($result);
$i = 0; $total = 0 ; $i = 0; $total = 0 ;
print "<TABLE border=\"1\" width=\"100%\">"; print "<TABLE border=\"1\" width=\"100%\">";
print "<TR class=\"liste_titre\">"; print "<TR class=\"liste_titre\">";

View File

@ -360,7 +360,7 @@ class Tva extends CommonObject
if ($result) if ($result)
{ {
if ($this->db->num_rows()) if ($this->db->num_rows($result))
{ {
$obj = $this->db->fetch_object($result); $obj = $this->db->fetch_object($result);
return $obj->amount; return $obj->amount;
@ -370,7 +370,7 @@ class Tva extends CommonObject
return 0; return 0;
} }
$this->db->free(); $this->db->free($result);
} }
else else
@ -399,7 +399,7 @@ class Tva extends CommonObject
if ($result) if ($result)
{ {
if ($this->db->num_rows()) if ($this->db->num_rows($result))
{ {
$obj = $this->db->fetch_object($result); $obj = $this->db->fetch_object($result);
return $obj->total_tva; return $obj->total_tva;
@ -441,7 +441,7 @@ class Tva extends CommonObject
if ($result) if ($result)
{ {
if ($this->db->num_rows()) if ($this->db->num_rows($result))
{ {
$obj = $this->db->fetch_object($result); $obj = $this->db->fetch_object($result);
return $obj->amount; return $obj->amount;

View File

@ -51,7 +51,7 @@ if ($result)
$var=True; $var=True;
$num = $db->num_rows(); $num = $db->num_rows($result);
$i = 0; $total = 0; $i = 0; $total = 0;
$sep = 0; $sep = 0;

View File

@ -51,18 +51,19 @@ class ExpeditionStats
$sql.= " AND entity = ".$conf->entity; $sql.= " AND entity = ".$conf->entity;
$sql.= " GROUP BY dm DESC"; $sql.= " GROUP BY dm DESC";
if ($this->db->query($sql)) $resql=$this->db->query($sql);
if ($resql)
{ {
$num = $this->db->num_rows(); $num = $this->db->num_rows($resql);
$i = 0; $i = 0;
while ($i < $num) while ($i < $num)
{ {
$row = $this->db->fetch_row($i); $row = $this->db->fetch_row($resql);
$result[$i] = $row; $result[$i] = $row;
$i++; $i++;
} }
$this->db->free(); $this->db->free($resql);
} }
return $result; return $result;
} }
@ -82,18 +83,19 @@ class ExpeditionStats
$sql.= " AND entity = ".$conf->entity; $sql.= " AND entity = ".$conf->entity;
$sql.= " GROUP BY dm DESC"; $sql.= " GROUP BY dm DESC";
if ($this->db->query($sql)) $resql=$this->db->query($sql);
if ($resql)
{ {
$num = $this->db->num_rows(); $num = $this->db->num_rows($resql);
$i = 0; $i = 0;
while ($i < $num) while ($i < $num)
{ {
$row = $this->db->fetch_row($i); $row = $this->db->fetch_row($resql);
$j = $row[0] * 1; $j = $row[0] * 1;
$result[$j] = $row[1]; $result[$j] = $row[1];
$i++; $i++;
} }
$this->db->free(); $this->db->free($resql);
} }
for ($i = 1 ; $i < 13 ; $i++) for ($i = 1 ; $i < 13 ; $i++)
{ {

View File

@ -45,13 +45,14 @@ $sql.= " WHERE fk_statut > 0";
$sql.= " AND entity = ".$conf->entity; $sql.= " AND entity = ".$conf->entity;
$sql.= " GROUP BY dm DESC "; $sql.= " GROUP BY dm DESC ";
if ($db->query($sql)) $resql=$db->query($sql);
if ($resql)
{ {
$num = $db->num_rows(); $num = $db->num_rows($resql);
$i = 0; $i = 0;
while ($i < $num) while ($i < $num)
{ {
$row = $db->fetch_row($i); $row = $db->fetch_row($resql);
$nbproduct = $row[0]; $nbproduct = $row[0];
$year = $row[1]; $year = $row[1];
print "<tr>"; print "<tr>";

View File

@ -94,7 +94,7 @@ $sql .= " ORDER BY $sortfield $sortorder ";
$resql=$db->query($sql); $resql=$db->query($sql);
if ($resql) if ($resql)
{ {
$num = $db->num_rows(); $num = $db->num_rows($resql);
$title = $langs->trans("Report")." ".dol_print_date(strtotime($start),"%B %Y"); $title = $langs->trans("Report")." ".dol_print_date(strtotime($start),"%B %Y");
print_barre_liste($title, $page, "rapport.php","&socid=".$socid,$sortfield,$sortorder,'',$num); print_barre_liste($title, $page, "rapport.php","&socid=".$socid,$sortfield,$sortorder,'',$num);

View File

@ -1083,7 +1083,7 @@ class CommandeFournisseur extends Commande
if ($resql) if ($resql)
{ {
$i = 0; $i = 0;
$num = $this->db->num_rows(); $num = $this->db->num_rows($resql);
$this->methodes_commande = array(); $this->methodes_commande = array();
while ($i < $num) while ($i < $num)
{ {

View File

@ -61,17 +61,18 @@ print "</table></form><br>\n";
*/ */
$prodser = array(); $prodser = array();
$sql = "SELECT count(*), fk_product_type FROM ".MAIN_DB_PREFIX."product as p GROUP BY fk_product_type"; $sql = "SELECT count(*), fk_product_type FROM ".MAIN_DB_PREFIX."product as p GROUP BY fk_product_type";
if ($db->query($sql)) $resql=$db->query($sql);
if ($resql)
{ {
$num = $db->num_rows(); $num = $db->num_rows($resql);
$i = 0; $i = 0;
while ($i < $num) while ($i < $num)
{ {
$row = $db->fetch_row($i); $row = $db->fetch_row($resql);
$prodser[$row[1]] = $row[0]; $prodser[$row[1]] = $row[0];
$i++; $i++;
} }
$db->free(); $db->free($resql);
} }
print '<table class="noborder" width="100%">'; print '<table class="noborder" width="100%">';

View File

@ -90,9 +90,10 @@ class mod_codecompta_digitaria extends ModeleAccountancyCode
$sql = "SELECT code_compta FROM ".MAIN_DB_PREFIX."societe"; $sql = "SELECT code_compta FROM ".MAIN_DB_PREFIX."societe";
$sql .= " WHERE code_compta = '".$code."'"; $sql .= " WHERE code_compta = '".$code."'";
if ($db->query($sql)) $resql=$db->query($sql);
if ($resql)
{ {
if ($db->num_rows() == 0) if ($db->num_rows($resql) == 0)
{ {
return 0; return 0;
} }

View File

@ -156,13 +156,14 @@ $sql = "SELECT p.label, sum(f.qty) as sumf, sum(pr.qty) as sumpr FROM ".MAIN_DB_
$sql.=" left join ".MAIN_DB_PREFIX."facturedet as f on p.rowid = f.fk_product"; $sql.=" left join ".MAIN_DB_PREFIX."facturedet as f on p.rowid = f.fk_product";
$sql.=" left join ".MAIN_DB_PREFIX."propaldet as pr on p.rowid = pr.fk_product"; $sql.=" left join ".MAIN_DB_PREFIX."propaldet as pr on p.rowid = pr.fk_product";
$sql.=" group by p.label"; $sql.=" group by p.label";
if ($db->query($sql)) $resql=$db->query($sql);
if ($resql)
{ {
$num = $db->num_rows(); $num = $db->num_rows($resql);
$i = 0; $i = 0;
while ($i < $num) while ($i < $num)
{ {
$obj = $db->fetch_object( $i); $obj = $db->fetch_object($resql);
print "<tr ".$bc[$var].">"; print "<tr ".$bc[$var].">";
print "<td>".$obj->label."</td>"; print "<td>".$obj->label."</td>";
print "<td>".$obj->sumf."</td>"; print "<td>".$obj->sumf."</td>";
@ -175,7 +176,7 @@ else {
dol_print_error($db); dol_print_error($db);
} }
print "</table>\n"; print "</table>\n";
$db->free(); $db->free($resql);
*/ */

View File

@ -331,17 +331,17 @@ class Entrepot extends CommonObject
$result = $this->db->query($sql) ; $result = $this->db->query($sql) ;
$i = 0; $i = 0;
$num = $this->db->num_rows(); $num = $this->db->num_rows($result);
if ( $result ) if ( $result )
{ {
while ($i < $num) while ($i < $num)
{ {
$row = $this->db->fetch_row($i); $row = $this->db->fetch_row($result);
$liste[$row[0]] = $row[1]; $liste[$row[0]] = $row[1];
$i++; $i++;
} }
$this->db->free(); $this->db->free($result);
} }
return $liste; return $liste;
} }

View File

@ -53,10 +53,10 @@ $sql = "SELECT d.datedon as datedon, d.nom, d.prenom, d.amount, d.public, d.soci
$sql.= " FROM ".MAIN_DB_PREFIX."don as d"; $sql.= " FROM ".MAIN_DB_PREFIX."don as d";
$sql.= " WHERE d.fk_statut in (2, 3) ORDER BY d.datedon DESC"; $sql.= " WHERE d.fk_statut in (2, 3) ORDER BY d.datedon DESC";
if ( $db->query( $sql) ) $resql=$db->query($sql);
if ($resql)
{ {
$num = $db->num_rows(); $num = $db->num_rows($resql);
if ($num) if ($num)
{ {
@ -73,7 +73,7 @@ if ( $db->query( $sql) )
$bc[0]='bgcolor="#f0f0f0"'; $bc[0]='bgcolor="#f0f0f0"';
while ($i < $num) while ($i < $num)
{ {
$objp = $db->fetch_object( $i); $objp = $db->fetch_object($resql);
$var=!$var; $var=!$var;
print "<TR $bc[$var]>"; print "<TR $bc[$var]>";

View File

@ -91,7 +91,7 @@ if ($_POST["action"] == 'add')
$result = $db->query($sql); $result = $db->query($sql);
if ($result) if ($result)
{ {
$num = $db->num_rows(); $num = $db->num_rows($result);
} }
if (!isset($_POST["nom"]) || !isset($_POST["prenom"]) || $_POST["prenom"]=='' || $_POST["nom"]=='') if (!isset($_POST["nom"]) || !isset($_POST["prenom"]) || $_POST["prenom"]=='' || $_POST["nom"]=='')
{ {

View File

@ -93,22 +93,20 @@ class CompanyBankAccount
$sql .= " WHERE fk_soc = ".$this->socid; $sql .= " WHERE fk_soc = ".$this->socid;
$result = $this->db->query($sql); $result = $this->db->query($sql);
if ($result) if ($result)
{ {
if ($this->db->num_rows() == 0) if ($this->db->num_rows($result) == 0)
{ {
$this->create(); $this->create();
} }
} }
else else
{ {
print $this->db->error(); dol_print_error($this->db);
return 0; return 0;
} }
$sql = "UPDATE ".MAIN_DB_PREFIX."societe_rib SET "; $sql = "UPDATE ".MAIN_DB_PREFIX."societe_rib SET ";
$sql .= " bank = '" .addslashes($this->bank)."'"; $sql .= " bank = '" .addslashes($this->bank)."'";
$sql .= ",code_banque='".$this->code_banque."'"; $sql .= ",code_banque='".$this->code_banque."'";
$sql .= ",code_guichet='".$this->code_guichet."'"; $sql .= ",code_guichet='".$this->code_guichet."'";
@ -119,11 +117,9 @@ class CompanyBankAccount
$sql .= ",domiciliation='".addslashes($this->domiciliation)."'"; $sql .= ",domiciliation='".addslashes($this->domiciliation)."'";
$sql .= ",proprio = '".addslashes($this->proprio)."'"; $sql .= ",proprio = '".addslashes($this->proprio)."'";
$sql .= ",adresse_proprio = '".addslashes($this->adresse_proprio)."'"; $sql .= ",adresse_proprio = '".addslashes($this->adresse_proprio)."'";
$sql .= " WHERE fk_soc = ".$this->socid; $sql .= " WHERE fk_soc = ".$this->socid;
$result = $this->db->query($sql); $result = $this->db->query($sql);
if ($result) if ($result)
{ {
return 1; return 1;

View File

@ -923,18 +923,19 @@ class User extends CommonObject
$sql.= " WHERE bydefault = 1"; $sql.= " WHERE bydefault = 1";
$sql.= " AND entity = ".$conf->entity; $sql.= " AND entity = ".$conf->entity;
if ($this->db->query($sql)) $resql=$this->db->query($sql);
if ($resql)
{ {
$num = $this->db->num_rows(); $num = $this->db->num_rows($resql);
$i = 0; $i = 0;
$rd = array(); $rd = array();
while ($i < $num) while ($i < $num)
{ {
$row = $this->db->fetch_row($i); $row = $this->db->fetch_row($resql);
$rd[$i] = $row[0]; $rd[$i] = $row[0];
$i++; $i++;
} }
$this->db->free(); $this->db->free($resql);
} }
$i = 0; $i = 0;
while ($i < $num) while ($i < $num)