dbmigrate_1.4-2.0.php

Go to the documentation of this file.

<?php
/***********************************************************
 Copyright (C) 2012 Hewlett-Packard Development Company, L.P.

 This program is free software; you can redistribute it and/or
 modify it under the terms of the GNU General Public License
 version 2 as published by the Free Software Foundation.

 This program is distributed in the hope that it will be useful,
 but WITHOUT ANY WARRANTY; without even the implied warranty of
 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 GNU General Public License for more details.

 You should have received a copy of the GNU General Public License along
 with this program; if not, write to the Free Software Foundation, Inc.,
 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301, USA.
 ***********************************************************/

function Migrate_14_20($DryRun)
{
  global $PG_CONN;

  /* array of agent_name, ars file name for tables to create */
  $ARSarray = array("pkgagent"  => "pkgagent_ars",
                    "copyright" => "copyright_ars",
                    "mimetype"  => "mimetype_ars",
                    "unpack"    => "ununpack_ars",
                    "ununpack"  => "ununpack_ars");

  foreach($ARSarray as $agent_name => $ARStablename)
  {
    /* Create the ars table if it doesn't exist */
    CreateARStable($ARStablename, $DryRun);

    /* Get the agent_pk */
    $agent_pk = GetAgentKey($agent_name, "");

    /* Select the jobqueue records for this agent */
    $sql = "select distinct job_upload_fk, jq_type, jq_starttime, jq_endtime from jobqueue
              join job on jq_job_fk=job_pk where jq_type='$agent_name' and (jq_end_bits=1) order by jq_type";
    $result = pg_query($PG_CONN, $sql);
    DBCheckResult($result, $sql, __FILE__, __LINE__);

    /* Loop through jobqueue records inserting ars table rows */
    while ($row = pg_fetch_assoc($result))
    {
      $upload_fk = $row['job_upload_fk'];

      /* prevent duplicate insert */
      $sql = "select ars_pk from $ARStablename where agent_fk=$agent_pk and upload_fk=$upload_fk and ars_success=true";
      $checkrec = pg_query($PG_CONN, $sql);
      DBCheckResult($checkrec, $sql, __FILE__, __LINE__);
      $num_rows = pg_num_rows($checkrec);
      pg_free_result($checkrec);
      if ($num_rows > 0) continue;

      /* add ars rec */
      $sql = "insert into $ARStablename (agent_fk, upload_fk, ars_success, ars_starttime, ars_endtime)
                  values ($agent_pk, $upload_fk, true, '$row[jq_starttime]', '$row[jq_endtime]')";
      if ($DryRun)
        echo "DryRun: $sql\n";
      else
      {
        $insresult = pg_query($PG_CONN, $sql);
        DBCheckResult($insresult, $sql, __FILE__, __LINE__);
        pg_free_result($insresult);
      }
    }
    pg_free_result($result);
  }
                    
  return 0;
} // Migrate_14_20


function CreateARStable($ARStablename)
{
  global $PG_CONN;

  if (DB_TableExists($ARStablename)) return;

  $sql = "CREATE TABLE $ARStablename () INHERITS (ars_master)";
  $result = pg_query($PG_CONN, $sql);
  DBCheckResult($result, $sql, __FILE__, __LINE__);
}
?>