Das deutsche Python-Forum

Code: Alles auswählen

import pymysql


class DBMS:


	def __init__(self):

		try:
			self.dbms = pymysql.connect(host="192.168.178.24",
								user="bxt",
								passwd="***",
								db="bxt",
								autocommit=True)
			self.cur = self.dbms.cursor()
			
		except Exception as e:
			print("Kann keine Verbindung zur Datenbank aufbauen!")
			print(e)
		

	def Search(self, name, vorname):
		x = self.cur.execute("SELECT * FROM schueler WHERE name LIKE \"%%%s%%\" AND vorname LIKE \"%%%s%%\"" %(name, vorname)) 
		print(x)
		
		for i in self.cur:
			print(i)

	def Save(self):
		pass


if __name__ == "__main__":
	session = DBMS()
	session.Search("Derks", "Patrick")

Code: Alles auswählen

x = cur.execute("SELECT * FROM schueler WHERE name LIKE %s AND vorname LIKE %s", (name, vorname))

Code: Alles auswählen

Datenbank:

    Tabelle: "Schueler"

        Attribute sind:
            Primary Key email
            vorname 
            name

    Tabelle: "schulden"

         Attribute sind:
            Primary Key ticket_id
            Foreign Key email
            betrag
            comment

Code: Alles auswählen

import pymysql
import sys

class DBMS:
	def __init__(self):
		try:
			self.dbms = pymysql.connect(host="192.168.2.102",
								user="bxt",
								passwd="***",
								db="bxt")
			
		except Exception as e:
			print("\n Kann keine Verbindung zur Datenbank aufbauen! \n %s" % (e))
			sys.exit()		


	def Search(self, name, vorname):
		# Hier wird der Jeweilige schüler ausgesucht und der Primär schlüssel wird gespeichert (email)

		cur = self.dbms.cursor()
		result = cur.execute("SELECT * FROM schueler WHERE name LIKE %s AND vorname LIKE %s", (name, vorname)) 

		if 	result == 1:
			for i in cur:
				print(i)
				self.email = i[0]
		else:
			print("Mehr als eine Person Gefunden! Bitte versuche es erneut!")

	def Save(self, betrag, comment):
		# Hier werden seine Schulden eingezahlt. Vorher muss der Primary Key self.email existieren.
		
		cur = self.dbms.cursor()
		result = cur.execute("INSERT schulden (email, betrag, comment) VALUES (%s, %s, %s)", (self.email, betrag, comment))
		self.dbms.commit()

		

	def End(self):
		self.dbms.rollback()
		self.dbms.close()

if __name__ == "__main__":
	session = DBMS()
	while(True):

		name = input("Name: ")
		vorname = input("Vorname: ")
		session.Search(name, vorname)
		
		if name == "1":
			break;

	session.End()

Code: Alles auswählen

#!/usr/bin/env python
# coding: utf8
from __future__ import absolute_import, division, print_function
from sqlalchemy import (
    Column, create_engine, DECIMAL, ForeignKey, func, INTEGER, TEXT, VARCHAR
)
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy.orm import relationship, Session


Base = declarative_base()


class Pupil(Base):
    __tablename__ = 'pupil'

    id = Column(INTEGER, primary_key=True)
    email = Column(VARCHAR(254), nullable=False, unique=True)
    given_name = Column(VARCHAR, nullable=False)
    surname = Column(VARCHAR, nullable=False)

    # `debit_positions` as back reference from `DebitPosition`.

    def add_position(self, amount, remark):
        self.debit_positions.append(
            DebitPosition(pupil=self, amount=amount, remark=remark)
        )

    @classmethod
    def search(cls, session, given_name=None, surname=None):
        query = session.query(cls)
        if given_name:
            query = query.filter(
                cls.given_name.like('%{0}%'.format(given_name))
            )
        if surname:
            query = query.filter(cls.surname.like('%{0}%'.format(surname)))
        return query.all()


