yugabytedb

README

yugabytedb

yugabytedb://user:password@host:port/dbname?query (yugabyte://, and ysql:// work, too)

URL Query	WithInstance Config	Description
x-migrations-table	MigrationsTable	Name of the migrations table
x-lock-table	LockTable	Name of the table which maintains the migration lock
x-force-lock	ForceLock	Force lock acquisition to fix faulty migrations which may not have released the schema lock (Boolean, default is false)
dbname	DatabaseName	The name of the database to connect to
user		The user to sign in as
password		The user's password
host		The host to connect to. Values that start with / are for unix domain sockets. (default is localhost)
port		The port to bind to. (default is 5432)
connect_timeout		Maximum wait for connection, in seconds. Zero or not specified means wait indefinitely.
sslcert		Cert file location. The file must contain PEM encoded data.
sslkey		Key file location. The file must contain PEM encoded data.
sslrootcert		The location of the root certificate file. The file must contain PEM encoded data.
sslmode		Whether or not to use SSL (disable|require|verify-ca|verify-full)

Documentation

Index

• Variables
• func ExecuteInTx(ctx context.Context, db *sql.DB, opts *sql.TxOptions, ...) (err error)
• func WithInstance(instance *sql.DB, config *Config) (database.Driver, error)
• type Config
• type YugabyteDB
  • func (c *YugabyteDB) Close() error
  • func (c *YugabyteDB) Drop() (err error)
  • func (c *YugabyteDB) Lock() error
  • func (c *YugabyteDB) Open(dbURL string) (database.Driver, error)
  • func (c *YugabyteDB) Run(migration io.Reader) error
  • func (c *YugabyteDB) SetVersion(version int, dirty bool) error
  • func (c *YugabyteDB) Unlock() error
  • func (c *YugabyteDB) Version() (version int, dirty bool, err error)

Variables

var (
	ErrNilConfig          = errors.New("no config")
	ErrNoDatabaseName     = errors.New("no database name")
	ErrMaxRetriesExceeded = errors.New("max retries exceeded")
)

var DefaultLockTable = "migrations_locks"

var DefaultMigrationsTable = "migrations"

Functions

func ExecuteInTx

func ExecuteInTx(ctx context.Context, db *sql.DB, opts *sql.TxOptions, fn func(tx *sql.Tx) error) (err error)

func WithInstance

func WithInstance(instance *sql.DB, config *Config) (database.Driver, error)

Types

type Config

type Config struct {
	MigrationsTable string
	LockTable       string
	ForceLock       bool
	DatabaseName    string
}

type YugabyteDB

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

func (*YugabyteDB) Close

func (c *YugabyteDB) Close() error

func (*YugabyteDB) Drop

func (c *YugabyteDB) Drop() (err error)

func (*YugabyteDB) Lock

func (c *YugabyteDB) Lock() error

Locking is done manually with a separate lock table. Implementing advisory locks in YugabyteDB is being discussed See: https://github.com/yugabyte/yugabyte-db/issues/3642

func (*YugabyteDB) Open

func (c *YugabyteDB) Open(dbURL string) (database.Driver, error)

func (*YugabyteDB) Run

func (c *YugabyteDB) Run(migration io.Reader) error

func (*YugabyteDB) SetVersion

func (c *YugabyteDB) SetVersion(version int, dirty bool) error

func (*YugabyteDB) Unlock

func (c *YugabyteDB) Unlock() error

Locking is done manually with a separate lock table. Implementing advisory locks in YugabyteDB is being discussed See: https://github.com/yugabyte/yugabyte-db/issues/3642

func (*YugabyteDB) Version

func (c *YugabyteDB) Version() (version int, dirty bool, err error)