Added host to database connection

Author: dmytrotsko

src/acquisition/fluview/fluview_notify.py

@@ -39,7 +39,7 @@
 
   # connect
   u, p = secrets.db.epi
-  cnx = mysql.connector.connect(user=u, password=p, database='epidata')
+  cnx = mysql.connector.connect(user=u, password=p, database='epidata', host=secrets.db.host)
   cur = cnx.cursor()
 
   # get the last known issue from the automation table `variables`

src/acquisition/fluview/fluview_update.py

@@ -302,7 +302,7 @@ def update_from_file_clinical(issue, date, filename, test_mode=False):
 
   # database connection
   u, p = secrets.db.epi
-  cnx = mysql.connector.connect(user=u, password=p, database='epidata')
+  cnx = mysql.connector.connect(user=u, password=p, database='epidata', host=secrets.db.host)
   rows1 = get_rows(cnx, CL_TABLE)
   print('rows before: %d' % (rows1))
   insert = cnx.cursor()
@@ -362,7 +362,7 @@ def update_from_file_public(issue, date, filename, test_mode=False):
 
   # database connection
   u, p = secrets.db.epi
-  cnx = mysql.connector.connect(user=u, password=p, database='epidata')
+  cnx = mysql.connector.connect(user=u, password=p, database='epidata', host=secrets.db.host)
   rows1 = get_rows(cnx, PHL_TABLE)
   print('rows before: %d' % (rows1))
   insert = cnx.cursor()
@@ -425,7 +425,7 @@ def update_from_file(issue, date, filename, test_mode=False):
 
   # database connection
   u, p = secrets.db.epi
-  cnx = mysql.connector.connect(user=u, password=p, database='epidata')
+  cnx = mysql.connector.connect(user=u, password=p, database='epidata', host=secrets.db.host)
   rows1 = get_rows(cnx)
   print('rows before: %d' % (rows1))
   insert = cnx.cursor()

src/acquisition/fluview/impute_missing_values.py

@@ -135,7 +135,7 @@ class Sql:
   def connect(self):
     """Connect to the database."""
     u, p = secrets.db.epi
-    self.cnx = mysql.connector.connect(user=u, password=p, database='epidata')
+    self.cnx = mysql.connector.connect(user=u, password=p, database='epidata', host=secrets.db.host)
     self.cur = self.cnx.cursor()
 
   def close(self, commit):