Всем привет!
Есть следующая задачка.
Есть распределенная POSTGRESQL БД. То есть есть ЦБД и множество БД. Все они имеют одинаковую структуру и данные в них синхронизируются.
Соответственно встала задача уникальности каждой записи в таблице в рамках всей распределенной БД.
Программа, которая работает с базами данных написана на C# и использует Fluent NHibernate. То есть все общение с данными через NHibernate происходит.
Так вот задачу уникальности я решил делать так:
у каждой БД есть номер org_id. Также для таблиц есть сиквенс. Генерим ID с помощью сиквенса, а далее вычисляем окончательное значение ID, как ID * 1000 + org_id. Все это генерим в Before Insert триггерах к таблицам.
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
21.
22.
23.
24.
25.
26.
27.
28.
29.
30.
31.
32.
-- This is script that creates identity triggers for all tables.
CREATE OR REPLACE FUNCTION GetOrganizationId() RETURNS bigint AS $$
select CAST(value AS bigint) from public.setting set
WHERE upper(set.name) = upper('org_id');
$$ LANGUAGE SQL;
CREATE OR REPLACE FUNCTION GetId(Id bigint) RETURNS bigint AS $$
select Id * 1000 + GetOrganizationId() AS result;
$$ LANGUAGE SQL;
----------------production_type:--------------------------------------
CREATE SEQUENCE production_type_id_seq
INCREMENT 1
MINVALUE 1
MAXVALUE 9223372036854775807
START 1
CACHE 1;
CREATE OR REPLACE FUNCTION production_type_identity() RETURNS trigger AS $production_type_identity$
BEGIN
IF NEW.ID IS NULL THEN
NEW.ID := GetId(nextval('production_type_id_seq'));
END IF;
RETURN NEW;
END;
$production_type_identity$ LANGUAGE plpgsql;
CREATE TRIGGER production_type_identity BEFORE INSERT ON production_type
FOR EACH ROW EXECUTE PROCEDURE production_type_identity();
------------------------------------------------------
Так вот проблема в том, что NHibernate не получает новое значение сгенерированное в триггере.
Юзал стандартный тип генерации:
1.
2.
3.
4.
5.
protected BaseMap()
{
Id(x => x.Id);
Map(x => x.ObjectVersion, "OBJECT_VERSION").Not.Nullable();
......
в этом случае после инсерта ОРМ делает select lastval() - а это последнее значение выбранное из сиквенса за текущую сессию, соот-но он без номера бд.
Также юзал и trigger-identity тип генерации, который как раз для триггеров before insert сделан:
1.
Id(x => x.Id).GeneratedBy.TriggerIdentity();
тут я получаю ошибку "nhibernate assertionfailure null identifier".
Братья и сестры, добрые, помогите, уже два дня гуглю. Ниче не нашел(
Может быть альтернативное решение подскажите...
