Added integration tests

Author: sanketsarang

src/test/java/com/blobcity/db/test/integration/data/EntityDataInsertIT.java

@@ -4,10 +4,13 @@
 import com.blobcity.db.annotations.Entity;
 import com.blobcity.db.config.Credentials;
 import com.blobcity.db.enums.CollectionType;
+import com.blobcity.db.search.Query;
+import com.blobcity.db.search.SearchParam;
 import com.google.gson.JsonObject;
 import org.junit.*;
 
 import java.util.Arrays;
+import java.util.List;
 
 /**
  * Created by sanketsarang on 18/11/16.
@@ -43,6 +46,12 @@ public void insertEntityOnDisk() {
 
         Assert.assertTrue("Cannot perform data insert tests as on-disk collection creation failed", Db.createCollection("User", CollectionType.ON_DISK));
         new User("name1","address1").insert();
+
+        List<User> userList = Db.search(Query.select().from(User.class).where(SearchParam.create("name").eq("name1")));
+
+        for(User user : userList) {
+            System.out.println(user.get_id());
+        }
     }
 
     @Test
@@ -56,29 +65,3 @@ public void insertJsonInMemoryND() {
     }
 }
 
-@Entity(ds = "test", collection = "User")
-class User extends Db {
-    private String name;
-    private String address;
-
-    public User(final String name, final String address) {
-        this.name = name;
-        this.address = address;
-    }
-
-    public String getName() {
-        return name;
-    }
-
-    public void setName(String name) {
-        this.name = name;
-    }
-
-    public String getAddress() {
-        return address;
-    }
-
-    public void setAddress(String address) {
-        this.address = address;
-    }
-}

src/test/java/com/blobcity/db/test/integration/data/EntityDataSaveIT.java

@@ -1,7 +1,69 @@
 package com.blobcity.db.test.integration.data;
 
+import com.blobcity.db.Db;
+import com.blobcity.db.search.Query;
+import com.blobcity.db.config.Credentials;
+import com.blobcity.db.enums.CollectionType;
+import com.blobcity.db.search.SearchParam;
+import org.junit.*;
+import java.util.List;
+
 /**
- * Created by sanketsarang on 27/02/17.
+ * @author Sanket Sarang
  */
 public class EntityDataSaveIT {
+
+    @BeforeClass
+    public static void setUpClass() {
+        Credentials.init("localhost:10111","root","root","test");
+        Assert.assertTrue("Cannot perform data insert tests as datastore creation failed", Db.createDs("test"));
+        Assert.assertTrue("Cannot perform data insert tests as on-disk collection creation failed", Db.createCollection("disk", CollectionType.ON_DISK));
+        Assert.assertTrue("Cannot perform data insert tests as in-memory collection creation failed", Db.createCollection("mem", CollectionType.IN_MEMORY));
+        Assert.assertTrue("Cannot perform data insert tests as in-memory-non-durable collection creation failed", Db.createCollection("memnd", CollectionType.IN_MEMORY_NON_DURABLE));
+    }
+
+    @AfterClass
+    public static void tearDownClass() {
+        Assert.assertTrue("Failed to drop datastore after test completion. Other tests may fail.", Db.dropDs("test"));
+        Credentials.unInit();
+    }
+
+    @Before
+    public void setUp() {
+    }
+
+    @After
+    public void tearDown() {
+    }
+
+    @Test
+    public void saveEntityOnDisk() {
+        System.out.println("IT: saveEntityOnDisk");
+
+        Assert.assertTrue("Cannot perform data insert tests as on-disk collection creation failed", Db.createCollection("User", CollectionType.ON_DISK));
+        new User("name1","address1").insert();
+
+
+        List<User> userList = Db.search(Query.select().from(User.class).where(SearchParam.create("name").eq("name1")));
+        userList.get(0).setName("name2");
+
+        userList.get(0).save();
+
+        userList = Db.search(Query.select().from(User.class).where(SearchParam.create("name").eq("name2")));
+
+        Assert.assertTrue("Failed to get updated record after save operation", !userList.isEmpty());
+        Assert.assertEquals("Updated record has incorrect value", userList.get(0).getName(), "name2");
+    }
+
+    @Test
+    public void saveJsonInMemory() {
+        System.out.println("IT: saveJsonInMemory - yet to be implemented");
+    }
+
+    @Test
+    public void saveJsonInMemoryND() {
+        System.out.println("IT: saveJsonInMemoryND - yet to be implemented");
+    }
 }
+
+

src/test/java/com/blobcity/db/test/integration/data/User.java

@@ -1,7 +1,38 @@
 package com.blobcity.db.test.integration.data;
 
+import com.blobcity.db.Db;
+import com.blobcity.db.annotations.Entity;
+
 /**
- * Created by sanketsarang on 27/02/17.
+ * @author Sanket Sarang
  */
-public class User {
+@Entity(ds = "test", collection = "User")
+public class User extends Db {
+    private String name;
+    private String address;
+
+    public User() {
+        //do nothing
+    }
+
+    public User(final String name, final String address) {
+        this.name = name;
+        this.address = address;
+    }
+
+    public String getName() {
+        return name;
+    }
+
+    public void setName(String name) {
+        this.name = name;
+    }
+
+    public String getAddress() {
+        return address;
+    }
+
+    public void setAddress(String address) {
+        this.address = address;
+    }
 }