被python折磨的死去活来 2023-12-11 11:39 采纳率: 0%
浏览 6

用python连接mysql连接不上啊


import pymysql.cursors
from tkinter import ttk
import tkinter as tk
import tkinter.font as tkFont
from tkinter import *
import tkinter.messagebox as messagebox
import time
connect=pymysql.Connect(
   host='localhost',
   port=3306,
   user='root',
   passwd='913109Myh',
   db='khglxt',
   charset='utf8'
)
 
 
class logincheck:
   def __init__(self,parent_window):
       parent_window.update()
       parent_window.destroy()
       self.window=tk.Tk()
       self.window.title("登录界面")
       self.window.geometry('700x600+70+50')
       def getTime():
           timeStr=time.strftime('%H:%M:%S')
           Rtime.configure(text=timeStr)
           self.window.after(1000, getTime)
       Rtime= Label(self.window,text='')
       Rtime.pack(pady=25)
       getTime()
       label = Label(self.window, text="客户管理系统登录", font=("楷体", 30))
       label.pack(pady=10)
       self.var_username=StringVar()
       self.var_pwd=StringVar()
 
       self.right_top_username_label = Label(text="用户名：", font=('楷体', 15)).pack(pady=15)
       self.right_top_username_entry = Entry(textvariable=self.var_username, font=('楷体', 15)).pack()
 
       self.right_top_pwd_label = Label(text="密码：", font=('楷体', 15)).pack(pady=15)
       self.right_top_pwd_entry = Entry(textvariable=self.var_pwd, font=('楷体', 15)).pack()
 
       self.right_top_button1 = ttk.Button(text='确定', width=20, command=self.new_row).pack(pady=30)
       self.right_top_button2 = ttk.Button(text='返回', width=20, command=self.back).pack()
       self.window.protocol("WM_DELETE_WINDOW", self.back)
 
       self.username=[]
       self.pwd=[]
 
       self.window.mainloop()
       db = pymysql.connect(host="localhost", user="root", passwd="913109Myh", db="khglxt")
       cursor = db.cursor()
       sql = "SELECT * FROM 客户登录 WHERE 用户名='%s'"%(self.var_username.get())
       try:
           cursor.execute(sql)
           results = cursor.fetchall()
           for row in results:
               self.username.append(row[0])
               self.pwd.append(row[1])
       except:
           print("Error: unable to fetch data")
           messagebox.showinfo('警告！', '数据库连接失败!')
       db.close()
 
   def back(self):
       self.window.destroy()
 
   def new_row(self):
       if self.var_username.get() != '' and self.var_pwd.get() != '' and self.var_username.get()=='test' and self.var_pwd.get()=='123':
           try:
               db = pymysql.connect(host="localhost", user="root", passwd="913109Myh", db="khglxt")
               cursor= db.cursor()
               sql = "SELECT * FROM 客户登录 WHERE 用户名=%s"
               cursor.execute(sql, (self.var_username.get(),))
               startpage(self.window)
           except pymysql.Error as e:
               messagebox.showinfo('警告！', '数据库连接失败！')
               db.close()
       else:
           messagebox.showinfo('提示！', '请填写正确的用户信息')
 
 
 
 
 
 
 
