Conflict-free replicated data types¶

競合のないレプリケートデータ型（CRDT）は、従来の解決のように行の1つを破棄するのではなく、同時に変更される行の値のマージをサポートします。

各CRDT型は、 bdr.crdt_handlers カタログに追加された追加のコールバックを備えた個別のPostgreSQLデータ型として実装されます。マージプロセスは、ユーザーアクションを必要とせずに、適用側のPGDライタ内で発生します。

CLCD で説明されているように、CRDTでは、テーブルで列レベルの競合解決を有効にする必要があります。

あなたが行う必要がある唯一のアクションは、整数などの標準の組み込みデータ型ではなく、CREATE / ALTER TABLEで特定のデータ型を使用することです。たとえば、1つの通常の整数カウンターと1つの行がある次のテーブルについて考えます。

CREATE TABLE non_crdt_example (
    id      integer             PRIMARY KEY,
    counter integer             NOT NULL DEFAULT 0
);

INSERT INTO non_crdt_example (id) VALUES (1);

2つのノードで次のSQLを同時に発行するとします。

UPDATE non_crdt_example
   SET counter = counter + 1    -- "reflexive" update
 WHERE id = 1;

両方の更新を適用した後、次のクエリを使用して結果の値を確認できます。

SELECT * FROM non_crdt_example WHERE id = 1;
   id |   counter
 -----+-----------
    1 |         1
(1 row)

このコードは、 update_if_newer 競合リゾルバーが原因でインクリメントの1つを失ったことを示しています。代わりにCRDTカウンターデータ型を使用すると、結果は次のようになります。

CREATE TABLE crdt_example (
    id      integer             PRIMARY KEY,
    counter bdr.crdt_gcounter   NOT NULL DEFAULT 0
);

ALTER TABLE crdt_example REPLICA IDENTITY FULL;

SELECT bdr.alter_table_conflict_detection(crdt_example,
            column_modify_timestamp, cts);

INSERT INTO crdt_example (id) VALUES (1);

再び2つのノードで次のSQLを同時に発行し、変更が適用されるのを待ちます。

UPDATE crdt_example
   SET counter = counter + 1    -- "reflexive" update
 WHERE id = 1;

SELECT id, counter FROM crdt_example WHERE id = 1;
   id |   counter
 -----+-----------
    1 |         2
(1 row)

この例は、CRDTが、そうでなければ競合する非同期同時更新に直面しても、アキュムレータ列が正しく機能できることを示しています。

crdt_gcounter タイプは、例が示すように、 x = x + 1 などの再帰 UPDATE SQLでのみ機能する状態ベースのCRDTタイプの例です。

bdr.crdt_raw_value 構成オプションは、クエリが現在の値を返すか、CRDT型の完全な内部状態を返すかを決定します。デフォルトでは、現在の数値のみが返されます。 true に設定すると、クエリは完全な状態の表現を返します。特別なハッシュ演算子（# ）を使用すると、特別な演算子を使用せずに現在の数値のみを要求できます（デフォルトの動作）。 bdr.crdt_raw_value = on を使用して完全な状態がダンプされる場合、値はbdr.crdt_raw_value = on でのみリロードできます。

注釈

bdr.crdt_raw_value は、クライアントに返されるデータ、つまり選択リスト内の単純な列参照のフォーマットのみを適用します。クエリの他の部分（WHERE 句や選択リスト内の式など）での列参照では、引き続き`#` 演算子の使用が必要になる場合があります。

CRDTデータ型の別のクラスは、 デルタCRDT 型と呼ばれます。これらは、オペレーションベースのCRDTの特別なサブクラスです。

デルタCRDTでは、値の更新は同じノード上の以前の値と比較されます。次に、変更は他のすべてのノードにデルタとして適用されます。

CREATE TABLE crdt_delta_example (
    id       integer            PRIMARY KEY,
    counter  bdr.crdt_delta_counter NOT NULL DEFAULT 0
);

ALTER TABLE crdt_delta_example REPLICA IDENTITY FULL;

SELECT bdr.alter_table_conflict_detection(crdt_delta_example,
            column_modify_timestamp, cts);

INSERT INTO crdt_delta_example (id) VALUES (1);

2つのノードで次のSQLを同時に発行するとします。

UPDATE crdt_delta_example
   SET counter = 2          -- notice NOT counter = counter + 2
 WHERE id = 1;

