trdsql

Oct 28, 2024

Changes in this version

type Format

+ const TEXT

type ReadOpt

+ func InRowNumber(t bool) ReadOpt

type ReadOpts

+ InRowNumber bool

+ type TextReader struct

+ func NewTextReader(reader io.Reader, opts *ReadOpts) (*TextReader, error)

+ func (r *TextReader) Names() ([]string, error)

+ func (r *TextReader) PreReadRow() [][]any

+ func (r *TextReader) ReadRow([]any) ([]any, error)

+ func (r *TextReader) Types() ([]string, error)

Dec 14, 2023

Changes in this version

+ func EnableMultipleQueries()

type DB

+ func (db *DB) OtherExecContext(ctx context.Context, query string) error

Nov 10, 2023

Changes in this version

+ func RegisterReaderFunc(ext string, readerFunc ReaderFunc)

type CSVReader

+ func NewPSVReader(reader io.Reader, opts *ReadOpts) (*CSVReader, error)

+ func NewTSVReader(reader io.Reader, opts *ReadOpts) (*CSVReader, error)

type Format

+ func OutputFormat(ext string) Format

+ type ReaderFunc func(io.Reader, *ReadOpts) (Reader, error)

Oct 16, 2023

Changes in this version

+ var DefaultDriver = "sqlite3"

Sep 28, 2023

Changes in this version

+ var ErrInvalidJSON = errors.New("invalid JSON")

+ var ErrInvalidYAML = errors.New("invalid YAML")

type Format

+ const YAML

type WriteOpts

+ OutJSONToYAML bool

+ type YAMLReader struct

+ func NewYAMLReader(reader io.Reader, opts *ReadOpts) (*YAMLReader, error)

+ func (r *YAMLReader) Names() ([]string, error)

+ func (r *YAMLReader) PreReadRow() [][]interface{}

+ func (r *YAMLReader) ReadRow(row []interface{}) ([]interface{}, error)

+ func (r *YAMLReader) Types() ([]string, error)

+ type YAMLWriter struct

+ func NewYAMLWriter(writeOpts *WriteOpts) *YAMLWriter

+ func (w *YAMLWriter) PostWrite() error

+ func (w *YAMLWriter) PreWrite(columns []string, types []string) error

+ func (w *YAMLWriter) WriteRow(values []interface{}, columns []string) error

Mar 18, 2023

Changes in this version

type Format

+ const WIDTH

+ type GWReader struct

+ func NewGWReader(reader io.Reader, opts *ReadOpts) (*GWReader, error)

+ func (r *GWReader) Names() ([]string, error)

+ func (r *GWReader) PreReadRow() [][]interface{}

+ func (r *GWReader) ReadRow(row []interface{}) ([]interface{}, error)

+ func (r *GWReader) Types() ([]string, error)

May 2, 2022

Changes in this version

type ReadOpt

+ func InNULL(s string) ReadOpt

+ func InNeedNULL(n bool) ReadOpt

type ReadOpts

+ InNULL string

+ InNeedNULL bool

+ func GuessOpts(readOpts *ReadOpts, fileName string) (*ReadOpts, string)

type WriteOpt

+ func OutNULL(s string) WriteOpt

+ func OutNeedNULL(n bool) WriteOpt

type WriteOpts

+ OutNULL string

+ OutNeedNULL bool

Jan 6, 2022

Changes in this version

type ReadOpt

+ func InLimitRead(p bool) ReadOpt

type ReadOpts

+ InLimitRead bool

May 24, 2021

Changes in this version

type Format

+ const PSV

+ const TSV

type ReadOpt

+ func InJQ(p string) ReadOpt

type ReadOpts

+ InJQuery string

Jan 26, 2021

Changes in this version

+ var ErrInvalidColumn = errors.New("invalid column")

+ var ErrNoMatchFound = errors.New("no match found")

+ var ErrNoReader = errors.New("no reader")

+ var ErrNoRows = errors.New("no rows")

