@@ -65,7 +65,8 @@ class MysqlDS(DataSourceBase):
database=self.database_name,
user=self.username,
password=self.password,
- ssl_disabled=not use_ssl)
+ ssl_disabled=not use_ssl,
+ connection_timeout=5)
cursor = conn.cursor()
for sql in sqls:
cursor.execute(sql)