sqlutil Code

from twisted.enterprise import adbapi

class dbpool (adbapi.ConnectionPool):
  """
  classe non bloccante che ritorna dei deferred con le risposte
    runQuery( self, *args, **kw )
    runOperation
    runInteraction
  """
  def __init__( self, dbname, **kw ):
    #utilizza lo user e la password (.mysqlrc) con cui viene fatto partire
    adbapi.ConnectionPool.__init__( self, 'MySQLdb', db=dbname, read_default_group='', **kw )
    self.dbname = dbname             # serve ??  ==> connkw['db']
    #self.debug = 1
  def getpassword( self, typedpass, typeduser, nfld=['utenti','user','pass'] ):
    # TROVARE UN POSTO PER QUESTA FUNZIONE !!!!!!!!
    q = 'SELECT MD5(%s),' + nfld[2] + ' FROM ' + nfld[0] 
    q += ' WHERE ' + nfld[1] + '=%s'
    return self.runQuery( q, (typedpass,typeduser) )
  def crs_fetchall( self, crs, metodo, *arg, **kw ):
    metodo( crs, *arg, **kw )
    return crs.fetchall()
  def runSelect( self, metodo, *arg, **kw ):
    return self.runInteraction( self.crs_fetchall, metodo, *arg, **kw )

if __name__ == '__main__':
  import sys
  l = len( sys.argv ) ; kw = {}
  if l >= 2: dbname = sys.argv[1]
  else: 
    print 'usage: dbname [user] [passwd]'
    sys.exit( 1 )
  if l >= 3: kw['user'] = sys.argv[2]
  if l >= 4: kw['passwd'] = sys.argv[3]
  dbp = dbpool( dbname, **kw )