com.alibaba.fastjson2.support.csv

Class CSVReader<T>

java.lang.Object

com.alibaba.fastjson2.stream.StreamReader<T>

com.alibaba.fastjson2.support.csv.CSVReader<T>

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

Direct Known Subclasses:

CSVReaderUTF16, CSVReaderUTF8

public abstract class CSVReader<T>
extends StreamReader<T>
implements java.io.Closeable

Nested Class Summary

Nested classes/interfaces inherited from class com.alibaba.fastjson2.stream.StreamReader

StreamReader.ColumnStat, StreamReader.Feature, StreamReader.StreamReaderSpliterator<T>

Field Summary

Fields

Modifier and Type	Field and Description
protected java.lang.Class<T>	objectClass
private boolean	objectSupport
(package private) boolean	quote

Fields inherited from class com.alibaba.fastjson2.stream.StreamReader

columns, columnStats, columnStatsMap, end, errorCount, features, fieldReaders, inputEnd, lineEnd, lineNextStart, lineSize, lineStart, lineTerminated, mapping, objectCreator, off, rowCount, SIZE_512K, typeReaders, types

Constructor Summary

Constructors

Constructor and Description
CSVReader()
CSVReader(java.lang.Class<T> objectClass)
CSVReader(java.lang.reflect.Type[] types)

Method Summary

Modifier and Type	Method and Description
void	config(StreamReader.Feature... features)
void	config(StreamReader.Feature feature, boolean state)
protected java.lang.Object	error(int columnIndex, java.lang.Exception e)
int	errorCount()
java.lang.String	getColumn(int columnIndex)
java.util.List<java.lang.String>	getColumns()
StreamReader.ColumnStat	getColumnStat(int i)
StreamReader.ColumnStat	getColumnStat(java.lang.String name)
java.util.List<StreamReader.ColumnStat>	getColumnStats()
java.lang.reflect.Type	getColumnType(int columnIndex)
abstract boolean	isEnd()
boolean	isObjectSupport()
static CSVReader	of(byte[] utf8Bytes, ByteArrayValueConsumer consumer)
static <T> CSVReader<T>	of(byte[] utf8Bytes, java.nio.charset.Charset charset, java.lang.Class<T> objectClass)
static <T> CSVReader<T>	of(byte[] utf8Bytes, java.lang.Class<T> objectClass)
static <T> CSVReader<T>	of(byte[] utf8Bytes, int off, int len, java.nio.charset.Charset charset, ByteArrayValueConsumer consumer)
static <T> CSVReader<T>	of(byte[] utf8Bytes, int off, int len, java.nio.charset.Charset charset, java.lang.Class<T> objectClass)
static <T> CSVReader<T>	of(byte[] utf8Bytes, int off, int len, java.lang.Class<T> objectClass)
static CSVReader	of(byte[] utf8Bytes, java.lang.reflect.Type... types)
static <T> CSVReader<T>	of(char[] chars, java.lang.Class<T> objectClass)
static <T> CSVReader<T>	of(char[] chars, int off, int len, CharArrayValueConsumer consumer)
static <T> CSVReader<T>	of(char[] utf8Bytes, int off, int len, java.lang.Class<T> objectClass)
static CSVReader	of(char[] chars, java.lang.reflect.Type... types)
static CSVReader	of(java.io.File file, ByteArrayValueConsumer consumer)
static CSVReader	of(java.io.File file, CharArrayValueConsumer consumer)
static CSVReader	of(java.io.File file, java.nio.charset.Charset charset, ByteArrayValueConsumer consumer)
static CSVReader	of(java.io.File file, java.nio.charset.Charset charset, CharArrayValueConsumer consumer)
static <T> CSVReader<T>	of(java.io.File file, java.nio.charset.Charset charset, java.lang.Class<T> objectClass)
static CSVReader	of(java.io.File file, java.nio.charset.Charset charset, java.lang.reflect.Type... types)
static <T> CSVReader<T>	of(java.io.File file, java.lang.Class<T> objectClass)
static CSVReader	of(java.io.File file, java.lang.reflect.Type... types)
static <T> CSVReader<T>	of(java.io.InputStream in, java.nio.charset.Charset charset, java.lang.Class<T> objectClass)
static CSVReader	of(java.io.InputStream in, java.nio.charset.Charset charset, java.lang.reflect.Type... types)
static <T> CSVReader<T>	of(java.io.InputStream in, java.lang.Class<T> objectClass)
static CSVReader	of(java.io.InputStream in, java.lang.reflect.Type... types)
static <T> CSVReader<T>	of(java.io.Reader reader, java.lang.Class<T> objectClass)
static CSVReader	of(java.io.Reader in, java.lang.reflect.Type... types)
static <T> CSVReader	of(java.lang.String str, java.lang.Class<T> objectClass)
static CSVReader	of(java.lang.String str, java.lang.reflect.Type... types)
abstract void	readAll()
abstract void	readAll(int maxRows)
java.util.List<java.lang.String>	readHeader()
java.lang.String[]	readLine()
java.util.List<java.lang.String[]>	readLineAll()
T	readLineObject()
java.util.List<T>	readLineObjectAll()
abstract void	readLineObjectAll(boolean readHeader, java.util.function.Consumer<T> consumer)
void	readLineObjectAll(java.util.function.Consumer<T> consumer)
java.lang.Object[]	readLineValues()
protected abstract java.lang.Object[]	readLineValues(boolean strings)
int	rowCount()
(package private) void	rowCount(byte[] bytes, int length)
static int	rowCount(byte[] bytes, StreamReader.Feature... features)
(package private) void	rowCount(char[] bytes, int length)
static int	rowCount(char[] chars, StreamReader.Feature... features)
static int	rowCount(java.io.File file)
static int	rowCount(java.io.InputStream in)
(package private) void	rowCount(java.lang.String bytes, int length)
static int	rowCount(java.lang.String str, StreamReader.Feature... features)
void	skipLines(int lines)
abstract void	statAll()
abstract void	statAll(int maxRows)