class DebitPosition(Base):
    __tablename__ = 'debit_position'

    id = Column(INTEGER, primary_key=True)
    pupil_id = Column(ForeignKey(Pupil.id), nullable=False)
    amount = Column(DECIMAL(6, 2), nullable=False)
    remark = Column(TEXT, nullable=False, default='')

    pupil = relationship(Pupil, backref='debit_positions')


def main():
    engine = create_engine(
        'mysql+pymysql://bxt:***@192.168.2.102/bxt?charset=utf-8',
        echo=True,  # Logs all the generated SQL queries.
        pool_recycle=3600
    )
    Base.metadata.create_all(engine)  # Creates the tables if they don't exist.
    
    session = Session(engine)

    # Neuen Schüler erstellen.
    session.add(
        Pupil(given_name='Peter', surname='Pan', email='pp@neverland.com')
    )
    session.commit()

    # Alle Schüler mit Vornamen 'Peter' abfragen und zusammen mit den
    # einzelnen Schuldenpositionen auflisten.
    pupils = Pupil.search(session, 'Peter')
    for pupil in pupils:
        print(u'{0.surname}, {0.given_name} ({0.email})'.format(pupil))
        for position in pupil.debit_positions:
            print('    {0.amount} - {0.remark}'.format(position))
    session.commit()

    # Für den ersten 'Peter' eine neue Sollstellung anlegen.
    pupil = pupils[0]
    pupil.add_position(42.23, 'Blah...')
    session.commit()

    # Gesamtzahl der Schüler und die Gesamtsumme ermitteln.
    print(
        '{0} Schueler haben insgesamt {1} EUR zu zahlen.'.format(
            session.query(Pupil).count(),
            session.query(func.sum(DebitPosition.amount)).scalar()
        )
    )
    session.commit()


if __name__ == '__main__':
    main()

Code: Alles auswählen

import pymysql
import subprocess

class Dbms():
	def __init__(self):

		try:
			self.dbms = pymysql.connect(host="192.168.2.100",
								user="bxt_system",
								passwd="***",
								db="bxt")

		except Exception as e:
			raise (e)

	def get_name(self, eingabe_vorname, eingabe_name):

		name = "%%%s%%" %(eingabe_name)
		vorname = "%%%s%%" %(eingabe_vorname)

		cur = self.dbms.cursor(pymysql.cursors.DictCursor)
		cur.execute("SELECT * FROM schueler WHERE name LIKE %s AND vorname LIKE %s", (name, vorname)) 
		result = cur.fetchall()

		return result

	def get_schulden(self, user):

		cur = self.dbms.cursor(pymysql.cursors.DictCursor)
		cur.execute("SELECT betrag, date, bezahlt, comment FROM schulden WHERE schueler_id = %s", (user[0]["schueler_id"]))
		result = cur.fetchall()

		return result

	def insert(self, user, betrag, comment):

		cur = self.dbms.cursor(pymysql.cursors.DictCursor)
		cur.execute("INSERT schulden VALUES (DEFAULT, %s, %s, %s, DEFAULT, CURDATE())", (user[0]["schueler_id"], betrag, comment))	
		result = cur.fetchall()
		self.dbms.commit()

	def End(cls):
		cls.dbms.rollback()
		cls.dbms.close()

