feat: enable PostgreSQL engine for sql sink (#745)

Cargo.toml

@@ -75,7 +75,7 @@ tonic = { version = "0.9.2", features = ["tls", "tls-roots"], optional = true }
 futures = { version = "0.3.28", optional = true }
 
 # sql
-sqlx = { version = "0.7", features = ["runtime-tokio", "tls-native-tls", "any", "sqlite"], optional = true }
+sqlx = { version = "0.7", features = ["runtime-tokio", "tls-native-tls", "any", "sqlite", "postgres"], optional = true }
 
 # aws
 aws-config = { version = "^1.1", optional = true }

examples/postgresql/README.md

@@ -0,0 +1,15 @@
+# PostgreSQL Sink Example
+
+## Steps
+
+1. initialize docker compose
+
+```
+docker-compose up
+```
+
+2. create required tables
+
+```
+psql -h localhost -p 5432 -U postgres -f init.sql
+```

examples/postgresql/daemon.toml

@@ -0,0 +1,17 @@
+[source]
+type = "N2N"
+peers = ["relays-new.cardano-mainnet.iohk.io:3001"]
+
+[intersect]
+type = "Point"
+value = [114220807, "01822b10afde3d09bd5e72758857b669ddadcdaad6776a3dc8ee902c3ace1d7e"]
+
+[[filters]]
+type = "SplitBlock"
+
+[sink]
+type = "SqlDb"
+connection = "postgres://postgres:example@localhost:5432/postgres"
+apply_template = "INSERT INTO txs (slot, cbor) VALUES ('{{point.slot}}', decode('{{record.hex}}', 'hex'));"
+undo_template = "DELETE FROM txs WHERE slot = {{point.slot}}"
+reset_template = "DELETE FROM txs WHERE slot > {{point.slot}}"

examples/postgresql/docker-compose.yml

@@ -0,0 +1,16 @@
+version: "3.1"
+
+services:
+  db:
+    image: postgres
+    # image: mumak
+    restart: always
+    environment:
+      POSTGRES_PASSWORD: example
+    volumes:
+      - postgres_db:/var/lib/postgresql/data
+    ports:
+      - 5432:5432
+
+volumes:
+  postgres_db:

examples/postgresql/init.sql

@@ -0,0 +1,6 @@
+CREATE TABLE txs (
+    slot INTEGER NOT NULL,
+    cbor BYTEA
+);
+
+CREATE INDEX idx_txs_slot ON txs(slot);