class startpage:
   def __init__(self,parent_window):
       parent_window.update()
       parent_window.destroy()
       self.window=tk.Tk()
       self.window.title("客户管理系统")
       self.window.geometry('1200x600+70+50')
       def getTime():
           timeStr=time.strftime('%H:%M:%S')
           Rtime.configure(text=timeStr)
           self.window.after(1000, getTime)
       Rtime= Label(self.window,text='')
       Rtime.pack(pady=25)
       getTime()
       label= Label(self.window,text="客户管理系统",font=("楷体",30))
       label.pack(pady=10)
       Button(self.window,text="添加客户",font=tkFont.Font(size=16),command=lambda: xinjian(self.window),width=20,height=2,fg='white',bg='gray').place(x=100,y=300)
       Button(self.window,text="查询",font=tkFont.Font(size=16), command=lambda: cangkucha(self.window), width=20,height=2, fg='white', bg='gray').place(x=400, y=300)
       Button(self.window, text="删除", font=tkFont.Font(size=16), command=lambda:shanchu(self.window), width=20,height = 2, fg = 'white', bg = 'gray').place(x=100, y=400)
       Button(self.window, text="退出系统", font=tkFont.Font(size=16), command=self.window.destroy, width=20,height=2, fg='white', bg='gray').place(x=400, y=400)
       Button(self.window, text="修改信息", font=tkFont.Font(size=16), command=lambda:xiugai(self.window),width=20,height=2,fg='white',bg='gray').place(x=700,y=300)
       self.window.mainloop()
 
class xinjian:
   def __init__(self,parent_window):
       parent_window.destroy()
       self.window=tk.Tk()
       self.window.title("添加客户")
       self.window.geometry('700x600+70+50')
       self.top_title=Label(self.window,text="添加客户",bg='SkyBlue', font=('楷体', 20), width=70, height=2)
       self.top_title.pack()
 
       self.var_id = StringVar()
       self.var_name = StringVar()
       self.var_gender = StringVar()
       self.var_age = StringVar()
       self.var_num = StringVar()
 
       self.right_top_id_label = Label(text="客户ID号：", font=('楷体', 15)).pack(pady=15)
       self.right_top_id_entry = Entry(textvariable=self.var_id, font=('楷体', 15)).pack()
 
       self.right_top_name_label =Label(text="客户姓名：", font=('楷体', 15)).pack(pady=15)
       self.right_top_name_entry = Entry(textvariable=self.var_name, font=('楷体', 15)).pack()
 
       self.right_top_gender_label = Label(text="客户性别:", font=('楷体', 15)).pack(pady=15)
       self.right_top_gender_entry = Entry(textvariable=self.var_gender, font=('楷体', 15)).pack()
 
       self.right_top_age_label = Label(text="客户年龄:", font=('楷体', 15)).pack(pady=15)
       self.right_top_age_entry = Entry(textvariable=self.var_age, font=('楷体', 15)).pack()
 
       self.right_top_num_label = Label(text="客户电话：",font=('楷体',15)).pack(pady=15)
       self.right_top_num_entry = Entry(textvariable=self.var_num, font=('楷体', 15)).pack()
 
 
       self.right_top_button1 = ttk.Button(text='确定', width=20, command=self.new_row).pack(pady=30)
       self.right_top_button2 = ttk.Button(text='返回', width=20, command=self.back).pack()
       self.window.protocol("WM_DELETE_WINDOW", self.back)  # 捕捉右上角关闭点击
 
       self.id=[]
       self.name=[]
       self.gender=[]
       self.age=[]
       self.num=[]
       db = pymysql.connect(host="localhost", user="root", passwd="913109Myh", db="khglxt")
       cursor = db.cursor()
       sql = "SELECT * FROM 客户表"
       try:
           cursor.execute(sql)
           results=cursor.fetchall()
           for row in results:
               self.id.append(row[0])
               self.name.append(row[1])
               self.gender.append(row[2])
               self.age.append(row[3])
               self.num.append(row[4])
       except:
           print("Error: unable to fetch data")
           messagebox.showinfo('警告！', '数据库连接失败！')
       db.close()
 
 
   def back(self):
       startpage(self.window)
   def new_row(self):
       if self.var_id.get() != '' and self.var_name.get() != '' and self.var_gender.get() != '' and self.var_age.get() != '':
           db=pymysql.connect(host="localhost", user="root", passwd="913109Myh", db="khglxt")
           cursor = db.cursor()  # 使用cursor()方法获取操作游标
           sql= "INSERT INTO 客户表(客户ID号,客户姓名,客户性别,客户年龄,客户电话) VALUES('%s','%s','%s','%s','%s')"%(self.var_id.get(), self.var_name.get(),self.var_gender.get(), self.var_age.get(), self.var_num.get())
           try:
               cursor.execute(sql)
               db.commit()
               messagebox.showinfo('提示！', '添加成功！')
           except:
               db.rollback()
               messagebox.showinfo('警告！', '数据库连接失败！')
           db.close()
       else:
           messagebox.showinfo('提示！', '请填写客户信息')