def main():
	while True:
		subprocess.call("cls", shell=True)
		try:
			name = input("Name: ")
			vorname = input("Vorname: ")

			session = Dbms()

			user = session.get_name(vorname, name)

			print("\nErgebniss der Suchanfrage: \n")
			for i in user:
				print("Vorname = %s \t \t Name = %s" % (i["vorname"],i["name"]))

			print("\n")	
			if len(user) == 1:
				while True:
					print("Es wurde ein Schüler ausgewählt. \n")
					print("Was möchten Sie tun:")
					print("\t \t 1 = Schulden Ausgeben lassen.")
					print("\t \t 2 = Schulden Eintragen.")
					print()
					auswahl = input("Geben Sie hier die Nummer ein: ")

					if auswahl == "1":
						schulden = session.get_schulden(user) # Ist es besser das Gesamte Dic der Klasse zu übergeben?
						for i in schulden:
							print(i)

					elif auswahl == "2":
						subprocess.call("cls", shell=True)

						while True:
							betrag = input("Geben sie den Betrag ein (Hinweiß Verwendet Sie ein Punkt anstatt ein Komma): ")
							try:
								float(betrag)
							except:
								print("Das war keine Gültige Eingabe. Versuchen Sie es erneut.")
								continue
							break

						comment = input("Fügen Sie ein Kommentar hinzu: ")
						session.insert(user, betrag, comment)
						break
					else:
						print("Fehler in der Auswahl!")
						continue



			if len(user) == 0:
				print("Kein Schüler gefunden! Versuche es erneut.")
				input("Weiter mit Enter")
				continue

			if len(user) > 1:
				print("Mehrer Schüler wurden gefunden! Versuche es erneut.")
				input("Weiter mit Enter")
				continue



		except KeyboardInterrupt:
			session.End()
			print("\n KeyboardInterrupt")
			break
		print("\n")
		input("Drücken Sie Enter um einen Neuen Schüler Auszuwählen.")

if __name__ == "__main__":
	main()

Code: Alles auswählen

import pymysql
from tkinter import *
from tkinter import messagebox as msg


