[Erp5-report] r34580 luke - in /erp5/trunk/utils/erp5.timmy: setup.py src/erp5/timmy/timmy.py

[nobody at svn.erp5.org]

Author: luke
Date: Thu Apr 15 15:01:28 2010
New Revision: 34580

URL: http://svn.erp5.org?rev=34580&view=rev
Log:
 - implement MysqlDatabase plugin

Modified:
    erp5/trunk/utils/erp5.timmy/setup.py
    erp5/trunk/utils/erp5.timmy/src/erp5/timmy/timmy.py

Modified: erp5/trunk/utils/erp5.timmy/setup.py
URL: http://svn.erp5.org/erp5/trunk/utils/erp5.timmy/setup.py?rev=34580&r1=34579&r2=34580&view=diff
==============================================================================
--- erp5/trunk/utils/erp5.timmy/setup.py [utf8] (original)
+++ erp5/trunk/utils/erp5.timmy/setup.py [utf8] Thu Apr 15 15:01:28 2010
@@ -28,8 +28,7 @@
     include_package_data = True,
     package_dir = {'':'src'},
     namespace_packages = ['erp5', 'erp5.timmy'],
-    install_requires = [
-    ],
+    install_requires = [ "MySQL-python" ],
     zip_safe=False,
     entry_points = """
     [console_scripts]

Modified: erp5/trunk/utils/erp5.timmy/src/erp5/timmy/timmy.py
URL: http://svn.erp5.org/erp5/trunk/utils/erp5.timmy/src/erp5/timmy/timmy.py?rev=34580&r1=34579&r2=34580&view=diff
==============================================================================
--- erp5/trunk/utils/erp5.timmy/src/erp5/timmy/timmy.py [utf8] (original)
+++ erp5/trunk/utils/erp5.timmy/src/erp5/timmy/timmy.py [utf8] Thu Apr 15 15:01:28 2010
@@ -3,6 +3,7 @@
 from optparse import OptionParser
 import sys
 import socket
+import MySQLdb
 
 SUPERVISORD = os.path.join('var', 'bin', 'supervisord')
 SUPERVISORCTL = os.path.join('var', 'bin', 'supervisorctl')
@@ -359,6 +360,30 @@
   def getPartitionState_Computer(self):
     return 'reportStarted', 'timmy was able to operate on running computer'
 
+  # Mysql Database
+  def MysqlDatabase(self):
+    pass
+
+  def install_MysqlDatabase(self):
+    return self.getPartitionState_MysqlDatabase()
+
+  def start_MysqlDatabase(self):
+    return self.getPartitionState_MysqlDatabase()
+
+  def stop_MysqlDatabase(self):
+    return self.getPartitionState_MysqlDatabase()
+
+  def getPartitionState_MysqlDatabase(self):
+    connection = self.partition_dict['CONNECTION_DICT']
+    try:
+      MySQLdb.connect(host=connection['HOSTNAME'] or connection['IP_ADDRESS'],
+          port = int(connection['TCP_PORT']), user = connection['USERNAME'],
+          passwd=connection['PASSWORD'])
+    except MySQLdb.OperationalError, e:
+      return 'reportError', 'Problem with connection %s' % e
+    else:
+      return 'reportStarted', 'Database accessible'
+
   # Mysql Server
   def MysqlServer(self):
     self.control_script = SUPERVISORCTL