Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

dbms

package

Go to main page

Versions in this module

v0

v0.2.1

Oct 8, 2024

v0.2.0

Aug 16, 2024

v0.1.9

Jun 1, 2024

v0.1.8

Feb 21, 2024

v0.1.7

Sep 20, 2023

v0.1.6

Jul 6, 2023

v0.1.5

Jul 4, 2023

v0.1.4

Jul 1, 2023

Changes in this version

type BaseConfig

+ QuerySQL []string

+ func (b *BaseConfig) GetQuerySQL() []string

type Config

+ GetQuerySQL func() []string

v0.1.3

Jun 20, 2023

v0.1.2

May 28, 2023

Changes in this version

+ func StartRead(ctx context.Context, reader BatchReader, sender plugin.RecordSender) (err error)

+ type BaseBatchReader struct

+ func NewBaseBatchReader(task *Task, mode string, opts *sql.TxOptions) *BaseBatchReader

+ func (b *BaseBatchReader) JobID() int64

+ func (b *BaseBatchReader) Parameter() database.Parameter

+ func (b *BaseBatchReader) Read(ctx context.Context, param database.Parameter, handler database.FetchHandler) (err error)

+ func (b *BaseBatchReader) TaskGroupID() int64

+ func (b *BaseBatchReader) TaskID() int64

+ type BaseColumn struct

+ Name string

+ func (b *BaseColumn) GetName() string

+ type BaseConfig struct

+ Column []string

+ Connection ConnConfig

+ Password string

+ Split SplitConfig

+ Username string

+ Where string

+ func NewBaseConfig(conf *config.JSON) (c *BaseConfig, err error)

+ func (b *BaseConfig) GetBaseTable() *database.BaseTable

+ func (b *BaseConfig) GetColumns() (columns []Column)

+ func (b *BaseConfig) GetPassword() string

+ func (b *BaseConfig) GetSplitConfig() SplitConfig

+ func (b *BaseConfig) GetURL() string

+ func (b *BaseConfig) GetUsername() string

+ func (b *BaseConfig) GetWhere() string

+ type BaseDbHandler struct

+ func NewBaseDbHandler(newQuerier func(name string, conf *config.JSON) (Querier, error), ...) *BaseDbHandler

+ func (d *BaseDbHandler) Config(conf *config.JSON) (Config, error)

+ func (d *BaseDbHandler) MaxParam(config Config, table database.Table) database.Parameter

+ func (d *BaseDbHandler) MinParam(config Config, table database.Table) database.Parameter

+ func (d *BaseDbHandler) Querier(name string, conf *config.JSON) (Querier, error)

+ func (d *BaseDbHandler) SplitParam(config Config, querier Querier) database.Parameter

+ func (d *BaseDbHandler) TableParam(config Config, querier Querier) database.Parameter

+ type BatchReader interface

+ JobID func() int64

+ Parameter func() database.Parameter

+ Read func(ctx context.Context, param database.Parameter, handler database.FetchHandler) (err error)

+ TaskGroupID func() int64

+ TaskID func() int64

+ type Column interface

+ GetName func() string

+ type Config interface

+ GetBaseTable func() *database.BaseTable

+ GetColumns func() []Column

+ GetPassword func() string

+ GetSplitConfig func() SplitConfig

+ GetURL func() string

+ GetUsername func() string

+ GetWhere func() string

+ type ConnConfig struct

+ Table TableConfig

+ URL string

+ type DbHandler interface

+ Config func(conf *config.JSON) (Config, error)

+ MaxParam func(config Config, table database.Table) database.Parameter

+ MinParam func(config Config, table database.Table) database.Parameter

+ Querier func(name string, conf *config.JSON) (Querier, error)

+ SplitParam func(config Config, querier Querier) database.Parameter

+ TableParam func(config Config, querier Querier) database.Parameter

+ type Job struct

+ Config Config

+ Querier Querier

+ func NewJob(handler DbHandler) *Job

+ func (j *Job) Destroy(ctx context.Context) (err error)

+ func (j *Job) Init(ctx context.Context) (err error)

+ func (j *Job) Split(ctx context.Context, number int) (configs []*config.JSON, err error)

+ type MaxParam struct

+ Config Config

+ func NewMaxParam(config Config, table database.Table, opts *sql.TxOptions) *MaxParam

+ func (m *MaxParam) Agrs(_ []element.Record) ([]interface{}, error)

+ func (m *MaxParam) Query(_ []element.Record) (string, error)

+ type MinParam struct

+ Config Config

+ func NewMinParam(config Config, table database.Table, opts *sql.TxOptions) *MinParam

+ func (m *MinParam) Agrs(_ []element.Record) ([]interface{}, error)

+ func (m *MinParam) Query(_ []element.Record) (string, error)

+ type Querier interface

+ Close func() error

+ FetchRecord func(ctx context.Context, param database.Parameter, handler database.FetchHandler) (err error)

+ FetchRecordWithTx func(ctx context.Context, param database.Parameter, handler database.FetchHandler) (err error)

+ FetchTableWithParam func(ctx context.Context, param database.Parameter) (database.Table, error)

+ PingContext func(ctx context.Context) error

+ QueryContext func(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)

+ Table func(*database.BaseTable) database.Table

+ type QueryParam struct

+ Config Config

+ func NewQueryParam(config Config, table database.Table, opts *sql.TxOptions) *QueryParam

+ func (q *QueryParam) Agrs(_ []element.Record) (a []interface{}, err error)

+ func (q *QueryParam) Query(_ []element.Record) (string, error)

+ type SplitConfig struct

+ Key string

+ Range SplitRange

+ TimeAccuracy string

+ type SplitParam struct

+ Config Config

+ func NewSplitParam(config Config, table TableParamTable, opts *sql.TxOptions) *SplitParam

+ func (s *SplitParam) Agrs(_ []element.Record) ([]interface{}, error)

+ func (s *SplitParam) Query(_ []element.Record) (string, error)

+ type SplitRange struct

+ Layout string

+ Left string

+ Right string

+ Type string

+ type TableConfig struct

+ Db string

+ Name string

+ Schema string

+ type TableParam struct

+ Config TableParamConfig

+ func NewTableParam(config TableParamConfig, table TableParamTable, opts *sql.TxOptions) *TableParam

+ func (t *TableParam) Agrs(_ []element.Record) ([]interface{}, error)

+ func (t *TableParam) Query(_ []element.Record) (string, error)

+ type TableParamConfig interface

+ GetBaseTable func() *database.BaseTable

+ GetColumns func() []Column

+ type TableParamTable interface

+ Table func(*database.BaseTable) database.Table

+ type Task struct

+ Config Config

+ Querier Querier

+ Table database.Table

+ func NewTask(handler DbHandler) *Task

+ func (t *Task) Destroy(ctx context.Context) (err error)

+ func (t *Task) Init(ctx context.Context) (err error)