class MainUI():
    """doc"""
    def __init__(self, master):
        self.master = master

        master.title("Klassenkasse")
        master.resizable(width=0, height=0)

        ### Frames werden gesetzt ###
        topframeleft = Frame(master, bd=2, relief="groove")
        topframeleft.grid(row=0, column=0)

        topframeright = Frame(master, bd=2, relief="groove")
        topframeright.grid(row=0, column=1)

        bottomframeleft = Frame(master, bd=2, relief="groove")
        bottomframeleft.grid(row=1, column=0, columnspan=2)

        ### TopFrameLeft ###
        user_label = Label(topframeleft, text="Benutzername")
        user_label.grid(row=0, column=0, pady=5, padx=5, sticky=E)

        passwd_label = Label(topframeleft, text="Passwort")
        passwd_label.grid(row=1, column=0, pady=5, padx=5, sticky=E)

        self.entry_login = Entry(topframeleft)
        self.entry_login.grid(row=0, column=1, pady=5, padx=5)

        self.entry_passwd = Entry(topframeleft, show="*")
        self.entry_passwd.grid(row=1, column=1, pady=5, padx=5)

        button_login = Button(topframeleft, text="Login", command=self.login)
        button_login.grid(row=0, column=2, rowspan=2, pady=5, padx=5)

        #self.checkbox_safe = IntVar()
        #checkbox_login = Checkbutton(topframeleft, text="Benutzername und Passwort speichern?",
        #    variable=self.checkbox_safe)
        #checkbox_login.grid(row=2, column=1)

        ### Topframeright ###
        self.label_nochzuzahlen = Label(topframeright)
        self.label_nochzuzahlen.grid(row=1, column=0)

        self.label_bereitsgezahlt = Label(topframeright)
        self.label_bereitsgezahlt.grid(row=2, column=0, columnspan=2)

        self.label_summe = Label(topframeright)
        self.label_summe.grid(row=3, column=0)

        ### BottomFrameLeft ###

        button_insert = Button(bottomframeleft, text="Eintragen", command=self.insert)
        button_insert.grid(row=0, column=0, pady=5, padx=5)

        button_send = Button(bottomframeleft, text="Sende Erinnerung", command=self.send)
        button_send.grid(row=0, column=1, pady=5, padx=5)

        button_bezahlt = Button(bottomframeleft, text="Zahlung eingegangen", command=self.zahlung)
        button_bezahlt.grid(row=0, column=2, pady=5, padx=5)

        button_hilfe = Button(bottomframeleft, text="Hilfe", command=self.show_hilfe)
        button_hilfe.grid(row=0, column=3, pady=5, padx=5)

        ### Text Box ###
        self.text_box = Text(master, bg="#8A8A8A", width=60, height=20, bd=2)
        self.text_box.grid(row=2, column=0, columnspan=2, padx=2, pady=2, sticky=S)

        ### List Box ###
        self.listbox = Listbox(master, bg="#4945F0", height=30, width=30, bd=2, relief="raised")
        self.listbox.grid(row=0, column=2, rowspan=3, padx=2, pady=2, sticky=N)

        ### Status Bar ###
        self.label_status = Label(master, bg="#858585", width=95, bd=2, relief="raised")
        self.label_status.grid(column=0, row=3, columnspan=3)

    def login(self):
        """doc"""
        try:
            user_name = self.entry_login.get()
            passwd = self.entry_passwd.get()

            self.dbms = Dbms(pymysql, user_name, passwd)
            text = "Sie sind Eingeloggt"

            ### Listet die User auf und speichert sie in die Rechte listbox ###
            self.listbox.delete(0, END)
            result = self.dbms.list_name()
            for user in result:
                user = "{0}-{1}-{2}".format(user["schueler_id"], user["vorname"], user["name"])
                self.listbox.insert(END, user)
            self.listbox.bind("<Double-Button-1>", self.schulden)
            self.label_status.config(text="Wähle einen User aus der Liste aus.")

            self.label_bereitsgezahlt.config(text="Geschlossene Tickets : %s" %(self.dbms.count_tickets_payed()))
            self.label_nochzuzahlen.config(text="Offene Tickets : %s" %(self.dbms.count_tickets_notpayed()))
            self.label_summe.config(text="Aktuelle Summe : %s €" %(self.dbms.summe()))

        except Exception as ex:
            msg.showwarning("Fehler beim Einloggen", ex)
            text = "Sie sind nicht Eingeloggt!"
        self.label_status.config(text=text)

    def schulden(self, event):
        """doc"""
        self.text_box.delete("1.0", END)

        widget = event.widget
        selection = widget.curselection()
        user = widget.get(selection[0])

        self.label_status.config(text="Ein User wurde ausgewählt: %s" % (user))

        schueler = user.split("-")

        self.label_status.config(text=schueler)
        self.text_box.insert(END, "Vorname = {0} \nName = {1} \n \n".format(
            schueler[1],
            schueler[2]))

        result = self.dbms.list_schulden(schueler[0])
        
        if len(result) != 0:
            for row in result:
                self.text_box.insert(END, " Betrag = {0} € \n Datum = {1}".format(row["betrag"], row["date"]))
                self.text_box.insert(END, "\n Bezahlt = {0} \n Kommentar = {1} \n \n".format(row["bezahlt"], row["comment"]))

    def insert(self):
        """doc"""
        pass
        #try: Probe versuch listeneintrag zu bekommen.
        #except: Kein Login fehler meldung anzeigen lassen.

    def send(self):
        """doc"""
        pass

    def zahlung(self):
        """doc"""
        pass

    def show_hilfe(self):
        """doc"""
        pass