Methods inherited from class com.alibaba.fastjson2.stream.StreamReader

seekLine, stream, stream

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.io.Closeable

close

Field Detail

quote

boolean quote

objectClass

protected java.lang.Class<T> objectClass

objectSupport

private boolean objectSupport

Constructor Detail

CSVReader

CSVReader()

CSVReader

CSVReader(java.lang.Class<T> objectClass)

CSVReader

public CSVReader(java.lang.reflect.Type[] types)

Method Detail

config

public void config(StreamReader.Feature... features)

config

public void config(StreamReader.Feature feature,
                   boolean state)

of

public static <T> CSVReader<T> of(java.io.Reader reader,
                                  java.lang.Class<T> objectClass)

of

public static <T> CSVReader of(java.lang.String str,
                               java.lang.Class<T> objectClass)

of

public static <T> CSVReader<T> of(char[] chars,
                                  java.lang.Class<T> objectClass)

of

public static <T> CSVReader<T> of(byte[] utf8Bytes,
                                  java.lang.Class<T> objectClass)

of

public static CSVReader of(java.io.File file,
                           java.lang.reflect.Type... types)
                    throws java.io.IOException

Throws:

java.io.IOException

of

public static CSVReader of(java.io.File file,
                           ByteArrayValueConsumer consumer)
                    throws java.io.IOException

Throws:

java.io.IOException

of

public static CSVReader of(java.io.File file,
                           java.nio.charset.Charset charset,
                           ByteArrayValueConsumer consumer)
                    throws java.io.IOException

Throws:

java.io.IOException

of

public static CSVReader of(java.io.File file,
                           CharArrayValueConsumer consumer)
                    throws java.io.IOException

Throws:

java.io.IOException

of

public static CSVReader of(java.io.File file,
                           java.nio.charset.Charset charset,
                           CharArrayValueConsumer consumer)
                    throws java.io.IOException

Throws:

java.io.IOException

of

public static CSVReader of(java.io.File file,
                           java.nio.charset.Charset charset,
                           java.lang.reflect.Type... types)
                    throws java.io.IOException

Throws:

java.io.IOException

of

public static <T> CSVReader<T> of(java.io.File file,
                                  java.lang.Class<T> objectClass)
                           throws java.io.IOException

Throws:

java.io.IOException

of

public static <T> CSVReader<T> of(java.io.File file,
                                  java.nio.charset.Charset charset,
                                  java.lang.Class<T> objectClass)
                           throws java.io.IOException

Throws:

java.io.IOException

of

public static CSVReader of(java.io.InputStream in,
                           java.lang.reflect.Type... types)
                    throws java.io.IOException

Throws:

java.io.IOException

of

