[rhmessaging-commits] rhmessaging commits: r4020 - mgmt/newdata/rosemary/python/rosemary.

[rhmessaging-commits at lists.jboss.org]

Author: justi9
Date: 2010-06-11 12:20:37 -0400 (Fri, 11 Jun 2010)
New Revision: 4020

Modified:
   mgmt/newdata/rosemary/python/rosemary/model.py
Log:
Add api for adding new sample data

Modified: mgmt/newdata/rosemary/python/rosemary/model.py
===================================================================
--- mgmt/newdata/rosemary/python/rosemary/model.py	2010-06-11 14:14:09 UTC (rev 4019)
+++ mgmt/newdata/rosemary/python/rosemary/model.py	2010-06-11 16:20:37 UTC (rev 4020)
@@ -449,6 +449,15 @@
 
         obj._sync_time = datetime.now()
 
+    def add_object_sample(self, cursor, obj, columns=None):
+        assert isinstance(obj, RosemaryObject)
+        assert obj._id, obj
+
+        if columns is None:
+            columns = self.sql_table._columns
+
+        self.sql_samples_insert.execute(cursor, columns, obj.__dict__)
+
     def delete_object(self, cursor, obj):
         assert isinstance(obj, RosemaryObject)
         assert obj._id
@@ -669,6 +678,9 @@
     def delete(self, cursor):
         self._class.delete_object(cursor, self)
 
+    def add_sample(self, cursor, columns=None):
+        self._class.add_object_sample(cursor, self, columns)
+
     def fake_qmf_values(self):
         self._qmf_agent_id = "__rosemary__"
         self._qmf_object_id = str(datetime.now())