func ExecuteCommand()

in quickstart/utils/queries/queries.go [13:40]


func ExecuteCommand(kustoClient *azkustodata.Client, databaseName string, command azkustodata.Statement, options ...azkustodata.QueryOption) {
	ctx := context.Background()
	var result query.Dataset
	var err error
	if strings.HasPrefix(command.String(), ".") {
		result, err = kustoClient.Mgmt(ctx, databaseName, command)
	} else {
		result, err = kustoClient.Query(ctx, databaseName, command, options...)
	}

	if err != nil {
		panic(fmt.Sprintf("Command execution failed: '%s'\n", err.Error()))
	}

	for _, table := range result.Tables() {
		if !table.IsPrimaryResult() {
			continue
		}

		for _, row := range table.Rows() {
			fmt.Println(row)
		}
	}

	if err != nil {
		panic(fmt.Sprintf("Failed printing the results: '%s'\n", err.Error()))
	}
}