ArcadeData · arcade-player · Jan 4, 2022 · Jan 4, 2022
diff --git a/console/src/main/java/com/arcadedb/console/Console.java b/console/src/main/java/com/arcadedb/console/Console.java
@@ -33,19 +33,19 @@
 import com.arcadedb.schema.DocumentType;
 import com.arcadedb.utility.RecordTableFormatter;
 import com.arcadedb.utility.TableFormatter;
-import org.jline.reader.Completer;
-import org.jline.reader.EndOfFileException;
-import org.jline.reader.LineReader;
-import org.jline.reader.LineReaderBuilder;
-import org.jline.reader.ParsedLine;
-import org.jline.reader.UserInterruptException;
+import org.jline.reader.*;
 import org.jline.reader.impl.completer.StringsCompleter;
 import org.jline.reader.impl.history.DefaultHistory;
 import org.jline.terminal.Terminal;
 import org.jline.terminal.TerminalBuilder;
 
-import java.io.*;
-import java.util.*;
+import java.io.BufferedReader;
+import java.io.File;
+import java.io.FileReader;
+import java.io.IOException;
+import java.util.ArrayList;
+import java.util.Iterator;
+import java.util.List;
 
 public class Console {
   private static final String           PROMPT               = "%n%s> ";

diff --git a/console/src/main/java/com/arcadedb/console/TerminalParser.java b/console/src/main/java/com/arcadedb/console/TerminalParser.java
@@ -18,7 +18,8 @@
 import org.jline.reader.ParsedLine;
 import org.jline.reader.impl.DefaultParser;
 
-import java.util.*;
+import java.util.LinkedList;
+import java.util.List;
 
 public class TerminalParser extends DefaultParser {
 

diff --git a/console/src/test/java/com/arcadedb/console/ConsoleTest.java b/console/src/test/java/com/arcadedb/console/ConsoleTest.java
@@ -22,7 +22,8 @@
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Test;
 
-import java.io.*;
+import java.io.File;
+import java.io.IOException;
 
 public class ConsoleTest {
   private static final String  DB_NAME = "console";

diff --git a/console/src/test/java/com/arcadedb/console/DumpCfgTest.java b/console/src/test/java/com/arcadedb/console/DumpCfgTest.java
@@ -17,8 +17,10 @@
 
 import com.arcadedb.GlobalConfiguration;
 
-import java.util.*;
-import java.util.stream.*;
+import java.util.Arrays;
+import java.util.Comparator;
+import java.util.List;
+import java.util.stream.Collectors;
 
 public class DumpCfgTest {
   public static void main(String[] args) {

diff --git a/console/src/test/java/com/arcadedb/console/RemoteConsoleIT.java b/console/src/test/java/com/arcadedb/console/RemoteConsoleIT.java
@@ -18,13 +18,9 @@
 import com.arcadedb.GlobalConfiguration;
 import com.arcadedb.remote.RemoteException;
 import com.arcadedb.server.BaseGraphServerTest;
-import org.junit.jupiter.api.AfterAll;
-import org.junit.jupiter.api.AfterEach;
-import org.junit.jupiter.api.Assertions;
-import org.junit.jupiter.api.BeforeEach;
-import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.*;
 
-import java.io.*;
+import java.io.IOException;
 
 public class RemoteConsoleIT extends BaseGraphServerTest {
   private static final String  URL               = "remote:localhost:2480/console root " + DEFAULT_PASSWORD_FOR_TESTS;

diff --git a/engine/src/main/java/com/arcadedb/ContextConfiguration.java b/engine/src/main/java/com/arcadedb/ContextConfiguration.java
@@ -18,9 +18,9 @@
 import com.arcadedb.utility.SystemVariableResolver;
 import org.json.JSONObject;
 
-import java.io.*;
-import java.util.*;
-import java.util.concurrent.*;
+import java.io.Serializable;
+import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
 
 /**
  * Represents a context configuration where custom setting could be defined for the context only. If not defined, globals will be

diff --git a/engine/src/main/java/com/arcadedb/GlobalConfiguration.java b/engine/src/main/java/com/arcadedb/GlobalConfiguration.java
@@ -23,9 +23,12 @@
 import com.arcadedb.utility.SystemVariableResolver;
 import org.json.JSONObject;
 
-import java.io.*;
-import java.util.*;
-import java.util.logging.*;
+import java.io.PrintStream;
+import java.util.Locale;
+import java.util.Map;
+import java.util.Timer;
+import java.util.TimerTask;
+import java.util.logging.Level;
 
 /**
  * Keeps all configuration settings. At startup assigns the configuration values by reading system properties.

diff --git a/engine/src/main/java/com/arcadedb/Profiler.java b/engine/src/main/java/com/arcadedb/Profiler.java
@@ -23,9 +23,13 @@
 
 import javax.management.MBeanServer;
 import javax.management.ObjectName;
-import java.io.*;
-import java.lang.management.*;
-import java.util.*;
+import java.io.File;
+import java.io.PrintStream;
+import java.lang.management.GarbageCollectorMXBean;
+import java.lang.management.ManagementFactory;
+import java.util.LinkedHashSet;
+import java.util.Map;
+import java.util.Set;
 
 public class Profiler {
   public static final Profiler INSTANCE = new Profiler();

diff --git a/engine/src/main/java/com/arcadedb/database/BaseDocument.java b/engine/src/main/java/com/arcadedb/database/BaseDocument.java
@@ -20,8 +20,8 @@
 import com.arcadedb.serializer.JavaBinarySerializer;
 
 import java.io.*;
-import java.math.*;
-import java.util.*;
+import java.math.BigDecimal;
+import java.util.Date;
 
 public abstract class BaseDocument extends BaseRecord implements Document, Serializable, Externalizable {
   protected final DocumentType type;

diff --git a/engine/src/main/java/com/arcadedb/database/BaseRecord.java b/engine/src/main/java/com/arcadedb/database/BaseRecord.java
@@ -19,7 +19,7 @@
 import com.arcadedb.graph.Edge;
 import com.arcadedb.graph.Vertex;
 
-import java.util.*;
+import java.util.Objects;
 
 public abstract class BaseRecord implements Record {
   protected final DatabaseInternal database;

diff --git a/engine/src/main/java/com/arcadedb/database/Database.java b/engine/src/main/java/com/arcadedb/database/Database.java
@@ -29,8 +29,9 @@
 import com.arcadedb.query.sql.executor.ResultSet;
 import com.arcadedb.schema.Schema;
 
-import java.util.*;
-import java.util.concurrent.*;
+import java.util.Iterator;
+import java.util.Map;
+import java.util.concurrent.Callable;
 
 public interface Database extends AutoCloseable {
   ContextConfiguration getConfiguration();

diff --git a/engine/src/main/java/com/arcadedb/database/DatabaseComparator.java b/engine/src/main/java/com/arcadedb/database/DatabaseComparator.java
@@ -22,8 +22,10 @@
 import com.arcadedb.index.Index;
 import com.arcadedb.schema.DocumentType;
 
-import java.io.*;
-import java.util.*;
+import java.io.IOException;
+import java.util.Arrays;
+import java.util.Collection;
+import java.util.HashMap;
 
 /**
  * Compares 2 databases if are identical.

diff --git a/engine/src/main/java/com/arcadedb/database/DatabaseContext.java b/engine/src/main/java/com/arcadedb/database/DatabaseContext.java
@@ -18,7 +18,10 @@
 import com.arcadedb.exception.TransactionException;
 import com.arcadedb.security.SecurityDatabaseUser;
 
-import java.util.*;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
 
 /**
  * Thread local to store transaction data.

diff --git a/engine/src/main/java/com/arcadedb/database/DatabaseEvents.java b/engine/src/main/java/com/arcadedb/database/DatabaseEvents.java
@@ -15,12 +15,7 @@
  */
 package com.arcadedb.database;
 
-import com.arcadedb.event.AfterRecordCreateListener;
-import com.arcadedb.event.AfterRecordDeleteListener;
-import com.arcadedb.event.AfterRecordUpdateListener;
-import com.arcadedb.event.BeforeRecordCreateListener;
-import com.arcadedb.event.BeforeRecordDeleteListener;
-import com.arcadedb.event.BeforeRecordUpdateListener;
+import com.arcadedb.event.*;
 
 public interface DatabaseEvents {
   DatabaseEvents registerListener(final BeforeRecordCreateListener listener);

diff --git a/engine/src/main/java/com/arcadedb/database/DatabaseEventsRegistry.java b/engine/src/main/java/com/arcadedb/database/DatabaseEventsRegistry.java
@@ -15,14 +15,10 @@
  */
 package com.arcadedb.database;
 
-import com.arcadedb.event.AfterRecordCreateListener;
-import com.arcadedb.event.AfterRecordDeleteListener;
-import com.arcadedb.event.AfterRecordUpdateListener;
-import com.arcadedb.event.BeforeRecordCreateListener;
-import com.arcadedb.event.BeforeRecordDeleteListener;
-import com.arcadedb.event.BeforeRecordUpdateListener;
-
-import java.util.*;
+import com.arcadedb.event.*;
+
+import java.util.ArrayList;
+import java.util.List;
 
 public class DatabaseEventsRegistry implements DatabaseEvents {
   private final List<BeforeRecordCreateListener>        beforeCreateListeners = new ArrayList<>();

diff --git a/engine/src/main/java/com/arcadedb/database/DatabaseFactory.java b/engine/src/main/java/com/arcadedb/database/DatabaseFactory.java
@@ -21,10 +21,12 @@
 import com.arcadedb.schema.EmbeddedSchema;
 import com.arcadedb.security.SecurityManager;
 
-import java.io.*;
-import java.nio.charset.*;
+import java.io.File;
+import java.nio.charset.Charset;
+import java.nio.charset.StandardCharsets;
 import java.util.*;
-import java.util.concurrent.*;
+import java.util.concurrent.Callable;
+import java.util.concurrent.ConcurrentHashMap;
 
 public class DatabaseFactory implements AutoCloseable {
   private              SecurityManager                                            security;

diff --git a/engine/src/main/java/com/arcadedb/database/DatabaseInternal.java b/engine/src/main/java/com/arcadedb/database/DatabaseInternal.java
@@ -25,9 +25,9 @@
 import com.arcadedb.security.SecurityDatabaseUser;
 import com.arcadedb.serializer.BinarySerializer;
 
-import java.io.*;
-import java.util.*;
-import java.util.concurrent.*;
+import java.io.IOException;
+import java.util.Map;
+import java.util.concurrent.Callable;
 
 /**
  * Internal API, do not use as an end user.

diff --git a/engine/src/main/java/com/arcadedb/database/DocumentIndexer.java b/engine/src/main/java/com/arcadedb/database/DocumentIndexer.java
@@ -20,7 +20,7 @@
 import com.arcadedb.index.Index;
 import com.arcadedb.schema.DocumentType;
 
-import java.util.*;
+import java.util.List;
 
 public class DocumentIndexer {
   private final EmbeddedDatabase database;

diff --git a/engine/src/main/java/com/arcadedb/database/EmbeddedDatabase.java b/engine/src/main/java/com/arcadedb/database/EmbeddedDatabase.java
@@ -23,55 +23,19 @@
 import com.arcadedb.database.async.OkCallback;
 import com.arcadedb.engine.Bucket;
 import com.arcadedb.engine.Dictionary;
-import com.arcadedb.engine.ErrorRecordCallback;
-import com.arcadedb.engine.FileManager;
-import com.arcadedb.engine.PageManager;
-import com.arcadedb.engine.PaginatedFile;
-import com.arcadedb.engine.TransactionManager;
-import com.arcadedb.engine.WALFile;
-import com.arcadedb.engine.WALFileFactory;
-import com.arcadedb.engine.WALFileFactoryEmbedded;
-import com.arcadedb.exception.ArcadeDBException;
-import com.arcadedb.exception.DatabaseIsClosedException;
-import com.arcadedb.exception.DatabaseIsReadOnlyException;
-import com.arcadedb.exception.DatabaseMetadataException;
-import com.arcadedb.exception.DatabaseOperationException;
-import com.arcadedb.exception.DuplicatedKeyException;
-import com.arcadedb.exception.InvalidDatabaseInstanceException;
-import com.arcadedb.exception.NeedRetryException;
-import com.arcadedb.exception.SchemaException;
-import com.arcadedb.exception.TransactionException;
-import com.arcadedb.graph.Edge;
-import com.arcadedb.graph.GraphEngine;
-import com.arcadedb.graph.MutableVertex;
-import com.arcadedb.graph.Vertex;
-import com.arcadedb.graph.VertexInternal;
+import com.arcadedb.engine.*;
+import com.arcadedb.exception.*;
+import com.arcadedb.graph.*;
 import com.arcadedb.index.Index;
 import com.arcadedb.index.IndexCursor;
 import com.arcadedb.index.TypeIndex;
 import com.arcadedb.index.lsm.LSMTreeIndexCompacted;
 import com.arcadedb.index.lsm.LSMTreeIndexMutable;
 import com.arcadedb.log.LogManager;
 import com.arcadedb.query.QueryEngineManager;
-import com.arcadedb.query.sql.executor.BasicCommandContext;
-import com.arcadedb.query.sql.executor.CommandContext;
-import com.arcadedb.query.sql.executor.InternalExecutionPlan;
-import com.arcadedb.query.sql.executor.ResultSet;
-import com.arcadedb.query.sql.executor.SQLEngine;
-import com.arcadedb.query.sql.executor.ScriptExecutionPlan;
-import com.arcadedb.query.sql.parser.BeginStatement;
-import com.arcadedb.query.sql.parser.CommitStatement;
-import com.arcadedb.query.sql.parser.ExecutionPlanCache;
-import com.arcadedb.query.sql.parser.LetStatement;
-import com.arcadedb.query.sql.parser.LocalResultSet;
-import com.arcadedb.query.sql.parser.LocalResultSetLifecycleDecorator;
-import com.arcadedb.query.sql.parser.Statement;
-import com.arcadedb.query.sql.parser.StatementCache;
-import com.arcadedb.schema.DocumentType;
-import com.arcadedb.schema.EmbeddedSchema;
-import com.arcadedb.schema.Property;
-import com.arcadedb.schema.Schema;
-import com.arcadedb.schema.VertexType;
+import com.arcadedb.query.sql.executor.*;
+import com.arcadedb.query.sql.parser.*;
+import com.arcadedb.schema.*;
 import com.arcadedb.security.SecurityDatabaseUser;
 import com.arcadedb.security.SecurityManager;
 import com.arcadedb.serializer.BinarySerializer;
@@ -80,15 +44,22 @@
 import com.arcadedb.utility.MultiIterator;
 import com.arcadedb.utility.RWLockContext;
 
-import java.io.*;
-import java.nio.channels.*;
-import java.nio.file.*;
+import java.io.File;
+import java.io.IOException;
+import java.io.RandomAccessFile;
+import java.nio.channels.ClosedChannelException;
+import java.nio.channels.FileChannel;
+import java.nio.channels.FileLock;
+import java.nio.file.Files;
+import java.nio.file.Paths;
 import java.util.*;
-import java.util.concurrent.*;
-import java.util.concurrent.atomic.*;
-import java.util.concurrent.locks.*;
-import java.util.logging.*;
-import java.util.stream.*;
+import java.util.concurrent.Callable;
+import java.util.concurrent.atomic.AtomicBoolean;
+import java.util.concurrent.atomic.AtomicLong;
+import java.util.concurrent.locks.Lock;
+import java.util.concurrent.locks.ReentrantLock;
+import java.util.logging.Level;
+import java.util.stream.Collectors;
 
 public class EmbeddedDatabase extends RWLockContext implements DatabaseInternal {
   public static final  int                                       EDGE_LIST_INITIAL_CHUNK_SIZE         = 64;

diff --git a/engine/src/main/java/com/arcadedb/database/ImmutableDocument.java b/engine/src/main/java/com/arcadedb/database/ImmutableDocument.java
@@ -19,7 +19,8 @@
 import com.arcadedb.schema.DocumentType;
 import org.json.JSONObject;
 
-import java.util.*;
+import java.util.Map;
+import java.util.Set;
 
 /**
  * Immutable document implementation. To modify the record, you need to get the mutable representation by calling {@link #modify()}. This implementation keeps the

diff --git a/engine/src/main/java/com/arcadedb/database/ImmutableEmbeddedDocument.java b/engine/src/main/java/com/arcadedb/database/ImmutableEmbeddedDocument.java
@@ -18,7 +18,7 @@
 import com.arcadedb.exception.DatabaseOperationException;
 import com.arcadedb.schema.DocumentType;
 
-import java.util.*;
+import java.util.Set;
 
 public class ImmutableEmbeddedDocument extends ImmutableDocument implements EmbeddedDocument {
   private final EmbeddedModifier modifier;

diff --git a/engine/src/main/java/com/arcadedb/database/JSONSerializer.java b/engine/src/main/java/com/arcadedb/database/JSONSerializer.java
@@ -23,7 +23,7 @@
 import org.json.JSONObject;
 
 import java.util.*;
-import java.util.logging.*;
+import java.util.logging.Level;
 
 public class JSONSerializer {
   private final Database database;

diff --git a/engine/src/main/java/com/arcadedb/database/RID.java b/engine/src/main/java/com/arcadedb/database/RID.java
@@ -20,8 +20,8 @@
 import com.arcadedb.graph.Vertex;
 import com.arcadedb.utility.NumberUtils;
 
-import java.io.*;
-import java.util.*;
+import java.io.Serializable;
+import java.util.Objects;
 
 /**
  * It represents the logical address of a record in the database. The record id is composed by the bucket id (the bucket containing the record) and the offset

diff --git a/engine/src/main/java/com/arcadedb/database/RecordEvents.java b/engine/src/main/java/com/arcadedb/database/RecordEvents.java
@@ -15,12 +15,7 @@
  */
 package com.arcadedb.database;
 
-import com.arcadedb.event.AfterRecordCreateListener;
-import com.arcadedb.event.AfterRecordDeleteListener;
-import com.arcadedb.event.AfterRecordUpdateListener;
-import com.arcadedb.event.BeforeRecordCreateListener;
-import com.arcadedb.event.BeforeRecordDeleteListener;
-import com.arcadedb.event.BeforeRecordUpdateListener;
+import com.arcadedb.event.*;
 
 public interface RecordEvents {
   RecordEvents registerListener(final BeforeRecordCreateListener listener);