Advertisement
Guest User

Untitled

a guest
Sep 21st, 2016
90
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 1.39 KB | None | 0 0
  1. #coding=utf-8
  2. import psycopg2
  3. import random
  4. import multiprocessing
  5.  
  6. conn = psycopg2.connect("dbname=test user=higis password=dbrgdbrg host=10.1.1.215 port=5432")
  7. cur = conn.cursor()
  8.  
  9. #test-SQl operate
  10. def multitest(num):
  11. global a
  12. global b
  13. global c
  14. global d
  15. a = random.randint(74,135)
  16. b = random.randint(18,53)
  17. c = random.randint(74,135)
  18. d = random.randint(18,53)
  19. if a>c:
  20. a=c
  21. if b>d:
  22. b=d
  23. try:
  24. sqltest = "SELECT ogc_fid FROM testindex_1 WHERE ST_MAKEENVELOPE" + str((a,b,c,d,4326))+str("&& wkb_geometry")
  25. cur.execute(sqltest)
  26. #print cur.fetchall()
  27. except Exception, e:
  28. print e
  29.  
  30.  
  31. #citus-SQL operate
  32. def multicitus(num):
  33. try:
  34. sqlcitus = "SELECT ogc_fid FROM citusindex_1 WHERE ST_MAKEENVELOPE" + str((a, b, c, d, 4326)) + str(
  35. "&& wkb_geometry")
  36. cur.execute(sqlcitus)
  37. #print cur.fetchall()
  38.  
  39. except Exception,e:
  40. print e
  41.  
  42. #test-multi-process
  43. if __name__ =="__main__":
  44. nums = 5
  45. for num in range(nums):
  46. p = multiprocessing.Process(target=multitest,args=(num,))
  47. #print 'process a %d is start'%num
  48. p.start()
  49. p.join()
  50.  
  51.  
  52. #citus-multi-process
  53. for num in range(nums):
  54. q = multiprocessing.Process(target=multicitus,args=(num,))
  55. #print 'process b %d is start'%num
  56. q.start()
  57. q.join()
  58.  
  59.  
  60.  
  61. cur.close()
  62. conn.close()
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement