add test

Author: KTC-YoheiMiyashita

dbAndCsvBatch/build.gradle

@@ -117,6 +117,10 @@ compileJava {
     sourceSets.main.java.srcDirs("build/generated-src/jooq/main")
 }
 
+tasks.named('compileTestJava') {
+    dependsOn generateJooq
+}
+
 tasks.named('build') {
     dependsOn 'generateJooq'
 }

dbAndCsvBatch/src/test/java/com/example/batch/repository/MemberRepositoryTest.java

@@ -0,0 +1,100 @@
+package com.example.batch.repository;
+
+import static org.junit.jupiter.api.Assertions.*;
+
+import com.example.batch.jooq.tables.records.MemberRecord;
+import java.util.List;
+import org.jooq.DSLContext;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.test.context.TestPropertySource;
+
+@TestPropertySource(
+    properties = {
+      "spring.batch.job.enabled=false",
+      "spring.datasource.mysqlmain.url=jdbc:mysql://localhost:3306/sampledb",
+      "spring.datasource.mysqlmain.username=sampleuser",
+      "spring.datasource.mysqlmain.password=samplepassword"
+    })
+@SpringBootTest
+class MemberRepositoryTest {
+
+  @Autowired private DSLContext dslContext;
+
+  private MemberRepository repository;
+
+  @BeforeEach
+  void setup() {
+    repository = new MemberRepository(dslContext);
+    cleanupRecordsByType((byte) 100);
+  }
+
+  @Test
+  void testInsertAndSelect() {
+    // Insert
+    MemberRecord member =
+        createMemberRecord("Test1", "[email protected]", "1234567890", "Address 1", (byte) 100);
+    repository.insert(member);
+
+    // Select & Verify
+    List<MemberRecord> selected =
+        repository.selectByTypeAndDeleteFlag(List.of((byte) 100), (byte) 0);
+    assertFalse(selected.isEmpty(), "Expected to find at least one record.");
+    assertEquals("Test1", selected.get(0).getName(), "Member name mismatch.");
+  }
+
+  @Test
+  void testUpdate() {
+    // Insert
+    MemberRecord member =
+        createMemberRecord("Test1", "[email protected]", "1234567890", "Address 1", (byte) 100);
+    repository.insert(member);
+
+    // Update
+    List<MemberRecord> selected =
+        repository.selectByTypeAndDeleteFlag(List.of((byte) 100), (byte) 0);
+    member.setId(selected.get(0).getId());
+    member.setName("Updated");
+    repository.update(member);
+
+    // Verify
+    selected = repository.selectByTypeAndDeleteFlag(List.of((byte) 100), (byte) 0);
+    assertEquals("Updated", selected.get(0).getName(), "Updated member name mismatch.");
+  }
+
+  @Test
+  void testDelete() {
+    // Insert
+    MemberRecord member =
+        createMemberRecord("Test1", "[email protected]", "1234567890", "Address 1", (byte) 100);
+    repository.insert(member);
+
+    // Delete
+    List<MemberRecord> selected =
+        repository.selectByTypeAndDeleteFlag(List.of((byte) 100), (byte) 0);
+    repository.delete(selected.get(0).getId());
+
+    // Verify
+    selected = repository.selectByTypeAndDeleteFlag(List.of((byte) 100), (byte) 0);
+    assertTrue(selected.isEmpty(), "Expected no records after deletion.");
+  }
+
+  private void cleanupRecordsByType(byte type) {
+    List<MemberRecord> existingRecords =
+        repository.selectByTypeAndDeleteFlag(List.of(type), (byte) 0);
+    existingRecords.forEach(record -> repository.delete(record.getId()));
+  }
+
+  private MemberRecord createMemberRecord(
+      String name, String email, String phone, String address, byte type) {
+    MemberRecord record = new MemberRecord();
+    record.setName(name);
+    record.setEmail(email);
+    record.setPhone(phone);
+    record.setAddress(address);
+    record.setType(type);
+    return record;
+  }
+}