sqimport

package

v1.0.35 Latest Latest Go to latest Published: Sep 11, 2021 License: Apache-2.0 Imports: 17 Imported by: 0

Details

This section is empty.

View Source

var (
	DefaultConfig = SQImportConfig{
		Header:     true,
		TrimSpace:  true,
		LazyQuotes: true,
	}
)

This section is empty.

type Importer struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func DefaultImporter(url string, writer SQWriter) (*Importer, error)

Create an importer with default configuation

func NewImporter(c SQImportConfig, u string, writer SQWriter) (*Importer, error)

Create a new importer with a database writer

func (this *Importer) Decoder(mimetype string) (SQImportDecoder, error)

Return a new decoder for the given mimetype

func (this *Importer) Name() string

func (this *Importer) NewCSVDecoder(r io.Reader, delimiter rune) (SQImportDecoder, error)

NewCSVDecoder returns a CSV decoder setting options

func (this *Importer) ReadWrite() error

Read a row from the source data and potentially insert into the table. On end of data, returns io.EOF.

func (this *Importer) URL() *url.URL

type SQLWriter struct {
	*sqlite3.ConnEx
	// contains filtered or unexported fields
}

func NewSQLWriter(c SQImportConfig, db *sqlite3.ConnEx) (*SQLWriter, error)

func (this *SQLWriter) Begin(name, schema string, cols []string) (WriterFunc, error)

Begin a transaction, passing a writing function back to the caller

func (this *SQLWriter) End(success bool) error

type WriterFunc func(row []interface{}) error