|
@@ -56,6 +56,15 @@ func (d *MySQLDriver) Open(dsn string) (driver.Conn, error) {
|
|
|
if err != nil {
|
|
if err != nil {
|
|
|
return nil, err
|
|
return nil, err
|
|
|
}
|
|
}
|
|
|
|
|
+
|
|
|
|
|
+ // Enable TCP Keepalives on TCP connections
|
|
|
|
|
+ if tc, ok := mc.netConn.(*net.TCPConn); ok {
|
|
|
|
|
+ if err := tc.SetKeepAlive(true); err != nil {
|
|
|
|
|
+ mc.Close()
|
|
|
|
|
+ return nil, err
|
|
|
|
|
+ }
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
mc.buf = newBuffer(mc.netConn)
|
|
mc.buf = newBuffer(mc.netConn)
|
|
|
|
|
|
|
|
// Reading Handshake Initialization Packet
|
|
// Reading Handshake Initialization Packet
|