Änderung und Abfrage von Python MySQL-Datenbanktabellen

#!/usr/bin/python 
 
MySQLdb importieren 
def doInsert(cursor,db): 
  #einfügen 
  # Bereiten Sie eine SQL-Abfrage vor, um einen Datensatz in die Datenbank EINZUFÜGEN. 
  sql = "UPDATE EMPLOYEE SET AGE = AGE+1 WHERE SEX = '%c'" %('M') 
  versuchen: 
    Cursor.Ausführen(SQL) 
    db.commit() 
  außer: 
    db.rollback() 
 
def do_query(cursor,db): 
  sql = "SELECT * FROM MITARBEITER \ 
     WO EINKOMMEN > '%d'" % (1000) 
  versuchen: 
    # Führen Sie den SQL-Befehl aus 
    Cursor.Ausführen(SQL) 
    # Alle Zeilen in einer Liste von Listen abrufen. 
    Ergebnisse = Cursor.fetchall() 
    drucke 'Ergebnisse', Cursor.Zeilenanzahl 
    für Zeile in Ergebnissen: 
      fname = Zeile[0] 
      lname = Zeile[1] 
      Alter = Zeile[2] 
      Geschlecht = Zeile[3] 
      Einkommen = Zeile[4] 
      # Jetzt das abgerufene Ergebnis drucken 
      drucken "Fname=%s,Lname=%s,Alter=%d,Geschlecht=%s,Einkommen=%d" % \ 
          (Vorname, Nachname, Alter, Geschlecht, Einkommen) 
  außer: 
    print "Fehler: Daten konnten nicht gefunden werden" 
 
def do_delete(cursor,db): 
  sql = 'LÖSCHEN VON MITARBEITER, WO ALTER > {}'.format(20) 
  versuchen: 
    Cursor.Ausführen(SQL) 
    db.commit() 
  außer: 
    db.rollback() 
 
def do_insert(Cursor, DB, Vorname, Nachname, Alter, Geschlecht, Einkommen): 
  sql = "INSERT INTO EMPLOYEE(VORNAME, \ 
    NACHNAME, ALTER, GESCHLECHT, EINKOMMEN) \ 
    WERTE ('%s', '%s', '%d', '%c', '%d' )" % \ 
    (Vorname, Nachname, Alter, Geschlecht, Einkommen) 
  versuchen: 
    Cursor.Ausführen(SQL) 
    db.commit() 
  außer: 
    db.rollback() 
  
# Datenbankverbindung öffnen 
# ändern Sie dies in Ihr MySQL-Konto 
#connect(Server,Benutzername,Passwort,Datenbankname) 
db = MySQLdb.connect("localhost","root","root","pydb" ) 
# Bereiten Sie ein Cursorobjekt mit der Cursor()-Methode vor 
Cursor = db.cursor() 
do_query(cursor,db) 
macheEinfügen(cursor,db) 
do_query(cursor,db) 
do_delete(cursor,db) 
do_query(cursor,db) 
do_insert(cursor,db,'hunter','xue',22,'M',2000) 
do_insert(Cursor, db, 'Mary', 'Yang', 22, 'f', 5555) 
do_insert(cursor,db,'zhang','xue',32,'M',5000) 
do_insert(cursor,db,'hunter','xue',22,'M',333) 
do_query(cursor,db) 
# Verbindung zum Server trennen 
db.schließen()