|
|
@@ -8,6 +8,7 @@ import com.example.bigsql.entity.UploadBigsqlFileRecordBaseVO;
|
|
|
import com.example.bigsql.util.ExecuteShellUtil;
|
|
|
import com.example.bigsql.util.JyDbUtil;
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
+import org.apache.commons.lang3.StringUtils;
|
|
|
import org.springframework.stereotype.Service;
|
|
|
|
|
|
import java.io.*;
|
|
|
@@ -212,7 +213,10 @@ public class CreateDatabasesByV3File {
|
|
|
Map<String, FileWriter> fileWriterMap = new HashMap<>();
|
|
|
File file = new File(path);
|
|
|
if (!list.isEmpty()) {
|
|
|
- File[] files = searchFile(file, list.get(0).getFileName());
|
|
|
+ File[] files = searchFile(file, StringUtils.trim(list.get(0).getFileName()));
|
|
|
+ if (files.length == 0) {
|
|
|
+ log.info("两个文件名不一致或没有找到相应的文件");
|
|
|
+ }
|
|
|
//根据文件名查找文件 正常没有数据或只有一条数据
|
|
|
for (File f : files) {
|
|
|
log.info("开始解析sql文件,文件名：" + f.getName());
|