+ var ErrNoStatement = errors.New("no SQL statement")

+ var ErrNonDefinition = errors.New("no definition")

+ var ErrUnableConvert = errors.New("unable to convert")

+ var ErrUnknownFormat = errors.New("unknown format")

+ func ImportFileContext(ctx context.Context, db *DB, fileName string, readOpts *ReadOpts) (string, error)

type BufferImporter

+ func (i *BufferImporter) ImportContext(ctx context.Context, db *DB, query string) (string, error)

type DB

+ func (db *DB) CreateTableContext(ctx context.Context, tableName string, columnNames []string, ...) error

+ func (db *DB) ImportContext(ctx context.Context, tableName string, columnNames []string, reader Reader) error

+ func (db *DB) SelectContext(ctx context.Context, query string) (*sql.Rows, error)

type Exporter

+ ExportContext func(ctx context.Context, db *DB, query string) error

type Importer

+ ImportContext func(ctx context.Context, db *DB, query string) (string, error)

type ReadFormat

+ func (i *ReadFormat) ImportContext(ctx context.Context, db *DB, query string) (string, error)

type SliceImporter

+ func (i *SliceImporter) ImportContext(ctx context.Context, db *DB, query string) (string, error)

type TRDSQL

+ func (trd *TRDSQL) ExecContext(ctx context.Context, sql string) error

type WriteFormat

+ func (e *WriteFormat) ExportContext(ctx context.Context, db *DB, query string) error

May 21, 2020

Changes in this version

type WriteOpt

+ func OutNoWrap(w bool) WriteOpt

type WriteOpts

+ OutNoWrap bool

Feb 4, 2020

Changes in this version

type WriteOpt

+ func OutAllQuotes(a bool) WriteOpt

+ func OutQuote(q string) WriteOpt

+ func OutUseCRLF(c bool) WriteOpt

type WriteOpts

+ OutAllQuotes bool

+ OutQuote string

+ OutUseCRLF bool

Dec 27, 2019

Changes in this version

type Format

+ const JSONL

+ type JSONLWriter struct

+ func NewJSONLWriter(writeOpts *WriteOpts) *JSONLWriter

+ func (w *JSONLWriter) PostWrite() error

+ func (w *JSONLWriter) PreWrite(columns []string, types []string) error

+ func (w *JSONLWriter) WriteRow(values []interface{}, columns []string) error

Oct 21, 2019

Changes in this version

+ var AppName = "trdsql"

+ func Analyze(fileName string, opts *AnalyzeOpts, readOpts *ReadOpts) error

+ type AnalyzeOpts struct

+ Color bool

+ Command string

+ Detail bool

+ OutStream io.Writer

+ Quote string

+ func NewAnalyzeOpts() *AnalyzeOpts

Sep 22, 2019

Changes in this version

+ var ErrInvalidNames = errors.New("invalid names")

+ var ErrInvalidTypes = errors.New("invalid types")

+ var ErrNilReader = errors.New("nil reader")

+ var ErrNoTransaction = errors.New("transaction has not been started")

+ var Version = `v0.7.0`

+ func SQLFields(query string) []string

type DB

+ func (db *DB) QuotedName(oldName string) string

Aug 8, 2019

Changes in this version

+ func TableNames(query string) []string

type SliceReader

+ func (r *SliceReader) TableName() (string, error)

Jun 23, 2019

Changes in this version

+ const DefaultDBType

+ func ConvertTypes(dbTypes []string) []string

+ func EnableDebug()

+ func ImportFile(db *DB, fileName string, readOpts *ReadOpts) (string, error)

+ func ValString(v interface{}) string

+ type BufferImporter struct

+ func NewBufferImporter(tableName string, r io.Reader, options ...ReadOpt) (*BufferImporter, error)

+ func (i *BufferImporter) Import(db *DB, query string) (string, error)

+ type CSVReader struct

+ func NewCSVReader(reader io.Reader, opts *ReadOpts) (*CSVReader, error)

