sqlrunner

type MySQLRunner ¶

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

MySQLRunner is responsible for creating and tearing down a test database in a local MySQL instance. This runner assumes mysql is already running locally, and does not start or stop the mysql service. mysql must be set up on localhost as described in the CONTRIBUTING.md doc in diego-release.

func NewMySQLRunner(sqlDBName string) *MySQLRunner

func (m *MySQLRunner) ConnectionString() string

func (m *MySQLRunner) DB() *sql.DB

func (p *MySQLRunner) DBName() string

func (m *MySQLRunner) DriverName() string

func (p *MySQLRunner) Password() string

func (p *MySQLRunner) Port() int

func (m *MySQLRunner) Reset()

func (m *MySQLRunner) ResetTables(tables []string)

func (m *MySQLRunner) Run(signals <-chan os.Signal, ready chan<- struct{}) error

func (p *MySQLRunner) Username() string

type PostgresRunner ¶

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

PostgresRunner is responsible for creating and tearing down a test database in a local Postgres instance. This runner assumes mysql is already running locally, and does not start or stop the mysql service. mysql must be set up on localhost as described in the CONTRIBUTING.md doc in diego-release.

func NewPostgresRunner(sqlDBName string) *PostgresRunner

func (p *PostgresRunner) ConnectionString() string

func (p *PostgresRunner) DB() *sql.DB

func (p *PostgresRunner) DBName() string

func (p *PostgresRunner) DriverName() string

func (p *PostgresRunner) Password() string

func (p *PostgresRunner) Port() int

func (p *PostgresRunner) Reset()

func (p *PostgresRunner) ResetTables(tables []string)

func (p *PostgresRunner) Run(signals <-chan os.Signal, ready chan<- struct{}) error

func (p *PostgresRunner) Username() string

type SQLRunner ¶

type SQLRunner interface {
	ifrit.Runner
	ConnectionString() string
	Reset()
	ResetTables(tables []string)
	DriverName() string
	Port() int
	DBName() string
	Username() string
	Password() string
	DB() *sql.DB
}