diff --git a/src/main/resources/db/changelog/5-hs-office/503-relation/5030-hs-office-relation.sql b/src/main/resources/db/changelog/5-hs-office/503-relation/5030-hs-office-relation.sql
index 80290067..2dc608cb 100644
--- a/src/main/resources/db/changelog/5-hs-office/503-relation/5030-hs-office-relation.sql
+++ b/src/main/resources/db/changelog/5-hs-office/503-relation/5030-hs-office-relation.sql
@@ -49,37 +49,37 @@ CREATE UNIQUE INDEX unique_partner_relation
 
 --//
 
-
 -- =====================================================================================
---changeset timotheus.pokorra:hs-office-relation-debitor-anchor-CONSTRAINT endDelimiter:--//
+--changeset marc.sandlus:hs-office-relation-debitor-anchor-CONSTRAINT-BY-TRIGGER endDelimiter:--//
 -- -------------------------------------------------------------------------------------
+alter table hs_office.relation
+    drop constraint if exists relation_check_debitor_anchor_person;
 
---
--- Name: relation_check_debitor_anchor_partner(RelationType, uuid); Type: FUNCTION; Schema: hs_office; Owner: test
---
+drop function if exists hs_office.relation_check_debitor_anchor_partner cascade;
 
-CREATE FUNCTION hs_office.relation_check_debitor_anchor_partner(mytype hs_office.RelationType, debitoranchoruuid uuid) RETURNS boolean
-    LANGUAGE plpgsql
-    AS '
+CREATE FUNCTION hs_office.relation_enforce_debitor_anchor_partner()
+returns trigger as $$
 declare
     countPartner integer;
 begin
-    if mytype = ''DEBITOR'' then
+    if NEW.type = 'DEBITOR' then
         SELECT COUNT(*) FROM hs_office.relation r
-            WHERE r.type = ''PARTNER'' AND r.holderuuid = debitoranchoruuid
+            WHERE r.type = 'PARTNER' AND r.holderuuid = NEW.anchorUuid
             INTO countPartner;
         if countPartner < 1 then
-            raise exception ''[400] invalid debitor relation: anchor person must have a PARTNER relation'';
+            raise exception '[400] invalid debitor relation: anchor person must have a PARTNER relation';
         end if;
     end if;
-    return true;
-end; ';
+    return NEW;
+end;
+$$ LANGUAGE plpgsql;;
 
-ALTER TABLE hs_office.relation ADD CONSTRAINT check_debitor_anchor_person CHECK (hs_office.relation_check_debitor_anchor_partner(type, anchorUuid));
+create trigger relation_enforce_debitor_anchor_partner_tg before insert
+    on hs_office.relation
+    for each row execute function hs_office.relation_enforce_debitor_anchor_partner();
 
 --//
 
-
 -- ============================================================================
 --changeset michael.hoennig:hs-office-relation-MAIN-TABLE-JOURNAL endDelimiter:--//
 -- ----------------------------------------------------------------------------
diff --git a/src/main/resources/db/changelog/5-hs-office/511-coopshares/5110-hs-office-coopshares.sql b/src/main/resources/db/changelog/5-hs-office/511-coopshares/5110-hs-office-coopshares.sql
index 2aa6fe72..c6327e7b 100644
--- a/src/main/resources/db/changelog/5-hs-office/511-coopshares/5110-hs-office-coopshares.sql
+++ b/src/main/resources/db/changelog/5-hs-office/511-coopshares/5110-hs-office-coopshares.sql
@@ -33,30 +33,36 @@ alter table hs_office.coopsharetx
 --//
 
 -- ============================================================================
---changeset michael.hoennig:hs-office-coopshares-SHARE-COUNT-CONSTRAINT endDelimiter:--//
+--changeset marc.sandlus:hs-office-coopshares-SHARE-COUNT-CONSTRAINT-BY-TRIGGER endDelimiter:--//
 -- ----------------------------------------------------------------------------
 
