Backup development

Polypheny-DB.ipr

@@ -0,0 +1,105 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="CompilerConfiguration">
+    <option name="DEFAULT_COMPILER" value="Javac"/>
+    <resourceExtensions>
+      <entry name=".+\.(properties|xml|html|dtd|tld)"/>
+      <entry name=".+\.(gif|png|jpeg|jpg)"/>
+    </resourceExtensions>
+    <wildcardResourcePatterns>
+      <entry name="!?*.class"/>
+      <entry name="!?*.scala"/>
+      <entry name="!?*.groovy"/>
+      <entry name="!?*.java"/>
+    </wildcardResourcePatterns>
+    <annotationProcessing enabled="false" useClasspath="true"/>
+    <bytecodeTargetLevel target="11"/>
+  </component>
+  <component name="CopyrightManager" default="">
+    <module2copyright/>
+  </component>
+  <component name="DependencyValidationManager">
+    <option name="SKIP_IMPORT_STATEMENTS" value="false"/>
+  </component>
+  <component name="Encoding" useUTFGuessing="true" native2AsciiForPropertiesFiles="false"/>
+  <component name="GradleUISettings">
+    <setting name="root"/>
+  </component>
+  <component name="GradleUISettings2">
+    <setting name="root"/>
+  </component>
+  <component name="IdProvider" IDEtalkID="11DA1DB66DD62DDA1ED602B7079FE97C"/>
+  <component name="JavadocGenerationManager">
+    <option name="OUTPUT_DIRECTORY"/>
+    <option name="OPTION_SCOPE" value="protected"/>
+    <option name="OPTION_HIERARCHY" value="true"/>
+    <option name="OPTION_NAVIGATOR" value="true"/>
+    <option name="OPTION_INDEX" value="true"/>
+    <option name="OPTION_SEPARATE_INDEX" value="true"/>
+    <option name="OPTION_DOCUMENT_TAG_USE" value="false"/>
+    <option name="OPTION_DOCUMENT_TAG_AUTHOR" value="false"/>
+    <option name="OPTION_DOCUMENT_TAG_VERSION" value="false"/>
+    <option name="OPTION_DOCUMENT_TAG_DEPRECATED" value="true"/>
+    <option name="OPTION_DEPRECATED_LIST" value="true"/>
+    <option name="OTHER_OPTIONS" value=""/>
+    <option name="HEAP_SIZE"/>
+    <option name="LOCALE"/>
+    <option name="OPEN_IN_BROWSER" value="true"/>
+  </component>
+  <component name="ProjectModuleManager">
+    <modules>
+      <module fileurl="file://$PROJECT_DIR$/Polypheny-DB.iml" filepath="$PROJECT_DIR$/Polypheny-DB.iml"/>
+      <module fileurl="file://$PROJECT_DIR$/plugins/mapdb-monitoring/mapdb-monitoring.iml" filepath="$PROJECT_DIR$/plugins/mapdb-monitoring/mapdb-monitoring.iml"/>
+    </modules>
+  </component>
+  <component name="ProjectRootManager" version="2" languageLevel="JDK_11" assert-keyword="true" jdk-15="true" project-jdk-type="JavaSDK" assert-jdk-15="true" project-jdk-name="17">
+    <output url="file://$PROJECT_DIR$/out"/>
+  </component>
+  <component name="SvnBranchConfigurationManager">
+    <option name="mySupportsUserInfoFilter" value="true"/>
+  </component>
+  <component name="VcsDirectoryMappings">
+    <mapping directory="" vcs=""/>
+  </component>
+  <component name="masterDetails">
+    <states>
+      <state key="ArtifactsStructureConfigurable.UI">
+        <UIState>
+          <splitter-proportions>
+            <SplitterProportionsDataImpl/>
+          </splitter-proportions>
+          <settings/>
+        </UIState>
+      </state>
+      <state key="Copyright.UI">
+        <UIState>
+          <splitter-proportions>
+            <SplitterProportionsDataImpl/>
+          </splitter-proportions>
+        </UIState>
+      </state>
+      <state key="ProjectJDKs.UI">
+        <UIState>
+          <splitter-proportions>
+            <SplitterProportionsDataImpl>
+              <option name="proportions">
+                <list>
+                  <option value="0.2"/>
+                </list>
+              </option>
+            </SplitterProportionsDataImpl>
+          </splitter-proportions>
+          <last-edited>1.6</last-edited>
+        </UIState>
+      </state>
+      <state key="ScopeChooserConfigurable.UI">
+        <UIState>
+          <splitter-proportions>
+            <SplitterProportionsDataImpl/>
+          </splitter-proportions>
+          <settings/>
+        </UIState>
+      </state>
+    </states>
+  </component>
+</project>

