db

package

v0.0.11 Latest Latest Go to latest Published: Aug 10, 2023 License: Apache-2.0 Imports: 6 Imported by: 0

Details

This section is empty.

This section is empty.

func CloseDB(globalDB *sql.DB)

func OpenDB(dbName, host string, port int, user, password string) (*sql.DB, error)

type BatchLoader interface {
	InsertValue(ctx context.Context, query []string) error
	Flush(ctx context.Context) error
}

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

SQLBatchLoader helps us insert in batch

func NewSQLBatchLoader(db *sql.DB, hint string, retryCount int, retryInterval time.Duration) *SQLBatchLoader

NewSQLBatchLoader creates a batch loader for database connection

func (b *SQLBatchLoader) Flush(ctx context.Context) error

Flush inserts all pending values

func (b *SQLBatchLoader) InsertValue(ctx context.Context, query []string) error

InsertValue inserts a value, the loader may flush all pending values.