+ oldVersion, newVersion, err := migrate.RunMigrations(DB, mig, "up")
+
+ if oldVersion != newVersion {
+ log.Infof("Migrate DB: %v -> %v", oldVersion, newVersion)
+ } else {
+ log.Infof("DB up-to-date: version '%v'", newVersion)
+ }
+ return err
+}
+
+func connect(config DBConfig) *pg.DB {
+ return pg.Connect(&pg.Options{
+ User: config.User,
+ Password: config.Password,
+ Database: config.Database,
+ Network: config.Type,
+ Addr: config.Address,
+ })