+ func (r *CSVReader) Names() ([]string, error)

+ func (r *CSVReader) PreReadRow() [][]interface{}

+ func (r *CSVReader) ReadRow(row []interface{}) ([]interface{}, error)

+ func (r *CSVReader) Types() ([]string, error)

+ type CSVWriter struct

+ func NewCSVWriter(writeOpts *WriteOpts) *CSVWriter

+ func (w *CSVWriter) PostWrite() error

+ func (w *CSVWriter) PreWrite(columns []string, types []string) error

+ func (w *CSVWriter) WriteRow(values []interface{}, columns []string) error

+ type DB struct

+ Tx *sql.Tx

+ func (db *DB) CreateTable(tableName string, names []string, types []string, isTemporary bool) error

+ func (db *DB) Disconnect() error

+ func (db *DB) EscapeName(oldName string) string

+ func (db *DB) Import(tableName string, columnNames []string, reader Reader) error

+ func (db *DB) RewriteSQL(query string, oldName string, newName string) (rewrite string)

+ func (db *DB) Select(query string) (*sql.Rows, error)

+ type Exporter interface

+ Export func(db *DB, query string) error

+ type Format int

+ const AT

+ const GUESS

+ const MD

+ const RAW

+ const TBLN

+ const VF

+ func (f Format) String() string

+ type Importer interface

+ Import func(db *DB, query string) (string, error)

+ type JSONReader struct

+ func NewJSONReader(reader io.Reader, opts *ReadOpts) (*JSONReader, error)

+ func (r *JSONReader) Names() ([]string, error)

+ func (r *JSONReader) PreReadRow() [][]interface{}

+ func (r *JSONReader) ReadRow(row []interface{}) ([]interface{}, error)

+ func (r *JSONReader) Types() ([]string, error)

+ type JSONWriter struct

+ func NewJSONWriter(writeOpts *WriteOpts) *JSONWriter

+ func (w *JSONWriter) PostWrite() error

+ func (w *JSONWriter) PreWrite(columns []string, types []string) error

+ func (w *JSONWriter) WriteRow(values []interface{}, columns []string) error

+ type LTSVReader struct

+ func NewLTSVReader(reader io.Reader, opts *ReadOpts) (*LTSVReader, error)

+ func (r *LTSVReader) Names() ([]string, error)

+ func (r *LTSVReader) PreReadRow() [][]interface{}

+ func (r *LTSVReader) ReadRow(row []interface{}) ([]interface{}, error)

+ func (r *LTSVReader) Types() ([]string, error)

+ type LTSVWriter struct

+ func NewLTSVWriter(writeOpts *WriteOpts) *LTSVWriter

+ func (w *LTSVWriter) PostWrite() error

+ func (w *LTSVWriter) PreWrite(columns []string, types []string) error

+ func (w *LTSVWriter) WriteRow(values []interface{}, columns []string) error

+ type RAWWriter struct

+ func NewRAWWriter(writeOpts *WriteOpts) *RAWWriter

+ func (w *RAWWriter) PostWrite() error

+ func (w *RAWWriter) PreWrite(columns []string, types []string) error

+ func (w *RAWWriter) WriteRow(values []interface{}, columns []string) error

+ type ReadFormat struct

+ func NewImporter(options ...ReadOpt) *ReadFormat

+ func (i *ReadFormat) Import(db *DB, query string) (string, error)

+ type ReadOpt func(*ReadOpts)

+ func InDelimiter(d string) ReadOpt

+ func InFormat(f Format) ReadOpt

+ func InHeader(h bool) ReadOpt

+ func InPreRead(p int) ReadOpt

+ func InSkip(s int) ReadOpt

+ func IsTemporary(t bool) ReadOpt

+ type ReadOpts struct

+ InDelimiter string

+ InFormat Format

+ InHeader bool

+ InPreRead int

+ InSkip int

+ IsTemporary bool

+ func NewReadOpts(options ...ReadOpt) *ReadOpts