両方の更新を適用した後、次のクエリを使用して結果の値を確認できます。

SELECT id, counter FROM crdt_delta_example WHERE id = 1;
   id | counter
 -----+---------
    1 |       4
(1 row)

通常のinteger 列の場合、結果は2 です。ただし、デルタCRDTカウンターで行を更新する場合、古い行バージョンから始めて新しい行バージョンを作成し、両方をリモートノードに送信します。そこで、そこにあるバージョン（ローカルバージョンなど）と比較します。標準CRDTはNEWバージョンとLOCALバージョンをマージしますが、デルタCRDTはOLDバージョンとNEWバージョンを比較し、デルタをLOCALバージョンに適用します。

CRDTタイプは、 bdr の一部としてbdr スキーマにインストールされます。便宜上、基本的な演算子（+ 、# および! ）と多くの一般的な集計関数（min 、max 、sum 、およびavg ）がpg_catalog で作成されます。したがって、search_path を調整せずに利用できます。

重要な質問は、クエリの計画と最適化がこれらの新しいデータ型でどのように機能するかです。 CRDTタイプは透過的に処理されます。 ANALYZE とオプティマイザーの両方が機能するため、見積もりとクエリプランニングは、他に何もしなくても正常に機能します。

状態ベースおよびオペレーションベースのCRDT¶

[1]の表記に従って、操作ベースと状態ベースの両方のCRDTが実装されます。

オペレーションベースのCRDTタイプ（CmCRDT）¶

オペレーションは明示的に転送されるのではなく、リモートノードから受け取った新旧の行から計算されるため、オペレーションベースの型の実装は簡単です。

現在、次のオペレーションベースのCRDTが実装されています。

crdt_delta_counter — bigint カウンター（インクリメント/デクリメント）
crdt_delta_sum — numeric sum（インクリメント/デクリメント）

これらの型は、デルタを計算するための少しのコードで既存のデータ型を活用します。たとえば、 crdt_delta_counter はbigint 上のドメインです。

このアプローチは、デルタの計算方法がわかっているタイプでのみ可能ですが、結果はシンプルで安価（スペースとCPUの両方）であり、いくつかの利点があります。たとえば、基になるデータ型の演算子/構文を活用できます。

主な欠点は、非同期および並行環境でこの値を確実にリセットできないことです。

注釈

カスタムデータ型を作成することにより、より複雑な操作ベースの型を実装し、状態と最後の操作を保存することが可能です。（すべての変更がデコードされて転送されるため、複数の操作は必要ありません）。しかし、その時点で、主な利点（単純さ、既存のデータ型の再利用）は失われ、領域要件を除き、状態ベースの型と比較して利点を得ることはありません（たとえば、まだリセットする機能はありません）。（ノードごとの状態は必要ありません。）

状態ベースのCRDTタイプ（CvCRDT）¶

状態ベースの型はより複雑な内部状態を必要とするため、操作ベースの型のように通常のデータ型を直接使用することはできません。

現在、4つの状態ベースのCRDTが実装されています。

crdt_gcounter — bigint カウンター（インクリメントのみ）
crdt_gsum — numeric 合計/カウンター（インクリメントのみ）
crdt_pncounter — bigint カウンター（インクリメント/デクリメント）
crdt_pnsum — numeric 合計/カウンター（インクリメント/デクリメント）

内部状態には通常、ノードごとの情報が含まれ、ディスク上のサイズが大きくなりますが、追加の利点が得られます。カスタムデータ型を実装する必要性は、より多くのコード（入出力関数と演算子）を意味します。

利点は、値を確実にリセットできること、変更が失われた場合の自己修復性（適切に動作するクラスターでは発生しません）、およびソースノード以外から変更を受信できることです。

たとえば、ノードAで値が変更され、AとC間のネットワーク問題が原因で、変更がBにレプリケートされますが、Cにはレプリケートされないとします。 Bが値を変更し、この変更がCにレプリケートされる場合、それにはAからの元の変更。オペレーションベースのCRDTでは、ノードCはA-Cネットワーク接続が再び機能し始めるまで変更を受け取りません。

CvCRDTの主な欠点は、ディスク領域とCPU使用率のコストが高いことです。クラスターから既に削除されたノードを含む、各ノードに関する少しの情報が必要です。状態の複雑な性質（varlenaタイプにシリアル化）は、CPU使用率の増加を意味します。

ディスク容量要件¶

