From 5a2fcea9dfc3dad5e0039640e74454659e70e022 Mon Sep 17 00:00:00 2001
From: Chaz <chaz@pokeit.co>
Date: Thu, 2 Dec 2010 00:27:03 -0500
Subject: [PATCH 1/4] turns out the the '+0' is for indexing and has nothing to
 do with NULLS so I put it back in

---
 pyfpdb/SQL.py | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/pyfpdb/SQL.py b/pyfpdb/SQL.py
index 1f91e822..1b6a9f4c 100644
--- a/pyfpdb/SQL.py
+++ b/pyfpdb/SQL.py
@@ -3964,12 +3964,12 @@ class Sql:
             street2Raises=street2Raises+%s,
             street3Raises=street3Raises+%s,
             street4Raises=street4Raises+%s
-        WHERE gametypeId=%s
+        WHERE gametypeId+0=%s
             AND   playerId=%s
             AND   activeSeats=%s
             AND   position=%s
             AND   (case when tourneyTypeId is NULL then 1 else 
-                   (case when tourneyTypeId=%s then 1 else 0 end) end)=1
+                   (case when tourneyTypeId+0=%s then 1 else 0 end) end)=1
             AND   styleKey=%s"""
 
         self.query['get_hero_hudcache_start'] = """select min(hc.styleKey)

From cbd6aa242e43076bcef2fb1206fef3248da97be0 Mon Sep 17 00:00:00 2001
From: Chaz <Chaz@Chaz-THINK>
Date: Thu, 2 Dec 2010 00:35:18 -0500
Subject: [PATCH 2/4] Added the 'cacheSessions' config option

---
 pyfpdb/Configuration.py       | 6 +++++-
 pyfpdb/HUD_config.test.xml    | 2 +-
 pyfpdb/HUD_config.xml.example | 2 +-
 pyfpdb/fpdb_import.py         | 4 ++++
 4 files changed, 11 insertions(+), 3 deletions(-)
 mode change 100755 => 100644 pyfpdb/fpdb_import.py

diff --git a/pyfpdb/Configuration.py b/pyfpdb/Configuration.py
index 4e01b796..ed12f7a4 100644
--- a/pyfpdb/Configuration.py
+++ b/pyfpdb/Configuration.py
@@ -479,12 +479,13 @@ class Import:
         self.hhArchiveBase = node.getAttribute("hhArchiveBase")
         self.hhBulkPath = node.getAttribute("hhBulkPath")
         self.saveActions = string_to_bool(node.getAttribute("saveActions"), default=False)
+        self.cacheSessions = string_to_bool(node.getAttribute("cacheSessions"), default=False)
         self.fastStoreHudCache = string_to_bool(node.getAttribute("fastStoreHudCache"), default=False)
         self.saveStarsHH = string_to_bool(node.getAttribute("saveStarsHH"), default=False)
 
     def __str__(self):
         return "    interval = %s\n    callFpdbHud = %s\n    hhArchiveBase = %s\n    saveActions = %s\n    fastStoreHudCache = %s\n" \
-            % (self.interval, self.callFpdbHud, self.hhArchiveBase, self.saveActions, self.fastStoreHudCache)
+            % (self.interval, self.callFpdbHud, self.hhArchiveBase, self.saveActions, self.cacheSessions, self.fastStoreHudCache)
 
 class HudUI:
     def __init__(self, node):
@@ -1259,6 +1260,9 @@ class Config:
 
         try:    imp['saveActions']     = self.imp.saveActions
         except:  imp['saveActions']     = False
+        
+        try:    imp['cacheSessions']     = self.imp.cacheSessions
+        except:  imp['cacheSessions']     = False
 
         try:    imp['saveStarsHH'] = self.imp.saveStarsHH
         except:  imp['saveStarsHH'] = False
diff --git a/pyfpdb/HUD_config.test.xml b/pyfpdb/HUD_config.test.xml
index 556bbede..964be208 100644
--- a/pyfpdb/HUD_config.test.xml
+++ b/pyfpdb/HUD_config.test.xml
@@ -2,7 +2,7 @@
 
 <FreePokerToolsConfig xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:noNamespaceSchemaLocation="FreePokerToolsConfig.xsd">
 
-    <import callFpdbHud = "True" interval = "10"  fastStoreHudCache="False" hhArchiveBase="~/.fpdb/HandHistories/" saveActions="True"></import>
+    <import callFpdbHud = "True" interval = "10"  fastStoreHudCache="False" hhArchiveBase="~/.fpdb/HandHistories/" saveActions="True" cacheSessions="True"></import>
 
 <!-- These values determine what stats are displayed in the HUD
 
diff --git a/pyfpdb/HUD_config.xml.example b/pyfpdb/HUD_config.xml.example
index 9ac66289..1d3c3e00 100644
--- a/pyfpdb/HUD_config.xml.example
+++ b/pyfpdb/HUD_config.xml.example
@@ -12,7 +12,7 @@
              config_difficulty="expert"
              />
 
