root/modules/branches/2.9/cidlookup/install.php

<?php
//This file is part of FreePBX.
//
//    FreePBX is free software: you can redistribute it and/or modify
//    it under the terms of the GNU General Public License as published by
//    the Free Software Foundation, either version 2 of the License, or
//    (at your option) any later version.
//
//    FreePBX 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 FreePBX.  If not, see <http://www.gnu.org/licenses/>.
//

global $db;
global $amp_conf;

$autoincrement = (($amp_conf["AMPDBENGINE"] == "sqlite") || ($amp_conf["AMPDBENGINE"] == "sqlite3")) ? "AUTOINCREMENT":"AUTO_INCREMENT";

// create the tables
$sql = "CREATE TABLE IF NOT EXISTS cidlookup (
  cidlookup_id INTEGER NOT NULL PRIMARY KEY $autoincrement,
  description varchar(50) NOT NULL,
  sourcetype varchar(100) NOT NULL,
  cache tinyint(1) NOT NULL default '0',
  deptname varchar(30) default NULL,
  http_host varchar(30) default NULL,
  http_port varchar(30) default NULL,
  http_username varchar(30) default NULL,
  http_password varchar(30) default NULL,
  http_path varchar(100) default NULL,
  http_query varchar(100) default NULL,
  mysql_host varchar(60) default NULL,
  mysql_dbname varchar(60) default NULL,
  mysql_query text,
  mysql_username varchar(30) default NULL,
  mysql_password varchar(30) default NULL
);";
$check = $db->query($sql);
if (DB::IsError($check)) {
        die_freepbx( "Can not create `cidlookup` table: " . $check->getMessage() .  "\n");
}


$sql = "CREATE TABLE IF NOT EXISTS cidlookup_incoming (
  cidlookup_id INT NOT NULL,
  extension VARCHAR(50),
  cidnum VARCHAR(30)
);";
$check = $db->query($sql);
if (DB::IsError($check)) {
        die_freepbx( "Can not create `cidlookup_incomming` table: " . $check->getMessage() .  "\n");
}

// first update
$sql = "SELECT cache FROM cidlookup";
$check = $db->getRow($sql, DB_FETCHMODE_ASSOC);
if (DB::IsError($check)) {
  // add new field
  $sql = "ALTER TABLE cidlookup ADD cache INTEGER NOT NULL DEFAULT 0;";
  $result = $db->query($sql);
  if(DB::IsError($result)) {
    die_freepbx($result->getMessage());
  }
}

outn(_("Migrating channel routing to Zap DID routing.."));
$sql = "SELECT channel FROM cidlookup_incoming";
$check = @$db->query($sql);
if (!DB::IsError($check)) {
  $chan_prefix = 'zapchan';
  $sql = "UPDATE cidlookup_incoming SET extension=CONCAT('$chan_prefix',channel), channel='' WHERE channel != ''";
  $results = $db->query($sql);
  if (DB::IsError($results)) { 
    out(_("FATAL: failed to transform old routes: ").$results->getMessage());
  } else {
    out(_("OK"));
    // ALTER...DROP is not supported by sqlite3.  This table was setup properly in the CREATE anyway
    if($amp_conf["AMPDBENGINE"] != "sqlite3")  {
      outn(_("Removing deprecated channel field from incoming.."));
      $sql = "ALTER TABLE cidlookup_incoming DROP channel";
      $results = $db->query($sql);
      if (DB::IsError($results)) { 
      out(_("ERROR: failed: ").$results->getMessage());
      } else {
        out(_("OK"));
      }
    }
  }
} else {
  out(_("Not Needed"));
}

// This field had been wrongfully added to incoming quite some time ago
// this should maybe be added to core as well
//
// ALTER...DROP is not supported by sqlite3.  This table was setup properly in the CREATE anyway
if($amp_conf["AMPDBENGINE"] != "sqlite3")  {

  outn(_("Checking for cidlookup field in core's incoming table.."));
  $sql = "ALTER TABLE incoming DROP cidlookup";
  $results = $db->query($sql);
  if (DB::IsError($results)) { 
    out(_("not present"));
  } else {
  out(_("removed"));
  }
}
?>