From 741fdf666ddd1d3221562a06ed18fb562b45749b Mon Sep 17 00:00:00 2001
From: esmailian <esmailian.w@gmail.com>
Date: Tue, 29 Apr 2025 12:26:23 +0330
Subject: [PATCH] add oracle datasource and tables for test cqrs and event
 driven read model now call rest from gateway and save in command db in srivce
 a and save on query db serivce a then send to kafka message queue and save on
 snapshot tabel on service b

---
 pom.xml                                       |  5 ++++
 .../testapp/Listner/UserEventListener.java    |  1 +
 .../mmad/testapp/entity/UserEntity.java       |  6 ++--
 .../oracleLiquibases/liquibase-1.1.xml        | 19 ++++++++++++
 .../oracleLiquibases/liquibase-1.2.xml        | 30 +++++++++++++++++++
 .../liquibase-1.1.xml                         |  0
 .../liquibase-1.2.xml                         |  0
 .../db/changelog/liquibase-master.xml         |  4 +--
 8 files changed, 60 insertions(+), 5 deletions(-)
 create mode 100755 src/main/resources/db/changelog/changes/oracleLiquibases/liquibase-1.1.xml
 create mode 100755 src/main/resources/db/changelog/changes/oracleLiquibases/liquibase-1.2.xml
 rename src/main/resources/db/changelog/changes/{ => postgresLiquibases}/liquibase-1.1.xml (100%)
 rename src/main/resources/db/changelog/changes/{ => postgresLiquibases}/liquibase-1.2.xml (100%)

diff --git a/pom.xml b/pom.xml
index b5896b9..2132004 100755
--- a/pom.xml
+++ b/pom.xml
@@ -96,6 +96,11 @@
             <groupId>org.springframework.kafka</groupId>
             <artifactId>spring-kafka</artifactId>
         </dependency>
+        <dependency>
+            <groupId>com.oracle.database.jdbc</groupId>
+            <artifactId>ojdbc8</artifactId>
+            <version>19.8.0.0</version>
+        </dependency>
     </dependencies>
 
     <dependencyManagement>
diff --git a/src/main/java/com/example/mmad/testapp/Listner/UserEventListener.java b/src/main/java/com/example/mmad/testapp/Listner/UserEventListener.java
index edf6136..535e79e 100644
--- a/src/main/java/com/example/mmad/testapp/Listner/UserEventListener.java
+++ b/src/main/java/com/example/mmad/testapp/Listner/UserEventListener.java
@@ -21,6 +21,7 @@ public class UserEventListener {
         userSnapshot.setId(user.getUserId());
         userSnapshot.setUserName(user.getUsername());
         userSnapshot.setEmail(user.getEmail());
+        userSnapshotRepository.save(userSnapshot);
         System.out.println("snapshot is updated" + user.getUserId());
 //        userSnapshotRepository.save(userSnapshot);
     }
diff --git a/src/main/java/com/example/mmad/testapp/entity/UserEntity.java b/src/main/java/com/example/mmad/testapp/entity/UserEntity.java
index d8fc944..002bb00 100755
--- a/src/main/java/com/example/mmad/testapp/entity/UserEntity.java
+++ b/src/main/java/com/example/mmad/testapp/entity/UserEntity.java
@@ -8,15 +8,15 @@ import static jakarta.persistence.GenerationType.SEQUENCE;
 @Entity
 @Getter
 @Setter