-    <import callFpdbHud = "True" interval = "10"  fastStoreHudCache="False" hhArchiveBase="~/.fpdb/HandHistories/" saveActions="True"></import>
+    <import callFpdbHud = "True" interval = "10"  fastStoreHudCache="False" hhArchiveBase="~/.fpdb/HandHistories/" saveActions="True" cacheSessions="True"></import>
 
     <gui_cash_stats>
         <col col_name="game"       disp_all="True"  disp_posn="True"  col_title="Game"     xalignment="0.0" field_format="%s"    field_type="str" />
diff --git a/pyfpdb/fpdb_import.py b/pyfpdb/fpdb_import.py
old mode 100755
new mode 100644
index 4c055bd1..e1c4b66a
--- a/pyfpdb/fpdb_import.py
+++ b/pyfpdb/fpdb_import.py
@@ -83,6 +83,7 @@ class Importer:
         self.pos_in_file = {}        # dict to remember how far we have read in the file
         #Set defaults
         self.callHud    = self.config.get_import_parameters().get("callFpdbHud")
+        self.cacheSessions = self.config.get_import_parameters().get("cacheSessions")
 
         # CONFIGURATION OPTIONS
         self.settings.setdefault("minPrint", 30)
@@ -110,6 +111,9 @@ class Importer:
     #Set functions
     def setCallHud(self, value):
         self.callHud = value
+        
+    def setCacheSessions(self, value):
+        self.cacheSessions = value
 
     def setMinPrint(self, value):
         self.settings['minPrint'] = int(value)

From a7f3b1326fda51ecb686711330a20474edd54a06 Mon Sep 17 00:00:00 2001
From: Chaz <chaz@pokeit.co>
Date: Thu, 2 Dec 2010 00:40:31 -0500
Subject: [PATCH 3/4] Added some logic so the importer won't try to send hands
 to HUD when HudCache is generated from the command line

---
 pyfpdb/fpdb_import.py | 13 +++++++------
 1 file changed, 7 insertions(+), 6 deletions(-)

diff --git a/pyfpdb/fpdb_import.py b/pyfpdb/fpdb_import.py
index e1c4b66a..4e4b09a4 100644
--- a/pyfpdb/fpdb_import.py
+++ b/pyfpdb/fpdb_import.py
@@ -497,12 +497,13 @@ class Importer:
                 self.database.commit()
 
                 #pipe the Hands.id out to the HUD
-                for hid in to_hud:
-                    try:
-                        print _("fpdb_import: sending hand to hud"), hand.dbid_hands, "pipe =", self.caller.pipe_to_hud
-                        self.caller.pipe_to_hud.stdin.write("%s" % (hid) + os.linesep)
-                    except IOError, e:
-                        log.error(_("Failed to send hand to HUD: %s") % e)
+                if self.caller:
+                    for hid in to_hud:
+                        try:
+                            print _("fpdb_import: sending hand to hud"), hand.dbid_hands, "pipe =", self.caller.pipe_to_hud
+                            self.caller.pipe_to_hud.stdin.write("%s" % (hid) + os.linesep)
+                        except IOError, e:
+                            log.error(_("Failed to send hand to HUD: %s") % e)
 
                 errors = getattr(hhc, 'numErrors')
                 stored = getattr(hhc, 'numHands')

From 925db93157eb64152fbf8ddb8c5df94fa7848077 Mon Sep 17 00:00:00 2001
From: Chaz <Chaz@Chaz-THINK>
Date: Thu, 2 Dec 2010 01:58:02 -0500
Subject: [PATCH 4/4] * Added 'cacheSessions' flag * Added a cacheSessions
 update call to import_file_dict() in fpdb_import.py * Added
 updateSessionsCache() method to Hands * Added storeSessionsCache() to
 Database --- WORK IN PROGRESS and set to pass TO DOs - add sessions queries
 to SQL - complete storeSessionsCache() so it works like we've discussed (save
 for adding sessionId to HP) - add SessionsCache keys - add SessionsCache to
 the default table creation and deletion methods in Database.py - update
 storeSessionsCache() and all the relevant db & sql code so it writes a
 sessionId to HP

---
 pyfpdb/Database.py            | 47 +++++++++++++++++++++++++++++++++++
 pyfpdb/HUD_config.test.xml    |  2 +-
 pyfpdb/HUD_config.xml.example |  2 +-
 pyfpdb/Hand.py                |  3 +++
 pyfpdb/fpdb_import.py         |  7 ++++++
 5 files changed, 59 insertions(+), 2 deletions(-)

diff --git a/pyfpdb/Database.py b/pyfpdb/Database.py
index c90b5fcb..b644cbd5 100644
--- a/pyfpdb/Database.py
+++ b/pyfpdb/Database.py
@@ -1966,6 +1966,53 @@ class Database:
             else:
                 #print "DEBUG: Successfully updated HudCacho using UPDATE"
                 pass
