Added host to database connection strings

Author: dmytrotsko

Diff for: src/acquisition/cdcp/cdc_dropbox_receiver.py

@@ -47,7 +47,7 @@ def trigger_further_processing():
 
   # connect
   u, p = secrets.db.auto
-  cnx = mysql.connector.connect(user=u, password=p, database='automation')
+  cnx = mysql.connector.connect(user=u, password=p, database='automation', host=secrets.db.host)
   cur = cnx.cursor()
 
   # add step "Process CDCP Data" to queue

Diff for: src/acquisition/cdcp/cdc_extract.py

@@ -154,7 +154,7 @@ def extract(first_week=None, last_week=None, test_mode=False):
 
   # 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()
 
   # weeks to update

Diff for: src/acquisition/cdcp/cdc_upload.py

@@ -165,7 +165,7 @@
 def upload(test_mode):
   # 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()
 
   # insert (or update) table `cdc`

Diff for: src/acquisition/ecdc/ecdc_db_update.py

@@ -48,7 +48,7 @@
 
 def ensure_tables_exist():
     (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)
     try:
         cursor = cnx.cursor()
         cursor.execute('''
@@ -92,7 +92,7 @@ def update_from_file(issue, date, dir, test_mode=False):
     # Read ECDC data from CSVs and insert into (or update) the database.
     # 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, 'ecdc_ili')
     print('rows before: %d' % (rows1))
     insert = cnx.cursor()

Diff for: src/acquisition/ght/ght_update.py

@@ -251,7 +251,7 @@
 def update(locations, terms, first=None, last=None, countries=['US']):
   # connect to the database
   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()
 
   def get_num_rows():

Diff for: src/acquisition/kcdc/kcdc_update.py

@@ -44,7 +44,7 @@
 
 def ensure_tables_exist():
     (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)
     try:
         cursor = cnx.cursor()
         cursor.execute('''

Diff for: src/acquisition/nidss/taiwan_update.py

@@ -105,7 +105,7 @@ def update(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', cnx=secrets.db.host)
   rows1 = get_rows(cnx)
   print('rows before (flu): %d' % (rows1[0]))
   print('rows before (dengue): %d' % (rows1[1]))

Diff for: src/acquisition/paho/paho_db_update.py

@@ -66,7 +66,7 @@
 
 def ensure_tables_exist():
     (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)
     try:
         cursor = cnx.cursor()
         cursor.execute('''
@@ -156,7 +156,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, 'paho_dengue')
     print('rows before: %d' % (rows1))
     insert = cnx.cursor()

Diff for: src/acquisition/quidel/quidel_update.py

@@ -63,7 +63,7 @@ def update(locations, first=None, last=None, force_update=False, load_email=True
   qd_ts = quidel.measurement_to_ts(qd_measurements,7,startweek=first,endweek=last)
   # connect to the database
   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()
 
   def get_num_rows():

Diff for: src/acquisition/twtr/twitter_update.py

@@ -62,7 +62,7 @@
 def run():
   # connect to the database
   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()
 
   def get_num_rows():

Diff for: src/acquisition/wiki/wiki_extract.py

@@ -60,7 +60,7 @@ def get_timestamp(name):
 def run(job_limit=100):
   # connect to the database
   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()
 
   # # Some preparation for utf-8, and it is a temporary trick solution. The real solution should change those char set and collation encoding to utf8 permanently

Diff for: src/acquisition/wiki/wiki_update.py

@@ -79,7 +79,7 @@ def get_manifest(year, month, optional=False):
 def run():
   # connect to the database
   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 most recent job in wiki_raw