Guest User

Untitled

a guest
Nov 30th, 2017
241
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 1.95 KB | None | 0 0
  1. def export_data():
  2.  
  3. infos = [
  4. 'Conta Corrente Itau',
  5. 'Cartao Itau Master',
  6. 'Cartao Itau VISA',
  7. 'Carteira'
  8. ]
  9.  
  10. chart_of_accounts = list(infos)
  11.  
  12. for account in chart_of_accounts:
  13. cnx = mariadb.connect(user='root', password='', database='base_completa')
  14. cursor = cnx.cursor()
  15. params = (account, account)
  16. query = """
  17. SELECT Y, M,(@total := @total + Fluxo) AS ValorTotal
  18. FROM (
  19. SELECT year(data) AS Y, month(data) AS M,
  20. (
  21. SUM(IF(Credito="%s", valor, 0))-
  22. SUM(IF(Debito="%s", valor, 0))
  23. ) AS Fluxo
  24. FROM ledger
  25. GROUP BY YEAR(DATA), MONTH(DATA)
  26. ) AS T,
  27. (SELECT @total:=0) AS n;
  28. """ % (params)
  29.  
  30. cursor.execute(query)
  31. rows = cursor.fetchall()
  32. desc = cursor.description
  33.  
  34. lista = [dict(itertools.izip([col[0] for col in desc], row))
  35. for row in rows]
  36.  
  37. cnx.commit()
  38.  
  39. print account
  40. print json.dumps(lista)
  41.  
  42. return lista
  43.  
  44. results = export_data()
  45.  
  46. cursor.execute(query, (chart_of_accounts[account] for account in chart_of_accounts))
  47.  
  48. SUM(IF(Credito=""Conta Corrente Itau"", valor, 0))
  49.  
  50. SUM(IF(Credito="%s", valor, 0))
  51.  
  52. params = (account, account)
  53.  
  54. with open(file_location+'\' + 'file_name' +'.sql','r') as inserts:
  55. sqlScript = inserts.read()
  56. for statement in sqlScript.split(';'):
  57. with cnx.cursor() as cur:
  58. cur.execute(statement)
  59.  
  60. query="Select * from output_table"
  61.  
  62. df=pd.read_sql_query(query, cnx)
  63.  
  64. Select * from output_table
  65.  
  66. params = (account, account)
Add Comment
Please, Sign In to add comment