aboutsummaryrefslogtreecommitdiffstats
path: root/python/database_consistency.py
blob: d2ba762ac617a5f0cfa39f7100ea6c42c0eed2af (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
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]))