fix: using mysql via a socket
This commit is contained in:
parent
efa1dc3106
commit
0a6bbc2efd
@ -112,11 +112,16 @@ func RegisterTableStructsForCache(val interface{}) {
|
|||||||
func initMysqlEngine() (engine *xorm.Engine, err error) {
|
func initMysqlEngine() (engine *xorm.Engine, err error) {
|
||||||
// We're using utf8mb here instead of just utf8 because we want to use non-BMP characters.
|
// We're using utf8mb here instead of just utf8 because we want to use non-BMP characters.
|
||||||
// See https://stackoverflow.com/a/30074553/10924593 for more info.
|
// See https://stackoverflow.com/a/30074553/10924593 for more info.
|
||||||
|
host := fmt.Sprintf("tcp(%s)", config.DatabaseHost.GetString())
|
||||||
|
if config.DatabaseHost.GetString()[0] == '/' { // looks like a unix socket
|
||||||
|
host = config.DatabaseHost.GetString()
|
||||||
|
}
|
||||||
|
|
||||||
connStr := fmt.Sprintf(
|
connStr := fmt.Sprintf(
|
||||||
"%s:%s@tcp(%s)/%s?charset=utf8mb4&parseTime=true&tls=%s",
|
"%s:%s@%s/%s?charset=utf8mb4&parseTime=true&tls=%s",
|
||||||
config.DatabaseUser.GetString(),
|
config.DatabaseUser.GetString(),
|
||||||
config.DatabasePassword.GetString(),
|
config.DatabasePassword.GetString(),
|
||||||
config.DatabaseHost.GetString(),
|
host,
|
||||||
config.DatabaseDatabase.GetString(),
|
config.DatabaseDatabase.GetString(),
|
||||||
config.DatabaseTLS.GetString())
|
config.DatabaseTLS.GetString())
|
||||||
engine, err = xorm.NewEngine("mysql", connStr)
|
engine, err = xorm.NewEngine("mysql", connStr)
|
||||||
|
Loading…
x
Reference in New Issue
Block a user