iSharkFly-Docs
/
java-tutorials
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

https://jira.baeldung.com/browse/BAEL-5403 

Editor Review changes:
* reverted SpringBootPersistenceApplication.java
* created SpringBootJsonConvertFileApplication.java in article package:
com.baeldung.boot.json.convertfile
This commit is contained in:
Ulisses Lima 2022-03-22 19:27:49 -03:00
parent ec403bd427
commit e5c34a56c2
2 changed files with 59 additions and 48 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

49
persistence-modules/spring-boot-persistence-mongodb/src/main/java/com/baeldung/SpringBootPersistenceApplication.java
View File

@ -1,60 +1,13 @@
package com.baeldung; package com.baeldung;
import java.io.File;
import java.util.ArrayList;
import java.util.List;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.ApplicationArguments;
import org.springframework.boot.ApplicationRunner;
import org.springframework.boot.SpringApplication; import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.ApplicationContext;
import com.baeldung.boot.json.convertfile.ImportUtils;
import com.baeldung.boot.json.convertfile.service.ImportJsonService;
@SpringBootApplication @SpringBootApplication
public class SpringBootPersistenceApplication implements ApplicationRunner { public class SpringBootPersistenceApplication {
private Logger log = LogManager.getLogger(this.getClass());
private static final String RESOURCE_PREFIX = "classpath:";
@Autowired
private ApplicationContext context;
public static void main(String ... args) { public static void main(String ... args) {
SpringApplication.run(SpringBootPersistenceApplication.class, args); SpringApplication.run(SpringBootPersistenceApplication.class, args);
} }
@Override
public void run(ApplicationArguments args) throws Exception {
if (args.containsOption("import")) {
if (!args.containsOption("collection"))
throw new IllegalArgumentException("required option: --collection with collection name when using --import");
String collection = args.getOptionValues("collection")
.get(0);
List<String> sources = args.getOptionValues("import");
for (String source : sources) {
List<String> jsonLines = new ArrayList<>();
if (source.startsWith(RESOURCE_PREFIX)) {
String resource = source.substring(RESOURCE_PREFIX.length());
jsonLines = ImportUtils.linesFromResource(resource);
} else {
jsonLines = ImportUtils.lines(new File(source));
}
if (jsonLines == null || jsonLines.isEmpty()) {
log.warn(source + " - no input to import");
} else {
ImportJsonService importService = context.getBean(ImportJsonService.class);
String result = importService.importTo(collection, jsonLines);
log.info(source + " - import result: " + result);
}
}
}
}
} }

58
persistence-modules/spring-boot-persistence-mongodb/src/main/java/com/baeldung/boot/json/convertfile/SpringBootJsonConvertFileApplication.java Normal file
View File

@ -0,0 +1,58 @@
package com.baeldung.boot.json.convertfile;
import java.io.File;
import java.util.ArrayList;
import java.util.List;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.ApplicationArguments;
import org.springframework.boot.ApplicationRunner;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import com.baeldung.boot.json.convertfile.service.ImportJsonService;
@SpringBootApplication
public class SpringBootJsonConvertFileApplication implements ApplicationRunner {
private Logger log = LogManager.getLogger(this.getClass());
private static final String RESOURCE_PREFIX = "classpath:";
@Autowired
private ImportJsonService importService;
public static void main(String ... args) {
SpringApplication.run(SpringBootJsonConvertFileApplication.class, args);
}
@Override
public void run(ApplicationArguments args) throws Exception {
if (args.containsOption("import")) {
if (!args.containsOption("collection"))
throw new IllegalArgumentException("required option: --collection with collection name when using --import");
String collection = args.getOptionValues("collection")
.get(0);
List<String> sources = args.getOptionValues("import");
for (String source : sources) {
List<String> jsonLines = new ArrayList<>();
if (source.startsWith(RESOURCE_PREFIX)) {
String resource = source.substring(RESOURCE_PREFIX.length());
jsonLines = ImportUtils.linesFromResource(resource);
} else {
jsonLines = ImportUtils.lines(new File(source));
}
if (jsonLines == null || jsonLines.isEmpty()) {
log.warn(source + " - no input to import");
} else {
// ImportJsonService importService = context.getBean(ImportJsonService.class);
String result = importService.importTo(collection, jsonLines);
log.info(source + " - import result: " + result);
}
}
}
}
}