gnue/gnue-common/gnue/common GDataObjects.py db...

[Jason Cater]

CVSROOT:        /home/cvs
Module name:    gnue
Changes by:     Jason Cater <address@hidden>    01/05/02 15:33:05

Modified files:
        gnue-common/gnue/common: GDataObjects.py 
Added files:
        gnue-common/gnue/common/dbdrivers/_dbsig: DBdriver.py 
                                                  __init__.py 
        gnue-common/gnue/common/dbdrivers/pg: DBdriver.py __init__.py 
                                              test.py 

Log message:
        Added first draft of DBdrivers using new DB-SIG 2 standard

CVSWeb URLs:
http://savannah.gnu.org/cgi-bin/viewcvs/gnue/gnue-common/gnue/common/GDataObjects.py.diff?cvsroot=OldCVS&tr1=1.1&tr2=1.2&r1=text&r2=text
http://savannah.gnu.org/cgi-bin/viewcvs/gnue/gnue-common/gnue/common/dbdrivers/_dbsig/DBdriver.py?cvsroot=OldCVS&rev=1.1
http://savannah.gnu.org/cgi-bin/viewcvs/gnue/gnue-common/gnue/common/dbdrivers/_dbsig/__init__.py?cvsroot=OldCVS&rev=1.1
http://savannah.gnu.org/cgi-bin/viewcvs/gnue/gnue-common/gnue/common/dbdrivers/pg/DBdriver.py?cvsroot=OldCVS&rev=1.1
http://savannah.gnu.org/cgi-bin/viewcvs/gnue/gnue-common/gnue/common/dbdrivers/pg/__init__.py?cvsroot=OldCVS&rev=1.1
http://savannah.gnu.org/cgi-bin/viewcvs/gnue/gnue-common/gnue/common/dbdrivers/pg/test.py?cvsroot=OldCVS&rev=1.1

Patches:
Index: gnue/gnue-common/gnue/common/GDataObjects.py
diff -u gnue/gnue-common/gnue/common/GDataObjects.py:1.1 
gnue/gnue-common/gnue/common/GDataObjects.py:1.2
--- gnue/gnue-common/gnue/common/GDataObjects.py:1.1    Tue Apr 24 19:12:52 2001
+++ gnue/gnue-common/gnue/common/GDataObjects.py        Wed May  2 15:33:04 2001
@@ -29,6 +29,9 @@
 # HISTORY:
 #
 
+import GDebug
+from string import lower
+
 ###########################################################
 #
 # 
@@ -45,8 +48,18 @@
     return self._resultSetClass()
 
   def addDetailDataSource(self, ds): 
+    GDebug.printMesg (1,"DataSource: adding a master/detail relationship")
     self._detailSources.append (ds)
 
+  def connect(self, connectData={}): 
+    pass
+
+  def commit(self): 
+    pass
+
+  def rollback(self): 
+    pass
+
 
 ###########################################################
 #
@@ -55,16 +68,18 @@
 ###########################################################
 class ResultSet: 
 
-  def __init__(self, recordSetClass=RecordSet, defaultValues = {}, 
masterRecordSet=None, ): 
-     self.current = None
+  def __init__(self, cursor=None,defaultValues={},masterRecordSet=None):
+     self._recordSetClass = RecordSet
+     self._cursor = cursor
      self._cachedRecords = []
      self._currentRecord = -1
-     self._recordSetClass = recordSetClass
      self._defaultValues = defaultValues
-     self._parentRecordSet = parentRecordSet
+     self._masterRecordSet = masterRecordSet
+
+     self.current = None
 
-     if parentRecordSet: 
-       self._masterRecordSet.
+#     if parentRecordSet: 
+#       self._masterRecordSet.
 
 
   # Returns 1=At first record, 0=Not first record
@@ -87,7 +102,7 @@
   # returns 1=New record loaded, 0=No more records
   def nextRecord(self):
     if self._currentRecord + 1 == len(self._cachedRecords): 
-      if !self._loadNextRecord(): 
+      if not self._loadNextRecord(): 
         return 0
   
     self._currentRecord = self._currentRecord + 1
@@ -137,13 +152,18 @@
 
   # Returns 1=DataSource has uncommitted changes 
   def isPending(self):
-    for chld
+    isPending = 0 
+    for rec in (self._cachedRecords):
+      isPending = isPending or rec.isPending()
+      if isPending: 
+        break
+    return isPending
 
 
   # Post changes to the database
   def post(self):
     # post our changes
-    for record in self._cachedRecords: 
+    for record in (self._cachedRecords): 
       record.post()
 
 
@@ -243,10 +263,17 @@
 
 
   # Sets current value of "field"
-  def setField(self):
+  def setField(self, field, value):
     self._emptyFlag = 0
     self._updateFlag = 1
-    
+    fn = lower(field)
+    self._fields[fn] = value
+    if self._modifiedFlags.has_key(fn): 
+      flag = self._modifiedFlags[fn] + 1
+    else: 
+      flag = 1
+    self._modifiedFlags[fn] = flag
+
 
   # Returns 1=Field has been modified
   def isFieldModified(self, fieldName):
@@ -264,7 +291,7 @@
       self._postChanges()
 
     # Post all details in 
-    for child (self._detailSources): 
+    for child in (self._detailSources): 
       child.post()