class kehudan:
   def __init__(self,parent_window):
       parent_window.destroy()  # 销毁子界面
       self.window = tk.Tk()
       self.window.title('客户清单')
       self.window.geometry('1200x600+70+50')
       db = pymysql.connect(host="localhost", user="root", passwd="913109Myh", db="khglxt")
       cursor = db.cursor()  # 使用cursor()方法获取操作游标
       sql = "SELECT * FROM 客户表"
       try:
           cursor.execute(sql)  # 执行sql语句
           results = cursor.fetchall()
           for row in results:
               self.id = '客户ID号: ' + row[0]
               self.name = '客户名称: ' + row[1]
               self.gender = '客户性别: ' + row[2]
               self.age = '客户年龄: ' + row[3]
               self.num = '客户电话：' + row[4]
 
               db.commit()
               Label(self.window, text=self.id + "\t" + self.name + "\t" + self.gender + "\t" +self.age + "\t" +self.num, font=('楷体', 18)).pack(pady=5)
       except:
           db.rollback()  # 发生错误时回滚
           messagebox.showinfo('警告！', '数据库连接失败！')
       db.close()  # 关闭数据库连接
       self.right_top_button4 = ttk.Button(text='返回', width=20, command=self.back).pack()
       self.window.protocol("WM_DELETE_WINDOW", self.back)
   def back(self):
       cangkucha(self.window)
 
class cangkucha:
   def __init__(self, parent_window):
       parent_window.destroy()
       self.window = tk.Tk()
       self.window.title('客户查询')
       self.window.geometry('700x600+70+50')
 
       self.student_id = StringVar()
       self.id = '客户ID号:' + ''
       self.name = '客户姓名:' + ''
       self.gender = '客户性别:' + ''
       self.age = '客户年龄:' + ''
       self.num = '客户电话：' + ''
 
       Button(self.window, text="客户清单", font=tkFont.Font(size=12), command=lambda: kehudan(self.window), width=20,
              height=2, fg='white', bg='gray').place(x=20, y=70)
       self.right_top_name_label = Label(text="客户查询", font=('楷体', 15)).pack(pady=15)
       self.right_top_name_entry = Entry(textvariable=self.student_id, font=('楷体', 15)).pack(pady=30)
 
       self.right_top_button3 = ttk.Button(text='确定', width=20, command=self.new_row).pack(pady=30)
       self.right_top_button4 = ttk.Button(text='返回', width=20, command=self.back).pack()
       self.window.protocol("WM_DELETE_WINDOW", self.back)
 
       # 打开数据库连接
       db = pymysql.connect(host="localhost", user="root", passwd="913109Myh", db="khglxt")
       cursor = db.cursor()
       sql = "SELECT * FROM 客户表 WHERE 客户ID号='%s'" % (self.student_id.get()) # SQL 查询语句
       try:
           # 执行SQL语句
           cursor.execute(sql)
           # 获取所有记录列表
           results = cursor.fetchall()
           for row in results:
               self.id = '客户ID号:' + row[0]
               self.name = '客户姓名:' + row[1]
               self.gender = '客户性别:' + row[2]
               self.age = '客户年龄:' + row[3]
               self.num ='客户电话:' + row[4]
       except:
           print("Error: unable to fetch data")
       db.close()
 
   def back(self):
       startpage(self.window)
 
   def new_row(self):
       if self.student_id.get() != '':
           db = pymysql.connect(host="localhost", user="root", passwd="913109Myh", db="khglxt")
           cursor = db.cursor()
           sql = "SELECT * FROM 客户表 where 客户ID号 = '%s'" % (self.student_id.get())  # SQL 插入语句
           try:
               cursor.execute(sql)
               results = cursor.fetchall()
               for row in results:
                   self.id = '客户ID号:' + row[0]
                   self.name = '客户姓名:' + row[1]
                   self.gender = '客户性别:' + row[2]
                   self.age = '客户年龄:' + row[3]
                   self.num ='客户电话:' + row[4]
               db.commit()
               label = tk.Label(self.window, text='客户信息查看', bg='SkyBlue', font=('楷体', 20), width=70, height=2)
               label.pack(pady=20)
               Label(self.window, text=self.id, font=('楷体', 18)).pack(pady=5)
               Label(self.window, text=self.name, font=('楷体', 18)).pack(pady=5)
               Label(self.window, text=self.gender, font=('楷体', 18)).pack(pady=5)
               Label(self.window, text=self.age, font=('楷体', 18)).pack(pady=5)
               Label(self.window, text=self.num, font=('楷体', 18)).pack(pady=5)
               Button(self.window, text="返回首页", width=8, font=tkFont.Font(size=12), command=self.back_1).pack(pady=150)
               self.window.protocol("WM_DELETE_WINDOW", self.back_1)
               self.window.mainloop()
           except:
               db.rollback()
               messagebox.showinfo('提示', '数据库连接失败！')
 
           db.close()
       else:
           messagebox.showinfo('提示', '请填写客户信息！')
 
 
   def back_1(self):
       cangkucha(self.window)
