shared

type DBConfig struct {
	Driver   string
	Host     string
	Port     string
	Username string
	Password string
	Database string
}

type DataTable struct {
	Columns []string
	Values  []map[string]*sql.NullString
}

type ExportDriver struct {
	Name       string
	BinName    string
	BinPaths   []string
	Lookup     func() (string, error)
	ExportFunc func(ctx context.Context, cfg *DBConfig, tables []string, structWriter, dataWriter io.Writer) error
}

type ExportExecutor func(ctx context.Context, noticer notice.Noticer,
	cfg *driver.DbAuth, tables []string, structWriter, dataWriter interface{}) error

type FileInfo struct {
	Start      time.Time
	End        time.Time
	Elapsed    time.Duration
	Path       string
	Size       int64
	Compressed bool
	Error      string `json:",omitempty"`
}

type FileInfos []*FileInfo

type ImportDriver struct {
	Name       string
	BinName    string
	BinPaths   []string
	Lookup     func() (string, error)
	ImportFunc func(ctx context.Context, cfg *DBConfig, files []string, noticer *notice.NoticeAndProgress) error
}

type ImportExecutor func(ctx context.Context, noticer *notice.NoticeAndProgress, cfg *driver.DbAuth, cacheDir string, files []string) error

type ImportFile struct {
	StructFiles []string
	DataFiles   []string
	// contains filtered or unexported fields
}

type Result struct {
	SQL          string
	SQLs         []string
	RowsAffected int64
	TimeStart    time.Time
	TimeEnd      time.Time
	Started      string
	Elapsed      string

	ErrorString string
	// contains filtered or unexported fields
}

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

type SQLStats struct {
	Total   int
	Success int
	Failed  int
	Errors  []string
}

type SelectData struct {
	Result  *Result
	Data    *DataTable
	Explain *DataTable
}

type TableQuerier func(rows *sql.Rows, limit int, textLength ...int) (columns []string, r []map[string]*sql.NullString, err error)