gora-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From djkevi...@apache.org
Subject [11/32] gora git commit: Add initial test base for aerorospike module
Date Thu, 27 Jul 2017 18:45:37 GMT
Add initial test base for aerorospike module


Project: http://git-wip-us.apache.org/repos/asf/gora/repo
Commit: http://git-wip-us.apache.org/repos/asf/gora/commit/7c3390d0
Tree: http://git-wip-us.apache.org/repos/asf/gora/tree/7c3390d0
Diff: http://git-wip-us.apache.org/repos/asf/gora/diff/7c3390d0

Branch: refs/heads/master
Commit: 7c3390d0a7cf72afe3ffb3e3748f993e85cce48b
Parents: d68be8d
Author: nishadi <ndimeshi@gmail.com>
Authored: Fri Jun 23 19:37:05 2017 +0530
Committer: nishadi <ndimeshi@gmail.com>
Committed: Fri Jun 23 19:37:05 2017 +0530

----------------------------------------------------------------------
 gora-aerospike/pom.xml                          |   9 +-
 .../src/test/conf/gora-aerospike-mapping.xml    |  49 +++
 gora-aerospike/src/test/conf/gora.properties    |  17 +
 .../gora/aerospike/GoraAerospikeTestDriver.java |  74 +++++
 .../org/apache/gora/aerospike/package-info.java |  17 +
 .../aerospike/store/TestAerospikeStore.java     | 330 +++++++++++++++++++
 .../gora/aerospike/store/package-info.java      |  21 ++
 pom.xml                                         |   6 +
 8 files changed, 522 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/gora/blob/7c3390d0/gora-aerospike/pom.xml
----------------------------------------------------------------------
diff --git a/gora-aerospike/pom.xml b/gora-aerospike/pom.xml
index b15693e..828f45d 100644
--- a/gora-aerospike/pom.xml
+++ b/gora-aerospike/pom.xml
@@ -63,7 +63,7 @@
     <sourceDirectory>src/main/java</sourceDirectory>
     <testResources>
       <testResource>
