Index: /trunk/ippToPsps/jython/ipptopspsdb.py
===================================================================
--- /trunk/ippToPsps/jython/ipptopspsdb.py	(revision 31198)
+++ /trunk/ippToPsps/jython/ipptopspsdb.py	(revision 31198)
@@ -0,0 +1,84 @@
+#!/usr/bin/env jython
+
+import re
+import sys
+import os
+
+from java.sql import *
+from xml.etree.ElementTree import ElementTree
+
+'''
+Class for ippToPsps database connectivity
+'''
+class IppToPspsDb(object):
+
+    driverName="com.mysql.jdbc.Driver"
+
+    '''
+    Constructor
+
+    '''
+    def __init__(self):
+
+        # open config
+        doc = ElementTree(file="config.xml")
+
+        # set up JDBC connection
+        dbName = doc.find("ipptopspsdatabase/name").text
+        dbHost = doc.find("ipptopspsdatabase/host").text
+        dbUser = doc.find("ipptopspsdatabase/user").text
+        dbPass = doc.find("ipptopspsdatabase/password").text
+        self.url = "jdbc:mysql://"+dbHost+"/"+dbName+"?user="+dbUser+"&password="+dbPass
+        self.con = DriverManager.getConnection(self.url)
+        self.stmt = self.con.createStatement()
+
+    '''
+    Creates a new batch
+    '''
+    def createNewBatch(self, expID, surveyType, batchType, dvoDb, datastoreProduct):
+
+        print "Creating nw batch in ippToPsps database"
+        sql = "SELECT batch_id FROM batches ORDER BY batch_id DESC LIMIT 1"
+
+        batchID = -1;
+
+        try:
+            rs = self.stmt.executeQuery(sql)
+            rs.first()
+            batchID = rs.getInt(1)
+        except:
+            print "Unable to get batch ID"
+
+        if batchID > 0:
+            batchID = batchID + 1
+
+            sql = "INSERT INTO batches \
+                   (batch_id, \
+                    exp_id, \
+                    survey_id, \
+                    batch_type, \
+                    dvo_db, \
+                    datastore_product) \
+                   VALUES \
+                   ("+str(batchID)+", \
+                    " + str(expID) + ", \
+                    '"+surveyType+"', \
+                    '"+batchType+"', \
+                    '"+dvoDb+"', \
+                    '"+datastoreProduct+"')"
+
+            self.stmt.execute(sql)
+
+        return batchID;
+
+    '''
+    Destructor
+    '''
+    def __del__(self):
+
+        print "IppToPspsDb destructor"
+        self.stmt.close()
+        self.con.close()
+
+
+