+ type Reader interface

+ Names func() ([]string, error)

+ PreReadRow func() [][]interface{}

+ ReadRow func([]interface{}) ([]interface{}, error)

+ Types func() ([]string, error)

+ func NewReader(reader io.Reader, readOpts *ReadOpts) (Reader, error)

+ type SliceImporter struct

+ func NewSliceImporter(tableName string, data interface{}) *SliceImporter

+ func (i *SliceImporter) Import(db *DB, query string) (string, error)

+ type SliceReader struct

+ func NewSliceReader(tableName string, args interface{}) *SliceReader

+ func (r *SliceReader) Names() ([]string, error)

+ func (r *SliceReader) PreReadRow() [][]interface{}

+ func (r *SliceReader) ReadRow(row []interface{}) ([]interface{}, error)

+ func (r *SliceReader) Types() ([]string, error)

+ type SliceWriter struct

+ Table [][]interface{}

+ func NewSliceWriter() *SliceWriter

+ func (w *SliceWriter) PostWrite() error

+ func (w *SliceWriter) PreWrite(columns []string, types []string) error

+ func (w *SliceWriter) WriteRow(values []interface{}, columns []string) error

+ type TBLNRead struct

+ func NewTBLNReader(reader io.Reader) (*TBLNRead, error)

+ func (r *TBLNRead) Names() ([]string, error)

+ func (r *TBLNRead) PreReadRow() [][]interface{}

+ func (r *TBLNRead) ReadRow(row []interface{}) ([]interface{}, error)

+ func (r *TBLNRead) Types() ([]string, error)

+ type TBLNWriter struct

+ func NewTBLNWriter(writeOpts *WriteOpts) *TBLNWriter

+ func (w *TBLNWriter) PostWrite() error

+ func (w *TBLNWriter) PreWrite(columns []string, types []string) error

+ func (w *TBLNWriter) WriteRow(values []interface{}, columns []string) error

type TRDSQL

+ Driver string

+ Dsn string

+ Exporter Exporter

+ Importer Importer

+ func NewTRDSQL(im Importer, ex Exporter) *TRDSQL

+ func (trd *TRDSQL) Exec(sql string) error

+ type TWWriter struct

+ func NewTWWriter(writeOpts *WriteOpts, markdown bool) *TWWriter

+ func (w *TWWriter) PostWrite() error

+ func (w *TWWriter) PreWrite(columns []string, types []string) error

+ func (w *TWWriter) WriteRow(values []interface{}, columns []string) error

+ type Table struct

+ type VFWriter struct

+ func NewVFWriter(writeOpts *WriteOpts) *VFWriter

+ func (w *VFWriter) PostWrite() error

+ func (w *VFWriter) PreWrite(columns []string, types []string) error

+ func (w *VFWriter) WriteRow(values []interface{}, columns []string) error

+ type WriteFormat struct

+ func NewExporter(writer Writer) *WriteFormat

+ func (e *WriteFormat) Export(db *DB, query string) error

+ type WriteOpt func(*WriteOpts)

+ func ErrStream(w io.Writer) WriteOpt

+ func OutDelimiter(d string) WriteOpt

+ func OutFormat(f Format) WriteOpt

+ func OutHeader(h bool) WriteOpt

+ func OutStream(w io.Writer) WriteOpt

+ type WriteOpts struct

+ ErrStream io.Writer

+ OutDelimiter string

+ OutFormat Format

+ OutHeader bool

+ OutStream io.Writer

+ type Writer interface

+ PostWrite func() error

+ PreWrite func([]string, []string) error

+ WriteRow func([]interface{}, []string) error

+ func NewWriter(options ...WriteOpt) Writer

Jan 13, 2019

Changes in this version

type CSVIn

+ func (cr *CSVIn) GetColumn(rowNum int) ([]string, error)

+ func (cr *CSVIn) PreReadRow() [][]interface{}

+ func (cr *CSVIn) ReadRow(row []interface{}) ([]interface{}, error)