class shanchu:
   def __init__(self,parent_window):
       parent_window.destroy()
 
       self.window = tk.Tk()
       self.window.title('删除表')
       self.window.geometry('700x600+70+50')
 
       self.top_title = Label(self.window, text='删除', bg='SkyBlue', font=('楷体', 20), width=70, height=2)
       self.top_title.pack()
 
       self.var_id = StringVar()
       self.var_name = StringVar()
       self.var_gender = StringVar()
       self.var_age = StringVar()
       self.var_num= StringVar()
       self.right_top_id_label = Label(text="客户ID号", font=('楷体', 15)).pack(pady=15)
       self.right_top_id_entry = Entry(textvariable=self.var_id, font=('楷体', 15)).pack()
 
       self.right_top_name_label = Label(text="客户姓名", font=('楷体', 15)).pack(pady=15)
       self.right_top_name_entry = Entry(textvariable=self.var_name, font=('楷体', 15)).pack()
 
       self.right_top_gender_label = Label(text="客户性别", font=('楷体', 15)).pack(pady=15)
       self.right_top_gender_entry = Entry(textvariable=self.var_gender, font=('楷体', 15)).pack()
 
       self.right_top_age_label = Label(text="客户年龄", font=('楷体', 15)).pack(pady=15)
       self.right_top_age_entry = Entry(textvariable=self.var_age, font=('楷体', 15)).pack()
 
       self.right_top_num_label= Label(text="客户电话", font=('楷体', 15)).pack(pady=15)
       self.right_top_num_entry = Entry(textvariable=self.var_num, font=('楷体', 15)).pack()
 
       self.right_top_button1 = ttk.Button(text='确定', width=20, command=self.new_row).pack(pady=30)
       self.right_top_button2 = ttk.Button(text='返回', width=20, command=self.back).pack()
       self.window.protocol("WM_DELETE_WINDOW", self.back)
 
       self.id = []
       self.name = []
       self.gender = []
       self.age = []
       self.num= []
       # 打开数据库连接
       db = pymysql.connect(host="localhost", user="root", passwd="913109Myh", db="khglxt")
       cursor = db.cursor()  # 使用cursor()方法获取操作游标
       sql = "SELECT * FROM 客户表"  # SQL 查询语句
       try:
           # 执行SQL语句
           cursor.execute(sql)
           # 获取所有记录列表
           results = cursor.fetchall()
           for row in results:
               self.id.append(row[0])
               self.name.append(row[1])
               self.gender.append(row[2])
               self.age.append(row[3])
               self.num.append(row[4])
       except:
           print("Error: unable to fetch data")
           messagebox.showinfo('提示', '数据库连接失败！')
       db.close()
 
   def back(self):
           startpage(self.window)
 
   def new_row(self):
           if self.var_id.get() != '' and self.var_name.get() != '':
               db = pymysql.connect(host="localhost", user="root", passwd="913109Myh", db="khglxt")
               cursor = db.cursor()
               sql = "DELETE FROM 客户表 WHERE 客户ID号 = '%s'" % (self.var_id.get())
               try:
                   cursor.execute(sql)
                   db.commit()
                   messagebox.showinfo('提示！', '删除成功！')
               except:
                   db.rollback()
                   messagebox.showinfo('警告！', '数据库连接失败！')
               db.close()
           else:
               messagebox.showinfo('警告！', '填写删除信息')
