queryexecute

Documentation

Index

• func ExecuteQueries(ctx context.Context, queries []string, client *db.Client) int
• func GetQueries(args []string, workspace *workspace.Workspace) []string
• func GetQueryFromArg(arg string, workspace *workspace.Workspace) (string, bool)
• func RunInteractiveSession(initChan *chan *db.QueryInitData)

Functions

func ExecuteQueries

func ExecuteQueries(ctx context.Context, queries []string, client *db.Client) int

func GetQueries

func GetQueries(args []string, workspace *workspace.Workspace) []string

GetQueries retrieves queries from args

For each arg check if it is a named query or a file, before falling back to treating it as sql

func GetQueryFromArg

func GetQueryFromArg(arg string, workspace *workspace.Workspace) (string, bool)

GetQueryFromArg attempts to resolve 'arg' to a query

the second return value indicates whether the arg was resolved as a named query/SQL file

func RunInteractiveSession

func RunInteractiveSession(initChan *chan *db.QueryInitData)