create extension if not exists plperl;
--регулярки от перла!!!
drop function if exists perl_regex_matches(text, text);
CREATE OR REPLACE FUNCTION perl_regex_matches(text, text)
  RETURNS SETOF text[] AS
    /*$1 - где ищем
$2 - что ищем
*/

$BODY$
	my ($sentense, $regexp) = @_;
	my @values = $sentense =~ /$regexp/g;
	return [ \@values ];
$BODY$
  LANGUAGE plperl VOLATILE
  COST 100
  ROWS 1000;
ALTER FUNCTION perl_regex_matches(text, text)
  OWNER TO postgres;
drop function if exists perl_regex_matches_t(text, text);
CREATE OR REPLACE FUNCTION perl_regex_matches_t(text, text)
  RETURNS SETOF text AS
    /*$1 - где ищем
$2 - что ищем
*/
$BODY$
	my ($sentense, $regexp) = @_;
	my @values = $sentense =~ /$regexp/g;
	return \@values;
$BODY$
  LANGUAGE plperl VOLATILE
  COST 100
  ROWS 1000;
ALTER FUNCTION perl_regex_matches_t(text, text)
  OWNER TO postgres;
drop function if exists perl_regex_split_t(text, text);
CREATE OR REPLACE FUNCTION perl_regex_split(text, text)
  RETURNS SETOF text[] AS
/*$1 - где ищем
$2 - что ищем
*/

$BODY$
	my ($sentense, $regexp) = @_;
	my @values = split /$regexp/, $sentense;
	return [ \@values ];
$BODY$
  LANGUAGE plperl VOLATILE
  COST 100
  ROWS 1000;
ALTER FUNCTION perl_regex_split(text, text)
  OWNER TO postgres;
drop function if exists perl_regex_split_t(text, text);
CREATE OR REPLACE FUNCTION perl_regex_split_t(text, text)
  RETURNS SETOF text AS
  /*$1 - где ищем
$2 - что ищем
*/
$BODY$
	my ($sentense, $regexp) = @_;
	my @values = split /$regexp/, $sentense;
	return \@values;
$BODY$
  LANGUAGE plperl VOLATILE
  COST 100
  ROWS 1000;
ALTER FUNCTION perl_regex_split_t(text, text)
  OWNER TO postgres;  
drop function if exists perl_regex_replace(text, text);
CREATE OR REPLACE FUNCTION perl_regex_replace(text, text, text)
  RETURNS text AS
/*$1 - где ищем
$2 - что ищем
$3 - чем меняем
*/
  $BODY$
my ($sentense, $pattern, $replace) = @_;
$sentense =~ s/$pattern/$replace/g;
return $sentense;
$BODY$
  LANGUAGE plperl VOLATILE
  COST 100;
ALTER FUNCTION perl_regex_replace(text, text, text)
  OWNER TO postgres;

           
            {
                _counter++;
                if (_counter > 50)
                {
                    _log.Write("Реконнект для профилактики памяти...");
                    _conn.Close();
                    _conn = new NpgsqlConnection(_connectionString);
                    _cmd.Connection = _conn;
                    _conn.Open();
                    index = WaitForReconnect();
                    _log.WriteLine("ОК");
                    _counter = 0;
                }
                _cmd.CommandText = cmdText;
                if (this.Debug) _log.WriteLine("Команда "+cmdText);
                index = Convert.ToInt64(_cmd.ExecuteScalar());

            }

                if (_counter > 50)
                {
                    _log.Write("Реконнект для профилактики памяти...");
                    _conn.Close();
                    _conn.ClearPool();
                    _conn.Dispose();
                    _conn = new NpgsqlConnection(_connectionString);
                    _cmd.Connection = _conn;
                    _conn.Open();
                    index = WaitForReconnect();
                    _log.WriteLine("ОК");
                    _counter = 0;
                }