/[dehs]/trunk/dehs_pg.php
ViewVC logotype

Diff of /trunk/dehs_pg.php

Parent Directory Parent Directory | Revision Log Revision Log | View Patch Patch

revision 84 by atomo64-guest, Tue Dec 18 20:49:31 2007 UTC revision 85 by atomo64-guest, Tue Dec 18 21:01:45 2007 UTC
# Line 64  if (in_array("-db_add",$argv))  db_add(( Line 64  if (in_array("-db_add",$argv))  db_add((
64      elseif (in_array("-keep_sources",$argv) || in_array("-download_sources",$argv))  download_sources();      elseif (in_array("-keep_sources",$argv) || in_array("-download_sources",$argv))  download_sources();
65      elseif (in_array("-db_popcon",$argv))  db_popcon($argv[2]);      elseif (in_array("-db_popcon",$argv))  db_popcon($argv[2]);
66      elseif (in_array("-dl_popcon",$argv) || in_array("-keep_popcon",$argv))  dl_popcon($argv[2]);      elseif (in_array("-dl_popcon",$argv) || in_array("-keep_popcon",$argv))  dl_popcon($argv[2]);
67      elseif (in_array("-db_upstream",$argv))  db_upstream($argv[2]);      elseif (in_array("-db_upstream",$argv))  db_upstream((!empty($argv[2])?$argv[2]:'%'));
68      elseif (in_array("-update_all",$argv))  update_all();      elseif (in_array("-update_all",$argv))  update_all();
69      elseif (in_array("-update_new",$argv))  update_new();      elseif (in_array("-update_new",$argv))  update_new();
70      elseif (in_array("-update_bogus",$argv))  update_bogus();      elseif (in_array("-update_bogus",$argv))  update_bogus();
# Line 72  if (in_array("-db_add",$argv))  db_add(( Line 72  if (in_array("-db_add",$argv))  db_add((
72      elseif (in_array("-dehsqa_db",$argv))  dehsqa_db();      elseif (in_array("-dehsqa_db",$argv))  dehsqa_db();
73      elseif (in_array("-clear_db",$argv))  clear_db();      elseif (in_array("-clear_db",$argv))  clear_db();
74      elseif (in_array("-db_up_error",$argv))  db_up_error();      elseif (in_array("-db_up_error",$argv))  db_up_error();
75      elseif (in_array("-up_changes",$argv))  up_changes($argv[2], true);      elseif (in_array("-up_changes",$argv))  up_changes((!empty($argv[2])?$argv[2]:'%'), true);
76      elseif (in_array("-watchf",$argv) || in_array("-wwiz",$argv))  watch_wizard((!empty($argv[2])?$argv[2]:''));      elseif (in_array("-watchf",$argv) || in_array("-wwiz",$argv))  watch_wizard((!empty($argv[2])?$argv[2]:'%'));
77      elseif (in_array("-kb_total",$argv))  print "Diff      elseif (in_array("-kb_total",$argv))  print "Diff
78  #stat_up_error();  #stat_up_error();
79  #stat_up_error();to download Kb => " . kb_total($argv[2]) . "\n" ;  #stat_up_error();to download Kb => " . kb_total($argv[2]) . "\n" ;
# Line 230  function db_add($initial='', $clear_db = Line 230  function db_add($initial='', $clear_db =
230              gzclose($zp) ;              gzclose($zp) ;
231          }          }
232      }      }
233      if ($clear_db)      clear_db($db, $clear_db);
     clear_db($db);  
