Merge pull request #1 from kadioglumf/csv-reader

feat: add csv reader.

pom.xml

@@ -35,6 +35,11 @@
             <artifactId>spring-boot-starter-web</artifactId>
         </dependency>
 
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-test</artifactId>
+        </dependency>
+
         <dependency>
             <groupId>javax.annotation</groupId>
             <artifactId>javax.annotation-api</artifactId>
@@ -77,5 +82,11 @@
             <version>${apache-commons-loggin.version}</version>
         </dependency>
 
+        <dependency>
+            <groupId>net.sf.supercsv</groupId>
+            <artifactId>super-csv</artifactId>
+            <version>2.4.0</version>
+        </dependency>
+
     </dependencies>
 </project>

src/main/java/com/kadioglumf/Main.java

@@ -1,27 +1,9 @@
 package com.kadioglumf;
 
-import com.kadioglumf.dto.excel.TestExcelDto;
-import com.kadioglumf.enums.FileExtension;
-import com.kadioglumf.service.ReaderService;
-import org.apache.commons.io.FilenameUtils;
-import org.springframework.context.i18n.LocaleContextHolder;
-
-import java.io.File;
-import java.io.FileInputStream;
-import java.util.List;
-import java.util.Locale;
-
 public class Main {
 
 
 
-    public static void main(String[] args) throws Exception {
-        LocaleContextHolder.setLocale(new Locale("tr", "TR"));
-
-        File file = new File(System.getProperty("user.dir") + "/src/main/resources/test.xlsx");
-        ReaderService readerService = new ReaderService();
-
-        List<TestExcelDto> list = readerService.readFile(TestExcelDto.class, new FileInputStream(file), FilenameUtils.getExtension(file.getName()), true);
-        list.forEach(System.out::println);
+    public static void main(String[] args) {
     }
 }

src/main/java/com/kadioglumf/annotations/csv/CsvColumn.java

@@ -0,0 +1,16 @@
+package com.kadioglumf.annotations.csv;
+
+import com.kadioglumf.cellprocessor.CellProcessor;
+import com.kadioglumf.cellprocessor.StringCell;
+
+import java.lang.annotation.ElementType;
+import java.lang.annotation.Retention;
+import java.lang.annotation.RetentionPolicy;
+import java.lang.annotation.Target;
+
+@Retention(RetentionPolicy.RUNTIME)
+@Target({ElementType.FIELD})
+public @interface CsvColumn {
+    int columnIndex();
+    Class<? extends CellProcessor> cellProcessor() default StringCell.class;
+}

src/main/java/com/kadioglumf/annotations/csv/ExportCsvSettings.java

@@ -0,0 +1,13 @@
+package com.kadioglumf.annotations.csv;
+
+import java.lang.annotation.*;
+
+@Documented
+@Target({ElementType.TYPE})
+@Retention(RetentionPolicy.RUNTIME)
+public @interface ExportCsvSettings {
+    char quoteChar() default '"';
+    char delimiterChar() default ',';
+    String endOfLineSymbols() default "\r\n";
+    boolean isFirstRowHeader() default true;
+}

src/main/java/com/kadioglumf/annotations/excel/ExcelColumn.java

@@ -8,7 +8,5 @@
 @Retention(RetentionPolicy.RUNTIME)
 @Target({ElementType.FIELD})
 public @interface ExcelColumn {
-
-    String columnName() default "";
     int columnIndex();
 }

src/main/java/com/kadioglumf/annotations/excel/ExportExcelSettings.java

@@ -0,0 +1,14 @@
+package com.kadioglumf.annotations.excel;
+
+import java.lang.annotation.Documented;
+import java.lang.annotation.ElementType;
+import java.lang.annotation.Retention;
+import java.lang.annotation.RetentionPolicy;
+import java.lang.annotation.Target;
+
+@Documented
+@Target({ElementType.TYPE})
+@Retention(RetentionPolicy.RUNTIME)
+public @interface ExportExcelSettings {
+    boolean isFirstRowHeader() default true;
+}

src/main/java/com/kadioglumf/cellprocessor/CellProcessor.java

@@ -0,0 +1,6 @@
+package com.kadioglumf.cellprocessor;
+
+public interface CellProcessor {
+
+    Object execute(Object var1, Class<?> targetType);
+}

src/main/java/com/kadioglumf/cellprocessor/DateCell.java

@@ -0,0 +1,14 @@
+package com.kadioglumf.cellprocessor;
+
+import com.kadioglumf.util.DateUtils;
+
+public class DateCell implements CellProcessor {
+
+    @Override
+    public Object execute(Object var1, Class<?> targetType) {
+        if (var1 == null) {
+            return null;
+        }
+        return DateUtils.parseStringToDateFormatted(targetType, String.valueOf(var1));
+    }
+}

src/main/java/com/kadioglumf/cellprocessor/NumberCell.java

@@ -0,0 +1,23 @@
+package com.kadioglumf.cellprocessor;
+
+import com.kadioglumf.util.NumberUtils;
+
+import java.text.ParseException;
+
+public class NumberCell implements CellProcessor {
+
+
+    @Override
+    public Object execute(Object var1, Class<?> targetType) {
+        if (var1 == null) {
+            return null;
+        }
+
+        try {
+            return NumberUtils.parseNumericValue(String.valueOf(var1), targetType);
+        }
+        catch (ParseException ex) {
+            throw new RuntimeException(); //TODO
+        }
+    }
+}

src/main/java/com/kadioglumf/cellprocessor/StringCell.java

@@ -0,0 +1,13 @@
+package com.kadioglumf.cellprocessor;
+
+public class StringCell implements CellProcessor {
+
+
+    @Override
+    public Object execute(Object var1, Class<?> targetType) {
+        if (var1 == null) {
+            return null;
+        }
+        return String.valueOf(var1);
+    }
+}

src/main/java/com/kadioglumf/dto/Tuple.java

@@ -0,0 +1,17 @@
+package com.kadioglumf.dto;
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+import lombok.Setter;
+
+import java.io.Serializable;
+
+@Getter
+@Setter
+@AllArgsConstructor
+@NoArgsConstructor
+public class Tuple<T, V> implements Serializable {
+    private transient T first;
+    private transient V second;
+}

src/main/java/com/kadioglumf/service/ReaderService.java

@@ -1,6 +1,7 @@
 package com.kadioglumf.service;
 
 import com.kadioglumf.enums.FileExtension;
+import com.kadioglumf.util.csv.CsvReaderUtils;
 import com.kadioglumf.util.excel.ExcelReaderUtil;
 import org.springframework.lang.NonNull;
 import org.springframework.stereotype.Service;
@@ -11,11 +12,15 @@
 @Service
 public class ReaderService {
 
-    public <T> List<T> readFile(@NonNull Class<T> clazz, @NonNull InputStream inputStream, @NonNull String fileExtension, @NonNull boolean isFirstRowHeader) throws Exception {
+    public <T> List<T> readFile(@NonNull Class<T> clazz, @NonNull InputStream inputStream, @NonNull String fileExtension) throws Exception {
         if (FileExtension.XLS.getValue().equals(fileExtension)
                 || FileExtension.XLSX.getValue().equals(fileExtension)) {
             ExcelReaderUtil readerUtil = new ExcelReaderUtil(inputStream, FileExtension.getFileExtensionByValue(fileExtension));
-            return readerUtil.read(clazz, isFirstRowHeader);
+            return readerUtil.read(clazz);
+        }
+        else if (FileExtension.CSV.getValue().equals(fileExtension)) {
+            CsvReaderUtils readerUtil = new CsvReaderUtils(inputStream, clazz);
+            return readerUtil.read(clazz);
         }
         return null;
     }

src/main/java/com/kadioglumf/util/BaseReaderUtils.java

@@ -4,5 +4,5 @@
 
 public abstract class BaseReaderUtils {
 
-    protected abstract <T> List<T> read(Class<T> clazz, boolean isFirstRowHeader) throws Exception;
+    protected abstract <T> List<T> read(Class<T> clazz) throws Exception;
 }