Добавление данных в pg через php

$sql='INSERT INTO "spravochnik" ("otdel", "dolzno", "zvanie", "FIO", "telefon") VALUES (\''.$Otdel.'\', \''.$Dolzno.'\', \''.$zvanie.'\', \''.$FIO.'\', \'E'.$telefon.'\');';
if(!pg_query($connect,$sql))
{
    echo pg_last_error($connect);
    pg_close($connect);
    die();
}

function yourtable_insert(yourarguments)
{
    $conn_id = pg_connect(con_str()); // строка подключения к базе данных
    $sql = "ВАШ SQL";
    pg_query($conn_id, $sql);       
    pg_close($conn_id); 
}

<?php
/**
 * Класс для работы с БД (PostgreSQL)
 */
 
class sql_db{
     
      var $host = 'localhost';
      var $user = 'admin';
      var $pass = 'nnz4';
      var $base = 'ok';
 
      var $is_connected = false;
  
      /**
       *  Устанавливает соединение с БД
      */
      function getConnect(){
        $db = pg_pconnect("host=$this->host dbname=$this->base user=$this->user password=$this->pass");
        if(!$db) {
            if(is_dir("install")) header("location: /install");
            $this->errLog($sql);
        }
        pg_query("SET NAMES 'utf8'");
        $this->is_connected = true;
       return $db;
      }
 
      /**
       *  Произвольный запрос 
      */
      function query($sql){
       $sql = $this->pg_replace($sql);
       return pg_query($sql)or die ($this->errLog($sql));      
      }
 
      /**
       *  Получает данные ввиде массива ROW 
      */
      function row($sql){
          $sql = $this->pg_replace($sql);
          $in = pg_query($sql);
       return pg_fetch_row($in) or die ($this->errLog($sql));   
      }
      
      /**
       *  Получает данные ввиде массива ASSOC
      */
      function assoc($sql){
         $sql = $this->pg_replace($sql);
         $in = pg_query($sql)or die ($this->errLog($sql));   
       return pg_fetch_assoc($in);
      }
      
      /**
       *  Производит подсчет кол-ва записей
      */
      function result($sql){
         $sql = $this->pg_replace($sql);
         $in = pg_query($sql)or die ($this->errLog($sql));
       return  pg_result($in,0);
      }
      
      /**
       *  Добавляет запись в БД
      */
      function insert($table, $val){
        pg_query("INSERT INTO $table VALUES (nextval('".$table."_id_seq'), $val);")or die ($this->errLog($sql));       
      }
 
      /**
       *  Обновить запись в БД. Автоматически сопоставляет поля форм с полями таблицы.
      */
      function auto_update($table, $forms, $id = ''){
         unset($forms['id']);
         $q = pg_query("SHOW COLUMNS FROM $table");
         while($assoc = pg_fetch_assoc($q)){
          $key = $assoc['Field'];
          if(isset($forms[$key])) $val .= $key." = '".$forms[$key]."',";
         }
         $val = substr($val, 0, strlen($val)-1);
        
         if($id) $where  = " WHERE id = '".$id."'";
         pg_query("UPDATE $table SET  $val $where")or die ($this->errLog($sql));
      }
    
      /**
       * Обновляет запись в БД
      */
      function update($table, $val){
        pg_query("UPDATE $table SET  $val")or die ($this->errLog($sql));
      }
 
      /**
       * Удаляет запись в БД
      */
      function delete($table, $id){
         pg_query("DELETE FROM $table WHERE id = '$id'")or die ($this->errLog($sql));   
      }
      
      /**
       * Удаляет записи по полю в БД
      */
      function delete_field($table, $field, $id){
         pg_query("DELETE FROM $table WHERE $field = '$id'")or die ($this->errLog($sql));   
      }
     
      /**
       * Очищает таблицу
      */
      function clear($table){
         pg_query("TRUNCATE TABLE `$table`")or die ($this->errLog($sql));   
      }
      
      /**
       *  Получает данные ввиде массива
      */
      function in_array($sql){
         $sql = $this->pg_replace($sql);
         $q = pg_query($sql)or die ($this->errLog($sql));   
         while($assoc = pg_fetch_assoc($q)){
          $out[] = $assoc;
         }
       return $out;
      }
 
      /**
       *  Получает данные ввиде спец. массива
      */
      function out_array_param($sql, $key, $val){
          $sql = $this->pg_replace($sql);
          $q = pg_query($sql)or die ($this->errLog($sql));
          while($row = pg_fetch_assoc($q)){
          $out[$row[$key]] = $row[$val];
          }
        return $out;
      }
     
      /**
       *  Производит чтение ячейки БД
      */
      function read($sql){
        $sql = $this->pg_replace($sql);
        $lst = pg_query($sql);
        $s = @pg_fetch_array($lst);
        return trim($s[0]);
      }
 
      /**
       *  Лог ошибок
      */
      function errLog($mess){
         $f = fopen("files/logs/log.txt", 'a');
         fwrite($f, $mess.'
         ');
      }
 
      /**
       *  Замена условий
      */
      function pg_replace($sql){
        $sql = str_replace('||', 'or', $sql);
        $sql = str_replace('&&', 'and', $sql);
        return $sql;
      }
 
      /**
       * Получение последнего добавленого id
       */
      function get_last_id(){
        $insert_query = pg_query("SELECT lastval();");
        $insert_row = pg_fetch_row($insert_query);
        return $insert_row[0];
      }
 
      /**
       *  Закрывает соединение с БД
      */
      function connectClose() {
        return @pg_close();
      }
}
?>