重要な考慮事項は、CRDTタイプ、特にディスク上のサイズに関連するオーバーヘッドです。

オペレーションベースのタイプの場合、タイプは他のタイプの上の単なるドメインであるため、これは簡単です。ノードの数に関係なく、ディスク領域の要件は同じです。

crdt_delta_counter — bigint と同じ（8バイト）
crdt_delta_sum — numeric と同じ（可変、精度とスケールに応じて）

オペレーションベースのCRDTタイプはノードごとの情報を格納しないため、ノード数に依存しません。

状態ベースの型の場合、状況はより複雑です。すべての型は可変長（基本的にbytea 列として格納）であり、ヘッダーと、値を変更した各ノードの一定量のノードごとの情報で構成されています。

bigint バリアントの場合、おおよそのサイズを計算する式は次のとおりです。

crdt_gcounter — 32B (header) + N * 12B (per-node)
crdt_pncounter -—48B (header) + N * 20B (per-node)

N は、この値を変更したノードの数を示します。

numeric バリアントの場合、ヘッダー部分とノードごとの部分の両方にnumeric 可変長値が含まれるため、正確な式はありません。そのような値をいくつ保持する必要があるかを知るには：

crdt_gsum -固定：20B (header) + N * 4B (per-node) -変数：(2 + N) numeric 値
crdt_pnsum -固定：20B (header) + N *4B(per-node)-変数：(4+2* N) numeric 値

注釈

値が複数のノードで更新されない場合、クラスター内にノードがいくつあっても構いません。また、更新が同時に行われたかどうか（競合が発生したかどうか）も関係ありません。

さらに、これらのノードのうちのいくつがクラスターから既に削除されていても構いません。状態をコンパクトにする方法はまだありません。

CRDTタイプと競合処理¶

テーブルにはCRDT列と非CRDT列の両方を含めることができるため（ほとんどの列は非CRDTであることが予想されます）、通常の競合解決とCRDTマージの両方を行う必要があります。

競合の解決が最初に行われ、保持するタプル（applytuple）と破棄するタプルを決定します。次にマージフェーズが発生し、破棄されたタプルのCRDT列のデータがapplytupleにマージされます。

注釈

この処理により、マージは毎回発生する必要があるため、CRDTタイプはプレーンな競合解決と比較してやや高価になります。これは、競合解決でいずれかの高速パス（現在のトランザクションで変更されたパスなど）を使用できる場合でも当てはまります。

CRDTタイプと競合レポート¶

デフォルトでは、検出された競合は個別に報告されます。 CRDTタイプがなければ、これは理にかなっています。競合解決は基本的に利用可能な情報の半分（構成に応じてローカルまたはリモートの行）を破棄するためです。これは、データの損失を示します。

CRDTタイプでは、何も捨てずに情報の両方の部分を結合できるため、データ損失の問題が解消されます。このアプローチにより、競合レポートが不要になります。

このため、CRDTマージで競合を完全に解決できる場合、競合レポートはスキップされます。各列は、次の2つの条件の少なくとも1つを満たす必要があります。

ローカルタプルとリモートタプルの値が同じ（NULLまたは等しい）。
CRDTデータ型を使用しているため、マージできます。

注釈

CRDT列がないが、ローカル/リモートのタプルのすべての値が等しい場合、競合レポートもスキップされます。

CRDT値のリセット¶

CRDT値をリセットすることは可能ですが、特別な処理が必要です。クラスターの非同期の性質は、実装方法に関係なく、さまざまなノードが変更ストリームのさまざまな場所でリセットオペレーションを見る可能性があることを意味します。異なるノードが同時に、つまり他のノードからのリセットを監視する前に、リセットを開始する場合もあります。

言い換えれば、リセット操作を正しく動作させるには、通常の操作に対して可換である必要があります。単一ノードでうまくいく可能性のある値をリセットする多くの素朴な方法は、この理由で失敗します。

たとえば、値をリセットする最も簡単なアプローチは次のとおりです。

UPDATE crdt_table SET cnt = 0 WHERE id = 1;

状態ベースのCRDTでは、これは機能しません。他のノードの状態を破棄しますが、ローカルのみです。リモートノードのマージ関数によって追加され、値が発散し、最終的に他のノードの変更により値が返されます。

