Initial checkin

src/test/java/com/kingsrook/qqq/backend/module/rdbms/actions/RDBMSInsertActionTest.java

@@ -0,0 +1,122 @@
+package com.kingsrook.qqq.backend.module.rdbms.actions;
+
+
+import java.util.List;
+import com.kingsrook.qqq.backend.core.model.actions.InsertRequest;
+import com.kingsrook.qqq.backend.core.model.actions.InsertResult;
+import com.kingsrook.qqq.backend.core.model.data.QRecord;
+import com.kingsrook.qqq.backend.core.utils.CollectionUtils;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
+import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.junit.jupiter.api.Assertions.assertNotNull;
+import static org.junit.jupiter.api.Assertions.assertTrue;
+
+
+/*******************************************************************************
+ **
+ *******************************************************************************/
+public class RDBMSInsertActionTest extends RDBMSActionTest
+{
+
+   /*******************************************************************************
+    **
+    *******************************************************************************/
+   @BeforeEach
+   public void beforeEach() throws Exception
+   {
+      super.primeTestDatabase();
+   }
+
+
+
+   /*******************************************************************************
+    **
+    *******************************************************************************/
+   @Test
+   public void testInsertOne() throws Exception
+   {
+      InsertRequest insertRequest = initInsertRequest();
+      QRecord record = new QRecord().withTableName("person")
+         .withValue("firstName", "James")
+         .withValue("lastName", "Kirk")
+         .withValue("email", "jamestk@starfleet.net")
+         .withValue("birthDate", "2210-05-20");
+      insertRequest.setRecords(List.of(record));
+      InsertResult insertResult = new RDBMSInsertAction().execute(insertRequest);
+      assertEquals(1, insertResult.getRecords().size(), "Should return 1 row");
+      assertNotNull(insertResult.getRecords().get(0).getValue("id"), "Should have an id in the row");
+      assertTrue(insertResult.getRecords().stream().noneMatch(qrs -> CollectionUtils.nullSafeHasContents(qrs.getErrors())), "There should be no errors");
+      runTestSql("SELECT * FROM person WHERE last_name = 'Kirk'", (rs -> {
+         int rowsFound = 0;
+         while(rs.next())
+         {
+            rowsFound++;
+            assertEquals(6, rs.getInt("id"));
+            assertEquals("James", rs.getString("first_name"));
+         }
+         assertEquals(1, rowsFound);
+      }));
+   }
+
+
+
+   /*******************************************************************************
+    **
+    *******************************************************************************/
+   @Test
+   public void testInsertMany() throws Exception
+   {
+      InsertRequest insertRequest = initInsertRequest();
+      QRecord record1 = new QRecord().withTableName("person")
+         .withValue("firstName", "Jean-Luc")
+         .withValue("lastName", "Picard")
+         .withValue("email", "jl@starfleet.net")
+         .withValue("birthDate", "2310-05-20");
+      QRecord record2 = new QRecord().withTableName("person")
+         .withValue("firstName", "William")
+         .withValue("lastName", "Riker")
+         .withValue("email", "notthomas@starfleet.net")
+         .withValue("birthDate", "2320-05-20");
+      insertRequest.setRecords(List.of(record1, record2));
+      InsertResult insertResult = new RDBMSInsertAction().execute(insertRequest);
+      assertEquals(2, insertResult.getRecords().size(), "Should return 1 row");
+      assertNotNull(insertResult.getRecords().get(0).getValue("id"), "Should have an id in the row");
+      assertNotNull(insertResult.getRecords().get(1).getValue("id"), "Should have an id in the row");
+      assertTrue(insertResult.getRecords().stream().noneMatch(qrs -> CollectionUtils.nullSafeHasContents(qrs.getErrors())), "There should be no errors");
+      runTestSql("SELECT * FROM person WHERE last_name = 'Picard'", (rs -> {
+         int rowsFound = 0;
+         while(rs.next())
+         {
+            rowsFound++;
+            assertEquals(6, rs.getInt("id"));
+            assertEquals("Jean-Luc", rs.getString("first_name"));
+         }
+         assertEquals(1, rowsFound);
+      }));
+      runTestSql("SELECT * FROM person WHERE last_name = 'Riker'", (rs -> {
+         int rowsFound = 0;
+         while(rs.next())
+         {
+            rowsFound++;
+            assertEquals(7, rs.getInt("id"));
+            assertEquals("William", rs.getString("first_name"));
+         }
+         assertEquals(1, rowsFound);
+      }));
+   }
+
+
+
+   /*******************************************************************************
+    **
+    *******************************************************************************/
+   private InsertRequest initInsertRequest()
+   {
+      InsertRequest insertRequest = new InsertRequest();
+      insertRequest.setInstance(defineInstance());
+      insertRequest.setTableName(defineTablePerson().getName());
+      return insertRequest;
+   }
+
+}