Cacher is the code snippet organizer for pro developers

# encoding: utf-8

from psycopg2 import connect
from psycopg2.extensions import ISOLATION_LEVEL_AUTOCOMMIT

def getValueForID(name,id,con):
    cursorX = con.cursor()
    if(name == "flurstueck"):
        cursorX.execute('SELECT lage_index FROM flurstuecke WHERE id =' + str(id))
        res = cursorX.fetchall()
        for elm in res:
            result = elm[0]
    else:
        cursorX.execute('SELECT nname, vname FROM bewirtschafter WHERE id =' + str(id))
        tmp = cursorX.fetchall()
        for el in tmp:
            result = el[1]+ " " + el[0]
    return result

dictTauschabend1 = {}
dictTauschabendN = {}

listeGetauschteFlurstuecke = []

AnzahlObjekteTA1 = 0
AnzahlObjekteTA2 = 0

nrTauschabend = 3


con = connect(user='postgres', host='localhost', password='???', database='owen')
con.set_isolation_level(ISOLATION_LEVEL_AUTOCOMMIT)

cursorA = con.cursor()
cursorA.execute('SELECT tauschabende_id, flurstuecke_id, bewirtschafter_id FROM tausch WHERE tauschabende_id = 1')
tauschEins = cursorA.fetchall()

cursorB = con.cursor()
cursorB.execute('SELECT tauschabende_id, flurstuecke_id, bewirtschafter_id FROM tausch WHERE tauschabende_id = ' + str(nrTauschabend ))
tauschZwei = cursorB.fetchall()

cursorA.close()
cursorB.close()


for tau in tauschEins:
    flurstueck = str(tau[1])
    bewirtschafter = str(tau[2])
    if (flurstueck in dictTauschabend1):
        pass
    else:
        dictTauschabend1[flurstueck] = bewirtschafter

for tau2 in tauschZwei:
    flurstueck = str(tau2[1])
    bewirtschafter = str(tau2[2])
    if (flurstueck in dictTauschabendN):
        pass
    else:
        dictTauschabendN[flurstueck] = bewirtschafter

AnzahlObjekteTA1 = str(len(dictTauschabend1))
AnzahlObjekteTA2 = str(len(dictTauschabendN))
print(AnzahlObjekteTA1 + " - " + AnzahlObjekteTA2)
fileOut = open("ListeTauschFlurstuecke.csv", "w+")
fileOut.write("Flurstueck_ID;BewirtschafterID Tauschabend 1;BewirtschafterID Tauschabend" + str(nrTauschabend)+ "\n")
for it1 in dictTauschabend1.items():
    bewirtschafterAusZwei = dictTauschabendN[it1[0]]
    bewirtschafterAusEins = it1[1]
    if(bewirtschafterAusZwei != bewirtschafterAusEins):
        listeGetauschteFlurstuecke.append(str(it1[0]))
        fileOut.write(getValueForID(name="flurstueck",id=str(it1[0]),con=con)+";"+ getValueForID(name="bewirtschafter",id=bewirtschafterAusEins, con=con) + ";" + getValueForID(name="bewirtschafter",id=bewirtschafterAusZwei, con=con)+ "\n")
    #print("Flurstueck: " + it1[0] + " in T1: " + bewirtschafterAusEins + " in TN: " + bewirtschafterAusZwei )
fileOut.close()
print("Getauschte Flurstücke: " + str(len(listeGetauschteFlurstuecke)))

con.close()

def getValueForID(self,name,id,con):
    cursorX = con.cursor()
    if(name == "flurstueck"):
        cursorX.execute('SELECT lage_index FROM flurstuecke WHERE id =' + str(id))
        res = cursorX.fetchone()
        for elm in res:
            result = elm[0]
    else:
        cursorX.execute('SELECT nname, vname FROM bewirtschafter WHERE id =' + str(id))
        tmp = cursorX.fetchone()
        for el in tmp:
            result = el[1]+ " " + el[0]

    return result