-create or replace function hs_office.coopsharestx_check_positive_total(forMembershipUuid UUID, newShareCount integer)
-returns boolean
-language plpgsql as $$
+alter table hs_office.coopsharetx drop constraint if exists check_positive_total_shares_count;
+
+drop function if exists hs_office.coopsharestx_check_positive_total cascade;
+
+create or replace function hs_office.coopsharetx_enforce_positive_total()
+returns trigger as $$
+
 declare
     currentShareCount integer;
     totalShareCount integer;
 begin
     select sum(cst.shareCount)
     from hs_office.coopsharetx cst
-    where cst.membershipUuid = forMembershipUuid
+    where cst.membershipUuid = NEW.membershipUuid
     into currentShareCount;
-    totalShareCount := currentShareCount + newShareCount;
+    totalShareCount := currentShareCount + NEW.shareCount;
     if totalShareCount < 0 then
         raise exception '[400] coop shares transaction would result in a negative number of shares';
     end if;
-    return true;
-end; $$;
+    return NEW;
+end;
+$$ LANGUAGE plpgsql;;
 
-alter table hs_office.coopsharetx
-    add constraint check_positive_total_shares_count
-        check ( hs_office.coopsharestx_check_positive_total(membershipUuid, shareCount) );
+
+create trigger positive_total_shares_count_tg before insert
+    on hs_office.coopsharetx
+    for each row execute function hs_office.coopsharetx_enforce_positive_total();
 
 --//
 
diff --git a/src/main/resources/db/changelog/5-hs-office/512-coopassets/5120-hs-office-coopassets.sql b/src/main/resources/db/changelog/5-hs-office/512-coopassets/5120-hs-office-coopassets.sql
index 524e620c..90d1c37b 100644
--- a/src/main/resources/db/changelog/5-hs-office/512-coopassets/5120-hs-office-coopassets.sql
+++ b/src/main/resources/db/changelog/5-hs-office/512-coopassets/5120-hs-office-coopassets.sql
@@ -73,33 +73,39 @@ CREATE TRIGGER enforce_transaction_constraints
 --//
 
 -- ============================================================================
---changeset michael.hoennig:hs-office-coopassets-ASSET-VALUE-CONSTRAINT endDelimiter:--//
+--changeset marc.sandlus:hs-office-coopassets-ASSET-VALUE-CONSTRAINT-BY-TRIGGER endDelimiter:--//
 -- ----------------------------------------------------------------------------
 
-create or replace function hs_office.coopassetstx_check_positive_total(forMembershipUuid UUID, newAssetValue numeric(12, 5))
-returns boolean
-language plpgsql as $$
+alter table hs_office.coopassettx
+    drop constraint if exists coopassetstx_check_positive_total;
+
+drop function if exists hs_office.coopassetstx_check_positive_total cascade;
+
+create or replace function hs_office.coopassettx_enforce_positive_total()
+returns trigger as $$
+
 declare
     currentAssetValue numeric(12,2);
     totalAssetValue numeric(12,2);
 begin
     select sum(cat.assetValue)
         from hs_office.coopassettx cat
-        where cat.membershipUuid = forMembershipUuid
+        where cat.membershipUuid = NEW.membershipUuid
         into currentAssetValue;
-    totalAssetValue := currentAssetValue + newAssetValue;
+    totalAssetValue := currentAssetValue + NEW.assetValue;
     if totalAssetValue::numeric < 0 then
         raise exception '[400] coop assets transaction would result in a negative balance of assets';
     end if;
-    return true;
-end; $$;
+    return NEW;
+end;
+$$ LANGUAGE plpgsql;;
+
+create trigger positive_total_assets_count_tg before insert
+    on hs_office.coopassettx
+    for each row execute function hs_office.coopassettx_enforce_positive_total();
 
-alter table hs_office.coopassettx
-    add constraint check_positive_total
-        check ( hs_office.coopassetstx_check_positive_total(membershipUuid, assetValue) );
 --//
 
-
 -- ============================================================================
 --changeset michael.hoennig:hs-office-coopassets-MAIN-TABLE-JOURNAL endDelimiter:--//
 -- ----------------------------------------------------------------------------