class Dbms():
    """docstring for Dbms"""
    def __init__(self, root, user, passwd):
        self.dbms = root.connect(
                host="192.168.2.100",
                user=user,
                passwd=passwd,
                db="bxt"
            )

    def list_name(self):
        """doc"""
        cur = self.dbms.cursor(pymysql.cursors.DictCursor)
        cur.execute("SELECT * FROM schueler")
        result = cur.fetchall()

        return result

    def list_schulden(self, user):
        """doc"""
        cur = self.dbms.cursor(pymysql.cursors.DictCursor)
        cur.execute("""SELECT betrag, date, bezahlt, comment FROM
             schulden WHERE schueler_id = %s""", (user))
        result = cur.fetchall()

        return result

    def summe(self):
        """doc"""
        cur = self.dbms.cursor(pymysql.cursors.DictCursor)
        cur.execute("SELECT SUM(betrag) betrag FROM schulden")
        result = cur.fetchall()
        return result[0]["betrag"]

    def count_tickets_payed(self):
        """doc"""
        cur = self.dbms.cursor(pymysql.cursors.DictCursor)
        cur.execute("SELECT COUNT(bezahlt) bezahlt FROM schulden WHERE bezahlt = \"Y\"")
        result = cur.fetchall()
        return result[0]["bezahlt"]
        print(result)


    def count_tickets_notpayed(self):
        """doc"""
        cur = self.dbms.cursor(pymysql.cursors.DictCursor)
        cur.execute("SELECT COUNT(bezahlt) bezahlt FROM schulden WHERE bezahlt = \"N\"")
        result = cur.fetchall()
        return result[0]["bezahlt"]


def main():
    """doc"""
    root = Tk()
    MainUI(root)
    root.mainloop()

if __name__ == '__main__':
    main()

Code: Alles auswählen

# coding: utf8
from __future__ import absolute_import, division, print_function
from tkinter import *
from tkinter.messagebox import showwarning
 
import pymysql
 

class Dbms(object):

    def __init__(self, host, user, password, database):
        self.dbms = pymysql.connect(
            host=host, user=user, passwd=password, db=database
        )
 
    def _execute(self, sql, values=None):
        cursor = self.dbms.cursor(pymysql.cursors.DictCursor)
        cursor.execute(sql, values)
        return cursor.fetchall()

    def get_users(self):
        return self._execute('SELECT * FROM schueler')
 
    def get_open_items(self, user):
        return self._execute(
            'SELECT betrag, date, bezahlt, comment'
            ' FROM schulden'
            ' WHERE schueler_id = %s',
            (user,)
        )

    def get_payment_statistics(self):
        result = self._execute(
            'SELECT bezahlt, COUNT(bezahlt) bezahlt_count, SUM(betrag) total'
            ' FROM schulden'
            ' GROUP BY bezahlt'
            ' ORDER BY bezahlt'
        )
        return [(row['bezahlt_count'], row['total']) for row in result]
 
 
