dbcsv

package module
v0.4.12 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 12, 2023 License: Apache-2.0 Imports: 31 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Unknown = FType("")
	Csv     = FType("csv")
	Xls     = FType("xls")
	XlsX    = FType("xlsx")
	Gzip    = FType("gzip")
	Zstd    = FType("zstd")
)

Variables

View Source 
var (
	DateEnd    string
	DateFormat = "2006-01-02"
)
View Source 
var DefaultEncoding = NamedEncoding{Encoding: encoding.Replacement, Name: "utf-8"}
View Source 
var ErrUnknownSheet = errors.New("unknown sheet")

Functions

func DumpCSV added in v0.2.0 

func DumpCSV(ctx context.Context, w io.Writer, rows *sql.Rows, columns []Column, header bool, sep string, raw bool) error

func DumpSheet added in v0.2.0 

func DumpSheet(ctx context.Context, sheet spreadsheet.Sheet, rows *sql.Rows, columns []Column) error

func ReadCSV 

func ReadCSV(ctx context.Context, fn func(context.Context, Row) error, r io.Reader, delim string, columns []int, skip int) error

func ReadXLSFile 

func ReadXLSFile(ctx context.Context, fn func(context.Context, string, Row) error, filename string, charset string, sheetIndex int, columns []int, skip int) error

func ReadXLSXFile 

func ReadXLSXFile(ctx context.Context, fn func(context.Context, string, Row) error, filename string, sheetIndex int, columns []int, skip int) error

func Wrap added in v0.0.5 

func Wrap(ctx context.Context) (context.Context, context.CancelFunc)

Wrap returns a new context with cancel that is canceled on interrupts.

Types

type Column added in v0.2.0 

type Column struct {
	reflect.Type
	Name, DatabaseType string
	Precision, Scale   int
}

func GetColumns added in v0.2.0 

func GetColumns(ctx context.Context, rows interface{}) ([]Column, error)

func (Column) Converter added in v0.2.0 

func (col Column) Converter(sep string) Stringer

type Config 

type Config struct {
	Delim         string
	Charset       string
	ColumnsString string

	Sheet, Skip int
	// contains filtered or unexported fields
}

func (*Config) Close 

func (cfg *Config) Close() error

func (*Config) Columns 

func (cfg *Config) Columns() ([]int, error)

func (*Config) Encoding 

func (cfg *Config) Encoding() (encoding.Encoding, error)

func (*Config) Open 

func (cfg *Config) Open(fileName string) error

func (*Config) ReadRows 

func (cfg *Config) ReadRows(ctx context.Context, fn func(context.Context, string, Row) error) (err error)

func (*Config) ReadSheets added in v0.0.5 

func (cfg *Config) ReadSheets(ctx context.Context) (map[int]string, error)

func (*Config) Rewind added in v0.0.17 

func (cfg *Config) Rewind() error

func (*Config) Type 

func (cfg *Config) Type() (FileType, error)

type FType added in v0.1.0 

type FType string

type FileType 

type FileType struct {
	Type        FType
	Compression FType
}

func DetectReaderType 

func DetectReaderType(r io.Reader, fileName string) (FileType, error)

type NamedEncoding added in v0.0.4 

type NamedEncoding struct {
	encoding.Encoding
	Name string
}

func EncFromName added in v0.0.4 

func EncFromName(e string) (NamedEncoding, error)

type Row 

type Row struct {
	Values  []string
	Columns []string
	Line    int
}

type Stringer added in v0.2.0 

type Stringer interface {
	String() string
	Pointer() interface{}
	sql.Scanner
	driver.Valuer
}

type StringsValue added in v0.0.4 

type StringsValue struct {
	Strings []string
}

func FlagStrings added in v0.0.4 

func FlagStrings() *StringsValue

func (*StringsValue) Set added in v0.0.4 

func (ss *StringsValue) Set(s string) error

