Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type SnowflakeSql ¶
func LoadSqls ¶
func LoadSqls(folder string) ([]SnowflakeSql, error)
type SnowflakeSqlExecutor ¶
type SnowflakeSqlExecutor struct {
// contains filtered or unexported fields
}
func NewSnowflakeSqlExecutor ¶
func NewSnowflakeSqlExecutor(options ...SnowflakeSqlExecutorOption) *SnowflakeSqlExecutor
func (*SnowflakeSqlExecutor) Execute ¶
func (s *SnowflakeSqlExecutor) Execute(ctx context.Context, snowSqls []SnowflakeSql) error
type SnowflakeSqlExecutorOption ¶
type SnowflakeSqlExecutorOption func(*SnowflakeSqlExecutor)
func WithDb ¶
func WithDb(db *sql.DB) SnowflakeSqlExecutorOption
func WithParallelDegree ¶
func WithParallelDegree(degree int) SnowflakeSqlExecutorOption
Click to show internal directories.
Click to hide internal directories.