sqlcon

Documentation

Index

• Variables
• func HandleError(err error) error
• func HelpMessage() string
• func MigratorSQLCmd(path, name string, logger logrus.FieldLogger, runners map[string]SchemaCreator) *cobra.Command
• type SQLConnection
  • func NewSQLConnection(db string, l logrus.FieldLogger) (*SQLConnection, error)
  • func (c *SQLConnection) GetDatabase() *sqlx.DB
  • func (c *SQLConnection) GetDatabaseRetry(maxWait time.Duration, failAfter time.Duration) (*sqlx.DB, error)
• type SchemaCreator

Variables

var (
	ErrUniqueViolation = &herodot.DefaultError{
		CodeField:   http.StatusConflict,
		StatusField: http.StatusText(http.StatusConflict),
		ErrorField:  "Unable to insert or update resource because a resource with that value exists already",
	}
	ErrNoRows = &herodot.DefaultError{
		CodeField:   http.StatusNotFound,
		StatusField: http.StatusText(http.StatusNotFound),
		ErrorField:  "Unable to locate the resource",
	}
)

Functions

func HandleError

func HandleError(err error) error

func HelpMessage

func HelpMessage() string

func MigratorSQLCmd

func MigratorSQLCmd(path, name string, logger logrus.FieldLogger, runners map[string]SchemaCreator) *cobra.Command

Types

type SQLConnection

type SQLConnection struct {
	URL *url.URL
	L   logrus.FieldLogger
	// contains filtered or unexported fields
}

func NewSQLConnection

func NewSQLConnection(db string, l logrus.FieldLogger) (*SQLConnection, error)

func (*SQLConnection) GetDatabase

func (c *SQLConnection) GetDatabase() *sqlx.DB

func (*SQLConnection) GetDatabaseRetry

func (c *SQLConnection) GetDatabaseRetry(maxWait time.Duration, failAfter time.Duration) (*sqlx.DB, error)

type SchemaCreator

type SchemaCreator interface {
	CreateSchemas(db *sqlx.DB) (int, error)
}