from dbUtil import Mydb
class MyService:
def __init__(self):
self.user=None
def login(self,uname,passsword):
sql="select * from t_user where uname=%s and password=%s"
user=Mydb().query_one(sql,uname,passsword)
if user:
self.user=user
return True
else:
return False
def add_music(self,files):
for f in files:
start=f.rfind("/")+1
end=f.rfind(".mp3")
music_name=f[start:end]
# 根据歌名查询数据是否有该首歌
sql="select * from t_music where music_name=%s"
music=Mydb().query_one(sql,music_name)
if music:
# 查询关联表t_list 该用户是否添加了这首歌
sql="select * from t_list where mid=%s and uid=%s"
t_list=Mydb().query_one(sql,music[0],self.user[0])
if not t_list:
sql = "insert into t_list(mid,uid) values(%s,%s)"
Mydb().exeDML(sql,music[0],self.user[0])
else:
# 将音乐保存到t_music
sql="insert into t_music(music_name,path) values(%s,%s)"
mid=Mydb().exeDML(sql,music_name,f)
# 用户选择的音乐保存到t_list
sql="insert into t_list(mid,uid) values(%s,%s)"
Mydb().exeDML(sql,mid,self.user[0])
# 查询用户的音乐列表
def findListByUser(self):
sql="select "
import pymysql
class Mydb:
config={
"host":"localhost",
"user":"root",
"password":"123",
"db":"music",
"charset":"utf8"
}
def __init__(self):
self.connection=pymysql.connect(**Mydb.config)
self.cursor=self.connection.cursor()
def close(self):
if self.cursor:
self.cursor.close()
if self.connection:
self.connection.close()
# 插入、修改、删除调用
def exeDML(self,sql,*args):
try:
# 执行sql
count=self.cursor.execute(sql,args)
id=self.connection.insert_id()
# 提交事务
self.connection.commit()
return id
except Exception as e:
print(e)
if self.connection:
self.connection.rollback()
finally:
self.close()
def query_one(self,sql,*args):
try:
# 执行sql
self.cursor.execute(sql,args)
# 获取结果集
return self.cursor.fetchone()
except Exception as e:
print(e)
finally:
self.close()
def query_all(self,sql,*args):
try:
# 执行sql
self.cursor.execute(sql,args)
# 获取结果集
return self.cursor.fetchall()
except Exception as e:
print(e)
finally:
self.close()
if __name__=="__main__":
dbUtil=Mydb()
# sql="insert into emp(empno,ename,sal) values(%s,%s,%s)"
# count=dbUtil.exeDML(sql,9999,'lili',12000)
# print(count)
# sql="select * from emp where empno=%s"
# emp=dbUtil.query_one(sql,7788)
# print(emp)
sql="select * from emp"
emps=dbUtil.query_all(sql)
for e in emps:
print(e,end="\n")
from MyService import MyService
import tkinter
from tkinter.filedialog import askopenfilenames
class PlayWindow:
def __init__(self,myService):
self.myService=myService
self.listbox=None
def impMusic(self,even):
print("点击了导入音乐按钮")
# 打开磁盘选择音乐
files=askopenfilenames(filetype=(["mp3","*.mp3"],))
# 导入音乐，将选择的音乐保存在数据库
self.myService.add_music(files)
# 查询当前用户的列表
def flush_list(self):
# 清空列表
self.listbox.delete(0,tkinter.END)
# 查询该用户的所有音乐列表
music_list=self.myService.findListByUser()
# 播放音乐
def playMusic(self,even):
print("点击了播放音乐按钮")
# 删除音乐
def deleteMusic(self,even):
print("点击了删除音乐按钮")
def showWindow(self):
# 显示窗口
top=tkinter.Tk()
# 添加按钮
play_button=tkinter.Button(top,text="播放")
imp_button=tkinter.Button(top,text="导入音乐")
delete_button=tkinter.Button(top,text="删除音乐")
play_button.grid(row=0,column=0,padx=5,pady=5)
imp_button.grid(row=0,column=2,padx=5,pady=5)
delete_button.grid(row=0,column=4,padx=5,pady=5)
# 添加列表
self.listbox=tkinter.Listbox(top)
self.listbox.grid(row=1,column=0,padx=5,pady=5,columnspan=9)
# 给按钮添加点击事件
imp_button.bind("<ButtonRelease-1>",self.impMusic)
play_button.bind("<ButtonRelease-1>",self.playMusic)
delete_button.bind("<ButtonRelease-1>",self.deleteMusic)
top.mainloop()
if __name__ == '__main__':
uname=input("请输入用户名:")
password=input("请输入密码:")
myservice=MyService()
if myservice.login(uname,password):
print("登陆成功")
playwindow=PlayWindow(myservice)
playwindow.showWindow()
else:
print("登录失败")
老师，帮我看看哪错了音乐添加不到数据库
我这个没法停止MySQL80服务，也不知道是啥问题
京公网安备 11011402011233号