type CSVOut

+ func (c *CSVOut) First(columns []string) error

+ func (c *CSVOut) Last() error

+ func (c *CSVOut) RowWrite(values []interface{}, columns []string) error

type Input

+ GetColumn func(rowNum int) ([]string, error)

+ PreReadRow func() [][]interface{}

+ ReadRow func([]interface{}) ([]interface{}, error)

type JSONIn

+ func (jr *JSONIn) GetColumn(rowNum int) ([]string, error)

+ func (jr *JSONIn) PreReadRow() [][]interface{}

+ func (jr *JSONIn) ReadRow(row []interface{}) ([]interface{}, error)

type JSONOut

+ func (js *JSONOut) First(columns []string) error

+ func (js *JSONOut) Last() error

+ func (js *JSONOut) RowWrite(values []interface{}, columns []string) error

type LTSVIn

+ func (lr *LTSVIn) GetColumn(rowNum int) ([]string, error)

+ func (lr *LTSVIn) PreReadRow() [][]interface{}

+ func (lr *LTSVIn) ReadRow(row []interface{}) ([]interface{}, error)

type LTSVOut

+ func (lw *LTSVOut) First(columns []string) error

+ func (lw *LTSVOut) Last() error

+ func (lw *LTSVOut) RowWrite(values []interface{}, columns []string) error

type Output

+ First func([]string) error

+ Last func() error

+ RowWrite func([]interface{}, []string) error

type RawOut

+ func (raw *RawOut) First(columns []string) error

+ func (raw *RawOut) Last() error

+ func (raw *RawOut) RowWrite(values []interface{}, columns []string) error

type TwOut

+ func (tw *TwOut) First(columns []string) error

+ func (tw *TwOut) Last() error

+ func (tw *TwOut) RowWrite(values []interface{}, columns []string) error

type VfOut

+ func (vf *VfOut) First(columns []string) error

+ func (vf *VfOut) Last() error

+ func (vf *VfOut) RowWrite(values []interface{}, columns []string) error

Jan 20, 2018

Changes in this version

+ var Icsv bool

+ var Ijson bool

+ var Iltsv bool

type DDB

+ func (db *DDB) CreateTable(table string, header []string) error

+ func (db *DDB) EscapeTable(oldname string) string

+ func (db *DDB) Import(tablename string, header []string, input Input, firstRow bool) error

+ func (db *DDB) RewriteSQL(sqlstr string, oldname string, newname string) (rewrite string)

type TRDSQL

+ func (trdsql *TRDSQL) Export(db *DDB, sqlstr string, output Output) error

+ func (trdsql *TRDSQL) Import(db *DDB, sqlstr string) (string, error)

+ func (trdsql *TRDSQL) InputNew(file io.Reader, tablename string) (Input, error)

Dec 31, 2017

Changes in this version

+ const CSV

+ const JSON

+ const LTSV

+ type JSONIn struct

Aug 5, 2017

Changes in this version

+ var Oat bool

+ var Ocsv bool

+ var Ojson bool

+ var Oltsv bool

+ var Omd bool

+ var Oraw bool

+ var Ovf bool

+ type CSVIn struct

+ type CSVOut struct

type DDB

+ func (db *DDB) InsertPrepare(table string, header []string) error

+ type Input interface

+ type JSONOut struct

+ type LTSVIn struct

+ type LTSVOut struct

+ type Output interface

+ type RawOut struct

+ type TwOut struct

+ type VfOut struct

Jul 28, 2017

Changes in this version

+ const VERSION

+ type DDB struct

+ func Connect(driver, dsn string) (*DDB, error)

+ func (db *DDB) Create(table string, header []string, head bool) error

+ func (db *DDB) Disconnect() error

+ func (db *DDB) ImportPrepare(table string, header []string, head bool) error

+ func (db *DDB) Select(sqlstr string) (*sql.Rows, error)

+ type TRDSQL struct

+ func (trdsql TRDSQL) Run(args []string) int