import json
import pprint
-from common.buildmonitor_db import do_query, get_value_from_query_data, do_many_query, connect_db, disconnect_db
+sys.path.insert(1, os.path.join(sys.path[0], '..'))
+
+from common.buildmonitor_db import do_query, get_value_from_query_data, do_many_query, connect_db, disconnect_db, get_multi_values_from_query_data
from common.buildmonitor_extention import BuildMonitorExtention
-def dtr_target_lookup_insert_fun(TOTAL_INFO):
+def dtr_target_lookup_insert_fun(TOTAL_INFO, arg_name):
connect_db()
# Insert values
disconnect_db()
-def dtr_test_comment_insert_fun(TOTAL_INFO):
+ return total_results
+
+
+def dtr_smoke_comment_insert_fun(TOTAL_INFO, arg_name):
connect_db()
# Insert values
disconnect_db()
+ return total_results
+
def dtr_smoke_result_insert_fun(TOTAL_INFO, LOOKUP_INFO, SMOKE_CASE_INFO, arg_name):
connect_db()
for case_idx, test_case_value in enumerate(total_results['test_case']): #22
tmp_value = total_results['smoke_result_list'][case_idx]
for value_idx, result_value in enumerate(tmp_value): #15
- total_results[arg_name].append((result_value, test_case_value, \
- int(SMOKE_CASE_INFO['DB_smoke_comment_table'][case_idx][0]), \
- int(LOOKUP_INFO['DB_lookup_table'][value_idx][0])))
+ total_results[arg_name].append((result_value, test_case_value, int(SMOKE_CASE_INFO['DB_smoke_comment_table'][case_idx][0]), int(LOOKUP_INFO['DB_lookup_table'][value_idx][0])))
- query = "INSERT INTO dtr_smoke_envorin_result (result, test_case, smoke_comment_id , target_lookup_id) VALUES(%s, %s, %s, %s)"
+# pprint.pprint(total_results[arg_name])
+
+ query = "INSERT INTO dtr_smoke_envorin_result (result, test_case, smoke_comment_id , target_lookup_id) VALUES(%s, %s, %s, %s)"
query_var_list = []
- for smoke_DB_values in total_results[arg_name]:
- query_var_list.append( smoke_DB_values )
+
+
+ for sample_DB_values in total_results[arg_name]:
+ query_var_list.append( sample_DB_values )
pprint.pprint(query_var_list)
do_many_query(query, query_var_list)