操作ベースのCRDTでは、更新が-cnt の減算として解釈されるため、これは機能するように見える場合があります。ただし、同時リセットがない場合にのみ機能します。 2つのノードが同時にリセットを試行すると、デルタが2回適用され、負の値が取得されます（これはリセットでは予期されません）。

DELETE + INSERT をリセットとして使用できるように思われるかもしれませんが、このアプローチにはいくつかの弱点もあります。行が同じキーで再挿入された場合、すべてのノードが他のノードからの変更に関して、操作のストリーム内の同じ位置でそれを見ることは保証されません。 PGDは、同時発生のデータ異常につながる可能性があるため、同じ主キー値の再利用を特にお勧めしません。

状態ベースのCRDT型は、次のような特別な! 演算子を使用して、リセットを確実に処理できます。

UPDATE tab SET counter = !counter WHERE ...;

「信頼できる」とは、値に複数の同時リセットと発散の2つの問題がないことを意味します。

操作ベースのCRDTタイプは、一般的な積極的なEager Replicationの効果を使用してのみ確実にリセットできます。これにより、複数の同時リセットが回避されるためです。 Eager Replicationを使用して、いずれかの種類のCRDTを特定の値に設定することもできます。

実装されたCRDTデータ型¶

現在、6つのCRDTデータ型が実装されています。

成長専用のカウンターと合計
正負のカウンターと合計
デルタカウンターと合計

カウンターと合計は、カウンター型が整数ベース（bigint ）であり、合計タイプが10進ベース（numeric ）であることを除いて、ほとんど同じように動作します。

[1]で説明されている追加のCRDTタイプは、後で実装される可能性があります。

次のクエリを使用して、現在実装されているCRDTデータ型をリストできます。

SELECT n.nspname, t.typname
FROM bdr.crdt_handlers c
JOIN (pg_type t JOIN pg_namespace n ON t.typnamespace = n.oid)
  ON t.oid = c.crdt_type_id;

成長専用カウンター（crdt_gcounter）¶

非負の値を持つインクリメントのみをサポート（value + int およびcounter + bigint 演算子）。
# 演算子を使用するか、bigint にキャストすることにより、カウンターの現在の値を取得できます。
counter = value のような単純な割り当てと互換性がありません（これは、アプリケーションのどこかで新しい値が計算される場合の一般的なパターンです）。
! 演算子（ counter = !counter ）を使用して、カウンターの単純なリセットを許可します。
crdt_gcounter_to_text を使用して内部状態を検査できます。

CREATE TABLE crdt_test (
    id       INT PRIMARY KEY,
    cnt      bdr.crdt_gcounter NOT NULL DEFAULT 0
);

INSERT INTO crdt_test VALUES (1, 0);      -- initialized to 0
INSERT INTO crdt_test VALUES (2, 129824); -- initialized to 129824
INSERT INTO crdt_test VALUES (3, -4531);  -- error: negative value

- - enable CLCD on the table
ALTER TABLE crdt_test REPLICA IDENTITY FULL;
SELECT bdr.alter_table_conflict_detection(crdt_test, column_modify_timestamp, cts);

- - increment counters
UPDATE crdt_test SET cnt = cnt + 1 WHERE id = 1;
UPDATE crdt_test SET cnt = cnt + 120 WHERE id = 2;

- - error: minus operator not defined
UPDATE crdt_test SET cnt = cnt - 1 WHERE id = 1;

- - error: increment has to be non-negative
UPDATE crdt_test SET cnt = cnt + (-1) WHERE id = 1;

- - reset counter
UPDATE crdt_test SET cnt = !cnt WHERE id = 1;

- - get current counter value
SELECT id, cnt::bigint, cnt FROM crdt_test;

- - show internal structure of counters
SELECT id, bdr.crdt_gcounter_to_text(cnt) FROM crdt_test;

成長のみの合計（crdt_gsum）¶

非負の値を持つインクリメントのみをサポートします（sum + numeric ）。
# 演算子を使用するか、numeric にキャストして、合計の現在の値を取得できます。
新しい値がアプリケーションのどこかで計算されるときの一般的なパターンであるsum = value のような単純な割り当てと互換性がありません。
! 演算子（sum = !sum ）を使用して、合計の単純なリセットを許可します。
crdt_gsum_to_text を使用して内部状態を検査できます。

CREATE TABLE crdt_test (
    id       INT PRIMARY KEY,
    gsum     bdr.crdt_gsum NOT NULL DEFAULT 0.0
);