-@Table(schema = "testapp", name = "user")
+@Table(schema = "TEST2", name = "USER_SNAPSHOT")
 @Builder
 @AllArgsConstructor
 @NoArgsConstructor
 public class UserEntity {
 
     @Id
-    @SequenceGenerator(name = "seqTest", sequenceName = "testapp.person_seq", allocationSize = 1)
-    @GeneratedValue(strategy = SEQUENCE, generator = "seqTest")
+//    @SequenceGenerator(name = "seqTest", sequenceName = "testapp.person_seq", allocationSize = 1)
+//    @GeneratedValue(strategy = SEQUENCE, generator = "seqTest")
     private Long id;
     @Column(name = "user_name")
     private String userName;
diff --git a/src/main/resources/db/changelog/changes/oracleLiquibases/liquibase-1.1.xml b/src/main/resources/db/changelog/changes/oracleLiquibases/liquibase-1.1.xml
new file mode 100755
index 0000000..22a769c
--- /dev/null
+++ b/src/main/resources/db/changelog/changes/oracleLiquibases/liquibase-1.1.xml
@@ -0,0 +1,19 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<databaseChangeLog
+        xmlns="http://www.liquibase.org/xml/ns/dbchangelog"
+        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+        xsi:schemaLocation="http://www.liquibase.org/xml/ns/dbchangelog http://www.liquibase.org/xml/ns/dbchangelog/dbchangelog-3.8.xsd">
+
+    <property name="now" value="UNIX_TIMESTAMP()" dbms="mysql"/>
+    <property name="now" value="sysdate" dbms="oracle"/>
+    <property name="now" value="now()" dbms="postgresql"/>
+
+    <changeSet id="1.1-1-mmad" author="mmad">
+        <insert schemaName="test2" tableName="person">
+            <column name="id" value="1"/>
+            <column name="first_name" value="mohammad"/>
+            <column name="last_name" value="Reza"/>
+        </insert>
+    </changeSet>
+
+</databaseChangeLog>
diff --git a/src/main/resources/db/changelog/changes/oracleLiquibases/liquibase-1.2.xml b/src/main/resources/db/changelog/changes/oracleLiquibases/liquibase-1.2.xml
new file mode 100755
index 0000000..0dde05b
--- /dev/null
+++ b/src/main/resources/db/changelog/changes/oracleLiquibases/liquibase-1.2.xml
@@ -0,0 +1,30 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<databaseChangeLog
+        xmlns="http://www.liquibase.org/xml/ns/dbchangelog"
+        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+        xsi:schemaLocation="http://www.liquibase.org/xml/ns/dbchangelog http://www.liquibase.org/xml/ns/dbchangelog/dbchangelog-3.8.xsd">
+
+    <property name="now" value="UNIX_TIMESTAMP()" dbms="mysql"/>
+    <property name="now" value="sysdate" dbms="oracle"/>
+    <property name="now" value="now()" dbms="postgresql"/>
+
+    <changeSet id="1.2-1-mmad" author="mmad">
+        <createTable schemaName="test2" tableName="PERSON" remarks="اشخاص">
+            <column name="ID" type="NUMBER(19)" remarks="شناسه اشخاص">
+                <constraints nullable="false" primaryKey="true" primaryKeyName="PK_PERSON_ID"/>
+            </column>
+            <column name="FIRST_NAME" type="VARCHAR2(255)" remarks="نام"/>
+            <column name="LAST_NAME" type="VARCHAR2(255)" remarks="نام خانوادگی"/>
+        </createTable>
+    </changeSet>
+    <changeSet id="1.2-2-mmad" author="mmad">
+        <createTable schemaName="test2" tableName="USER_SNAPSHOT" remarks="کاربر">
+            <column name="ID" type="NUMBER(19)" remarks="شناسه کاربر">
+                <constraints nullable="false" primaryKey="true" primaryKeyName="PK_USER_ID"/>
+            </column>
+            <column name="user_name" type="VARCHAR2(255)" remarks="نام کاربری"/>
+            <column name="email" type="VARCHAR2(255)" remarks="ایمیل"/>
+        </createTable>
+    </changeSet>
+
+</databaseChangeLog>
\ No newline at end of file
diff --git a/src/main/resources/db/changelog/changes/liquibase-1.1.xml b/src/main/resources/db/changelog/changes/postgresLiquibases/liquibase-1.1.xml
similarity index 100%
rename from src/main/resources/db/changelog/changes/liquibase-1.1.xml
rename to src/main/resources/db/changelog/changes/postgresLiquibases/liquibase-1.1.xml
diff --git a/src/main/resources/db/changelog/changes/liquibase-1.2.xml b/src/main/resources/db/changelog/changes/postgresLiquibases/liquibase-1.2.xml
similarity index 100%
rename from src/main/resources/db/changelog/changes/liquibase-1.2.xml
rename to src/main/resources/db/changelog/changes/postgresLiquibases/liquibase-1.2.xml
diff --git a/src/main/resources/db/changelog/liquibase-master.xml b/src/main/resources/db/changelog/liquibase-master.xml
index 8934557..41ab05c 100755
--- a/src/main/resources/db/changelog/liquibase-master.xml
+++ b/src/main/resources/db/changelog/liquibase-master.xml
@@ -4,7 +4,7 @@
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://www.liquibase.org/xml/ns/dbchangelog http://www.liquibase.org/xml/ns/dbchangelog/dbchangelog-3.8.xsd">
 
-    <include file="changes/liquibase-1.2.xml" relativeToChangelogFile="true"/>
-    <include file="changes/liquibase-1.1.xml" relativeToChangelogFile="true"/>
+    <include file="changes/oracleLiquibases/liquibase-1.2.xml" relativeToChangelogFile="true"/>
+    <include file="changes/oracleLiquibases/liquibase-1.1.xml" relativeToChangelogFile="true"/>
 
 </databaseChangeLog>