-        <directory>${project.basedir}/src/test/resources</directory>
+        <directory>${project.basedir}/src/test/conf</directory>
         <includes>
           <include>**/*</include>
         </includes>
@@ -141,6 +141,13 @@
       <artifactId>junit</artifactId>
     </dependency>
 
+    <dependency>
+      <groupId>org.testcontainers</groupId>
+      <artifactId>testcontainers</artifactId>
+      <version>1.1.0</version>
+      <scope>test</scope>
+    </dependency>
+
   </dependencies>
 
 </project>

http://git-wip-us.apache.org/repos/asf/gora/blob/7c3390d0/gora-aerospike/src/test/conf/gora-aerospike-mapping.xml
----------------------------------------------------------------------
diff --git a/gora-aerospike/src/test/conf/gora-aerospike-mapping.xml b/gora-aerospike/src/test/conf/gora-aerospike-mapping.xml
new file mode 100644
index 0000000..f3f6eee
--- /dev/null
+++ b/gora-aerospike/src/test/conf/gora-aerospike-mapping.xml
@@ -0,0 +1,49 @@
+<?xml version="1.0" encoding="UTF-8"?>
+
+<!--
+   Licensed to the Apache Software Foundation (ASF) under one or more
+   contributor license agreements.  See the NOTICE file distributed with
+   this work for additional information regarding copyright ownership.
+   The ASF licenses this file to You under the Apache License, Version 2.0
+   (the "License"); you may not use this file except in compliance with
+   the License.  You may obtain a copy of the License at
+
+       http://www.apache.org/licenses/LICENSE-2.0
+
+   Unless required by applicable law or agreed to in writing, software
+   distributed under the License is distributed on an "AS IS" BASIS,
+   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+   See the License for the specific language governing permissions and
+   limitations under the License.
+-->
+
+<gora-otd>
+
+  <class name="org.apache.gora.examples.generated.Employee" keyClass="java.lang.String"
+         set="Employee" namespace = "test">
+    <field name="name" bin="name"/>
+    <field name="dateOfBirth" bin="dateOfBirth"/>
+    <field name="ssn" bin="ssn"/>
+    <field name="salary" bin="salary"/>
+    <field name="boss" bin="boss"/>
+    <field name="webpage" bin="webpage"/>
+  </class>
+
+  <class name="org.apache.gora.examples.generated.WebPage" keyClass="java.lang.String"
+         table="WebPage" namespace = "test">
+    <field name="url" bin="url"/>
+    <field name="content" bin="content"/>
+    <field name="parsedContent" bin="parsedContent"/>
+    <field name="outlinks" bin="outlinks"/>
+    <field name="headers" bin="headers"/>
+    <field name="metadata" bin="metadata"/>
+    <field name="byteData" bin="byteData"/>
+    <field name="stringData" bin="stringData"/>
+  </class>
+
+
+  <class name="org.apache.gora.examples.generated.TokenDatum" keyClass="java.lang.String"
namespace = "test">
+    <field name="count" bin="count"/>
+  </class>
+
+</gora-otd>

http://git-wip-us.apache.org/repos/asf/gora/blob/7c3390d0/gora-aerospike/src/test/conf/gora.properties
----------------------------------------------------------------------
diff --git a/gora-aerospike/src/test/conf/gora.properties b/gora-aerospike/src/test/conf/gora.properties
new file mode 100644
index 0000000..c0230ec
--- /dev/null
+++ b/gora-aerospike/src/test/conf/gora.properties
@@ -0,0 +1,17 @@
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements.  See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License.  You may obtain a copy of the License at
+#
+#     http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
+gora.datastore.default=org.apache.gora.aerospike.store.AerospikeStore
+gora.datastore.mapping.file=gora-aerospike-mapping.xml
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/gora/blob/7c3390d0/gora-aerospike/src/test/java/org/apache/gora/aerospike/GoraAerospikeTestDriver.java
----------------------------------------------------------------------
diff --git a/gora-aerospike/src/test/java/org/apache/gora/aerospike/GoraAerospikeTestDriver.java
b/gora-aerospike/src/test/java/org/apache/gora/aerospike/GoraAerospikeTestDriver.java
new file mode 100644
index 0000000..1281d9b
--- /dev/null
+++ b/gora-aerospike/src/test/java/org/apache/gora/aerospike/GoraAerospikeTestDriver.java
@@ -0,0 +1,74 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.gora.aerospike;
+
+import org.apache.gora.GoraTestDriver;
+import org.apache.gora.aerospike.store.AerospikeStore;
+import org.apache.gora.persistency.Persistent;
+import org.apache.gora.store.DataStore;
+import org.apache.gora.store.DataStoreFactory;
+import org.apache.gora.util.GoraException;
+import org.testcontainers.containers.GenericContainer;
+
+import java.util.Properties;
+
+/**
+ * Helper class for third part tests using gora-aerospike backend.
+ * @see GoraTestDriver
+ */
+public class GoraAerospikeTestDriver extends GoraTestDriver {
+
+  private GenericContainer aerospikeContainer;
+  private Properties properties = DataStoreFactory.createProps();
+
+  public GoraAerospikeTestDriver(GenericContainer aerospikeContainer) {
+    super(AerospikeStore.class);
+    this.aerospikeContainer = aerospikeContainer;
+  }
+
+  @Override
+  public void setUpClass() throws Exception {
+    properties.setProperty("server.ip", "localhost");
+    properties.setProperty("server.port", aerospikeContainer.getMappedPort(3000).toString());
+  }
+
+  @Override
+  public void tearDownClass() throws Exception {
+  }
+
+  /**
+   * Instantiate a new {@link DataStore}. Uses 'null' schema.
+   *
+   * @param keyClass The key class.
+   * @param persistentClass The value class.
+   * @return A new store instance.
+   * @throws GoraException
+   */
+  @Override
+  public <K, T extends Persistent> DataStore<K, T> createDataStore(Class<K>
keyClass, Class<T> persistentClass)
+          throws GoraException {
+
+    final DataStore<K, T> dataStore = DataStoreFactory
+            .createDataStore((Class<? extends DataStore<K, T>>) dataStoreClass,
keyClass, persistentClass, conf,
+                    properties);
+    dataStores.add(dataStore);
+    log.info("Datastore for {} was added.", persistentClass);
+    return dataStore;
+  }
+}