core/src/main/java/org/polypheny/db/adapter/AdapterSettingDeserializer.java

@@ -0,0 +1,79 @@
+/*
+ * Copyright 2019-2023 The Polypheny Project
+ *
+ * Licensed 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.polypheny.db.adapter;
+
+import com.google.gson.JsonDeserializationContext;
+import com.google.gson.JsonDeserializer;
+import com.google.gson.JsonElement;
+import com.google.gson.JsonObject;
+import com.google.gson.JsonParseException;
+import java.lang.reflect.Type;
+import java.util.ArrayList;
+import java.util.List;
+
+
+// See https://stackoverflow.com/questions/19588020/gson-serialize-a-list-of-polymorphic-objects/22081826#22081826
+public class AdapterSettingDeserializer implements JsonDeserializer<AbstractAdapterSetting> {
+
+    @Override
+    public AbstractAdapterSetting deserialize( JsonElement json, Type typeOfT, JsonDeserializationContext context ) throws JsonParseException {
+        JsonObject jsonObject = json.getAsJsonObject();
+        String type = jsonObject.get( "type" ).getAsString();
+        String name = jsonObject.get( "name" ).getAsString();
+        boolean canBeNull = jsonObject.get( "canBeNull" ).getAsBoolean();
+        boolean required = jsonObject.get( "required" ).getAsBoolean();
+        boolean modifiable = jsonObject.get( "modifiable" ).getAsBoolean();
+        String subOf = jsonObject.has( "subOf" ) ? jsonObject.get( "subOf" ).getAsString() : null;
+        int position = jsonObject.get( "position" ).getAsInt();
+        String description = null;
+        if ( jsonObject.get( "description" ) != null ) {
+            description = jsonObject.get( "description" ).getAsString();
+        }
+
+        AbstractAdapterSetting out;
+        switch ( type ) {
+            case "Integer":
+                int integer = jsonObject.get( "defaultValue" ).getAsInt();
+                out = new AbstractAdapterSettingInteger( name, canBeNull, subOf, required, modifiable, integer, new ArrayList<>(), position );
+                break;
+            case "String":
+                String string = jsonObject.get( "defaultValue" ).getAsString();
+                out = new AbstractAdapterSettingString( name, canBeNull, subOf, required, modifiable, string, new ArrayList<>(), position );
+                break;
+            case "Boolean":
+                boolean bool = jsonObject.get( "defaultValue" ).getAsBoolean();
+                out = new AbstractAdapterSettingBoolean( name, canBeNull, subOf, required, modifiable, bool, new ArrayList<>(), position );
+                break;
+            case "List":
+                List<String> options = context.deserialize( jsonObject.get( "options" ), List.class );
+                String defaultValue = context.deserialize( jsonObject.get( "defaultValue" ), String.class );
+                out = new AbstractAdapterSettingList( name, canBeNull, subOf, required, modifiable, options, new ArrayList<>(), defaultValue, position );
+                break;
+            case "Directory":
+                String directory = context.deserialize( jsonObject.get( "directory" ), String.class );
+                String[] fileNames = context.deserialize( jsonObject.get( "fileNames" ), String[].class );
+                String value = context.deserialize( jsonObject.get( "defaultValue" ), String.class );
+                out = new AbstractAdapterSettingDirectory( name, value, canBeNull, subOf, required, modifiable, new ArrayList<>(), position ).setDirectory( directory ).setFileNames( fileNames );
+                break;
+            default:
+                throw new RuntimeException( "Could not deserialize AdapterSetting of type " + type );
+        }
+        out.setDescription( description );
+        return out;
+    }
+
+}

core/src/main/java/org/polypheny/db/algebra/core/DocumentAggregateCall.java

@@ -0,0 +1,84 @@
+/*
+ * Copyright 2019-2023 The Polypheny Project
+ *
+ * Licensed 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.polypheny.db.algebra.core;
+
+import java.util.List;
+import java.util.Optional;
+import org.polypheny.db.algebra.AlgCollations;
+import org.polypheny.db.algebra.fun.AggFunction;
+import org.polypheny.db.algebra.type.AlgDataType;
+import org.polypheny.db.catalog.exceptions.GenericRuntimeException;
+import org.polypheny.db.plan.AlgCluster;
+import org.polypheny.db.rex.RexNode;
+import org.polypheny.db.type.PolyType;
+
+public class DocumentAggregateCall {
+
+    public final String name;
+    public final AggFunction function;
+    private final RexNode input;
+
+
+    public DocumentAggregateCall( String name, AggFunction function, RexNode input ) {
+        this.name = name;
+        this.function = function;
+        this.input = input;
+    }
+
+
+    public static DocumentAggregateCall create( String name, AggFunction function, RexNode input ) {
+        return new DocumentAggregateCall( name, function, input );
+    }
+
+
+    public Optional<RexNode> getInput() {
+        return Optional.ofNullable( input );
+    }
+
+
+    public AggregateCall toAggCall( AlgDataType rowType, AlgCluster cluster ) {
+        int index = rowType.getFieldNames().indexOf( name );
+        return AggregateCall.create( function, false, false, List.of( index ), -1, AlgCollations.EMPTY, getType( cluster ), name );
+    }
+
+
+    private AlgDataType getType( AlgCluster cluster ) {
+        switch ( function.getKind() ) {
+            case COUNT:
+                return cluster.getTypeFactory().createPolyType( PolyType.BIGINT );
+            case SUM:
+            case AVG:
+                return cluster.getTypeFactory().createPolyType( PolyType.DOUBLE );
+            default:
+                throw new GenericRuntimeException( "Unknown aggregate function: " + function.getKind() );
+        }
+    }
+
+
+    public Optional<AlgDataType> requiresCast( AlgCluster cluster ) {
+        switch ( function.getKind() ) {
+            case COUNT:
+                return Optional.empty();
+            case SUM:
+            case AVG:
+                return Optional.ofNullable( cluster.getTypeFactory().createPolyType( PolyType.DOUBLE ) );
+            default:
+                return Optional.empty();
+        }
+    }
+
+}

core/src/main/java/org/polypheny/db/algebra/enumerable/EnumerableInterpretable.java

@@ -12,23 +12,6 @@
  * 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 file incorporates code covered by the following terms:
- *
- * 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.polypheny.db.algebra.enumerable;

core/src/main/java/org/polypheny/db/algebra/enumerable/EnumerableProjectRule.java

@@ -12,23 +12,6 @@
  * 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 file incorporates code covered by the following terms:
- *
- * 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.polypheny.db.algebra.enumerable;

core/src/main/java/org/polypheny/db/algebra/enumerable/EnumerableRelTableFunctionScan.java

@@ -108,4 +108,3 @@ private boolean isQueryable() {
     }
 
 }
-

core/src/main/java/org/polypheny/db/algebra/enumerable/JavaTupleFormat.java

@@ -274,4 +274,3 @@ public Expression comparer() {
      */
     public abstract Expression field( Expression expression, int field, Type fromType, Type fieldType );
 }
