sqlserverwriter

package

v1.4.0 Latest Latest Go to latest Published: Sep 29, 2025 License: MIT Imports: 11 Imported by: 0

Details

View Source

const (
	DefaultBatchSize = 1024
)

This section is empty.

This section is empty.

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

SQLServerWriterJob SQL Server写入作业

func NewSQLServerWriterJob() *SQLServerWriterJob

func (job *SQLServerWriterJob) Destroy() error

func (job *SQLServerWriterJob) Init(config config.Configuration) error

func (job *SQLServerWriterJob) Post() error

func (job *SQLServerWriterJob) Prepare() error

func (job *SQLServerWriterJob) Split(mandatoryNumber int) ([]config.Configuration, error)

type SQLServerWriterJobFactory struct{}

SQLServerWriterJobFactory 实现WriterJobFactory接口

func (f *SQLServerWriterJobFactory) CreateWriterJob() plugin.WriterJob

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

SQLServerWriterTask SQL Server写入任务

func NewSQLServerWriterTask() *SQLServerWriterTask

func (task *SQLServerWriterTask) Destroy() error

func (task *SQLServerWriterTask) Init(config config.Configuration) error

func (task *SQLServerWriterTask) Post() error

func (task *SQLServerWriterTask) Prepare() error

func (task *SQLServerWriterTask) StartWrite(recordReceiver plugin.RecordReceiver) error

type SQLServerWriterTaskFactory struct{}

SQLServerWriterTaskFactory 实现WriterTaskFactory接口

func (f *SQLServerWriterTaskFactory) CreateWriterTask() plugin.WriterTask