+            
+    def storeSessionsCache(self, pids, starttime, pdata):
+        """Update cached sessions. If update fails because no record exists, do an insert."""
+        #In development
+        pass
+
+        #update_sessionscache = self.sql.query['update_sessionscache']
+        #update_sessionscache = update_sessionscache.replace('%s', self.sql.query['placeholder'])
+        #insert_sessionscache = self.sql.query['insert_sessionscache']
+        #insert_sessionscache = insert_sessionscache.replace('%s', self.sql.query['placeholder'])
+        #merge_sessionscache = self.sql.query['merge_sessionscache']
+        #merge_sessionscache = merge_sessionscache.replace('%s', self.sql.query['placeholder'])
+
+        #print "DEBUG: %s %s %s" %(hid, pids, pdata)
+        #inserts = []
+        #for p in pdata:
+            #line = [0]*5
+
+            #line[0] = 1 # HDs
+            #line[1] = pdata[p]['totalProfit']
+            
+            #line[2] = pids[p]    # playerId
+            #line[3] = sessionStart
+            #line[4] = sessionEnd
+            #inserts.append(line)
+
+
+        #cursor = self.get_cursor()
+
+        #for row in inserts:
+            # Try to do the update first:
+            #num = cursor.execute(update_sessionscache, row)
+            #print "DEBUG: values: %s" % row[-3:]
+            # Test statusmessage to see if update worked, do insert if not
+            # num is a cursor in sqlite
+            #if ((self.backend == self.PGSQL and cursor.statusmessage != "UPDATE 1")
+                    #or (self.backend == self.MYSQL_INNODB and num == 0)
+                    #or (self.backend == self.SQLITE and num.rowcount == 0)):
+                #move the last 6 items in WHERE clause of row from the end of the array
+                # to the beginning for the INSERT statement
+                #print "DEBUG: using INSERT: %s" % num
+                #row = row[-3:] + row[:-3]
+                #num = cursor.execute(insert_sessionscache, row)
+                #print "DEBUG: Successfully(?: %s) updated HudCacho using INSERT" % num
+            #else:
+                #print "DEBUG: Successfully updated HudCacho using UPDATE"
+                #pass
 
     def isDuplicate(self, gametypeID, siteHandNo):
         dup = False
diff --git a/pyfpdb/HUD_config.test.xml b/pyfpdb/HUD_config.test.xml
index 964be208..f62a13bf 100644
--- a/pyfpdb/HUD_config.test.xml
+++ b/pyfpdb/HUD_config.test.xml
@@ -2,7 +2,7 @@
 
 <FreePokerToolsConfig xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:noNamespaceSchemaLocation="FreePokerToolsConfig.xsd">
 
-    <import callFpdbHud = "True" interval = "10"  fastStoreHudCache="False" hhArchiveBase="~/.fpdb/HandHistories/" saveActions="True" cacheSessions="True"></import>
+    <import callFpdbHud = "True" interval = "10"  fastStoreHudCache="False" hhArchiveBase="~/.fpdb/HandHistories/" saveActions="True" cacheSessions="False"></import>
 
 <!-- These values determine what stats are displayed in the HUD
 
diff --git a/pyfpdb/HUD_config.xml.example b/pyfpdb/HUD_config.xml.example
index 1d3c3e00..423d577a 100644
--- a/pyfpdb/HUD_config.xml.example
+++ b/pyfpdb/HUD_config.xml.example
@@ -12,7 +12,7 @@
              config_difficulty="expert"
              />
 
-    <import callFpdbHud = "True" interval = "10"  fastStoreHudCache="False" hhArchiveBase="~/.fpdb/HandHistories/" saveActions="True" cacheSessions="True"></import>
+    <import callFpdbHud = "True" interval = "10"  fastStoreHudCache="False" hhArchiveBase="~/.fpdb/HandHistories/" saveActions="True" cacheSessions="False"></import>
 
     <gui_cash_stats>
         <col col_name="game"       disp_all="True"  disp_posn="True"  col_title="Game"     xalignment="0.0" field_format="%s"    field_type="str" />
diff --git a/pyfpdb/Hand.py b/pyfpdb/Hand.py
index ce0e4e7a..250067f8 100644
--- a/pyfpdb/Hand.py
+++ b/pyfpdb/Hand.py
@@ -278,6 +278,9 @@ db: a connected Database object"""
 
     def updateHudCache(self, db):
         db.storeHudCache(self.dbid_gt, self.dbid_pids, self.startTime, self.stats.getHandsPlayers())
+        
+    def updateSessionsCache(self, db):
+        db.storeSessionsCache(self.dbid_pids, self.startTime, self.stats.getHandsPlayers())
 
     def select(self, handId):
         """ Function to create Hand object from database """
diff --git a/pyfpdb/fpdb_import.py b/pyfpdb/fpdb_import.py
index 4e4b09a4..15043503 100644
--- a/pyfpdb/fpdb_import.py
+++ b/pyfpdb/fpdb_import.py
@@ -495,6 +495,13 @@ class Importer:
                         if hand is not None and not hand.is_duplicate:
                             hand.updateHudCache(self.database)
                 self.database.commit()
+                
+                # Call sessionsCache update
+                if self.cacheSessions:
+                    for hand in handlist:
+                        if hand is not None and not hand.is_duplicate:
+                            hand.updateSessionsCache(self.database)
+                self.database.commit()
 
                 #pipe the Hands.id out to the HUD
                 if self.caller: