spanner

Oct 6, 2024

Changes in this version

type Migration

+ Kind StatementKind

+ type StatementKind string

+ const StatementKindDDL

+ const StatementKindDML

+ const StatementKindPartitionedDML

Mar 14, 2024

Changes in this version

type Config

+ StmtTimeout time.Duration

Mar 7, 2024

Changes in this version

type Migration

+ FileName string

+ type MigrationsOutput map[string]migrationInfo

+ func (i MigrationsOutput) String() string

Oct 20, 2022

Changes in this version

+ const ErrorCodeUndirtyMigration

type Client

+ func (c *Client) RepairMigration(ctx context.Context, tableName string) error

Oct 10, 2020

Changes in this version

type Client

+ func (c *Client) LoadStaticDatas(ctx context.Context, tables []string) ([]StaticData, error)

+ type StaticData struct

+ Count int

+ Statements []string

+ TableName string

+ func (s StaticData) ToFileName() string

Jul 30, 2020

Changes in this version

type Client

+ func (c *Client) LoadDDLs(ctx context.Context) ([]SchemaDDL, error)

+ type SchemaDDL struct

+ Filename string

+ ObjectType string

+ Statement string

Jul 24, 2020

Changes in this version

+ const ErrorCodeCloseClient

+ const ErrorCodeCompleteUpgrade

+ const ErrorCodeCreateClient

+ const ErrorCodeCreateDatabase

+ const ErrorCodeDropDatabase

+ const ErrorCodeEnsureMigrationTables

+ const ErrorCodeExecuteMigrations

+ const ErrorCodeGetMigrationVersion

+ const ErrorCodeLoadSchema

+ const ErrorCodeMigrationVersionDirty

+ const ErrorCodeNoMigration

+ const ErrorCodeSetMigrationVersion

+ const ErrorCodeTruncateAllTables

+ const ErrorCodeUpdateDDL

+ const ErrorCodeUpdateDML

+ const ErrorCodeUpdatePartitionedDML

+ const ErrorCodeWaitOperation

+ const ExistingMigrationsNoUpgrade

+ const ExistingMigrationsUpgradeCompleted

+ const ExistingMigrationsUpgradeStarted

+ const FirstRun

+ var MigrationNameRegex = regexp.MustCompile(`[a-zA-Z0-9_\-]+`)

+ type Client struct

+ func NewClient(ctx context.Context, config *Config) (*Client, error)

+ func (c *Client) ApplyDDL(ctx context.Context, statements []string) error

+ func (c *Client) ApplyDDLFile(ctx context.Context, ddl []byte) error

+ func (c *Client) ApplyDML(ctx context.Context, statements []string) (int64, error)

+ func (c *Client) ApplyDMLFile(ctx context.Context, ddl []byte, partitioned bool) (int64, error)

+ func (c *Client) ApplyPartitionedDML(ctx context.Context, statements []string) (int64, error)

+ func (c *Client) Close() error

+ func (c *Client) CreateDatabase(ctx context.Context, ddl []byte) error

+ func (c *Client) DetermineUpgradeStatus(ctx context.Context, tableName string) (UpgradeStatus, error)

+ func (c *Client) DropDatabase(ctx context.Context) error

+ func (c *Client) EnsureMigrationTable(ctx context.Context, tableName string) error

+ func (c *Client) ExecuteMigrations(ctx context.Context, migrations Migrations, limit int, tableName string) error

+ func (c *Client) GetMigrationHistory(ctx context.Context, versionTableName string) ([]MigrationHistoryRecord, error)

+ func (c *Client) GetMigrationLock(ctx context.Context, tableName, lockIdentifier string) (lock MigrationLock, err error)

+ func (c *Client) GetSchemaMigrationVersion(ctx context.Context, tableName string) (uint, bool, error)

+ func (c *Client) LoadDDL(ctx context.Context) ([]byte, error)

+ func (c *Client) SetSchemaMigrationVersion(ctx context.Context, version uint, dirty bool, tableName string) error

+ func (c *Client) SetupMigrationLock(ctx context.Context, tableName string) error

+ func (c *Client) TruncateAllTables(ctx context.Context) error

+ func (c *Client) UpgradeExecuteMigrations(ctx context.Context, migrations Migrations, limit int, tableName string) error

+ type Config struct

+ CredentialsFile string

+ Database string

+ Instance string

+ Project string

+ func (c *Config) URL() string

+ type Error struct

+ Code ErrorCode

+ func (e *Error) Error() string

+ type ErrorCode int

+ type Migration struct

+ Name string

+ Statements []string

+ Version uint

+ type MigrationHistoryRecord struct

+ Created time.Time

+ Dirty bool

+ Modified time.Time

+ Version int64

+ type MigrationLock struct

+ Expiry time.Time

+ LockIdentifier string

+ Release func()

+ Success bool

+ type Migrations []*Migration

+ func LoadMigrations(dir string) (Migrations, error)

+ func (ms Migrations) Len() int

+ func (ms Migrations) Less(i, j int) bool

+ func (ms Migrations) Swap(i, j int)

+ type UpgradeStatus string