-

core/src/main/java/org/polypheny/db/algebra/logical/common/LogicalStreamer.java

@@ -184,7 +184,6 @@ public static void attachFilter( AlgNode modify, AlgBuilder algBuilder, RexBuild
             }
         }
 
-
         attachFilter( modify.getEntity(), algBuilder, rexBuilder, indexes );
     }
 

core/src/main/java/org/polypheny/db/algebra/metadata/AlgMetadataQuery.java

@@ -236,6 +236,7 @@ public Double getTupleCount( AlgNode alg ) {
                 rowCountHandler = revise( e.algClass, TupleCount.DEF );
             } catch ( CyclicMetadataException e ) {
                 log.warn( "Cyclic metadata detected while computing row count for {}", alg );
+                return 100D;
             }
         }
     }

core/src/main/java/org/polypheny/db/catalog/impl/NCatalog.java

@@ -0,0 +1,43 @@
+/*
+ * Copyright 2019-2023 The Polypheny Project
+ *
+ * Licensed 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.polypheny.db.catalog.impl;
+
+import io.activej.serializer.annotations.SerializeClass;
+import org.polypheny.db.catalog.impl.logical.DocumentCatalog;
+import org.polypheny.db.catalog.impl.logical.GraphCatalog;
+import org.polypheny.db.catalog.impl.logical.RelationalCatalog;
+import org.polypheny.db.catalog.logistic.DataModel;
+
+@SerializeClass(subclasses = { GraphCatalog.class, RelationalCatalog.class, DocumentCatalog.class }) // required for deserialization
+public interface NCatalog {
+
+    void commit();
+
+    void rollback();
+
+    boolean hasUncommittedChanges();
+
+    DataModel getType();
+
+    default <T extends NCatalog> T unwrap( Class<T> clazz ) {
+        if ( !this.getClass().isAssignableFrom( clazz ) ) {
+            throw new RuntimeException( String.format( "Error on retrieval the %s catalog.", clazz.getSimpleName() ) );
+        }
+        return clazz.cast( this );
+    }
+
+}