INSERT INTO crdt_test VALUES (1, 0.0);      -- initialized to 0
INSERT INTO crdt_test VALUES (2, 1298.24); -- initialized to 1298.24
INSERT INTO crdt_test VALUES (3, -45.31);  -- error: negative value

- - enable CLCD on the table
ALTER TABLE crdt_test REPLICA IDENTITY FULL;
SELECT bdr.alter_table_conflict_detection(crdt_test, column_modify_timestamp, cts);

- - increment sum
UPDATE crdt_test SET gsum = gsum + 11.5 WHERE id = 1;
UPDATE crdt_test SET gsum = gsum + 120.33 WHERE id = 2;

- - error: minus operator not defined
UPDATE crdt_test SET gsum = gsum - 15.2 WHERE id = 1;

- - error: increment has to be non-negative
UPDATE crdt_test SET gsum = gsum + (-1.56) WHERE id = 1;

- - reset sum
UPDATE crdt_test SET gsum = !gsum WHERE id = 1;

- - get current sum value
SELECT id, gsum::numeric, gsum FROM crdt_test;

- - show internal structure of sums
SELECT id, bdr.crdt_gsum_to_text(gsum) FROM crdt_test;

ポジティブネガティブカウンター（crdt_pncounter）¶

正と負の両方の値でインクリメントをサポート（counter + int およびcounter + bigint オペレーターを介して）。
# 演算子を使用するか、 bigint にキャストすることにより、カウンターの現在の値を取得できます。
新しい値がアプリケーションのどこかで計算されるときの一般的なパターンであるcounter = value のような単純な割り当てと互換性がありません。
! 演算子（counter = !counter ）を使用して、カウンターの単純なリセットを許可します。
crdt_pncounter_to_text を使用して内部状態を検査できます。

CREATE TABLE crdt_test (
    id       INT PRIMARY KEY,
    cnt      bdr.crdt_pncounter NOT NULL DEFAULT 0
);

INSERT INTO crdt_test VALUES (1, 0);      -- initialized to 0
INSERT INTO crdt_test VALUES (2, 129824); -- initialized to 129824
INSERT INTO crdt_test VALUES (3, -4531);  -- initialized to -4531

- - enable CLCD on the table
ALTER TABLE crdt_test REPLICA IDENTITY FULL;
SELECT bdr.alter_table_conflict_detection(crdt_test, column_modify_timestamp, cts);

- - increment counters
UPDATE crdt_test SET cnt = cnt + 1      WHERE id = 1;
UPDATE crdt_test SET cnt = cnt + 120    WHERE id = 2;
UPDATE crdt_test SET cnt = cnt + (-244) WHERE id = 3;

- - decrement counters
UPDATE crdt_test SET cnt = cnt - 73    WHERE id = 1;
UPDATE crdt_test SET cnt = cnt - 19283 WHERE id = 2;
UPDATE crdt_test SET cnt = cnt - (-12) WHERE id = 3;

- - get current counter value
SELECT id, cnt::bigint, cnt FROM crdt_test;

- - show internal structure of counters
SELECT id, bdr.crdt_pncounter_to_text(cnt) FROM crdt_test;

- - reset counter
UPDATE crdt_test SET cnt = !cnt WHERE id = 1;

- - get current counter value after the reset
SELECT id, cnt::bigint, cnt FROM crdt_test;

正負の合計（crdt_pnsum）¶

sum + numeric を介して正と負の両方の値を持つインクリメントをサポートします。
then # 演算子を使用するか、numeric にキャストすることにより、合計の現在の値を取得できます。
新しい値がアプリケーションのどこかで計算されるときの一般的なパターンであるsum = value のような単純な割り当てと互換性がありません。
! 演算子（sum = !sum ）を使用して、合計の単純なリセットを許可します。
crdt_pnsum_to_text を使用して内部状態を検査できます。

CREATE TABLE crdt_test (
    id       INT PRIMARY KEY,
    pnsum    bdr.crdt_pnsum NOT NULL DEFAULT 0
);

INSERT INTO crdt_test VALUES (1, 0);       -- initialized to 0
INSERT INTO crdt_test VALUES (2, 1298.24); -- initialized to 1298.24
INSERT INTO crdt_test VALUES (3, -45.31);  -- initialized to -45.31

- - enable CLCD on the table
ALTER TABLE crdt_test REPLICA IDENTITY FULL;
SELECT bdr.alter_table_conflict_detection(crdt_test, column_modify_timestamp, cts);

