function get_provider_data($provider_id)
{
    $qry = pg_query_params("select sp_home_page, contactemail from techmatcher.serviceprovider where serviceprovider_id=\$1", array($provider_id)) or die(pg_errormessage());
    $result = pg_fetch_assoc($qry);
    $_SESSION['provider']['contactemail'] = $result['contactemail'];
    return $result["sp_home_page"];
}

 /**
  * Удалить код активации
  *
  * @param integer $fid	ID Пользователя, у которого удаляем код активации
  * @return string	Сообщение об ошибке
  */
 function Delete($fid)
 {
     global $DB;
     $sql = "DELETE FROM activate_mail WHERE user_id = ?";
     $DB->query($sql, $fid);
     return pg_errormessage();
 }

 public function executeQuery($sql)
 {
     //prepare query
     $sql = $this->prepareQuery($sql);
     $parts = explode(" ", trim($sql));
     $type = strtolower($parts[0]);
     $hash = md5($sql);
     $this->lastHash = $hash;
     if ($type == "select") {
         if (isset($this->results[$hash])) {
             if (is_resource($this->results[$hash])) {
                 return $this->results[$hash];
             }
         }
     } else {
         if ("update" == $type || "delete" == $type) {
             $this->results = array();
             //clear the result cache
         }
     }
     $query = pg_query($this->connection, $sql);
     if (!$query) {
         echo pg_errormessage($this->connection);
     }
     $this->results[$hash] = $query;
     return $this->results[$hash];
 }

 public function query($string = '')
 {
     if ($string != '') {
         $this->query = $this->escape($string);
     } else {
         $this->query = $this->select . $this->insert . $this->update . $this->delete . $this->create . $this->from . $this->join . $this->where . $this->group . $this->order . $this->limit;
     }
     $this->insert = " RETURNING id";
     $this->result = pg_exec($this->connection, $this->query);
     $this->inserted_id = $this->result;
     $this->error = pg_errormessage($this->connection);
     $this->affected_rows = pg_affected_rows($this->result);
     $this->select = '';
     $this->insert = '';
     $this->update = '';
     $this->delete = '';
     $this->create = '';
     $this->from = '';
     $this->join = '';
     $this->where = '';
     $this->group = '';
     $this->order = '';
     $this->limit = '';
     return $this;
 }

function my_handler($sql_insert)
{
    global $table, $link, $new_name;
    $sql_insert = ereg_replace($table, $new_name, $sql_insert);
    $result = pg_exec($link, pre_query($sql_insert)) or pg_die(pg_errormessage($link), $sql_insert, __FILE__, __LINE__);
    $sql_query = $sql_insert;
}

 /**
  * Изменить параметр "видимости" анонима на противоположный
  *
  * @param integer $aid		идентификатор анонима
  * @return char				сообщение об ошибке
  */
 function ChVisible($aid)
 {
     global $DB;
     $sql = "UPDATE anonymous SET visible = NOT visible::bool WHERE id = ?";
     $DB->squery($sql, $aid);
     $error = pg_errormessage();
     return $error;
 }

function get_address_by_serviceid($serviceprovider_id)
{
    $result = pg_query_params("SELECT address_id FROM techmatcher.serviceprovidertoaddress WHERE serviceprovider_id=\$1 AND address_deleted=\$2", array($serviceprovider_id, "FALSE")) or die(pg_errormessage());
    $names = array();
    while ($name = pg_fetch_assoc($result)) {
        $names[] = $name;
    }
    return $names;
}

 public function ejecutarConsulta($sql)
 {
     $resultado = pg_query($this->conexion, $sql) or die("La consulta fallo1: " . pg_last_error($this->conexion));
     if (!isset($resultado)) {
         echo "La consulta fallo2: " . pg_errormessage();
         exit;
     }
     return $resultado;
 }

function set_privilege($sql_set_privilege)
{
    global $link;
    if (!($res = @pg_exec($link, $sql_set_privilege))) {
        pg_die(pg_errormessage($link), $sql_set_privilege, __FILE__, __LINE__);
    } else {
        echo "<p>{$sql_set_privilege}</p>\n";
    }
}

function get_staff_for_provider($serviceprovider_id)
{
    $result = pg_query_params("SELECT spstaff_id FROM techmatcher.serviceprovidershavestaff WHERE serviceprovider_id = \$1", array($serviceprovider_id)) or die(pg_errormessage());
    $names = array();
    while ($name = pg_fetch_assoc($result)) {
        $names[] = $name;
    }
    return $names;
}

 /**
  * A method to set the client charset
  *
  * @param string $charset
  * @return mixed True on success, PEAR_Error otherwise
  */
 function setClientCharset($charset)
 {
     if (!empty($charset) && $this->oDbh) {
         $pg = $this->oDbh->getConnection();
         if (@pg_set_client_encoding($pg, $charset) == -1) {
             return new PEAR_Error(pg_errormessage($pg));
         }
     }
     return true;
 }

 function connect()
 {
     $this->link = pg_connect("host='" . $this->hostname . "' port='" . $this->port . "' dbname='" . $this->db . "' user='" . $this->username . "' password='" . $this->password . "'");
     if (!$this->link) {
         $this->error = pg_errormessage($this->db);
         return false;
     }
     $this->exeq("set search_path to '" . $this->schema . "'");
     return true;
 }

