mysqlWEntities.py

from elixir import *
from sqlalchemy import *
def initDB():
    metadata.bind = create_engine('mysql://root:pwd@localhost:3306/parafarmacie')
    metadata.bind.echo = False

    setup_all()
    # if not os.path.exists(dbfile):
     #    create_all()


    global saveData
    import elixir
    if elixir.__version__ < "0.6":
         saveData=session.flush
    else:
         saveData=session.commit
class rel_pv_pot(Entity):
     using_table_options(useexisting=True)
     using_options(tablename='rel_pv_pot')
     pv_id=Field(Integer,primary_key=True)
     tc_clpot_id =Field(Integer)
     tc_pot_id =Field(Integer,primary_key=True)
     valore =Field(Float)
     ins_data =Field(DateTime)
     ins_utente =Field(Integer)
     mod_data =Field(DateTime)
     mod_utente =Field(Integer)

class Pv(Entity):
     """
     A task for your TODO list.
     """
     using_table_options(useexisting=True)
     using_options(tablename='pv')
     pv_id = Field(Integer,  primary_key=True)
     codice = Field(Unicode,required=True)
     pref_mmas =Field(Unicode,required=True)
     cod_mmas =Field(Integer, colname="cod_mmas")
     certificato =Field(Boolean,colname="certificato")
     pv_mt  =  Field(Boolean,colname="pv_mt")
     cliente=  Field(Boolean,colname="cliente")
     cod_cliente  =Field(Unicode)
     ragione_sociale   =Field(String(50),colname="nome1")

     titolare    =Field(String(50),colname="nome2")
     tc_istat_id=Field(Integer)
     indirizzo    =Field(String(100))

     cap  =Field(Unicode)
     comune    =Field(Unicode)
     provincia    =Field(Unicode(2))
     tel1    =Field(String(20))
     tel2    =Field(String(20))
     tel3    =Field(String(20))
     cf_pi    =Field(Unicode)
     fax    =Field(Unicode)
     sito =Field(Unicode)
     email  =Field(Unicode)
     note    =Field(UnicodeText)
     data_aggiornamento    =Field(DateTime)
     tc_stato_id    =Field(Integer)
     ins_data    =Field(DateTime)
     ins_utente    =Field(Integer)
     mod_data    =Field(DateTime)
     mod_utente   =Field(Integer)

def main():

     # Initialize database
    initDB()

    for task in rel_pv_pot.query.all():
            print  task.pv_id,task.tc_pot_id,task.ins_data,task.valore
            #print task.id, task.codice, task.nome1,task.indirizzo,task.comune
#main()