234      pg_close($db);      pg_close($db);
235  }  }
236  function db_query($pkg,$dist='%') {  function db_query($pkg,$dist='%') {
# Line 381  function remote_dist_dir($dist) { Line 380  function remote_dist_dir($dist) {
380      #else      #else
381      return "/debian/dists";      return "/debian/dists";
382  }  }
383  function clear_db(&$db) {  function clear_db(&$db, $fullClean = true) {
384      #global $dbconn;      #global $dbconn;
385      #if (check_db()) die_status("Il Database era vuoto\n");      #if (check_db()) die_status("Il Database era vuoto\n");
386      #download_sources();      #download_sources();
# Line 391  function clear_db(&$db) { Line 390  function clear_db(&$db) {
390      $sql2=      "Delete from pkgs where id NOT IN (select id FROM pkgs INNER JOIN pkgs_atsrc USING (name,dist))" ;      $sql2=      "Delete from pkgs where id NOT IN (select id FROM pkgs INNER JOIN pkgs_atsrc USING (name,dist))" ;
391      $sql3=      "UPDATE pkgs SET wwiz=NULL, wwiz_type=NULL, wwiz_version=NULL WHERE watch IS NOT NULL or watch!=''" ;      $sql3=      "UPDATE pkgs SET wwiz=NULL, wwiz_type=NULL, wwiz_version=NULL WHERE watch IS NOT NULL or watch!=''" ;
392      $sql4=      "UPDATE pkgs SET up_changes=NULL WHERE wwiz_version=up_version OR up_version=version" ;      $sql4=      "UPDATE pkgs SET up_changes=NULL WHERE wwiz_version=up_version OR up_version=version" ;
393      if(pg_exec($db,$sql1) AND pg_exec($db,$sql2) AND pg_exec($db,$sql3) AND pg_exec($db,$sql4)) print "Db clear complete\n";      if(pg_exec($db,$sql1) && pg_exec($db,$sql2) && (!$fullClean || (pg_exec($db,$sql3) && pg_exec($db,$sql4)))) {
394            print "Db clear complete\n";
395        }
396  }  }
397  function db_popcon($initial='') {  function db_popcon($initial='') {
398      global $dirs,$dbconn;      global $dirs,$dbconn;
# Line 441  function db_upstream($initial='%') { Line 442  function db_upstream($initial='%') {
442      global $dirs,$dbconn;      global $dirs,$dbconn;
443      check_db();      check_db();
444      $db = pg_pconnect($dbconn) ;      $db = pg_pconnect($dbconn) ;
445      $rsql=pg_exec($db, "SELECT id, pkgs.name,pkgs.dist,up_version,version,watch FROM pkgs WHERE watch is not null AND name LIKE '$initial%' ORDER BY name DESC");      $rsql=pg_exec($db, "SELECT id, pkgs.name,pkgs.dist,up_version,version,watch FROM pkgs WHERE watch is not null AND name LIKE '$initial' ORDER BY name DESC");
446      $tot=pg_numrows($rsql);      $tot=pg_numrows($rsql);
447      while ($res_array=pg_fetch_array($rsql)) {      while ($res_array=pg_fetch_array($rsql)) {
448          $uscan_res=uscan_foo($res_array['name'],$res_array['version'],$res_array['watch']);          $uscan_res=uscan_foo($res_array['name'],$res_array['version'],$res_array['watch']);
# Line 531  function up_changes($src_name='%', $forc Line 532  function up_changes($src_name='%', $forc
532    
533      $changes_files=array("CHANGES","NEWS","Changelog","ChangeLog","changelog");      $changes_files=array("CHANGES","NEWS","Changelog","ChangeLog","changelog");
534      $db = pg_pconnect($dbconn) ;      $db = pg_pconnect($dbconn) ;
535      $rsql=pg_exec($db, "SELECT id,up_url FROM pkgs WHERE up_url!=''  AND keep_changes='t' AND name LIKE '$src_name%'");      $rsql=pg_exec($db, "SELECT id,up_url FROM pkgs WHERE up_url!=''  AND keep_changes='t' AND name LIKE '$src_name'");
536      $tot=pg_numrows($rsql);      $tot=pg_numrows($rsql);
537      while ($res_array=pg_fetch_array($rsql)) {      while ($res_array=pg_fetch_array($rsql)) {
538          $localfile=tempnam("/tmp/", "dehs-" . $res_array[id] . ".tar.gz");          $localfile=tempnam("/tmp/", "dehs-" . $res_array[id] . ".tar.gz");
# Line 683  function watch_wizard($src_name='%'){ Line 684  function watch_wizard($src_name='%'){
684    
685      $sqlstring="SELECT mpop_inst,name,pkgs.version,pkgs.dversionmangled,pkgs.section,pkgs.dist,tot_up_error, tot_avg_error_date, wwiz_version FROM pkgs INNER JOIN      $sqlstring="SELECT mpop_inst,name,pkgs.version,pkgs.dversionmangled,pkgs.section,pkgs.dist,tot_up_error, tot_avg_error_date, wwiz_version FROM pkgs INNER JOIN
686          (Select max(pop_inst) as mpop_inst,SUM(up_error) as tot_up_error,AVG(avg_error_date) as tot_avg_error_date,name,dist FROM binpkgs GROUP BY name,dist HAVING max(pop_inst) IS NOT NULL) as binpkgs using(name,dist)          (Select max(pop_inst) as mpop_inst,SUM(up_error) as tot_up_error,AVG(avg_error_date) as tot_avg_error_date,name,dist FROM binpkgs GROUP BY name,dist HAVING max(pop_inst) IS NOT NULL) as binpkgs using(name,dist)
687          WHERE (watch IS NULL OR watch='') AND name LIKE '$src_name%' ORDER BY mpop_inst DESC";          WHERE (watch IS NULL OR watch='') AND name LIKE '$src_name' ORDER BY mpop_inst DESC";
688      $rsql=pg_exec($db, $sqlstring);      $rsql=pg_exec($db, $sqlstring);
689    
690      while ($res_array=pg_fetch_array($rsql)) {      while ($res_array=pg_fetch_array($rsql)) {
# Line 876  function md5_of_file($inFile) { Line 877  function md5_of_file($inFile) {
877  function update_all() {  function update_all() {
878      global $email;      global $email;
879      $intime=gmdate('D, d M Y H:i:s \C\E\S\T',time()+3600*2);      $intime=gmdate('D, d M Y H:i:s \C\E\S\T',time()+3600*2);
880        echo __FUNCTION__ . ' started the ' . $intime . "\n";
881      db_add();      db_add();
882      dl_popcon();      dl_popcon();
883      db_popcon();      db_popcon();
# Line 895  function update_all() { Line 897  function update_all() {
897  function update_new() {  function update_new() {
898      global $email_all;      global $email_all;
899      $intime=gmdate('D, d M Y H:i:s \C\E\S\T',time()+3600*2);      $intime=gmdate('D, d M Y H:i:s \C\E\S\T',time()+3600*2);
900        echo __FUNCTION__ . ' started the ' . $intime . "\n";
901      db_add('',false);      db_add('',false);
902      dl_popcon();      dl_popcon();
903      db_popcon();      db_popcon();
# Line 927  function update_new() { Line 930  function update_new() {
930  function update_bogus() {  function update_bogus() {
931      global $email_all,$dbconn;      global $email_all,$dbconn;
932      $intime=gmdate('D, d M Y H:i:s \C\E\S\T',time()+3600*2);      $intime=gmdate('D, d M Y H:i:s \C\E\S\T',time()+3600*2);
933        echo __FUNCTION__ . ' started the ' . $intime . "\n";
934      check_db();      check_db();
935      $db = pg_pconnect($dbconn);      $db = pg_pconnect($dbconn);
936      $sql="SELECT name FROM pkgs WHERE up_version='' AND watch!=''";      $sql="SELECT name FROM pkgs WHERE up_version='' AND watch!=''";

Legend:
Removed from v.84  
changed lines
  Added in v.85

  ViewVC Help
Powered by ViewVC 1.1.5