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]))