Changed default buckets per type to 1

engine/src/main/java/com/arcadedb/GlobalConfiguration.java

@@ -200,7 +200,7 @@ public Object call(final Object value) {
       50),
 
   TYPE_DEFAULT_BUCKETS("arcadedb.typeDefaultBuckets", SCOPE.DATABASE, "Default number of buckets to create per type", Integer.class,
-      8),
+      1),
 
   BUCKET_DEFAULT_PAGE_SIZE("arcadedb.bucketDefaultPageSize", SCOPE.DATABASE,
       "Default page size in bytes for buckets. Default is 64KB", Integer.class, 65_536),

engine/src/main/java/com/arcadedb/query/sql/executor/SelectExecutionPlanner.java

@@ -897,8 +897,7 @@ else if (o instanceof Result && ((Result) o).isElement())
       }
       info.fetchExecutionPlan.chain(new ParallelExecStep(plans, context));
     } else if (target.getIndex() != null) {
-      if (info.buckets.size() > 1)
-        handleIndexAsTarget(info.fetchExecutionPlan, info, target.getIndex(), null, context);
+      handleIndexAsTarget(info.fetchExecutionPlan, info, target.getIndex(), null, context);
     } else if (target.getSchema() != null) {
       handleSchemaAsTarget(info.fetchExecutionPlan, target.getSchema(), context);
     } else if (target.getRids() != null && !target.getRids().isEmpty()) {
@@ -1697,17 +1696,17 @@ private List<ExecutionStepInternal> handleTypeAsTargetWithIndex(
 
     final List<IndexSearchDescriptor> indexSearchDescriptors =
         info.flattenedWhereClause.stream()
-        .map(x -> findBestIndexFor(context, indexes, x, typez))
+            .map(x -> findBestIndexFor(context, indexes, x, typez))
             .filter(Objects::nonNull)
             .collect(Collectors.toList());
 
     if (indexSearchDescriptors.isEmpty())
       return null;
 
     // TODO
-        if (indexSearchDescriptors.size() != info.flattenedWhereClause.size()) {
-          return null; //some blocks could not be managed with an index
-        }
+    if (indexSearchDescriptors.size() != info.flattenedWhereClause.size()) {
+      return null; //some blocks could not be managed with an index
+    }
 
 //    // ARCADEDB: NOT APPLICABLE TO ORIENTDB
 //    // IF THERE ARE ANY CHANGES IN TX, AVOID IT

engine/src/test/java/com/arcadedb/ACIDTransactionTest.java

@@ -317,7 +317,7 @@ public void testAsyncIOExceptionAfterWALIsWrittenManyRecords() {
   @Test
   public void multiThreadConcurrentTransactions() {
     database.transaction(() -> {
-      final DocumentType type = database.getSchema().createDocumentType("Stock");
+      final DocumentType type = database.getSchema().createDocumentType("Stock", 8);
       type.createProperty("symbol", Type.STRING);
       type.createProperty("date", Type.DATETIME);
       type.createProperty("history", Type.LIST);

engine/src/test/java/com/arcadedb/TransactionIsolationTest.java

@@ -16,7 +16,7 @@ protected void beginTest() {
     database.transaction(() -> {
       if (database.getSchema().existsType("Node"))
         database.getSchema().dropType("Node");
-      database.getSchema().createVertexType("Node");
+      database.getSchema().createVertexType("Node", 8);
     });
   }
 

engine/src/test/java/com/arcadedb/query/sql/executor/ScriptExecutionTest.java

@@ -201,7 +201,7 @@ public void testCommitRetry() {
   @Test
   public void testCommitRetryMultiThreadsSQLIncrement() throws IOException {
     String className = "testCommitRetryMTSQLIncrement";
-    database.getSchema().createDocumentType(className);
+    database.getSchema().createDocumentType(className, 8);
 
     // AVOID RETRY, EXPECTING TO MISS SOME UPDATES
     database.transaction(() -> {
@@ -258,7 +258,7 @@ public void testCommitRetryMultiThreadsSQLIncrement() throws IOException {
   @Test
   public void testCommitRetryMultiThreadsSQLIncrementRepeatableRead() throws IOException {
     String className = "testCommitRetryMTSQLIncrement";
-    database.getSchema().createDocumentType(className);
+    database.getSchema().createDocumentType(className, 8);
 
     // AVOID RETRY, EXPECTING TO MISS SOME UPDATES
     database.transaction(() -> {

engine/src/test/java/com/arcadedb/query/sql/executor/SelectStatementExecutionTest.java

@@ -1070,7 +1070,7 @@ public void testFetchFromSingleRidParam() {
 
   @Test
   public void testFetchFromSingleRid3() {
-    database.getSchema().createDocumentType("testFetchFromSingleRid3");
+    database.getSchema().createDocumentType("testFetchFromSingleRid3", 8);
     database.begin();
     MutableDocument doc = database.newDocument("testFetchFromSingleRid3");
     doc.save();
@@ -1089,7 +1089,7 @@ public void testFetchFromSingleRid3() {
 
   @Test
   public void testFetchFromSingleRid4() {
-    database.getSchema().createDocumentType("testFetchFromSingleRid4");
+    database.getSchema().createDocumentType("testFetchFromSingleRid4", 8);
     database.begin();
     MutableDocument doc = database.newDocument("testFetchFromSingleRid4");
     doc.save();