gnue/common/src/dbdrivers/sapdb DBdriver.py

[Jason Cater]

CVSROOT:        /home/cvs
Module name:    gnue
Changes by:     Jason Cater <address@hidden>    02/10/08 00:20:24

Modified files:
        common/src/dbdrivers/sapdb: DBdriver.py 

Log message:
        added Daniel Dittmar's enhancement patch to SAP-DB driver

CVSWeb URLs:
http://savannah.gnu.org/cgi-bin/viewcvs/gnue/common/src/dbdrivers/sapdb/DBdriver.py.diff?cvsroot=OldCVS&tr1=1.9&tr2=1.10&r1=text&r2=text

Patches:
Index: gnue/common/src/dbdrivers/sapdb/DBdriver.py
diff -c gnue/common/src/dbdrivers/sapdb/DBdriver.py:1.9 
gnue/common/src/dbdrivers/sapdb/DBdriver.py:1.10
*** gnue/common/src/dbdrivers/sapdb/DBdriver.py:1.9     Mon Sep 23 16:04:00 2002
--- gnue/common/src/dbdrivers/sapdb/DBdriver.py Tue Oct  8 00:20:24 2002
***************
*** 31,38 ****
--- 31,56 ----
  #
  #     host=      This is the SAP-DB host for your connection (optional)
  #     dbname=    This is the SAP-DB database to use (required)
+ #     timeout=   Command timeout in seconds (optional)
+ #     isolation= Isolation level (options)
+ #     sqlmode=   INTERNAl or ORACLE (optional)
+ #     sqlsubmode= ODBC or empty (optional)
  #
  
+ _exampleConfig = """
+ # This connection uses the SAP DB  driver
+ # We will be connecting to the SAP DB server on
+ # "localhost" to a database called "TST".
+ [sapdb]
+ comment = XYZ Development Database
+ provider = sapdb
+ dbname = TST
+ # host = localhost   # (optional)
+ # sqlmode = INTERNAL # (default) or ORACLE
+ # sqlsubmode = ODBC  # (for compatibility with the SAP DB ODBC driver)
+ # timeout = 900      # (command timeout in seconds)
+ # isolation = 1      # 0, 1 (default), 10, 15, 2, 20, 3, 30
+ """
  #### THIS IS AN UNTESTED DRIVER ####
  ####      Any volunteers?       ####
  
***************
*** 72,83 ****
    def connect(self, connectData={}):
      GDebug.printMesg(1,"SAP database driver initializing")
      try:
!       self._dataConnection = SIG2api.connect( \
!                    user=connectData['_username'], \
!                    password=connectData['_password'], \
!                    database=connectData['dbname'], \
!                    host=connectData.get ('host', ''), \
!                    autocommit="off")
      except self._DatabaseError, value:
        raise GDataObjects.LoginError, value
  
--- 90,112 ----
    def connect(self, connectData={}):
      GDebug.printMesg(1,"SAP database driver initializing")
      try:
!       options = {'autocommit': 'off'}
!       for gnueName, sapdbName in [('sqlmode', 'sqlmode'),
!                                   ('timeout', 'timeout'),
!                                   ('isolation', 'isolation'),
!                                   ('sqlsubmode', 'component')]:
!           if connectData.has_key (gnueName):
!               options [sapdbName] = connectData [gnueName]
!       self._dataConnection = apply (SIG2api.connect,
!         (connectData['_username'], connectData['_password'],
!         connectData['dbname'], connectData.get ('host', '')),
!         options)
!       #self._dataConnection = SIG2api.connect( \
!       #             user=connectData['_username'], \
!       #             password=connectData['_password'], \
!       #             database=connectData['dbname'], \
!       #             host=connectData.get ('host', ''), \
!       #             autocommit="off")
      except self._DatabaseError, value:
        raise GDataObjects.LoginError, value
  
***************
*** 270,279 ****
  ######################################
  
  #
! #  All datasouce "types" and corresponding DataObject class
  #
  supportedDataObjects = {
    'object': SAP_DataObject_Object,
    'sql':    SAP_DataObject_SQL
  }
  
--- 299,324 ----
  ######################################
  
  #
! #  All datasource "types" and corresponding DataObject class
  #
  supportedDataObjects = {
    'object': SAP_DataObject_Object,
    'sql':    SAP_DataObject_SQL
  }
  
+ def createConnection (conn, **overrides):
+     from gnue.common.GConnections import GConnections
+     connections = GConnections (r'D:\Python22\etc\connections.conf')
+     parameters = connections.getConnectionParameters (conn).copy ()
+     dataObject = connections.getDataObject (conn, 'object')
+     parameters.update (overrides)
+     dataObject.connect (parameters)
+     return dataObject
+ 
+ def testConnection ():
+     conn, user, pwd = sys.argv [1:4]
+     connection = createConnection (conn, _username = user, _password = pwd)
+     connection.getSchemaList ()
+ 
+ if __name__ == "__main__":
+     testConnection ()