-
Notifications
You must be signed in to change notification settings - Fork 0
/
database.go
60 lines (49 loc) · 1.75 KB
/
database.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
package repository
import (
"database/sql"
"errors"
"github.com/golang-migrate/migrate/v4"
migratedriver "github.com/golang-migrate/migrate/v4/database/sqlite3"
_ "github.com/golang-migrate/migrate/v4/source/file"
"github.com/jmoiron/sqlx"
"github.com/judoassistant/judoassistant-meta-service/config"
judoerrors "github.com/judoassistant/judoassistant-meta-service/errors"
"github.com/mattn/go-sqlite3"
_ "github.com/mattn/go-sqlite3"
)
const _migrationsPath string = "file://repository/migrations"
func NewDatabase(config *config.Config) (*sqlx.DB, error) {
// Connect to database
db, err := sqlx.Connect("sqlite3", config.DatabasePath)
if err != nil {
return nil, judoerrors.WrapWithCode(err, "unable to initialize database", errorCodeFromDatabaseError(err))
}
// Perform migrations
driver, err := migratedriver.WithInstance(db.DB, &migratedriver.Config{})
if err != nil {
return nil, judoerrors.WrapWithCode(err, "unable to create migration driver", errorCodeFromDatabaseError(err))
}
migrations, err := migrate.NewWithDatabaseInstance(_migrationsPath, "sqlite3", driver)
if err != nil {
return nil, judoerrors.WrapWithCode(err, "unable to load database migrations", errorCodeFromDatabaseError(err))
}
if err := migrations.Up(); !errors.Is(err, migrate.ErrNoChange) {
return nil, judoerrors.WrapWithCode(err, "unable to execute database migrations", errorCodeFromDatabaseError(err))
}
return db, nil
}
func errorCodeFromDatabaseError(err error) int {
if errors.Is(err, sql.ErrNoRows) {
return judoerrors.CodeNotFound
}
sqliteErr, ok := err.(sqlite3.Error)
if !ok {
return judoerrors.CodeUnavailable
}
switch sqliteErr.Code {
case sqlite3.ErrConstraint:
return judoerrors.CodeConflict
default:
return judoerrors.CodeUnavailable
}
}