sqlengine

Documentation

Index

• Constants
• Variables
• type MySQLEngine
  • func NewMySQLEngine(logger lager.Logger) *MySQLEngine
  • func (d *MySQLEngine) Close()
  • func (d *MySQLEngine) CreateExtensions(extensions []string) error
  • func (d *MySQLEngine) CreateUser(bindingID, dbname string, readOnly bool) (username, password string, err error)
  • func (d *MySQLEngine) DropExtensions(extensions []string) error
  • func (d *MySQLEngine) DropUser(bindingID string) error
  • func (d *MySQLEngine) JDBCURI(address string, port int64, dbname string, username string, password string) string
  • func (d *MySQLEngine) Open(address string, port int64, dbname string, username string, password string) error
  • func (d *MySQLEngine) ResetState() error
  • func (d *MySQLEngine) URI(address string, port int64, dbname string, username string, password string) string
• type PostgresEngine
  • func NewPostgresEngine(logger lager.Logger) *PostgresEngine
  • func (d *PostgresEngine) Close()
  • func (d *PostgresEngine) CreateExtensions(extensions []string) error
  • func (d *PostgresEngine) CreateUser(bindingID, dbname string, readOnly bool) (username, password string, err error)
  • func (d *PostgresEngine) DropExtensions(extensions []string) error
  • func (d *PostgresEngine) DropUser(bindingID string) error
  • func (d *PostgresEngine) JDBCURI(address string, port int64, dbname string, username string, password string) string
  • func (d *PostgresEngine) Open(address string, port int64, dbname string, username string, password string) error
  • func (d *PostgresEngine) ResetState() error
  • func (d *PostgresEngine) URI(address string, port int64, dbname string, username string, password string) string
• type Provider
• type ProviderService
  • func NewProviderService(logger lager.Logger) *ProviderService
  • func (p *ProviderService) GetSQLEngine(engine string) (SQLEngine, error)
• type SQLEngine

Constants

const ER_ACCESS_DENIED_ERROR = 1045

Variables

var LoginFailedError = errors.New("Login failed")

Types

type MySQLEngine

type MySQLEngine struct {
	UsernameGenerator func(string) string
	// contains filtered or unexported fields
}

func NewMySQLEngine

func NewMySQLEngine(logger lager.Logger) *MySQLEngine

func (*MySQLEngine) Close

func (d *MySQLEngine) Close()

func (*MySQLEngine) CreateExtensions

func (d *MySQLEngine) CreateExtensions(extensions []string) error

func (*MySQLEngine) CreateUser

func (d *MySQLEngine) CreateUser(bindingID, dbname string, readOnly bool) (username, password string, err error)

func (*MySQLEngine) DropExtensions

func (d *MySQLEngine) DropExtensions(extensions []string) error

func (*MySQLEngine) DropUser

func (d *MySQLEngine) DropUser(bindingID string) error

func (*MySQLEngine) JDBCURI

func (d *MySQLEngine) JDBCURI(address string, port int64, dbname string, username string, password string) string

func (*MySQLEngine) Open

func (d *MySQLEngine) Open(address string, port int64, dbname string, username string, password string) error

func (*MySQLEngine) ResetState

func (d *MySQLEngine) ResetState() error

func (*MySQLEngine) URI

func (d *MySQLEngine) URI(address string, port int64, dbname string, username string, password string) string

type PostgresEngine

type PostgresEngine struct {
	UsernameGenerator func(string) string
	// contains filtered or unexported fields
}

func NewPostgresEngine

func NewPostgresEngine(logger lager.Logger) *PostgresEngine

func (*PostgresEngine) Close

func (d *PostgresEngine) Close()

func (*PostgresEngine) CreateExtensions

func (d *PostgresEngine) CreateExtensions(extensions []string) error

func (*PostgresEngine) CreateUser

func (d *PostgresEngine) CreateUser(bindingID, dbname string, readOnly bool) (username, password string, err error)

func (*PostgresEngine) DropExtensions

func (d *PostgresEngine) DropExtensions(extensions []string) error

func (*PostgresEngine) DropUser

func (d *PostgresEngine) DropUser(bindingID string) error

func (*PostgresEngine) JDBCURI

func (d *PostgresEngine) JDBCURI(address string, port int64, dbname string, username string, password string) string

func (*PostgresEngine) Open

func (d *PostgresEngine) Open(address string, port int64, dbname string, username string, password string) error

func (*PostgresEngine) ResetState

func (d *PostgresEngine) ResetState() error

func (*PostgresEngine) URI

func (d *PostgresEngine) URI(address string, port int64, dbname string, username string, password string) string

type Provider

type Provider interface {
	GetSQLEngine(engine string) (SQLEngine, error)
}

type ProviderService

type ProviderService struct {
	// contains filtered or unexported fields
}

func NewProviderService

func NewProviderService(logger lager.Logger) *ProviderService

func (*ProviderService) GetSQLEngine

func (p *ProviderService) GetSQLEngine(engine string) (SQLEngine, error)

type SQLEngine

type SQLEngine interface {
	Open(address string, port int64, dbname string, username string, password string) error
	Close()
	CreateUser(bindingID, dbname string, readOnly bool) (string, string, error)
	DropUser(bindingID string) error
	ResetState() error
	URI(address string, port int64, dbname string, username string, password string) string
	JDBCURI(address string, port int64, dbname string, username string, password string) string
	CreateExtensions(extensions []string) error
	DropExtensions(extensions []string) error
}