controller

Documentation

Overview

This file defines middlewares to be used in the pipeline defined in pipeline.go

This file defines a pipeline that can be used to modify a SQL query before running it on the server.

It works by chaining multiple middlewares For example it is used to rewrite MySQL specific queries to SQLite

Once the pipeline is run, the result is printed to the output file

Index

• func AliasAdd(cmd *cobra.Command, args []string) error
• func AliasDelete(cmd *cobra.Command, args []string) error
• func AliasList(cmd *cobra.Command, args []string) error
• func ConnectionAdd(cmd *cobra.Command, args []string) error
• func ConnectionList(cmd *cobra.Command, args []string) error
• func ConnectionRemove(cmd *cobra.Command, args []string) error
• func DevInit(cmd *cobra.Command, args []string) error
• func DevNewTable(cmd *cobra.Command, args []string) error
• func HashDir(cmd *cobra.Command, args []string) error
• func MySQLPassword(cmd *cobra.Command, args []string) error
• func PluginInstall(cmd *cobra.Command, args []string) error
• func PluginUninstall(cmd *cobra.Command, args []string) error
• func PluginUpdate(cmd *cobra.Command, args []string) error
• func PluginsList(cmd *cobra.Command, args []string) error
• func ProfileDelete(cmd *cobra.Command, args []string) error
• func ProfileList(cmd *cobra.Command, args []string) error
• func ProfileNew(cmd *cobra.Command, args []string) error
• func ProfileUpdate(cmd *cobra.Command, args []string) error
• func Query(cmd *cobra.Command, args []string) error
• func RegistryAdd(cmd *cobra.Command, args []string) error
• func RegistryGet(cmd *cobra.Command, args []string) error
• func RegistryList(cmd *cobra.Command, args []string) error
• func RegistryRefresh(cmd *cobra.Command, args []string) error
• func RegistryRemove(cmd *cobra.Command, args []string) error
• func Run(cmd *cobra.Command, args []string) error
• func Server(cmd *cobra.Command, args []string) error
• type QueryData

Functions

func AliasAdd

func AliasAdd(cmd *cobra.Command, args []string) error

func AliasDelete

func AliasDelete(cmd *cobra.Command, args []string) error

func AliasList

func AliasList(cmd *cobra.Command, args []string) error

func ConnectionAdd

func ConnectionAdd(cmd *cobra.Command, args []string) error

func ConnectionList

func ConnectionList(cmd *cobra.Command, args []string) error

func ConnectionRemove

func ConnectionRemove(cmd *cobra.Command, args []string) error

func DevInit

func DevInit(cmd *cobra.Command, args []string) error

func DevNewTable

func DevNewTable(cmd *cobra.Command, args []string) error

func HashDir

func HashDir(cmd *cobra.Command, args []string) error

func MySQLPassword

func MySQLPassword(cmd *cobra.Command, args []string) error

func PluginInstall

func PluginInstall(cmd *cobra.Command, args []string) error

func PluginUninstall

func PluginUninstall(cmd *cobra.Command, args []string) error

func PluginUpdate

func PluginUpdate(cmd *cobra.Command, args []string) error

func PluginsList

func PluginsList(cmd *cobra.Command, args []string) error

func ProfileDelete

func ProfileDelete(cmd *cobra.Command, args []string) error

func ProfileList

func ProfileList(cmd *cobra.Command, args []string) error

func ProfileNew

func ProfileNew(cmd *cobra.Command, args []string) error

func ProfileUpdate

func ProfileUpdate(cmd *cobra.Command, args []string) error

func Query

func Query(cmd *cobra.Command, args []string) error

func RegistryAdd

func RegistryAdd(cmd *cobra.Command, args []string) error

func RegistryGet

func RegistryGet(cmd *cobra.Command, args []string) error

func RegistryList

func RegistryList(cmd *cobra.Command, args []string) error

func RegistryRefresh

func RegistryRefresh(cmd *cobra.Command, args []string) error

func RegistryRemove

func RegistryRemove(cmd *cobra.Command, args []string) error

func Run

func Run(cmd *cobra.Command, args []string) error

func Server

func Server(cmd *cobra.Command, args []string) error

Types

type QueryData

type QueryData struct {

	// The query to exec before/after the query
	// Useful to create temporary tables
	PreExec, PostExec []string

	// The query to run
	SQLQuery string

	// The arguments to pass to the query
	Args []interface{}

	// The result of the query
	Result *sql.Rows

	// The database to connect to
	DB *sql.DB

	// The message to return to the client if Result is nil
	Message string

	// The status code of the message
	//
	//    - inferior or equal 0 => INFO
	//    - equal 1 => WARNING
	//    - greater than 2 => ERROR
	//
	StatusCode int

	// The configuration that will be passed to the middlewares
	// This is a reference to the configuration of the pipeline
	Config middlewareConfiguration
}