Create a postgres DB instance with 'the_simpsons' schema.

Author: emeraldjava

debezium/docker-compose.yml

@@ -0,0 +1,21 @@
+version: '3.8'
+services:
+  # https://hub.docker.com/_/postgres
+  db:
+    container_name: db
+    image: postgres
+    restart: always
+    environment:
+      - POSTGRES_USER=postgres
+      - POSTGRES_PASSWORD=postgres
+    ports:
+      - '5432:5432'
+    volumes:
+      - ./postgres_data:/var/lib/postgresql/data
+      - ./src/main/resources/dml/schema.sql:/docker-entrypoint-initdb.d/schema.sql
+    command: [ "postgres", "-c", "wal_level=logical" ]
+  adminer:
+    image: adminer
+    restart: always
+    ports:
+      - 8081:8081

debezium/pom.xml

@@ -18,6 +18,8 @@
         <maven.compiler.target>21</maven.compiler.target>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
         <spring-boot.version>2.7.18</spring-boot.version>
+        <postgresql.version>42.2.5</postgresql.version>
+        <debezium.version>2.7.2.Final</debezium.version>
     </properties>
 
     <dependencies>
@@ -50,6 +52,24 @@
             <version>1.18.30</version>
             <scope>provided</scope>
         </dependency>
+
+        <dependency>
+            <groupId>org.postgresql</groupId>
+            <artifactId>postgresql</artifactId>
+            <version>${postgresql.version}</version>
+        </dependency>
+
+        <!-- Debezium -->
+        <dependency>
+            <groupId>io.debezium</groupId>
+            <artifactId>debezium-embedded</artifactId>
+            <version>${debezium.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>io.debezium</groupId>
+            <artifactId>debezium-connector-postgres</artifactId>
+            <version>${debezium.version}</version>
+        </dependency>
     </dependencies>
 
     <dependencyManagement>
@@ -86,6 +106,39 @@
                     </execution>
                 </executions>
             </plugin>
+
+            <plugin>
+                <groupId>io.fabric8</groupId>
+                <artifactId>docker-maven-plugin</artifactId>
+                <version>0.45.0</version>
+                <configuration></configuration>
+                <executions>
+                    <execution>
+                        <id>start</id>
+                        <!--<phase>pre-integration-test</phase>-->
+                        <phase>generate-test-resources</phase>
+                        <goals>
+                            <goal>build</goal>
+                            <goal>start</goal>
+                        </goals>
+                    </execution>
+                    <execution>
+                        <id>stop</id>
+                        <phase>post-integration-test</phase>
+                        <goals>
+                            <goal>stop</goal>
+                        </goals>
+                    </execution>
+                    <execution>
+                        <id>stop-pre</id>
+                        <phase>clean</phase>
+                        <goals>
+                            <goal>stop</goal>
+                        </goals>
+                    </execution>
+                </executions>
+            </plugin>
+
         </plugins>
     </build>
 

debezium/readme.md

@@ -5,6 +5,7 @@
 https://www.baeldung.com/debezium-intro
 https://ishansoninitj.medium.com/change-data-capture-cdc-using-debezium-in-a-springboot-application-97ddde8b991a
 https://gist.github.com/tzolov/c3bfa56237f0d4ceb53a93b6c80436e3
+https://github.com/tzolov/cdc-debezium/tree/master
 
 ### Avro
 

debezium/src/main/resources/dml/schema.sql

@@ -0,0 +1,29 @@
+------/* schema.*/
+--- https://github.com/hackmods/The-the_simpsons-SQL
+CREATE SCHEMA the_simpsons;
+------/* character.*/
+CREATE TABLE IF NOT EXISTS the_simpsons.character (
+    id SERIAL NOT NULL PRIMARY KEY,
+    name VARCHAR NOT NULL,
+    surname VARCHAR NOT NULL,
+    update_ts TIMESTAMP DEFAULT current_timestamp NOT NULL
+);
+------/*Insertion des données dans la table character.*/
+INSERT INTO the_simpsons.character  (nom, pays) VALUES
+    ('Homer','Simpson'),
+    ('Bart','Simpson'),
+    ('Lisa','Simpson');
+------/*Trigger pour maj de la date "update_ts"*/
+CREATE OR REPLACE FUNCTION maj_date()
+RETURNS TRIGGER AS $$
+BEGIN
+    NEW.update_ts := NOW();
+RETURN NEW;
+END;
+$$ LANGUAGE plpgsql;
+CREATE TRIGGER maj_date_trigger
+    BEFORE INSERT OR UPDATE ON the_simpsons.character
+                         FOR EACH ROW
+                         EXECUTE FUNCTION maj_date();
+------/*Tres utile pour obtenir des details dans la section before de la donnée*/
+ALTER TABLE the_simpsons.character REPLICA IDENTITY FULL;