http://git-wip-us.apache.org/repos/asf/gora/blob/7c3390d0/gora-aerospike/src/test/java/org/apache/gora/aerospike/package-info.java
----------------------------------------------------------------------
diff --git a/gora-aerospike/src/test/java/org/apache/gora/aerospike/package-info.java b/gora-aerospike/src/test/java/org/apache/gora/aerospike/package-info.java
new file mode 100644
index 0000000..9eb6fbf
--- /dev/null
+++ b/gora-aerospike/src/test/java/org/apache/gora/aerospike/package-info.java
@@ -0,0 +1,17 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.gora.aerospike;
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/gora/blob/7c3390d0/gora-aerospike/src/test/java/org/apache/gora/aerospike/store/TestAerospikeStore.java
----------------------------------------------------------------------
diff --git a/gora-aerospike/src/test/java/org/apache/gora/aerospike/store/TestAerospikeStore.java
b/gora-aerospike/src/test/java/org/apache/gora/aerospike/store/TestAerospikeStore.java
new file mode 100644
index 0000000..e1af3cd
--- /dev/null
+++ b/gora-aerospike/src/test/java/org/apache/gora/aerospike/store/TestAerospikeStore.java
@@ -0,0 +1,330 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.gora.aerospike.store;
+
+import org.apache.gora.aerospike.GoraAerospikeTestDriver;
+import org.apache.gora.examples.generated.Employee;
+import org.apache.gora.examples.generated.WebPage;
+import org.apache.gora.store.DataStoreFactory;
+import org.apache.gora.store.DataStoreTestBase;
+import org.junit.ClassRule;
+import org.junit.Ignore;
+import org.junit.Test;
+import org.testcontainers.containers.GenericContainer;
+
+import java.io.IOException;
+
+/**
+ * Test case for AerospikeStore.
+ */
+public class TestAerospikeStore extends DataStoreTestBase {
+
+  private static final String DOCKER_CONTAINER_NAME = "aerospike:3.14.0";
+
+  @ClassRule
+  public static GenericContainer aerospikeContainer = new GenericContainer(DOCKER_CONTAINER_NAME);
+
+  static {
+    setTestDriver(new GoraAerospikeTestDriver(aerospikeContainer));
+  }
+
+  @Override
+  public void setUp() throws Exception {
+    super.setUp();
+  }
+
+  @Override
+  public void tearDown() throws Exception {
+    super.tearDown();
+  }
+
+  @Test
+  @Ignore("To be implemented")
+  @Override
+  public void testNewInstance() throws Exception {
+    // super.testNewInstance();
+  }
+
+  @Test
+  @Ignore("To be implemented")
+  @Override
+  public void testCreateSchema() throws Exception {
+    // super.testCreateSchema();
+  }
+
+  @Override
+  public void assertSchemaExists(String schemaName) throws Exception {
+    super.assertSchemaExists(schemaName);
+  }
+
+  @Test
+  @Ignore("To be implemented")
+  @Override
+  public void testAutoCreateSchema() throws Exception {
+    super.testAutoCreateSchema();
+  }
+
+  @Test
+  @Ignore("To be implemented")
+  @Override
+  public void assertAutoCreateSchema() throws Exception {
+    super.assertAutoCreateSchema();
+  }
+
+  @Test
+  @Ignore("To be implemented")
+  @Override
+  public void testTruncateSchema() throws Exception {
+    super.testTruncateSchema();
+  }
+
+  @Test
+  @Ignore("To be implemented")
+  @Override
+  public void testDeleteSchema() throws Exception {
+    super.testDeleteSchema();
+  }
+
+  @Test
+  @Ignore("To be implemented")
+  @Override
+  public void testSchemaExists() throws Exception {
+    super.testSchemaExists();
+  }
+
+  @Test
+  @Ignore("To be implemented")
+  @Override
+  public void testPut() throws Exception {
+    super.testPut();
+  }
+
+  @Override
+  public void assertPut(Employee employee) throws IOException {
+    super.assertPut(employee);
+  }
+
+  @Test
+  @Ignore("To be implemented")
+  @Override
+  public void testPutNested() throws Exception {
+    super.testPutNested();
+  }
+
+  @Test
+  @Ignore("To be implemented")
+  @Override
+  public void testPutArray() throws Exception {
+    super.testPutArray();
+  }
+
+  @Test
+  @Ignore("To be implemented")
+  @Override
+  public void assertPutArray() throws IOException {
+    super.assertPutArray();
+  }
+
+  @Test
+  @Ignore("To be implemented")
+  @Override
+  public void testPutBytes() throws Exception {
+    super.testPutBytes();
+  }
+
+  @Override
+  public void assertPutBytes(byte[] contentBytes) throws IOException {
+    super.assertPutBytes(contentBytes);
+  }
+
+  @Test
+  @Ignore("To be implemented")
+  @Override
+  public void testPutMap() throws Exception {
+    super.testPutMap();
+  }
+
+  @Test
+  @Ignore("To be implemented")
+  @Override
+  public void assertPutMap() throws IOException {
+    super.assertPutMap();
+  }
+
+  @Test
+  @Ignore("To be implemented")
+  @Override
+  public void testPutMixedMaps() throws Exception {
+    super.testPutMixedMaps();
+  }
+
+  @Test
+  @Ignore("To be implemented")
+  @Override
+  public void testUpdate() throws Exception {
+    super.testUpdate();
+  }
+
+  @Test
+  @Ignore("To be implemented")
+  @Override
+  public void testEmptyUpdate() throws Exception {
+    super.testEmptyUpdate();
+  }
+
+  @Test
+  @Ignore("To be implemented")
+  @Override
+  public void testGet() throws Exception {
+    super.testGet();
+  }
+
+  @Test
+  @Ignore("To be implemented")
+  @Override
+  public void testGetRecursive() throws Exception {
+    super.testGetRecursive();
+  }
+
+  @Test
+  @Ignore("To be implemented")
+  @Override
+  public void testGetDoubleRecursive() throws Exception {
+    super.testGetDoubleRecursive();
+  }
+
+  @Test
+  @Ignore("To be implemented")
+  @Override
+  public void testGetNested() throws Exception {
+    super.testGetNested();
+  }
+
+  @Test
+  @Ignore("To be implemented")
+  @Override
+  public void testGet3UnionField() throws Exception {
+    super.testGet3UnionField();
+  }
+
+  @Test
+  @Ignore("To be implemented")
+  @Override
+  public void testGetWithFields() throws Exception {
+    super.testGetWithFields();
+  }
+
+  @Test
+  @Ignore("To be implemented")
+  @Override
+  public void testGetWebPage() throws Exception {
+    super.testGetWebPage();
+  }
+
+  @Test
+  @Ignore("To be implemented")
+  @Override
+  public void testGetWebPageDefaultFields() throws Exception {
+    super.testGetWebPageDefaultFields();
+  }
+
+  @Test
+  @Ignore("To be implemented")
+  @Override
+  public void testGetNonExisting() throws Exception {
+    super.testGetNonExisting();
+  }
+
+  @Test
+  @Ignore("To be implemented")
+  @Override
+  public void testQuery() throws Exception {
+    super.testQuery();
+  }
+
+  @Test
+  @Ignore("To be implemented")
+  @Override
+  public void testQueryStartKey() throws Exception {
+    super.testQueryStartKey();
+  }
+
+  @Test
+  @Ignore("To be implemented")
+  @Override
+  public void testQueryEndKey() throws Exception {
+    super.testQueryEndKey();
+  }
+
+  @Test
+  @Ignore("To be implemented")
+  @Override
+  public void testQueryKeyRange() throws Exception {
+    super.testQueryKeyRange();
+  }
+
+  @Test
+  @Ignore("To be implemented")
+  @Override
+  public void testQueryWebPageSingleKey() throws Exception {
+    super.testQueryWebPageSingleKey();
+  }
+
+  @Test
+  @Ignore("To be implemented")
+  @Override
+  public void testQueryWebPageSingleKeyDefaultFields() throws Exception {
+    super.testQueryWebPageSingleKeyDefaultFields();
+  }
+
+  @Test
+  @Ignore("To be implemented")
+  @Override
+  public void testQueryWebPageQueryEmptyResults() throws Exception {
+    super.testQueryWebPageQueryEmptyResults();
+  }
+
+  @Test
+  @Ignore("To be implemented")
+  @Override
+  public void testDelete() throws Exception {
+    super.testDelete();
+  }
+
+  @Test
+  @Ignore("To be implemented")
+  @Override
+  public void testDeleteByQuery() throws Exception {
+    super.testDeleteByQuery();
+  }
+
+  @Test
+  @Ignore("To be implemented")
+  @Override
+  public void testDeleteByQueryFields() throws Exception {
+    super.testDeleteByQueryFields();
+  }
+
+  @Test
+  @Ignore("To be implemented")
+  @Override
+  public void testGetPartitions() throws Exception {
+    super.testGetPartitions();
+  }
+}

