Level_2.py 1.5 KB

1234567891011121314151617181920212223242526272829303132333435363738
  1. import Support as sp
  2. import numpy as np
  3. def get_level2Instance_by_LV4Instance(lv4_instances, conn):
  4. #initialize array
  5. #lv4_Lv2_map = np.array([], dtype=[('lv4', int),('lv2',int), ('data', float)])
  6. #fill array
  7. cur = conn.cursor()
  8. # #lv4_instances=np.array(lv4_instances,dtype=[('keys', int), ('data', float)])
  9. #create and execute lv2 query
  10. liststring = sp.list_to_string(lv4_instances)
  11. query = "select i.called_by from instances i where i.instance in (select called_by from instances i where i.instance in(" + liststring + "))"
  12. cur.execute(query)
  13. sqlResult = cur.fetchall()
  14. lv2_instances = np.array([], dtype=int)
  15. for entry in sqlResult:
  16. lv2_instance = np.array(int(entry[0]), dtype = lv2_instances.dtype)
  17. lv2_instances=np.append(lv2_instances,lv2_instance)
  18. # print(query)
  19. #print("LV2")
  20. #print(lv2_instances)
  21. return lv2_instances
  22. def orderLV2InstancesChronoligically(lv2_instances, conn):
  23. cur = conn.cursor()
  24. liststring = sp.list_to_string(lv2_instances)
  25. query = "select distinct instance from logEntries where instance in (" + liststring + ") order by timestamp asc"
  26. #print(query)
  27. cur.execute(query)
  28. sqlResult = cur.fetchall()
  29. lv2_instances = np.array([], dtype=int)
  30. for entry in sqlResult:
  31. lv2_instances = np.append(lv2_instances, np.array([int(entry[0])], dtype=lv2_instances.dtype))
  32. #print("lv2_Sorted")
  33. #print(lv2_instances)
  34. return lv2_instances