- - increment sums
UPDATE crdt_test SET pnsum = pnsum + 1.44     WHERE id = 1;
UPDATE crdt_test SET pnsum = pnsum + 12.20    WHERE id = 2;
UPDATE crdt_test SET pnsum = pnsum + (-24.34) WHERE id = 3;

- - decrement sums
UPDATE crdt_test SET pnsum = pnsum - 7.3      WHERE id = 1;
UPDATE crdt_test SET pnsum = pnsum - 192.83   WHERE id = 2;
UPDATE crdt_test SET pnsum = pnsum - (-12.22) WHERE id = 3;

- - get current sum value
SELECT id, pnsum::numeric, pnsum FROM crdt_test;

- - show internal structure of sum
SELECT id, bdr.crdt_pnsum_to_text(pnsum) FROM crdt_test;

- - reset sum
UPDATE crdt_test SET pnsum = !pnsum WHERE id = 1;

- - get current sum value after the reset
SELECT id, pnsum::numeric, pnsum FROM crdt_test;

デルタカウンター（crdt_delta_counter）¶

bigint ドメインとして定義されているため、bigint 列とまったく同じように機能します。
正負両方の値のインクリメントをサポートします。
新しい値がアプリケーションのどこかで計算されるときに一般的なcounter = value のような単純な割り当てと互換性があります。
値を確実にリセットする簡単な方法はありません。

CREATE TABLE crdt_test (
    id       INT PRIMARY KEY,
    cnt      bdr.crdt_delta_counter NOT NULL DEFAULT 0
);

INSERT INTO crdt_test VALUES (1, 0);      -- initialized to 0
INSERT INTO crdt_test VALUES (2, 129824); -- initialized to 129824
INSERT INTO crdt_test VALUES (3, -4531);  -- initialized to -4531

- - enable CLCD on the table
ALTER TABLE crdt_test REPLICA IDENTITY FULL;
SELECT bdr.alter_table_conflict_detection(crdt_test, column_modify_timestamp, cts);

- - increment counters
UPDATE crdt_test SET cnt = cnt + 1      WHERE id = 1;
UPDATE crdt_test SET cnt = cnt + 120    WHERE id = 2;
UPDATE crdt_test SET cnt = cnt + (-244) WHERE id = 3;

- - decrement counters
UPDATE crdt_test SET cnt = cnt - 73    WHERE id = 1;
UPDATE crdt_test SET cnt = cnt - 19283 WHERE id = 2;
UPDATE crdt_test SET cnt = cnt - (-12) WHERE id = 3;

- - get current counter value
SELECT id, cnt FROM crdt_test;

デルタサム（crdt_delta_sum）¶

numeric ドメインとして定義されるため、numeric 列とまったく同じように機能します。
正負両方の値のインクリメントをサポートします。
新しい値がアプリケーションのどこかで計算されるときに一般的なsum = value のような単純な割り当てと互換性があります。
値を確実にリセットする簡単な方法はありません。

CREATE TABLE crdt_test (
    id       INT PRIMARY KEY,
    dsum     bdr.crdt_delta_sum NOT NULL DEFAULT 0
);

INSERT INTO crdt_test VALUES (1, 0);       -- initialized to 0
INSERT INTO crdt_test VALUES (2, 129.824); -- initialized to 129824
INSERT INTO crdt_test VALUES (3, -4.531);  -- initialized to -4531

- - enable CLCD on the table
ALTER TABLE crdt_test REPLICA IDENTITY FULL;
SELECT bdr.alter_table_conflict_detection(crdt_test, column_modify_timestamp, cts);

- - increment counters
UPDATE crdt_test SET dsum = dsum + 1.32   WHERE id = 1;
UPDATE crdt_test SET dsum = dsum + 12.01  WHERE id = 2;
UPDATE crdt_test SET dsum = dsum + (-2.4) WHERE id = 3;

- - decrement counters
UPDATE crdt_test SET dsum = dsum - 7.33   WHERE id = 1;
UPDATE crdt_test SET dsum = dsum - 19.83  WHERE id = 2;
UPDATE crdt_test SET dsum = dsum - (-1.2) WHERE id = 3;

- - get current counter value
SELECT id, cnt FROM crdt_test;

[1] https://en.wikipedia.org/wiki/Conflict-free_replicated_data_type