class xiugai:
   def __init__(self,parent_window):
       parent_window.destroy()
       self.window = tk.Tk()
       self.window.title('修改信息')
       self.window.geometry('700x600+70+50')
       self.top_title = Label(self.window, text='修改信息', bg='SkyBlue', font=('楷体', 20), width=70, height=2)
       self.top_title.pack()
 
       self.var_id = StringVar()
       self.var_name = StringVar()
       self.var_gender = StringVar()
       self.var_age = StringVar()
       self.var_num = StringVar()
       self.right_top_id_label = Label(text="客户ID号", font=('楷体', 15)).pack(pady=15)
       self.right_top_id_entry = Entry(textvariable=self.var_id, font=('楷体', 15)).pack()
 
       self.right_top_name_label = Label(text="客户姓名", font=('楷体', 15)).pack(pady=15)
       self.right_top_name_entry = Entry(textvariable=self.var_name, font=('楷体', 15)).pack()
 
       self.right_top_gender_label = Label(text="客户性别", font=('楷体', 15)).pack(pady=15)
       self.right_top_gender_entry = Entry(textvariable=self.var_gender, font=('楷体', 15)).pack()
 
       self.right_top_age_label = Label(text="客户年龄", font=('楷体', 15)).pack(pady=15)
       self.right_top_age_entry = Entry(textvariable=self.var_age, font=('楷体', 15)).pack()
 
       self.right_top_num_label = Label(text="客户电话", font=('楷体', 15)).pack(pady=15)
       self.right_top_num_entry = Entry(textvariable=self.var_num, font=('楷体', 15)).pack()
 
       self.right_top_button1 = ttk.Button(text='确定', width=20, command=self.new_row).pack(pady=30)
       self.right_top_button2 = ttk.Button(text='返回', width=20, command=self.back).pack()
       self.window.protocol("WM_DELETE_WINDOW", self.back)
       self.id = []
       self.name = []
       self.gender = []
       self.age = []
       self.num = []
       # 打开数据库连接
       db = pymysql.connect(host="localhost", user="root", passwd="913109Myh", db="khglxt")
       cursor = db.cursor()  # 使用cursor()方法获取操作游标
       sql = "SELECT * FROM 客户表"  # SQL 查询语句
       try:
           # 执行SQL语句
           cursor.execute(sql)
           # 获取所有记录列表
           results = cursor.fetchall()
           for row in results:
               self.id.append(row[0])
               self.name.append(row[1])
               self.gender.append(row[2])
               self.age.append(row[3])
               self.num.append(row[4])
       except:
           print("Error: unable to fetch data")
           messagebox.showinfo('提示', '数据库连接失败！')
       db.close()
 
   def back(self):
           startpage(self.window)
   def new_row(self):
           if self.var_id.get() != '':
               db = pymysql.connect(host="localhost", user="root", passwd="913109Myh", db="khglxt")
               cursor = db.cursor()
               sql = "UPDATE  客户表 SET 客户ID号='%s',客户姓名='%s',客户性别='%s',客户年龄='%s',客户电话='%s' WHERE 客户ID号='%s'" % (self.var_id.get(),self.var_name.get(),self.var_gender.get(),self.var_age.get(),self.var_num.get(),self.var_id.get())
 
 
               try:
                   cursor.execute(sql)
                   db.commit()
                   messagebox.showinfo('提示！', '修改成功！')
               except:
                   db.rollback()
                   messagebox.showinfo('警告！', '数据库连接失败！')
               db.close()
           else:
               messagebox.showinfo('警告！', '填写修改信息')
 
 
 