public static <T> CSVReader<T> of(java.io.InputStream in,
                                  java.lang.Class<T> objectClass)

of

public static <T> CSVReader<T> of(java.io.InputStream in,
                                  java.nio.charset.Charset charset,
                                  java.lang.Class<T> objectClass)

of

public static CSVReader of(java.io.InputStream in,
                           java.nio.charset.Charset charset,
                           java.lang.reflect.Type... types)

of

public static CSVReader of(java.io.Reader in,
                           java.lang.reflect.Type... types)

of

public static CSVReader of(java.lang.String str,
                           java.lang.reflect.Type... types)

of

public static CSVReader of(char[] chars,
                           java.lang.reflect.Type... types)

of

public static <T> CSVReader<T> of(char[] chars,
                                  int off,
                                  int len,
                                  CharArrayValueConsumer consumer)

of

public static CSVReader of(byte[] utf8Bytes,
                           java.lang.reflect.Type... types)

of

public static CSVReader of(byte[] utf8Bytes,
                           ByteArrayValueConsumer consumer)

of

public static <T> CSVReader<T> of(byte[] utf8Bytes,
                                  int off,
                                  int len,
                                  java.nio.charset.Charset charset,
                                  ByteArrayValueConsumer consumer)

of

public static <T> CSVReader<T> of(byte[] utf8Bytes,
                                  java.nio.charset.Charset charset,
                                  java.lang.Class<T> objectClass)

of

public static <T> CSVReader<T> of(byte[] utf8Bytes,
                                  int off,
                                  int len,
                                  java.lang.Class<T> objectClass)

of

public static <T> CSVReader<T> of(byte[] utf8Bytes,
                                  int off,
                                  int len,
                                  java.nio.charset.Charset charset,
                                  java.lang.Class<T> objectClass)

of

public static <T> CSVReader<T> of(char[] utf8Bytes,
                                  int off,
                                  int len,
                                  java.lang.Class<T> objectClass)

skipLines

public void skipLines(int lines)
               throws java.io.IOException

Throws:

java.io.IOException

readHeader

public java.util.List<java.lang.String> readHeader()

getColumns

public java.util.List<java.lang.String> getColumns()

getColumn

public java.lang.String getColumn(int columnIndex)

getColumnType

public java.lang.reflect.Type getColumnType(int columnIndex)

getColumnStats

public java.util.List<StreamReader.ColumnStat> getColumnStats()

readLineObjectAll

public void readLineObjectAll(java.util.function.Consumer<T> consumer)

readLineObjectAll

public abstract void readLineObjectAll(boolean readHeader,
                                       java.util.function.Consumer<T> consumer)

readLineObject

public T readLineObject()

Specified by:

readLineObject in class StreamReader<T>

isEnd

public abstract boolean isEnd()

readLineValues

public final java.lang.Object[] readLineValues()

readLineValues

protected abstract java.lang.Object[] readLineValues(boolean strings)

readLine

public final java.lang.String[] readLine()

rowCount

public static int rowCount(java.lang.String str,
                           StreamReader.Feature... features)

rowCount

public static int rowCount(byte[] bytes,
                           StreamReader.Feature... features)

rowCount

public static int rowCount(char[] chars,
                           StreamReader.Feature... features)

rowCount

public static int rowCount(java.io.File file)
                    throws java.io.IOException

Throws:

java.io.IOException

rowCount

public static int rowCount(java.io.InputStream in)
                    throws java.io.IOException

Throws:

java.io.IOException

errorCount

public int errorCount()

rowCount

public int rowCount()

rowCount

void rowCount(java.lang.String bytes,
              int length)

rowCount

void rowCount(byte[] bytes,
              int length)

rowCount

void rowCount(char[] bytes,
              int length)

error

protected java.lang.Object error(int columnIndex,
                                 java.lang.Exception e)

getColumnStat

public StreamReader.ColumnStat getColumnStat(java.lang.String name)

getColumnStat

public StreamReader.ColumnStat getColumnStat(int i)

readLineAll

public java.util.List<java.lang.String[]> readLineAll()

Since:

2.0.30

readLineObjectAll

public java.util.List<T> readLineObjectAll()

Since:

2.0.30

isObjectSupport

public boolean isObjectSupport()

statAll

public abstract void statAll()

statAll

public abstract void statAll(int maxRows)

readAll

public abstract void readAll()

readAll

public abstract void readAll(int maxRows)