http://git-wip-us.apache.org/repos/asf/gora/blob/7c3390d0/gora-aerospike/src/test/java/org/apache/gora/aerospike/store/package-info.java
----------------------------------------------------------------------
diff --git a/gora-aerospike/src/test/java/org/apache/gora/aerospike/store/package-info.java
b/gora-aerospike/src/test/java/org/apache/gora/aerospike/store/package-info.java
new file mode 100644
index 0000000..69670f8
--- /dev/null
+++ b/gora-aerospike/src/test/java/org/apache/gora/aerospike/store/package-info.java
@@ -0,0 +1,21 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+/**
+ * This package contains all the unit tests for basic CRUD operations
+ * functionality of the Aerospike dataStore.
+ */
+package org.apache.gora.aerospike.store;
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/gora/blob/7c3390d0/pom.xml
----------------------------------------------------------------------
diff --git a/pom.xml b/pom.xml
index b81d7e6..2d05a71 100644
--- a/pom.xml
+++ b/pom.xml
@@ -939,6 +939,12 @@
         <artifactId>gora-aerospike</artifactId>
         <version>${project.version}</version>
       </dependency>
+      <dependency>
+        <groupId>org.apache.gora</groupId>
+        <artifactId>gora-aerospike</artifactId>
+        <version>${project.version}</version>
+        <type>test-jar</type>
+      </dependency>
       <!-- End of Internal Depednecies -->
 
       <dependency>


Mime
View raw message