commit

Documentation

Index

• Constants
• func AssertPostgresVersionMatch(conn *pgx.Conn) error
• func ConnectRemotePostgres(username, password, database, host string) (*pgx.Conn, error)
• func Run(_ctx context.Context, username, password, database string, fsys afero.Fs) error

Constants

const (
	CHECK_MIGRATION_EXISTS = "SELECT 1 FROM supabase_migrations.schema_migrations LIMIT 1"
	LIST_MIGRATION_VERSION = "SELECT version FROM supabase_migrations.schema_migrations ORDER BY version"
	CREATE_MIGRATION_TABLE = `` /* 137-byte string literal not displayed */

	INSERT_MIGRATION_VERSION = "INSERT INTO supabase_migrations.schema_migrations(version) VALUES($1)"
)

Functions

func AssertPostgresVersionMatch

func AssertPostgresVersionMatch(conn *pgx.Conn) error

func ConnectRemotePostgres

func ConnectRemotePostgres(username, password, database, host string) (*pgx.Conn, error)

Connnect to remote Postgres with optimised settings. The caller is responsible for closing the connection returned.

func Run

func Run(_ctx context.Context, username, password, database string, fsys afero.Fs) error

TODO: Handle cleanup on SIGINT/SIGTERM.