function getSP_Rated()
{
    $qry = "SELECT * FROM techmatcher.ratingevents where ratingtotal>0;";
    $result = pg_query_params($qry, array()) or die(pg_errormessage());
    if (pg_num_rows($result) > 0) {
        return $result;
    } else {
        return false;
    }
}

 function FetchByMaster($MasterName)
 {
     $sql = "\nSELECT id          AS slave_port_id,\n       name        AS slave_port_name,\n       category_id AS slave_category_id,\n       category    AS slave_category_name\n  FROM ports_active\n WHERE master_port = '" . pg_escape_string($MasterName) . "'\nORDER BY slave_category_name, slave_port_name";
     #echo "sql = <pre>$sql</pre>";
     $this->LocalResult = pg_exec($this->dbh, $sql);
     if (!$this->LocalResult) {
         echo pg_errormessage() . " {$sql}";
     }
     $numrows = pg_numrows($this->LocalResult);
     return $numrows;
 }

 function Insert()
 {
     # delete the ignore entry for this commit/port combination
     $sql = "\nINSERT INTO commit_log_ports_ignore (commit_log_id, port_id, reason)\n   values ({$this->commit_log_id}, {$this->port_id}, '" . pg_escape_string($this->reason) . "')";
     echo "\$sql='<pre>{$sql}</pre><br>\n";
     $this->result = pg_exec($this->dbh, $sql);
     if (!$this->result) {
         echo pg_errormessage() . " {$sql}";
     }
     $numrows = pg_affected_rows($this->result);
     return $numrows;
 }

 function next_record()
 {
     $this->Record = @pg_fetch_array($this->Query_ID, $this->Row);
     $this->Row += 1;
     $this->Error = pg_errormessage();
     $stat = is_array($this->Record);
     if (!$stat) {
         pg_freeresult($this->Query_ID);
         $this->Query_ID = 0;
     }
     return $this->Record;
 }

function obtenerMaximo($tabla, $campo, $b)
{
    $query = "SELECT max({$campo}) as maximo\r\n\t              FROM {$tabla}";
    if ($result = pg_query($b, $query)) {
        while ($row = pg_fetch_array($result)) {
            $maximo = $row["maximo"];
        }
    } else {
        $maximo = pg_errormessage($this->dbOrigen);
    }
    pg_free_result($result);
    return $maximo;
}

function freshports_WatchListCountDefault($db, $UserID)
{
    $sql = "select WatchListCountDefault({$UserID}) as count";
    #	echo $sql;
    $result = pg_exec($db, $sql);
    if (!$result) {
        echo "error " . pg_errormessage();
        exit;
    }
    $myrow = pg_fetch_array($result, 0);
    #	echo $myrow["count"];
    return $myrow["count"];
}

 function FetchInitialise($port_id)
 {
     # get ready to fetch all the commit_log_ports_vuxml for this port
     # return the number of commits found
     $sql = "\nselect CLPV.id,\n       CLPV.commit_log_id, \n       CLPV.port_id,\n       CLPV.vuxml_id,\n       vuxml.vid\n  from commit_log_ports_vuxml CLPV, vuxml\n where CLPV.port_id  = {$port_id}\n   and CLPV.vuxml_id = vuxml.id\n order by CLPV.commit_log_id ";
     #		echo "\$sql='<pre>$sql</pre><br>\n";
     $this->result = pg_exec($this->dbh, $sql);
     if (!$this->result) {
         echo pg_errormessage() . " {$sql}";
     }
     $numrows = pg_numrows($this->result);
     return $numrows;
 }

 public function storeEvent(EventEnvelope $event, $seriesName)
 {
     $seriesNumber = $this->createSeriesIfNeeded($seriesName);
     $this->ensureConnection();
     $prepareRes = pg_prepare($this->connection, 'storeEvent', 'insert into ' . $this->config->get('postgres.prefix', true) . 'events values (now(), $1, $2, $3)');
     if ($prepareRes === false) {
         throw new \RuntimeException(pg_errormessage($this->connection));
     }
     $res = pg_execute($this->connection, 'storeEvent', array($seriesNumber, $event->value, json_encode($event->payload)));
     if ($res === false) {
         throw new \RuntimeException(pg_errormessage($this->connection));
     }
     return true;
 }