migrate export to database

applications/facade/build.gradle

@@ -5,6 +5,12 @@ description = 'Neo4j Graph Data Science :: Application Facade'
 group = 'org.neo4j.gds'
 
 dependencies {
+    neodeps().each {
+        compileOnly(group: 'org.neo4j', name: it, version: ver.'neo4j') {
+            transitive = false
+        }
+    }
+
     implementation project(":algo")
     implementation project(":algorithms-machinery")
     implementation project(":centrality-algorithms")

applications/facade/src/main/java/org/neo4j/gds/applications/ApplicationsFacade.java

@@ -22,7 +22,6 @@
 import org.neo4j.gds.algorithms.similarity.WriteRelationshipService;
 import org.neo4j.gds.applications.algorithms.centrality.CentralityApplications;
 import org.neo4j.gds.applications.algorithms.community.CommunityApplications;
-import org.neo4j.gds.applications.modelcatalog.ModelRepository;
 import org.neo4j.gds.applications.algorithms.embeddings.NodeEmbeddingApplications;
 import org.neo4j.gds.applications.algorithms.machinery.AlgorithmEstimationTemplate;
 import org.neo4j.gds.applications.algorithms.machinery.AlgorithmProcessingTemplate;
@@ -40,13 +39,16 @@
 import org.neo4j.gds.applications.graphstorecatalog.GraphCatalogApplications;
 import org.neo4j.gds.applications.modelcatalog.DefaultModelCatalogApplications;
 import org.neo4j.gds.applications.modelcatalog.ModelCatalogApplications;
+import org.neo4j.gds.applications.modelcatalog.ModelRepository;
 import org.neo4j.gds.applications.operations.OperationsApplications;
 import org.neo4j.gds.core.loading.GraphStoreCatalogService;
 import org.neo4j.gds.core.model.ModelCatalog;
 import org.neo4j.gds.logging.Log;
 import org.neo4j.gds.memest.DatabaseGraphStoreEstimationService;
 import org.neo4j.gds.metrics.algorithms.AlgorithmMetricsService;
 import org.neo4j.gds.metrics.projections.ProjectionMetricsService;
+import org.neo4j.graphdb.GraphDatabaseService;
+import org.neo4j.graphdb.Transaction;
 
 import java.util.Optional;
 import java.util.function.Function;
@@ -106,7 +108,9 @@ public static ApplicationsFacade create(
         RequestScopedDependencies requestScopedDependencies,
         WriteContext writeContext,
         ModelCatalog modelCatalog,
-        ModelRepository modelRepository
+        ModelRepository modelRepository,
+        GraphDatabaseService graphDatabaseService,
+        Transaction procedureTransaction
     ) {
         var databaseGraphStoreEstimationService = new DatabaseGraphStoreEstimationService(
             requestScopedDependencies.getGraphLoaderContext(),
@@ -154,9 +158,12 @@ public static ApplicationsFacade create(
 
         var graphCatalogApplications = createGraphCatalogApplications(
             log,
-            graphCatalogApplicationsDecorator,
             graphStoreCatalogService,
-            projectionMetricsService
+            projectionMetricsService,
+            requestScopedDependencies,
+            graphDatabaseService,
+            procedureTransaction,
+            graphCatalogApplicationsDecorator
         );
 
         var miscellaneousApplications = MiscellaneousApplications.create(
@@ -245,14 +252,20 @@ private static AlgorithmProcessingTemplate createAlgorithmProcessingTemplate(
 
     private static GraphCatalogApplications createGraphCatalogApplications(
         Log log,
-        Optional<Function<GraphCatalogApplications, GraphCatalogApplications>> graphCatalogApplicationsDecorator,
         GraphStoreCatalogService graphStoreCatalogService,
-        ProjectionMetricsService projectionMetricsService
+        ProjectionMetricsService projectionMetricsService,
+        RequestScopedDependencies requestScopedDependencies,
+        GraphDatabaseService graphDatabaseService,
+        Transaction procedureTransaction,
+        Optional<Function<GraphCatalogApplications, GraphCatalogApplications>> graphCatalogApplicationsDecorator
     ) {
         var graphCatalogApplications = DefaultGraphCatalogApplications.create(
             log,
             graphStoreCatalogService,
-            projectionMetricsService
+            projectionMetricsService,
+            requestScopedDependencies,
+            graphDatabaseService,
+            procedureTransaction
         );
 
         if (graphCatalogApplicationsDecorator.isEmpty()) return graphCatalogApplications;

applications/graph-store-catalog/build.gradle

@@ -38,6 +38,7 @@ dependencies {
     implementation project(':graph-projection-api')
     implementation project(':graph-sampling')
     implementation project(':graph-schema-api')
+    implementation project(':io-core')
     implementation project(':legacy-cypher-projection')
     implementation project(':logging')
     implementation project(':memory-usage')

applications/graph-store-catalog/src/main/java/org/neo4j/gds/applications/graphstorecatalog/DatabaseExportResult.java

@@ -0,0 +1,46 @@
+/*
+ * Copyright (c) "Neo4j"
+ * Neo4j Sweden AB [http://neo4j.com]
+ *
+ * This file is part of Neo4j.
+ *
+ * Neo4j is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program.  If not, see <http://www.gnu.org/licenses/>.
+ */
+package org.neo4j.gds.applications.graphstorecatalog;
+
+public class DatabaseExportResult extends GraphStoreExportResult {
+    public final String dbName;
+
+    public DatabaseExportResult(
+        String graphName,
+        String dbName,
+        long nodeCount,
+        long relationshipCount,
+        long relationshipTypeCount,
+        long nodePropertyCount,
+        long relationshipPropertyCount,
+        long writeMillis
+    ) {
+        super(
+            graphName,
+            nodeCount,
+            relationshipCount,
+            relationshipTypeCount,
+            nodePropertyCount,
+            relationshipPropertyCount,
+            writeMillis
+        );
+        this.dbName = dbName;
+    }
+}

applications/graph-store-catalog/src/main/java/org/neo4j/gds/applications/graphstorecatalog/DefaultGraphCatalogApplications.java

@@ -24,7 +24,9 @@
 import org.neo4j.gds.api.GraphName;
 import org.neo4j.gds.api.User;
 import org.neo4j.gds.applications.algorithms.machinery.MemoryEstimateResult;
+import org.neo4j.gds.applications.algorithms.machinery.RequestScopedDependencies;
 import org.neo4j.gds.beta.filter.GraphFilterResult;
+import org.neo4j.gds.core.io.db.GraphStoreToDatabaseExporterConfig;
 import org.neo4j.gds.core.loading.CatalogRequest;
 import org.neo4j.gds.core.loading.GraphDropNodePropertiesResult;
 import org.neo4j.gds.core.loading.GraphDropRelationshipResult;
@@ -44,6 +46,7 @@
 import org.neo4j.gds.termination.TerminationFlag;
 import org.neo4j.gds.transaction.TransactionContext;
 import org.neo4j.graphdb.GraphDatabaseService;
+import org.neo4j.graphdb.Transaction;
 
 import java.util.List;
 import java.util.Map;
@@ -104,6 +107,7 @@ public class DefaultGraphCatalogApplications implements GraphCatalogApplications
     private final GraphSamplingApplication graphSamplingApplication;
     private final EstimateCommonNeighbourAwareRandomWalkApplication estimateCommonNeighbourAwareRandomWalkApplication;
     private final GenerateGraphApplication generateGraphApplication;
+    private final ExportToDatabaseApplication exportToDatabaseApplication;
 
     DefaultGraphCatalogApplications(
         Log log,
@@ -128,7 +132,8 @@ public class DefaultGraphCatalogApplications implements GraphCatalogApplications
         WriteNodeLabelApplication writeNodeLabelApplication,
         WriteNodePropertiesApplication writeNodePropertiesApplication,
         WriteRelationshipPropertiesApplication writeRelationshipPropertiesApplication,
-        WriteRelationshipsApplication writeRelationshipsApplication
+        WriteRelationshipsApplication writeRelationshipsApplication,
+        ExportToDatabaseApplication exportToDatabaseApplication
     ) {
         this.log = log;
         this.graphStoreCatalogService = graphStoreCatalogService;
@@ -155,12 +160,16 @@ public class DefaultGraphCatalogApplications implements GraphCatalogApplications
         this.graphSamplingApplication = graphSamplingApplication;
         this.estimateCommonNeighbourAwareRandomWalkApplication = estimateCommonNeighbourAwareRandomWalkApplication;
         this.generateGraphApplication = generateGraphApplication;
+        this.exportToDatabaseApplication = exportToDatabaseApplication;
     }
 
     public static GraphCatalogApplications create(
         Log log,
         GraphStoreCatalogService graphStoreCatalogService,
-        ProjectionMetricsService projectionMetricsService
+        ProjectionMetricsService projectionMetricsService,
+        RequestScopedDependencies requestScopedDependencies,
+        GraphDatabaseService graphDatabaseService,
+        Transaction procedureTransaction
     ) {
         var graphNameValidationService = new GraphNameValidationService();
 
@@ -175,6 +184,7 @@ public static GraphCatalogApplications create(
         var dropNodePropertiesApplication = new DropNodePropertiesApplication(log);
         var dropRelationshipsApplication = new DropRelationshipsApplication(log);
         var estimateCommonNeighbourAwareRandomWalkApplication = new EstimateCommonNeighbourAwareRandomWalkApplication();
+        var exportToDatabaseApplication = new ExportToDatabaseApplication(log, graphStoreCatalogService, graphDatabaseService, procedureTransaction, requestScopedDependencies.getDatabaseId(), requestScopedDependencies.getTaskRegistryFactory(), requestScopedDependencies.getUser(), requestScopedDependencies.getUserLogRegistryFactory());
         var generateGraphApplication = new GenerateGraphApplication(log, graphStoreCatalogService);
         var graphMemoryUsageApplication = new GraphMemoryUsageApplication(graphStoreCatalogService);
         var graphSamplingApplication = new GraphSamplingApplication(log, graphStoreCatalogService);
@@ -209,6 +219,7 @@ public static GraphCatalogApplications create(
             .withDropNodePropertiesApplication(dropNodePropertiesApplication)
             .withDropRelationshipsApplication(dropRelationshipsApplication)
             .withEstimateCommonNeighbourAwareRandomWalkApplication(estimateCommonNeighbourAwareRandomWalkApplication)
+            .withExportToDatabaseApplication(exportToDatabaseApplication)
             .withGenerateGraphApplication(generateGraphApplication)
             .withGraphMemoryUsageApplication(graphMemoryUsageApplication)
             .withGraphSamplingApplication(graphSamplingApplication)
@@ -234,9 +245,9 @@ public boolean graphExists(User user, DatabaseId databaseId, String graphNameAsS
     }
 
     /**
-     * @param failIfMissing enable validation that graphs exist before dropping them
-     * @param databaseNameOverride  optional override
-     * @param usernameOverride      optional override
+     * @param failIfMissing        enable validation that graphs exist before dropping them
+     * @param databaseNameOverride optional override
+     * @param usernameOverride     optional override
      * @throws IllegalArgumentException if a database name was null or blank or not a String
      */
     @Override
@@ -254,7 +265,13 @@ public List<GraphStoreCatalogEntry> dropGraph(
         var databaseId = currentDatabase.orOverride(databaseNameOverride);
         var parsedUsernameOverride = User.parseUsernameOverride(usernameOverride);
 
-        return dropGraphApplication.compute(validatedGraphNames, failIfMissing, databaseId, operator, parsedUsernameOverride);
+        return dropGraphApplication.compute(
+            validatedGraphNames,
+            failIfMissing,
+            databaseId,
+            operator,
+            parsedUsernameOverride
+        );
     }
 
     @Override
@@ -968,6 +985,14 @@ public GraphGenerationStats generateGraph(
         return generateGraphApplication.compute(databaseId, averageDegree, configuration);
     }
 
+    @Override
+    public DatabaseExportResult exportToDatabase(
+        GraphName graphName,
+        GraphStoreToDatabaseExporterConfig configuration
+    ) {
+        return exportToDatabaseApplication.run(graphName, configuration);
+    }
+
     private RandomWalkSamplingResult sampleRandomWalk(
         User user,
         DatabaseId databaseId,