|
@@ -66,11 +66,6 @@ func (d MySQLDriver) Open(dsn string) (driver.Conn, error) {
|
|
|
mc.parseTime = mc.cfg.ParseTime
|
|
mc.parseTime = mc.cfg.ParseTime
|
|
|
mc.strict = mc.cfg.Strict
|
|
mc.strict = mc.cfg.Strict
|
|
|
|
|
|
|
|
- // Call startWatcher for context support (From Go 1.8)
|
|
|
|
|
- if s, ok := interface{}(mc).(watcher); ok {
|
|
|
|
|
- s.startWatcher()
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
// Connect to Server
|
|
// Connect to Server
|
|
|
if dial, ok := dials[mc.cfg.Net]; ok {
|
|
if dial, ok := dials[mc.cfg.Net]; ok {
|
|
|
mc.netConn, err = dial(mc.cfg.Addr)
|
|
mc.netConn, err = dial(mc.cfg.Addr)
|
|
@@ -92,6 +87,11 @@ func (d MySQLDriver) Open(dsn string) (driver.Conn, error) {
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
+ // Call startWatcher for context support (From Go 1.8)
|
|
|
|
|
+ if s, ok := interface{}(mc).(watcher); ok {
|
|
|
|
|
+ s.startWatcher()
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
mc.buf = newBuffer(mc.netConn)
|
|
mc.buf = newBuffer(mc.netConn)
|
|
|
|
|
|
|
|
// Set I/O timeouts
|
|
// Set I/O timeouts
|