helper

Documentation

Index

• func Chunk[Q chunkImp[Q, T], T any](ctx context.Context, query Q, chunk int, ...) error
• func WithTx[Q clientImp[T], T txImp](ctx context.Context, client Q, fn func(ctx context.Context, tx T) error) error

Functions

func Chunk

func Chunk[Q chunkImp[Q, T], T any](ctx context.Context, query Q, chunk int, fn func(batchIndex int, items []*T) error) error

Chunk 分批处理数据 example:

client, err := ent.Open("mysql", os.Getenv("ACCOUNT_DB_DSN"))
if err != nil {
	panic(err)
}
ctx := context.Background()
err = enthelper.Chunk(ctx, client.Account.Query(), 100, func(batchIndex int, items []*ent.Account) error {
	for i, item := range items {
		fmt.Println(batch, i, item.Email)
	}
	return nil
})

func WithTx

func WithTx[Q clientImp[T], T txImp](ctx context.Context, client Q, fn func(ctx context.Context, tx T) error) error