|
@@ -32,14 +32,14 @@ func newGormDB(dbConfig *DBConfig) (*gorm.DB, error) {
|
|
|
|
|
|
switch dbConfig.Type {
|
|
|
case databaseTypePostgres:
|
|
|
- innerGormDB, err := newPostgresSQLOperationsItem(dbConfig)
|
|
|
+ innerGormDB, err := newPostgresGormDB(dbConfig)
|
|
|
if err != nil {
|
|
|
return nil, err
|
|
|
}
|
|
|
|
|
|
gormDB = innerGormDB
|
|
|
default:
|
|
|
- innerGormDB, err := newPostgresSQLOperationsItem(dbConfig)
|
|
|
+ innerGormDB, err := newPostgresGormDB(dbConfig)
|
|
|
if err != nil {
|
|
|
return nil, err
|
|
|
}
|
|
@@ -50,7 +50,7 @@ func newGormDB(dbConfig *DBConfig) (*gorm.DB, error) {
|
|
|
return gormDB, nil
|
|
|
}
|
|
|
|
|
|
-func newPostgresSQLOperationsItem(dbConfig *DBConfig) (*gorm.DB, error) {
|
|
|
+func newPostgresGormDB(dbConfig *DBConfig) (*gorm.DB, error) {
|
|
|
dsn := "host=%s port=%s user=%s password=%s dbname=%s sslmode=disable TimeZone=Asia/Shanghai"
|
|
|
connStr := fmt.Sprintf(dsn, dbConfig.Address, dbConfig.Port, dbConfig.UserName, dbConfig.Password, dbConfig.Database)
|
|
|
return gorm.Open(postgres.Open(connStr), &gorm.Config{
|