You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@gump.apache.org by bo...@apache.org on 2010/09/02 06:30:36 UTC
svn commit: r991802 - /gump/trunk/python/gump/actor/stats/mysql/statsdb.py
Author: bodewig
Date: Thu Sep 2 04:30:36 2010
New Revision: 991802
URL: http://svn.apache.org/viewvc?rev=991802&view=rev
Log:
commit into stats tables as well
Modified:
gump/trunk/python/gump/actor/stats/mysql/statsdb.py
Modified: gump/trunk/python/gump/actor/stats/mysql/statsdb.py
URL: http://svn.apache.org/viewvc/gump/trunk/python/gump/actor/stats/mysql/statsdb.py?rev=991802&r1=991801&r2=991802&view=diff
==============================================================================
--- gump/trunk/python/gump/actor/stats/mysql/statsdb.py (original)
+++ gump/trunk/python/gump/actor/stats/mysql/statsdb.py Thu Sep 2 04:30:36 2010
@@ -190,17 +190,22 @@ class StatisticsDB:
for (key, value) in extras.items():
settings[key] = value
+ def setter(helper):
+ helper.set(table_name, column_name, stats.name, settings)
+ helper.commit()
+
# Perform the update (we've ensured a row exists).
- self._with_reconnect_on_error(\
- lambda helper:
- helper.set(table_name, column_name, stats.name, settings))
+ self._with_reconnect_on_error(setter)
def _delStats(self, table_name, column_name, stats):
""" Perform an SQL DELETE """
+
+ def deleter(helper):
+ helper.delete(table_name, column_name, stats.name)
+ helper.commit()
+
# Perform the delete
- self._with_reconnect_on_error(\
- lambda helper:
- helper.delete(table_name, column_name, stats.name))
+ self._with_reconnect_on_error(deleter)
def _getBaseStats(self, stats, settings):
"""
@@ -244,7 +249,7 @@ class StatisticsDB:
#print "SET ATTR : " + `value`
settings[column] = "'" +\
value.strftime('%Y-%m-%d %H:%M:%S') + "'"
- elif isinstance(value,types.StringTypes):
+ elif isinstance(value, types.StringTypes):
settings[column] = "'" + str(value) + "'"
else:
settings[column] = str(value)