fix for issue #29

Author: anidotnet

gradle.properties

@@ -50,6 +50,7 @@ nexusStagingPlugin=0.8.0
 objenesisVersion=2.6
 okhttpVersion=3.6.0
 orientdbVersion=2.2.10
+podamVersion=7.0.5.RELEASE
 propDepsPluginVersion=0.0.7
 shadowPluginVersion=1.2.4
 slf4jVersion=1.7.21

nitrite/build.gradle

@@ -49,7 +49,7 @@ dependencies {
     testCompile "joda-time:joda-time:$jodaTimeVersion"
     testCompile "com.squareup.okhttp3:mockwebserver:$okhttpVersion"
     testCompile "org.meanbean:meanbean:$meanbeanVersion"
-
+    testCompile "uk.co.jemos.podam:podam:$podamVersion"
 }
 
 gradle.buildFinished { BuildResult result ->

nitrite/src/main/java/org/dizitart/no2/NitriteId.java

@@ -20,6 +20,7 @@
 import org.dizitart.no2.exceptions.InvalidIdException;
 
 import java.io.Serializable;
+import java.util.concurrent.atomic.AtomicLong;
 
 import static org.dizitart.no2.Constants.ID_PREFIX;
 import static org.dizitart.no2.Constants.ID_SUFFIX;
@@ -43,11 +44,12 @@
 @EqualsAndHashCode
 public final class NitriteId implements Comparable<NitriteId>, Serializable {
     private static final long serialVersionUID = 1477462375L;
+    private static final AtomicLong counter = new AtomicLong(System.nanoTime());
 
     private Long idValue;
 
     private NitriteId() {
-        idValue = new ObjectId().toLong();
+        idValue = counter.getAndIncrement();
     }
 
     private NitriteId(Long value) {

nitrite/src/test/java/org/dizitart/no2/NitriteStressTest.java

@@ -0,0 +1,170 @@
+package org.dizitart.no2;
+
+import org.dizitart.no2.objects.Id;
+import org.dizitart.no2.objects.ObjectRepository;
+import org.junit.Test;
+import uk.co.jemos.podam.api.PodamFactory;
+import uk.co.jemos.podam.api.PodamFactoryImpl;
+
+import javax.xml.bind.annotation.XmlElement;
+import javax.xml.bind.annotation.XmlSchemaType;
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * @author Anindya Chatterjee
+ */
+public class NitriteStressTest {
+    private PodamFactory podamFactory = new PodamFactoryImpl();
+
+    private static final int TEST_SET_COUNT = 15000;
+    private Nitrite database;
+    private ObjectRepository<TestDto> testRepository;
+
+    @Test
+    public void stressTest() {
+        database = Nitrite.builder().openOrCreate();
+        testRepository = database.getRepository(TestDto.class);
+        testRepository.createIndex("lastName", IndexOptions.indexOptions(IndexType.Fulltext));
+        testRepository.createIndex("birthDate", IndexOptions.indexOptions(IndexType.NonUnique));
+
+        int counter = 0;
+        try {
+            for (TestDto testDto : createTestSet()) {
+                testRepository.insert(testDto);
+                counter++;
+            }
+        } catch (Throwable t) {
+            System.err.println("Crashed after " + counter + " records");
+            throw t;
+        }
+    }
+
+    private List<TestDto> createTestSet() {
+        List<TestDto> testData = new ArrayList<>();
+        for (int i = 0; i < TEST_SET_COUNT; i++) {
+            TestDto testRecords = podamFactory.manufacturePojo(TestDto.class);
+            testData.add(testRecords);
+        }
+        return testData;
+    }
+
+    public class TestDto {
+
+        @XmlElement(
+                name = "StudentNumber",
+                required = true
+        )
+        @Id
+        protected String studentNumber;
+
+        @XmlElement(
+                name = "LastName",
+                required = true
+        )
+        protected String lastName;
+
+        @XmlElement(
+                name = "Prefixes"
+        )
+        protected String prefixes;
+
+        @XmlElement(
+                name = "Initials",
+                required = true
+        )
+        protected String initials;
+
+        @XmlElement(
+                name = "FirstNames"
+        )
+        protected String firstNames;
+        @XmlElement(
+                name = "Nickname"
+        )
+        protected String nickName;
+
+        @XmlElement(
+                name = "BirthDate",
+                required = true
+        )
+        @XmlSchemaType(
+                name = "date"
+        )
+        protected String birthDate;
+
+
+        public TestDto() {
+        }
+
+
+        public String getStudentNumber() {
+            return this.studentNumber;
+        }
+
+
+        public void setStudentNumber(String value) {
+            this.studentNumber = value;
+        }
+
+
+        public String getLastName() {
+            return this.lastName;
+        }
+
+
+        public void setLastName(String value) {
+            this.lastName = value;
+        }
+
+
+        public String getPrefixes() {
+            return this.prefixes;
+        }
+
+
+        public void setPrefixes(String value) {
+            this.prefixes = value;
+        }
+
+
+        public String getInitials() {
+            return this.initials;
+        }
+
+
+        public void setInitials(String value) {
+            this.initials = value;
+        }
+
+
+        public String getFirstNames() {
+            return this.firstNames;
+        }
+
+
+        public void setFirstNames(String value) {
+            this.firstNames = value;
+        }
+
+
+        public String getNickName() {
+            return this.nickName;
+        }
+
+
+        public void setNickName(String value) {
+            this.nickName = value;
+        }
+
+
+        public String getBirthDate() {
+            return this.birthDate;
+        }
+
+
+        public void setBirthDate(String value) {
+            this.birthDate = value;
+        }
+    }
+}