Fix up the database
This commit is contained in:
11
db.go
11
db.go
@@ -19,10 +19,13 @@ type DBWrapper struct {
|
||||
var db *DBWrapper
|
||||
|
||||
func GetDB() (DB, error) {
|
||||
if db != nil {
|
||||
return db, nil
|
||||
}
|
||||
var err error
|
||||
|
||||
dbFile := filepath.Join("data.sqlite")
|
||||
db, err := gorm.Open(sqlite.Open(dbFile), &gorm.Config{
|
||||
dbFile := filepath.Join("sqlite-latest.sqlite")
|
||||
gdb, err := gorm.Open(sqlite.Open(dbFile), &gorm.Config{
|
||||
// SkipDefaultTransaction: true,
|
||||
PrepareStmt: true,
|
||||
// Logger: gormlogger.Default.LogMode(gormlogger.Silent),
|
||||
@@ -31,11 +34,11 @@ func GetDB() (DB, error) {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
return &DBWrapper{db: db}, nil
|
||||
db := &DBWrapper{db: gdb}
|
||||
return db, nil
|
||||
}
|
||||
|
||||
|
||||
// Just a wrapper
|
||||
func (db *DBWrapper) Raw(sql string, args ...any) *gorm.DB {
|
||||
return db.db.Raw(sql, args...)
|
||||
}
|
||||
|
||||
6
main.go
6
main.go
@@ -9,6 +9,12 @@ import (
|
||||
func main() {
|
||||
flag.Parse()
|
||||
logger.InitFlag()
|
||||
db, err := GetDB()
|
||||
if err != nil {
|
||||
logger.Error("Failed to get database: %v", err)
|
||||
return
|
||||
}
|
||||
db.DB().AutoMigrate(&Killmail{}, &Attacker{}, &Victim{}, &Item{}, &Position{})
|
||||
|
||||
file := "data/killmails-2025-01-01.tar.bz2"
|
||||
killmails := make(chan Killmail)
|
||||
|
||||
Reference in New Issue
Block a user