CREATE TABLE t_audit_tables
(
  id serial NOT NULL, -- первичный ключ
  table_name character varying NOT NULL, -- название таблицы
  CONSTRAINT t_audit_tables_id PRIMARY KEY (id),
  CONSTRAINT "u_t_audit_tables->table_name" UNIQUE (table_name)
) 

CREATE TABLE t_audit_table_fields
(
  id serial NOT NULL, -- первичный ключ
  table_id integer NOT NULL, -- таблица, к поторой это поле привязано.
  field_name character varying( 100 ) NOT NULL, -- название поля в таблице
  CONSTRAINT t_audit_table_fields_id PRIMARY KEY (id),
  CONSTRAINT fk_t_audit_table_fields FOREIGN KEY (table_id)
      REFERENCES t_audit_tables (id) MATCH SIMPLE
      ON UPDATE NO ACTION ON DELETE CASCADE,
  CONSTRAINT "u_t_audit_table_fields->uniq" UNIQUE (table_id, field_name)
) 

CREATE TABLE t_audit_field_values
(
  id serial NOT NULL,
  field_id integer NOT NULL, -- поле, значение которого хранится
  field_value text, -- хранимое значение
  user_name text NOT NULL, -- пользователь, внесший изменение
  date_rec timestamp without time zone NOT NULL, -- дата записи.
  record_id integer NOT NULL DEFAULT  0 , -- номер строки, для которой ведем логи. надо для того, чтобы потом (скажем при инсерте) можно было собрать одну строку.
  ip inet DEFAULT inet_client_addr(), -- адрес, с которого было внесено изменение
  CONSTRAINT pk_audit_field_values PRIMARY KEY (id),
  CONSTRAINT fk_audit_field_values FOREIGN KEY (field_id)
      REFERENCES t_audit_table_fields (id) MATCH SIMPLE
      ON UPDATE NO ACTION ON DELETE NO ACTION
) 

CREATE OR REPLACE FUNCTION audit_biu()
  RETURNS "trigger" AS
$BODY$
# --------------- by Rastafarra

# --------------- проверили чтобы не войти в рекурсию. ну мало ли? просто на всякий случай...
if {[string equal -nocase $TG_table_name "audit_field_values"]} then {
	return OK;
}

# --------------- посмотрели, надо ли вообще эту таблицку пихать в логи.
spi_exec -array log_array "select atf.field_name as field_name, atf.id as field_id from t_audit_table_fields atf
			inner join t_audit_tables at on at.id=atf.table_id
			where 
				at.table_name='$TG_table_name'"
if {[array size log_array] == "0"} then {
	return OK
}

--------------- эта штука выбирает имя primary key для произвольной таблицы.
set pk_name ""
spi_exec "SELECT a.attname AS pk_name FROM pg_class c, pg_attribute a, pg_index i
	WHERE c.relname = '$TG_table_name'
	AND c.oid=i.indrelid
	AND a.attnum > 0
	AND a.attrelid = i.indexrelid
	AND i.indisprimary='t'"

 --------------- эта штука выбирает для primary key произвольной таблицы собсно значение этого primary key
set pk_value ""
foreach field $TG_relatts {
	if {[string equal -nocase [lindex [array get NEW $field]  0 ] $pk_name]} {
		set pk_value [lindex [array get NEW $field]  1 ]
		break;
	}
}

switch $TG_op {
	INSERT {
		# начитали список полей для логов. может быть можно это сделать краше, но я не нашел пока как.
		spi_exec -array C "select atf.field_name as atf_field_name, atf.id as atf_id from t_audit_table_fields atf
					inner join t_audit_tables at on at.id=atf.table_id
					where 
						at.table_name='$TG_table_name'" {
			foreach field_name $TG_relatts {
				if {$C(atf_field_name) == $field_name} then {
					set field_value [string trim [lindex [array get NEW $field_name]  1 ]]
					set field_id $C(atf_id)
					spi_exec "insert into t_audit_field_values (field_value, field_id, user_name, date_rec, record_id)
						values ('$field_value', $field_id, user, CURRENT_TIMESTAMP, $pk_value)"
				}
			}
		}
	}
	UPDATE {
		# начитали список полей для логов. может быть можно это сделать краше, но я не нашел пока как.
		spi_exec -array C "select atf.field_name as atf_field_name, atf.id as atf_id from t_audit_table_fields atf
					inner join t_audit_tables at on at.id=atf.table_id
					where 
						at.table_name='$TG_table_name'" {
			foreach field_name $TG_relatts {
				if {$C(atf_field_name) == $field_name} then {
					set new_val [string trim [lindex [array get NEW $field_name]  1 ]]
					set old_val [string trim [lindex [array get OLD $field_name]  1 ]]
					if {$new_val != $old_val} then {
						set field_id $C(atf_id)
						spi_exec "insert into t_audit_field_values (field_value, field_id, user_name, date_rec, record_id)
							values ('$new_val', $field_id, user, CURRENT_TIMESTAMP, $pk_value)"
					}
				}
			}
		}
	}
	default { return OK }
}
return [array get NEW]
$BODY$
  LANGUAGE 'pltcl' VOLATILE;

# --------------- проверили чтобы не войти в рекурсию. ну мало ли? просто на всякий случай...
if {[string equal -nocase $TG_table_name "audit_field_values"]} then {
	return OK;
}

# --------------- проверили чтобы не войти в рекурсию. ну мало ли? просто на всякий случай...
if {[string equal -nocase $TG_table_name "t_audit_field_values"]} then {
	return OK;
}