test/logdb
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

fix timeout 15s

Browse Source
This commit is contained in:
huangsimin 2018-12-10 14:58:29 +08:00
parent fc789d2322
commit f9dab01687
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
logdb.go
View File

@ -48,7 +48,7 @@ func (logdb *LogDB) Ping() (result bool) {
log.Println(err, logdb.Hosts[logdb.hostid], " is unconnect ") log.Println(err, logdb.Hosts[logdb.hostid], " is unconnect ")
hostlen := len(logdb.Hosts) hostlen := len(logdb.Hosts)
for i := 0; i < hostlen; i++ { for i := 0; i < hostlen; i++ {
db, err := sql.Open("mysql", fmt.Sprintf("%s:%s@tcp(%s:%s)/%s?timeout=1s&charset=%s", logdb.User, logdb.Password, logdb.Hosts[i], logdb.Port, logdb.DB, logdb.Charset)) db, err := sql.Open("mysql", fmt.Sprintf("%s:%s@tcp(%s:%s)/%s?timeout=15s&charset=%s", logdb.User, logdb.Password, logdb.Hosts[i], logdb.Port, logdb.DB, logdb.Charset))
if err != nil { if err != nil {
log.Println(err, logdb.Hosts[i], " is connect fail") log.Println(err, logdb.Hosts[i], " is connect fail")
continue continue
@ -79,7 +79,7 @@ func (logdb *LogDB) Connect() {
if logdb.hostid >= len(logdb.Hosts) { if logdb.hostid >= len(logdb.Hosts) {
logdb.hostid = 0 logdb.hostid = 0
} }
db, err := sql.Open("mysql", fmt.Sprintf("%s:%s@tcp(%s:%s)/%s?timeout=1s&charset=%s", logdb.User, logdb.Password, logdb.Hosts[logdb.hostid], logdb.Port, logdb.DB, logdb.Charset)) db, err := sql.Open("mysql", fmt.Sprintf("%s:%s@tcp(%s:%s)/%s?timeout=15s&charset=%s", logdb.User, logdb.Password, logdb.Hosts[logdb.hostid], logdb.Port, logdb.DB, logdb.Charset))
if err != nil { if err != nil {
panic(err) panic(err)
} }