Skip to content

Commit 7bb63f5

Browse files
authored
[WVuGDROz] Allow cypher.export.schema return using a stream (#4072)
1 parent 1368ca7 commit 7bb63f5

File tree

2 files changed

+3
-5
lines changed

2 files changed

+3
-5
lines changed

core/src/main/java/apoc/export/cypher/ExportCypher.java

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -148,9 +148,6 @@ public Stream<DataProgressInfo> schema(
148148
throws IOException {
149149
if (Util.isNullOrEmpty(fileName)) fileName = null;
150150
String source = String.format("database: nodes(%d), rels(%d)", Util.nodeCount(tx), Util.relCount(tx));
151-
// streamStatements
152-
config.put("stream", false);
153-
config.put("streamStatements", false);
154151
return exportCypher(fileName, source, new DatabaseSubGraph(tx), new ExportConfig(config), true);
155152
}
156153

@@ -202,7 +199,7 @@ private void doExport(
202199
ExportFileManager cypherFileManager) {
203200
MultiStatementCypherSubGraphExporter exporter = new MultiStatementCypherSubGraphExporter(graph, c, db);
204201

205-
if (onlySchema) exporter.exportOnlySchema(cypherFileManager, c);
202+
if (onlySchema) exporter.exportOnlySchema(cypherFileManager, reporter, c);
206203
else exporter.export(c, reporter, cypherFileManager);
207204
}
208205

core/src/main/java/apoc/export/cypher/MultiStatementCypherSubGraphExporter.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -117,10 +117,11 @@ public void export(ExportConfig config, Reporter reporter, ExportFileManager cyp
117117
reporter.done();
118118
}
119119

120-
public void exportOnlySchema(ExportFileManager cypherFileManager, ExportConfig config) {
120+
public void exportOnlySchema(ExportFileManager cypherFileManager, Reporter reporter, ExportConfig config) {
121121
PrintWriter schemaWriter = cypherFileManager.getPrintWriter("schema");
122122
exportSchema(schemaWriter, config);
123123
schemaWriter.close();
124+
reporter.done();
124125
}
125126

126127
// ---- Nodes ----

0 commit comments

Comments
 (0)