mirror of
https://github.com/ManyakRus/starter.git
synced 2025-11-27 23:18:34 +02:00
сделал postgres_pgx
This commit is contained in:
@@ -364,11 +364,6 @@ loop:
|
|||||||
log.Warn("Context app is canceled. postgres_pgx.ping")
|
log.Warn("Context app is canceled. postgres_pgx.ping")
|
||||||
break loop
|
break loop
|
||||||
case <-ticker.C:
|
case <-ticker.C:
|
||||||
//IsClosed
|
|
||||||
if Conn.IsClosed() == true {
|
|
||||||
NeedReconnect = true
|
|
||||||
log.Error("postgres_pgx error: IsClosed() = true")
|
|
||||||
}
|
|
||||||
|
|
||||||
//ping в базе данных
|
//ping в базе данных
|
||||||
err = Conn.Ping(contextmain.GetContext())
|
err = Conn.Ping(contextmain.GetContext())
|
||||||
@@ -385,6 +380,12 @@ loop:
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
} else {
|
||||||
|
//IsClosed
|
||||||
|
if Conn.IsClosed() == true {
|
||||||
|
NeedReconnect = true
|
||||||
|
log.Error("postgres_pgx error: IsClosed() = true")
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
//ping порта
|
//ping порта
|
||||||
|
|||||||
Reference in New Issue
Block a user