|
|
@ -2,14 +2,14 @@ package io.sc.platform.data.csv; |
|
|
|
|
|
|
|
import com.opencsv.CSVReader; |
|
|
|
import com.opencsv.CSVReaderBuilder; |
|
|
|
import com.opencsv.CSVWriter; |
|
|
|
import io.sc.platform.data.ItemReader; |
|
|
|
import org.springframework.core.io.DefaultResourceLoader; |
|
|
|
import org.springframework.core.io.Resource; |
|
|
|
import org.springframework.util.StringUtils; |
|
|
|
|
|
|
|
import java.io.BufferedReader; |
|
|
|
import java.io.IOException; |
|
|
|
import java.io.InputStreamReader; |
|
|
|
import java.io.*; |
|
|
|
import java.util.Arrays; |
|
|
|
import java.util.Iterator; |
|
|
|
|
|
|
|
public class CsvItemReader implements ItemReader<Record> { |
|
|
@ -96,4 +96,25 @@ public class CsvItemReader implements ItemReader<Record> { |
|
|
|
public void setIterator(Iterator<String[]> iterator) { |
|
|
|
this.iterator = iterator; |
|
|
|
} |
|
|
|
|
|
|
|
public static void main(String[] args) throws IOException { |
|
|
|
FileWriter writer =new FileWriter("/Users/wangshaoping/wspsc/workspace/wangshaoping/v8/platform/io.sc.platform.data/new.csv"); |
|
|
|
CSVWriter csvWriter = new CSVWriter(writer); |
|
|
|
String[] records =new String[2]; |
|
|
|
records[0] ="col1"; |
|
|
|
records[1] ="col2,name\nok,\"ok\""; |
|
|
|
csvWriter.writeNext(records); |
|
|
|
records =new String[2]; |
|
|
|
records[0] ="col1"; |
|
|
|
records[1] ="col2,name\nok,\"ok\""; |
|
|
|
csvWriter.writeNext(records); |
|
|
|
csvWriter.close(); |
|
|
|
|
|
|
|
BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(new FileInputStream("/Users/wangshaoping/wspsc/workspace/wangshaoping/v8/platform/io.sc.platform.data/new.csv"))); |
|
|
|
CSVReader reader = new CSVReaderBuilder(bufferedReader).build(); |
|
|
|
Iterator<String[]> iterator = reader.iterator(); |
|
|
|
while(iterator.hasNext()){ |
|
|
|
System.out.println(Arrays.toString(iterator.next())); |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|