2021-08-26 16:16:50 +03:00
|
|
|
package db
|
|
|
|
|
|
|
|
import (
|
|
|
|
"context"
|
|
|
|
"log"
|
|
|
|
|
|
|
|
Config "micrach/config"
|
|
|
|
|
|
|
|
"github.com/jackc/pgx/v4/pgxpool"
|
|
|
|
)
|
|
|
|
|
|
|
|
var Pool *pgxpool.Pool
|
|
|
|
|
|
|
|
func Init() {
|
|
|
|
var err error
|
2021-09-10 19:16:53 +03:00
|
|
|
Pool, err = pgxpool.Connect(context.TODO(), Config.Db.Url)
|
2021-08-26 16:16:50 +03:00
|
|
|
if err != nil {
|
|
|
|
log.Println("database - offline")
|
|
|
|
log.Panicln(err)
|
|
|
|
}
|
|
|
|
|
|
|
|
log.Println("database - online")
|
|
|
|
}
|
2021-11-07 11:42:54 +03:00
|
|
|
|
|
|
|
func Migrate() {
|
|
|
|
// m, err := migrate.New("file://migrations", Config.Db.Url)
|
|
|
|
// if err != nil {
|
|
|
|
// log.Panicln(err)
|
|
|
|
// }
|
|
|
|
// err = m.Up()
|
|
|
|
// if err != nil && err != migrate.ErrNoChange {
|
|
|
|
// log.Panicln(err)
|
|
|
|
// }
|
|
|
|
// m.Close()
|
|
|
|
// TODO: check another libraries
|
|
|
|
log.Println("database migrations - online")
|
|
|
|
}
|