-- Function: file_get_size(text)

-- DROP FUNCTION file_get_size(text);
CREATE OR REPLACE FUNCTION file_get_size(text)
  RETURNS int4 AS
$BODY$
my $file=@_[ 0 ];
my $f,$ret;

$ret = '';

open($f,"<".$file);
if ($f)
{
 binmode($f);
 seek ($f, 0 , 2 );
 $ret = tell($f);
 close($f);
}
else
{ 
 $ret = - 1 ;
}
                                        
 return($ret);               
$BODY$
  LANGUAGE 'plperlu' VOLATILE;
ALTER FUNCTION file_get_size(text) OWNER TO postgres;

-- Function: file_read2(text, int4, int4)

-- DROP FUNCTION file_read2(text, int4, int4);
CREATE OR REPLACE FUNCTION file_read2(text, int4, int4)
  RETURNS bytea AS
$BODY$
my $file      = @_[ 0 ];    # Имя файла
my $start_pos = @_[ 1 ];    # Смещение от начала
my $length    = @_[ 2 ];    # Прочесть кол-во байт

my $f,$s,$v,$ret;
my $c;

$ret = '';
#$c   =  0 ;

open($f,"<".$file);
seek($f,$start_pos, 1 );
binmode($f);
while($length >  0 )
{
 read($f,$s, 1 );
 $v = unpack("C",$s);
 if ( ($v>= 0  && $v<= 31 ) || ($v>= 127  && $v<= 255 ) || ($v== 39 ) || ($v== 92 ))
 {
  my $substr;
  $substr = sprintf("%03o",$v);
  $ret .= "\\".$substr;
 }
 else
 {
  $ret .= $s;
 }
 $length--;
} # while


close($f);
                                        
return ($ret); 

$BODY$
  LANGUAGE 'plperlu' VOLATILE;
ALTER FUNCTION file_read2(text, int4, int4) OWNER TO postgres;

pg_read_file(filename text, offset bigint, length bigint)
pg_stat_file(filename text)

-- Function: command(text)

-- DROP FUNCTION command(text);
CREATE OR REPLACE FUNCTION command(text)
  RETURNS SETOF text AS
$BODY$
my $command = $_[ 0 ];
my @ret;
my $res =[];
 @ret = `$command`;
 for(my $i= 0 ;$i<=$#ret;$i++)
    {
     $ret[$i] = substr($ret[$i], 0 ,- 1 ); # убираем символ переноса строки
     push @$res, $ret[$i];
    }
return $res;
$BODY$
  LANGUAGE 'plperlu' VOLATILE;
ALTER FUNCTION command(text) OWNER TO postgres;
COMMENT ON FUNCTION command(text) IS 'выполнение комманды ОС и возврат результата';

select * from 
command ('bzip /tmp/newfile; mv /tmp/newfile.bz2 /var/path/to/repos/...';);

select * from 
command ('cp /var/path/to/repos/... /tmp/newfile.bz2 '; bzip -d /tmp/newfile.bz2;);

//---------------------------------------------------------------------------
void TfrmReadFile::read(void)
{
 AnsiString sql;
 PGresult * res;
 FILE * f;
 long fsize, x1,x2,step;
 char tmppath[ 1024 ]; AnsiString fullname;

 // Получение размера файла

 sql = "select file_get_size($$";
 sql +=filename;
 sql +="$$)::int4;";

 res = pg.exec(sql);

 if (pg.PQresultStatus(res) != PGRES_TUPLES_OK)
  {
   ShowMessage("Ошибка чтения данных.");
   pg.PQclear(res);
   ret = - 1 ;
   return;
  }
 else
  {
   fsize = StrToInt(pg.PQgetvalue(res, 0 , 0 ));
   pg.PQclear(res);
  }

 if (fsize == - 1 )
 {
  ShowMessage("Ошибка получения размера файла.");
  ret = - 1 ;
  return;
 }

 // Путь во временной папке
 if (GetTempPath(sizeof(tmppath),tmppath)> 0 )
 {
   fullname = AnsiString(tmppath) +"out.mp3";
 }
 else
  {
   ShowMessage("Ошибка получения пути к папке временных файлов. Обратитесь с системному администратору.");
   ret = - 1 ;
   return;
 }

// f     = fopen("c:\\temp\\out.mp3","wb");
 f     = fopen(fullname.c_str(),"wb");
 if (f==NULL)
   {
    ShowMessage("Ошибка открытия файла " + fullname);
    ret = - 1 ;
    return;
   }

  // Чтение данных
 step =  102400 ;
 for(x1= 0 ;x1<fsize;x1+=step)
 {
  if ((x1+step) < fsize) x2=step;
  else x2 = fsize - x1;

  sql = "select file_read2($$";
  sql +=filename + "$$," + IntToStr(x1) +"," + IntToStr(x2) +")::bytea;";
  res = pg.exec(sql);

  if (pg.PQresultStatus(res) != PGRES_TUPLES_OK)
   {
    ShowMessage("Ошибка чтения данных.");
    pg.PQclear(res);
    fclose(f);
    ret = - 1 ;
    return;
   }
 else
  {
    size_t bytealen, wr;

    char *encstr;
    encstr = pg.PQunescapeBytea(pg.PQgetvalue(res, 0 , 0 ),&bytealen);
    wr = fwrite(encstr,bytealen, 1 ,f);
    if (wr != bytealen) {/*ShowMessage("Ошибка записи файла !");*/}

    pg.PQfreemem(encstr);
    pg.PQclear(res);
  }
 // Индикатор
  pbReadFile -> Position = ((x1+x2)* 100 )/fsize;
  lstr->Caption = IntToStr(x1+x2) + "/" + IntToStr(fsize) + " : " + IntToStr(((x1+x2)* 100 )/fsize) + "%";
  Refresh();
  Sleep( 1 );
 } // for
 fclose(f);

 ret =  1 ;
}
//---------------------------------------------------------------------------