Browse Source

mysql data provider: add read and write timeout

This should hopefully fix #47
Nicola Murino 5 years ago
parent
commit
bf00ca334d
1 changed files with 1 additions and 1 deletions
  1. 1 1
      dataprovider/mysql.go

+ 1 - 1
dataprovider/mysql.go

@@ -19,7 +19,7 @@ func initializeMySQLProvider() error {
 	var connectionString string
 	var connectionString string
 	logSender = MySQLDataProviderName
 	logSender = MySQLDataProviderName
 	if len(config.ConnectionString) == 0 {
 	if len(config.ConnectionString) == 0 {
-		connectionString = fmt.Sprintf("%v:%v@tcp([%v]:%v)/%v?charset=utf8&interpolateParams=true&timeout=10s&tls=%v",
+		connectionString = fmt.Sprintf("%v:%v@tcp([%v]:%v)/%v?charset=utf8&interpolateParams=true&timeout=10s&tls=%v&writeTimeout=10s&readTimeout=10s",
 			config.Username, config.Password, config.Host, config.Port, config.Name, getSSLMode())
 			config.Username, config.Password, config.Host, config.Port, config.Name, getSSLMode())
 	} else {
 	} else {
 		connectionString = config.ConnectionString
 		connectionString = config.ConnectionString