()
| 435 | } |
| 436 | |
| 437 | func (e ErrNonCompatibleMigrationVersion) Error() string { |
| 438 | return fmt.Sprintf("non-compatible migration version %d (acceptable versions: %v)", e.version, e.acceptableVersions) |
| 439 | } |
| 440 | |
| 441 | func checkMigrationVersion(ctx context.Context, pool *pgxpool.Pool, migrationTable string, acceptableVersions []int) error { |
| 442 | checkMigrationVersionQuery := fmt.Sprintf("SELECT MAX(version) FROM %s", migrationTable) |
no outgoing calls