This repository has been archived by the owner on Apr 2, 2023. It is now read-only.
-
Notifications
You must be signed in to change notification settings - Fork 36
/
database.go
108 lines (101 loc) · 3.86 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
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
package baseproject
import (
"fmt"
"github.com/uberswe/golang-base-project/config"
"github.com/uberswe/golang-base-project/models"
"gorm.io/driver/mysql"
"gorm.io/driver/postgres"
"gorm.io/driver/sqlite"
"gorm.io/gorm"
"time"
)
func connectToDatabase(c config.Config) (db *gorm.DB, err error) {
return connectLoop(c, 0)
}
func connectLoop(c config.Config, count int) (db *gorm.DB, err error) {
db, err = attemptConnection(c)
if err != nil {
if count > 300 {
return db, fmt.Errorf("could not connect to database after 300 seconds")
}
time.Sleep(1 * time.Second)
return connectLoop(c, count+1)
}
return db, err
}
func attemptConnection(c config.Config) (db *gorm.DB, err error) {
if c.Database == "sqlite" {
// In-memory sqlite if no database name is specified
dsn := "file::memory:?cache=shared"
if c.DatabaseName != "" {
dsn = fmt.Sprintf("%s.db", c.DatabaseName)
}
db, err = gorm.Open(sqlite.Open(dsn), &gorm.Config{})
} else if c.Database == "mysql" {
dsn := fmt.Sprintf("%s:%s@tcp(%s:%s)/%s?charset=utf8mb4&parseTime=True&loc=Local", c.DatabaseUsername, c.DatabasePassword, c.DatabaseHost, c.DatabasePort, c.DatabaseName)
db, err = gorm.Open(mysql.Open(dsn), &gorm.Config{})
} else if c.Database == "postgres" {
dsn := fmt.Sprintf("host=%s user=%s password=%s dbname=%s port=%s sslmode=disable TimeZone=UTC", c.DatabaseHost, c.DatabaseUsername, c.DatabasePassword, c.DatabaseName, c.DatabasePort)
db, err = gorm.Open(postgres.Open(dsn), &gorm.Config{})
} else {
return db, fmt.Errorf("no database specified: %s", c.Database)
}
return db, err
}
func migrateDatabase(db *gorm.DB) error {
err := db.AutoMigrate(&models.User{}, &models.Token{}, &models.Session{}, &models.Website{})
seed(db)
return err
}
func seed(db *gorm.DB) {
// We seed some websites for our search results
websites := []models.Website{
{
Title: "A Tour of Go",
Description: "A Tour of Go has several interactive examples of how Go which you can learn from. There is a menu available if you would like to skip to different sections.",
URL: "https://go.dev/tour/welcome/1",
},
{
Title: "Go by Example",
Description: "As described on the website: Go by Example is a hands-on introduction to Go using annotated example programs. I have used this site many times as a reference when I need to look something up.",
URL: "https://gobyexample.com/",
},
{
Title: "Go.dev",
Description: "Learn how to install Go on your machine and read the documentation on the Go website.",
URL: "https://go.dev/learn/",
},
{
Title: "Uberswe on Github",
Description: "I am the creator of Golang Base Project. This is my Github profile.",
URL: "https://github.com/uberswe",
},
{
Title: "Tournify",
Description: "A website to create tournaments or free which uses this project as a base.",
URL: "https://tournify.io",
},
{
Title: "GORM",
Description: "The fantastic ORM library for Golang.",
URL: "https://gorm.io/",
},
{
Title: "Bootstrap",
Description: "Quickly design and customize responsive mobile-first sites with Bootstrap, the world’s most popular front-end open source toolkit, featuring Sass variables and mixins, responsive grid system, extensive prebuilt components, and powerful JavaScript plugins.",
URL: "https://getbootstrap.com/",
},
{
Title: "Gin Web Framework",
Description: "Gin is a HTTP web framework written in Go (Golang). It features a Martini-like API with much better performance -- up to 40 times faster. If you need smashing performance, get yourself some Gin.",
URL: "https://github.com/gin-gonic/gin",
},
}
for _, w := range websites {
res := db.Where(&w).First(&w)
// If no record exists we insert
if res.Error != nil && res.Error == gorm.ErrRecordNotFound {
db.Save(&w)
}
}
}