diff options
| -rw-r--r-- | python/database_consistency.py | 24 |
1 files changed, 24 insertions, 0 deletions
diff --git a/python/database_consistency.py b/python/database_consistency.py new file mode 100644 index 00000000..d2ba762a --- /dev/null +++ b/python/database_consistency.py @@ -0,0 +1,24 @@ +from db import query_db +import pdb +import datetime + +if __name__=="__main__": + sqlstr1 = "select dealname, \"Curr Collat Bal\", \"Latest Update\" from clo_universe" + sqlstr2 = "select dealname, sum(currentbalance), updatedate from et_collateral group by dealname, updatedate" + + data1 = query_db(sqlstr1, one=False) + data2 = query_db(sqlstr2, one=False) + dict1 = {(e[0], e[2]): e[1] for e in data1} + dict2 = {(e[0], e[2]): e[1] for e in data2} + res = [] + for k, v in dict1.items(): + try: + if abs(dict2[k] -v)>1: + pass + res.append([k, v, dict2[k]]) + except KeyError: + #res.append([k, v]) + pass + res = sorted(res, key=lambda x: x[0][1]) + for e in res: + print("{0} {1} {2} {3}".format(e[0][0], e[0][1], e[1], e[2])) |