class MainUI(object):

    def __init__(self, master):
        self.master = master
        self.dbms = None
 
        master.title('Klassenkasse')
        master.resizable(width=0, height=0)
 
        ### Frames werden gesetzt ###
        topframeleft = Frame(master, bd=2, relief=GROOVE)
        topframeleft.grid(row=0, column=0)
 
        topframeright = Frame(master, bd=2, relief=GROOVE)
        topframeright.grid(row=0, column=1)
 
        bottomframeleft = Frame(master, bd=2, relief=GROOVE)
        bottomframeleft.grid(row=1, column=0, columnspan=2)
 
        ### TopFrameLeft ###
        user_label = Label(topframeleft, text='Benutzername')
        user_label.grid(row=0, column=0, pady=5, padx=5, sticky=E)
 
        passwd_label = Label(topframeleft, text='Passwort')
        passwd_label.grid(row=1, column=0, pady=5, padx=5, sticky=E)
 
        self.entry_login = Entry(topframeleft)
        self.entry_login.grid(row=0, column=1, pady=5, padx=5)
 
        self.entry_passwd = Entry(topframeleft, show='*')
        self.entry_passwd.grid(row=1, column=1, pady=5, padx=5)
 
        button_login = Button(topframeleft, text='Login', command=self.login)
        button_login.grid(row=0, column=2, rowspan=2, pady=5, padx=5)
 
        ### Topframeright ###
        self.label_nochzuzahlen = Label(topframeright)
        self.label_nochzuzahlen.grid(row=1, column=0)
 
        self.label_bereitsgezahlt = Label(topframeright)
        self.label_bereitsgezahlt.grid(row=2, column=0, columnspan=2)
 
        self.label_summe = Label(topframeright)
        self.label_summe.grid(row=3, column=0)
 
        ### BottomFrameLeft ###
        button_insert = Button(
            bottomframeleft, text='Eintragen', command=self.add_open_item
        )
        button_insert.grid(row=0, column=0, pady=5, padx=5)
 
        button_send = Button(
            bottomframeleft, text='Sende Erinnerung', command=self.send_reminder
        )
        button_send.grid(row=0, column=1, pady=5, padx=5)
 
        button_bezahlt = Button(
            bottomframeleft, text='Zahlung eingegangen', command=self.close_item
        )
        button_bezahlt.grid(row=0, column=2, pady=5, padx=5)
 
        button_hilfe = Button(
            bottomframeleft, text='Hilfe', command=self.show_help
        )
        button_hilfe.grid(row=0, column=3, pady=5, padx=5)
 
        self.text_box = Text(master, bg='#8A8A8A', width=60, height=20, bd=2)
        self.text_box.grid(
            row=2, column=0, columnspan=2, padx=2, pady=2, sticky=S
        )
 
        self.listbox = Listbox(
            master, bg='#4945F0', height=30, width=30, bd=2, relief=RAISED
        )
        self.listbox.grid(row=0, column=2, rowspan=3, padx=2, pady=2, sticky=N)
        self.users = dict()

        self.label_status = Label(
            master, bg='#858585', width=95, bd=2, relief=RAISED
        )
        self.label_status.grid(column=0, row=3, columnspan=3)
 
    def login(self):
        try:
            self.dbms = Dbms(
                '192.168.2.100',
                self.entry_login.get(),
                self.entry_passwd.get(),
                'bxt'
            )
 
            ### Listet die User auf und speichert sie in die Rechte listbox ###
            self.listbox.delete(0, END)
            self.users = dict()
            for user in self.dbms.get_users():
                user_string = (
                    '{0["schueler_id"]}-{0["vorname"]}-{0["name"]}'.format(user)
                )
                self.listbox.insert(END, user_string)
                self.users[user_string] = user
            self.listbox.bind('<Double-Button-1>', self.on_user_selected)
 
            (
                (unpaid_count, unpaid_total), (paid_count, paid_total)
            ) = self.dbms.get_payment_statistics()
            self.label_bereitsgezahlt['text'] = (
                'Geschlossene Tickets : {0}'.format(paid_count)
            )
            self.label_nochzuzahlen['text'] = (
                'Offene Tickets : {0}'.format(unpaid_count)
            )
            self.label_summe['text'] = (
                'Aktuelle Summe : {0:.2f} €'.format(unpaid_total + paid_total)
            )
        except Exception as error:
            showwarning('Fehler beim Einloggen', str(error))
            status_text = 'Sie sind nicht angemeldet!'
        else:
            status_text = 'Sie sind angemeldet.'

        self.label_status['text'] = status_text
 
    def on_user_selected(self, _event=None):
        user_key = self.listbox.get(self.listbox.curselection()[0])
        self.label_status['text'] = 'Ein User wurde ausgewählt: {0}'.format(
            user_key
        )
        user = self.users[user_key]
        self.text_box.delete('1.0', END)
        self.text_box.insert(
            END,
            'Vorname = {0["vorname"]}\nName = {0["name"]}\n\n'.format(user)
        )
        for row in self.dbms.get_open_items(user['schueler_id']):
            self.text_box.insert(
                END,
                ' Betrag = {0["betrag"]} €\n'
                ' Datum = {0["date"]}\n'
                ' Bezahlt = {1}\n'
                ' Kommentar = {0["comment"]}\n\n'.format(
                    row, 'J' if row['bezahlt'] else 'N'
                )
            )
 
    def add_open_item(self):
        pass
 
    def send_reminder(self):
        pass
 
    def close_item(self):
        pass
 
    def show_help(self):
        pass
 

def main():
    root = Tk()
    MainUI(root)
    root.mainloop()

 
if __name__ == '__main__':
    main()