wie Exporteur gae Daten zu mysql

meine 'College' Modell-Daten :

alt-text http://omploader.org/vNG9zNw

meine str_loader.py ist :

class MySQLExporter(bulkloader.Exporter):
    def output_entities(self, entity_generator):
        conn = MySQLdb.connect(host='localhost',user='root',passwd='root',db='test',charset="utf8")
        c = conn.cursor()
        for entity in entity_generator:
          c.execute("INSERT INTO haha (a,b) VALUES (%s, %s)",
                    (entity['cid'], entity['name']))

class Mysql_download(MySQLExporter):
    def __init__(self):
        MySQLExporter.__init__(self,'College',
                                   [
                                    ('cid', str,None),
                                    ('name', lambda x: unicode(x, 'utf8'),None),
                                   ])

exporters = [Mysql_download]

und es läuft erfolgreich :

alt-text http://omploader.org/vNG9zNA

aber es ist nicht das einfügen von Daten zu mysql :

alt-text http://omploader.org/vNG9zNg

Dank

aktualisiert

es ist jetzt ok :

class MySQLExporter(bulkloader.Exporter):
    def output_entities(self, entity_generator):
        conn = MySQLdb.connect(host='localhost',user='root',passwd='root',db='test',charset="utf8")
        c = conn.cursor()
        for entity in entity_generator:
          c.execute("INSERT INTO haha (a,b) VALUES (%s, %s)",
                    (entity['cid'], entity['name']))
        conn.commit() 
  • Ausgewählte Antwort
    Nick Johnson
    4. Mai 2019

    Versuchen Sie den Aufruf .commit() auf die Verbindung nach dem laden der entities.