-
Notifications
You must be signed in to change notification settings - Fork 0
/
database.go
92 lines (71 loc) · 2.24 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
package goutil
import (
"database/sql"
"errors"
"fmt"
"log"
"os"
"strings"
"time"
"github.com/jmoiron/sqlx"
"gopkg.in/guregu/null.v4"
"gorm.io/driver/mysql"
"gorm.io/driver/postgres"
"gorm.io/gorm"
"gorm.io/gorm/logger"
)
type logLevel int
const (
LoggerSilent = logLevel(logger.Silent)
LoggerError = logLevel(logger.Error)
LoggerWarn = logLevel(logger.Warn)
LoggerInfo = logLevel(logger.Info)
)
// NewMySQL is a function for set up db mysql connection
func NewMySQL(user, password, url, schema string, parameters []string) (*sql.DB, error) {
parameter := strings.Join(parameters, "&")
conn := fmt.Sprintf("%s:%s@tcp(%s)/%s?%s", user, password, url, schema, parameter)
db, err := sql.Open("mysql", conn)
if err != nil {
return nil, err
}
return db, err
}
// NewPostgreSQL is a function for set up db postgresql connection
func NewPostgreSQL(user, password, host, schema string, sslMode null.String, port int) (*sql.DB, error) {
if !sslMode.Valid {
sslMode.SetValid("disable")
}
conn := fmt.Sprintf("host=%s port=%d user=%s password=%s dbname=%s sslmode=%s", host, port, user, password, schema, sslMode.String)
db, err := sql.Open("postgres", conn)
if err != nil {
return nil, err
}
return db, err
}
// NewGorm is a override sql from native sql to gorm.
// driverName is a package of database your using, currently we have only mysql package.
// level is a info log of query, value is 1 - 4 (Silent, Error, Warn & Info)
func NewGorm(db *sql.DB, driverName string, level logLevel) (*gorm.DB, error) {
gormConfig := &gorm.Config{
Logger: logger.New(log.New(os.Stdout, "\r\n", log.LstdFlags), logger.Config{
SlowThreshold: time.Second,
LogLevel: logger.LogLevel(level),
Colorful: true,
})}
switch driverName {
case "mysql":
return gorm.Open(mysql.New(mysql.Config{Conn: db}), gormConfig)
case "postgres":
return gorm.Open(postgres.New(postgres.Config{Conn: db}), gormConfig)
}
return nil, errors.New("driver name is not registered")
}
// NewSqlx is a override sql from native sql to sqlx
func NewSqlx(db *sql.DB, driverName string) *sqlx.DB {
sqlxCon := sqlx.NewDb(db, driverName)
sqlxCon.SetConnMaxLifetime(time.Minute * 3)
sqlxCon.SetMaxOpenConns(10)
sqlxCon.SetMaxIdleConns(10)
return sqlxCon
}