sqlutil Code

from MySQLdb.connections import Connection
from MySQLdb.cursors import Cursor

class dbasecursor (Cursor):
  def onerow( self, query=None, args=None ):
    self.execute( query, args )
    return self.fetchone()
  def onecol( self, query=None, args=None, col=0 ):
    self.execute( query, args )
    list = []
    for r in range( self.rowcount ):
      row = self.fetchone()
      list.append( row[col] )
    return list
 
class dbase (Connection):
  #default_cursor = dbasecursor
  def __init__( self, name, **kw ):
    self.cnt = 0
    if not kw.has_key( 'db' ): kw['db'] = name
    if not kw.has_key( 'read_default_group' ): kw['read_default_group'] = ''
    Connection.__init__( self, **kw )
    self.dbname = name

if __name__ == '__main__':
  db = dbase( 'citta' )
  crs = db.cursor()
  print dir(db)