func (StringsValue) String added in v0.0.4 

func (ss StringsValue) String() string

type ValBytes added in v0.4.1 

type ValBytes struct {
	Sep string
	// contains filtered or unexported fields
}

func (*ValBytes) Pointer added in v0.4.1 

func (v *ValBytes) Pointer() interface{}

func (*ValBytes) Scan added in v0.4.1 

func (v *ValBytes) Scan(x interface{}) error

func (ValBytes) String added in v0.4.1 

func (v ValBytes) String() string

func (ValBytes) StringRaw added in v0.4.1 

func (v ValBytes) StringRaw() string

func (ValBytes) Value added in v0.4.1 

func (v ValBytes) Value() (driver.Value, error)

type ValFloat added in v0.2.0 

type ValFloat struct {
	// contains filtered or unexported fields
}

func (*ValFloat) Pointer added in v0.2.0 

func (v *ValFloat) Pointer() interface{}

func (*ValFloat) Scan added in v0.2.0 

func (v *ValFloat) Scan(x interface{}) error

func (ValFloat) String added in v0.2.0 

func (v ValFloat) String() string

func (ValFloat) Value added in v0.2.0 

func (v ValFloat) Value() (driver.Value, error)

type ValInt added in v0.2.0 

type ValInt struct {
	// contains filtered or unexported fields
}

func (*ValInt) Pointer added in v0.2.0 

func (v *ValInt) Pointer() interface{}

func (*ValInt) Scan added in v0.2.0 

func (v *ValInt) Scan(x interface{}) error

func (ValInt) String added in v0.2.0 

func (v ValInt) String() string

func (ValInt) Value added in v0.2.0 

func (v ValInt) Value() (driver.Value, error)

type ValNumber added in v0.4.6 

type ValNumber struct {
	Sep string
	// contains filtered or unexported fields
}

func (*ValNumber) Pointer added in v0.4.6 

func (v *ValNumber) Pointer() interface{}

func (*ValNumber) Scan added in v0.4.6 

func (v *ValNumber) Scan(x interface{}) error

func (ValNumber) String added in v0.4.6 

func (v ValNumber) String() string

func (ValNumber) StringRaw added in v0.4.6 

func (v ValNumber) StringRaw() string

func (ValNumber) Value added in v0.4.6 

func (v ValNumber) Value() (driver.Value, error)

type ValString added in v0.2.0 

type ValString struct {
	Sep string
	// contains filtered or unexported fields
}

func (*ValString) Pointer added in v0.2.0 

func (v *ValString) Pointer() interface{}

func (*ValString) Scan added in v0.2.0 

func (v *ValString) Scan(x interface{}) error

func (ValString) String added in v0.2.0 

func (v ValString) String() string

func (ValString) StringRaw added in v0.2.0 

func (v ValString) StringRaw() string

func (ValString) Value added in v0.2.0 

func (v ValString) Value() (driver.Value, error)

type ValTime added in v0.2.0 

type ValTime struct {
	Quote bool
	// contains filtered or unexported fields
}

func (*ValTime) Pointer added in v0.2.0 

func (v *ValTime) Pointer() interface{}

func (*ValTime) Scan added in v0.2.0 

func (vt *ValTime) Scan(v interface{}) error

func (ValTime) String added in v0.2.0 

func (v ValTime) String() string

func (ValTime) StringRaw added in v0.2.0 

func (v ValTime) StringRaw() string

func (ValTime) Value added in v0.2.0 

func (v ValTime) Value() (driver.Value, error)

Source Files

View all Source files

Directories

Path Synopsis
Package main in csvdump represents a cursor->csv dumper
 Package main in csvdump represents a cursor->csv dumper
lib
Package main in paraexp represents a parallel query-to-JSON dumper
 Package main in paraexp represents a parallel query-to-JSON dumper
Package main in tablecopy is a table copier between databases.
 Package main in tablecopy is a table copier between databases.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.