if __name__ == '__main__':
           window = tk.Tk()
           logincheck(window)
  • 写回答

2条回答 默认 最新

  • 小孟多 2023-12-11 15:00
    关注

    我注意到你在代码中有一些问题。首先，你在登录界面类和其他类中都提到了数据库连接的参数，这样会导致代码的重复，并且不易维护。其次，你在每个类中都打开了数据库连接，但没有关闭它们，在实际使用中可能导致数据库连接泄漏。最后，你需要使用pymysql.cursors.DictCursor来获取字典形式的查询结果，以便更方便地处理数据。

    我建议你重新组织你的代码，将数据库连接放在单独的模块中，并确保在使用完毕后关闭连接。另外，你可以将数据库操作封装成函数，以减少重复的代码，并提高代码的可读性和可维护性。

    以下是一个简单的示例，帮助你重新组织你的代码：

    # db.py
import pymysql.cursors

def get_connection():
    return pymysql.connect(
        host='localhost',
        port=3306,
        user='root',
        passwd='913109Myh',
        db='khglxt',
        charset='utf8'
    )

def close_connection(connection):
    connection.close()

def execute_query(sql, params=None):
    connection = get_connection()
    cursor = connection.cursor(pymysql.cursors.DictCursor)
    try:
        if params:
            cursor.execute(sql, params)
        else:
            cursor.execute(sql)
        results = cursor.fetchall()
        return results
    finally:
        close_connection(connection)

# logincheck.py
from db import execute_query

class LoginCheck:
    # ... 其他代码 ...

    def validate_user(self, username, password):
        sql = "SELECT * FROM users WHERE username=%s AND password=%s"
        result = execute_query(sql, (username, password))
        return len(result) > 0

# startpage.py
from db import execute_query

class StartPage:
    # ... 其他代码 ...

    def get_customers(self):
        sql = "SELECT * FROM customers"
        return execute_query(sql)

# 其他类似的文件...

    在这个示例中，我们将数据库连接和查询操作封装在db.py中，而在其他文件中只需要调用相应的函数即可。这样可以减少重复代码，更好地组织代码结构。希望对你有所帮助！

    评论

报告相同问题？

问题事件

  • 创建了问题 12月11日

悬赏问题

  • ¥20 WPF MVVM模式 handycontrol 框架， hc:SearchBar 控件 Text="{Binding NavMenusKeyWords}" 绑定取不到值
  • ¥15 需要手写数字信号处理Dsp三个简单题 不用太复杂
  • ¥15 数字信号处理考试111
  • ¥100 关于#audobe audition#的问题，如何解决？
  • ¥15 allegro17.2生成bom表是空白的
  • ¥15 请问一下怎么打通CAN通讯
  • ¥20 如何在 rocky9.4 部署 CDH6.3.2？
  • ¥35 navicat将excel中的数据导入mysql出错
  • ¥15 rt-thread线程切换的问题
  • ¥15 高通uboot 打印ubi init err 22