文章导读
本文用于巩固Pymysql操作MySQL与MySQL操作的知识点,实现一个简易的音乐播放器,拟实现的功能包括:用户登录,窗口显示,加载本地音乐,加入和删除播放列表,播放音乐。
点击此处获取参考源码https://pan.baidu.com/s/1HNLc7tCVBjoBMpnezzm7_g?pwd=vqr4
1、创建数据库和表
概述:本章的操作均在navicat的查询中实现。
1.1、创建数据库
实操:通过navicat创建一个名为db_music的数据库,用于存储本实战中所有的表。
CREATE DATABASE db_music DEFAULT CHARACTER SET="utf8";
运行结果如下:
1.2、创建用户表
实操前准备:通过navicat切换到我们创建的数据库db_music,这里直接关闭之前打开的查询,然后按如下图所示的步骤操作。
实操:在db_music数据库下创建一个名为user_info的用户表,包含的字段如下:id,用户名(uname),密码(password),并将id设置为主键。
CREATE TABLE user_info(
id int PRIMARY KEY,
uname VARCHAR(20),
password VARCHAR(30)
)
运行后的结果为(也可以刷新数据库,查看db_music数据库下的表):
1.3、创建音乐列表
实操:在db_music数据库下创建一个用于保存本地音乐的表,取名为music_info,包含以下字段:id,歌曲名(name),歌手(singer)和存放路径(path),并将id设置为主键自增长。
CREATE TABLE music_info(
id int PRIMARY KEY auto_increment,
name varchar(30),
singer varchar(20),
path varchar(80)
);
运行结果如下:
1.4、创建播放列表
实操:在db_music数据库下创建一个用于播放本地音乐的表,取名为play_info,包含以下字段:歌单唯一标识(id),用于关联用户唯一标识id,通过该字段知道这是谁的播放列表(u_id),用于关联本地音乐的唯一标识id,通过该字段知道播放哪首音乐(m_id),并将id设置为主键自增长,正确的设置u_id和m_id的外键。
CREATE TABLE play_info(
id int PRIMARY KEY auto_increment,
u_id int,
m_id int,
FOREIGN KEY(u_id) REFERENCES user_info(id),
FOREIGN KEY(m_id) REFERENCES music_info(id)
);
运行结果如下:
此时,数据库db_music下就创建了三张表:
2、实现用户登录
2.1、插入数据
概述:为了能实现用户登录,首先得为user_info表中插入用户数据用于验证后续程序的可行性。
INSERT INTO user_info VALUES(1,"muxikeqi","123321");
运行后的user_info表数据如下:
2.2、引入链接数据库的工具类
概述:新建一个名为tools.py的文件,然后将学习Python操作MySQL时写的工具类拷贝过来并加以修改(这里主要是修改链接的数据库),用于简化后续对数据库操作。
import pymysql
class DBUtil:
"""
工具类用于简化链接和关闭数据库的操作以及对数据的操作
"""
# 单独保存链接的参数,可以将其保存到特定文件中,直接调用文件获取也可
config = {
'host': "localhost",
'user': "root",
'passwd': "root",
'db': "db_music",
'charset': "utf8",
'port': 3306
}
def __init__(self) -> None:
"""
构造函数用于获取链接和游标
"""
# **指字典对象
self.con = pymysql.connect(**DBUtil.config)
self.cursor = self.con.cursor()
def close(self) -> None:
"""
该函数用于关闭链接和游标(关闭前需要判断是否存在)
"""
# 存在游标就关闭
if self.cursor:
self.cursor.close()
# 存在链接就关闭
if self.con:
self.con.close()
def dml(self, sql, args):
"""
本函数用于封装Mysql的DML语句,用于实现数据的增删改
"""
# 进行DML语句操作时一定要注意报错导致无法正常关闭链接
try:
# 执行sql中的DML语句
self.cursor.execute(sql, args)
# DML操作一定要通过链接对象提交事务
self.con.commit()
except Exception as e:
print("存在错误,错误信息如下:", e)
# 回滚前先判断链接还是否存在
if self.con:
# 回滚到原状态
self.con.rollback()
# 使用try...except...finally...最重要的作用就是保证链接正常关闭
finally:
print("即将关闭链接")
self.close()
def query_one(self, sql, args):
"""
本函数用于查询单条数据
"""
try:
self.cursor.execute(sql, args)
re = self.cursor.fetchone()
return re
except Exception as e:
print("存在错误,错误信息如下:", e)
finally:
print("即将关闭链接")
self.close()
def query_many(self, sql):
"""
本函数用于查询所有数据
"""
try:
self.cursor.execute(sql)
# 获取结果并返回数据
return self.cursor.fetchall()
except Exception as e:
print("存在错误,错误信息如下:", e)
finally:
print("即将关闭链接")
self.close()
if __name__ == "__main__":
# 获取链接对象
db = DBUtil()
# 准备sql语句及其对应的参数
sql = "select * from user_info where uname=%s and password=%s;"
args =["muxikeqi","123321"]
# 运行sql语句并关闭链接
re = db.query_one(sql,args)
print(re)
pass
2.3、实现用户登录
概述:创建一个名为service.py的文件(与前面引入的tools.py文件放在同一目录),该文件用于写后端逻辑类代码,首先在service.py文件中写一个名为login的函数用于连接数据库并判断用户是否能登录成功。
from tools import DBUtil
class Music:
def login(self, uname: str, password: str) -> bool:
"""
:param uname:用户名
:param password:密码
:return: 登录成功返回True,登录失败返回False
"""
# 准备要执行的sql语句
sql = "select * from user_info where uname=%s and password=%s"
# 准备sql语句需要的参数
args = (uname, password)
# 创建工具对象(实际时获取数据库的链接对象和游标对象)
db = DBUtil()
# 利用游标对象调用对应的单条查询方法
re = db.query_one(sql, args)
# 由于query_one函数运行成功后是有返回值的,可以通过返回值判断是否查询成功,进而判断是否有该用户
if re:
print("登录成功")
return True
else:
print("登录失败")
return False
# 测试代码
if __name__ == "__main__":
# 创建Music类的实例对象
service = Music()
# 利用实例对象调用实例方法
re = service.login("muxikeqi", "123321")
print(re)
运行结果如下:
3、实现窗口(了解)
3.1、实现显示窗口
概述:窗口的实现将采用Tkinter实现,通过菜鸟教程可以查看其用法。
实操:创建一个名为ui.py的文件放在前面创建的.py文件的同级目录,该文件主要写前端页面的代码,文件中用一个名为Ui的类承载显示窗口的内容,为了让程序进入Ui类就能显示窗口所以推荐将显示窗口的内容直接放进构造函数中。
import tkinter
class Ui:
def __init__(self):
# 主窗口
top = tkinter.Tk()
# 创建按钮对象,第一个参数是父容器,text表示显示的内容
b1 = tkinter.Button(top, text="播放")
b2 = tkinter.Button(top, text="导入音乐")
b3 = tkinter.Button(top, text="删除音乐")
# 设置按钮显示位置(row表示放在哪一行,column表示放在哪一列,pad表示距离边框的内边距,单位为像素)
b1.grid(row=1,column=1,padx=10,pady=10)
b2.grid(row=1,column=2,padx=10,pady=10)
b3.grid(row=1,column=3,padx=10,pady=10)
# 创建播放列表
lisbox = tkinter.Listbox(top)
# 设置播放列表位置,columnspan表示垮了多少列
lisbox.grid(row=2,column=0,columnspan=4,padx=10,pady=10)
# 进入消息循环
top.mainloop()
if __name__=="__main__":
ui = Ui()
运行结果如下:
3.2、实现登陆后显示窗口
概述:前面已经实现了用户登录和窗口的显示,如果要实现登陆后显示窗口只需在ui.py文件中做出修改即可。
import tkinter
from service import Music
class Ui:
def __init__(self):
# 主窗口
top = tkinter.Tk()
# 创建按钮对象,第一个参数是父容器,text表示显示的内容
b1 = tkinter.Button(top, text="播放")
b2 = tkinter.Button(top, text="导入音乐")
b3 = tkinter.Button(top, text="删除音乐")
# 设置按钮显示位置(row表示放在哪一行,column表示放在哪一列,pad表示距离边框的内边距,单位为像素)
b1.grid(row=1,column=1,padx=10,pady=10)
b2.grid(row=1,column=2,padx=10,pady=10)
b3.grid(row=1,column=3,padx=10,pady=10)
# 创建播放列表
lisbox = tkinter.Listbox(top)
# 设置播放列表位置,columnspan表示垮了多少列
lisbox.grid(row=2,column=0,columnspan=4,padx=10,pady=10)
# 进入消息循环
top.mainloop()
if __name__=="__main__":
# 获取用户名和密码
uname = input("请输入用户名:")
password = input("请输入密码:")
# 创建Music类的实例对象
ser = Music()
# 利用实例对象调用实例方法(由于会返回布尔值,所以直接进行判断)
if ser.login(uname,password):
ui = Ui()
else:
print("用户名或密码错误!")
运行结果如下:
弹出的窗口如下:
4、实现播放音乐
概述:播放音乐将使用pygame模块实现。
实操前准备1:进入终端通过如下命令下载pygame模块。
pip install pygame
运行结果如下:
实操前准备2:去任意音乐网站下载任意首歌曲放在music项目目录中的任意文件夹中(这里我放在了名为music的文件夹中)
实操:利用pygame模块实现任意一首音乐的播放。
import pygame
import time
# 初始化加载音乐的混合器
pygame.mixer.init()
# 加载音乐(路径可以是相对路径也可以是绝对路径)
pygame.mixer.music.load(f".\music\c.flac")
# 播放音乐
pygame.mixer.music.play()
# 程序进入等待(不要立即关闭程序),单位为秒
time. Sleep(20)
20秒后程序运行结果如下:
5、为UI界面设置导入音乐的事件
概述:首先需要为导入音乐的按钮添加一个点击事件,点击事件用于打开文件夹让用户选择音乐文件。(只需要对ui.py文件做修改即可)
import tkinter
from service import Music
import tkinter.filedialog
class Ui:
def __init__(self):
# 主窗口
top = tkinter.Tk()
# 创建按钮对象,第一个参数是父容器,text表示显示的内容
b1 = tkinter.Button(top, text="播放")
b2 = tkinter.Button(top, text="导入音乐")
b3 = tkinter.Button(top, text="删除音乐")
# 设置按钮显示位置(row表示放在哪一行,column表示放在哪一列,pad表示距离边框的内边距,单位为像素)
b1.grid(row=1,column=1,padx=10,pady=10)
b2.grid(row=1,column=2,padx=10,pady=10)
b3.grid(row=1,column=3,padx=10,pady=10)
# 为导入音乐的按钮添加点击事件,bind方法的第一个参数是事件名称(写法固定,不能修改),第二个参数是点击事件(点击按钮后触发的函数)
b2.bind("<Button-1>",self.importMusic)
# 创建播放列表
lisbox = tkinter.Listbox(top)
# 设置播放列表位置,columnspan表示垮了多少列
lisbox.grid(row=2,column=0,columnspan=4,padx=10,pady=10)
# 进入消息循环
top.mainloop()
# 导入音乐的点击事件
def importMusic(self,event):
# 弹出选择框(返回的结果是元组)(一定要通过filetypes限制文件类型,否则什么文件都能加入进来)
filenames = tkinter.filedialog.askopenfilenames(filetypes=[("mp3",".mp3"),("flac",".flac")])
if __name__=="__main__":
# 获取用户名和密码
uname = input("请输入用户名:")
password = input("请输入密码:")
# 创建Music类的实例对象
ser = Music()
# 利用实例对象调用实例方法(由于会返回布尔值,所以直接进行判断)
if ser.login(uname,password):
ui = Ui()
else:
print("用户名或密码错误!")
运行结果如下:
点击导入音乐按钮后的效果如下:
6、为后台添加导入音乐的逻辑
概述:本章节将实现前端选择音乐,后端将音乐名和音乐存放在本地的路径导入到db_music数据库下的music_info表的对应字段中。
首先,在service.py文件中的Music类中添加一个名为add_music的实例方法,用于将前端的数据添加到db_music数据库下music_info表中:
def add_music(self,files:tuple[str]) -> None:
"""
该函数用于将前台返回的文件路径存储到数据库中
:param file:音乐文件的路径,默认是多个,元素类型为字符串
:return: None
"""
# 编写sql语句
sql = "insert into music_info(name,path) values(%s,%s)"
# 遍历数据
for f in files:
print(f)
# 根据路径获取歌曲名
name = f[f.rfind("/")+1:f.rfind(".")]
print(name)
# 创建数据库链接对象
db = DBUtil()
# 准备参数
args=(name,f)
# 执行插入语句
db.dml(sql,args)
接下来修改ui.py文件的内容,用于将tkinter.filedialog.askopenfilenames返回的歌曲路径(返回类型是元组,返回的是歌曲在本地的绝对路径)传入前面写的add_music函数中进行处理,而add_music又属于Music类,所以要先创建一个实例对象,再通过实例对象调用add_music方法:
def importMusic(self,event):
# 弹出选择框(返回的结果是元组)(一定要通过filetypes限制文件类型,否则什么文件都能加入进来)
filenames = tkinter.filedialog.askopenfilenames(filetypes=[("mp3",".mp3"),("flac",".flac"),("mgg",".mgg")])
# 创建服务对象
ser = Music()
# 调用增加音乐的功能(将前端的数据发送给后端处理)
ser.add_music(filenames)
运行后的结果如下:
加入歌曲后db_music数据库下music_info表的数据如下:
完整ui.py文件如下:
import tkinter
from service import Music
import tkinter.filedialog
class Ui:
def __init__(self):
# 主窗口
top = tkinter.Tk()
# 创建按钮对象,第一个参数是父容器,text表示显示的内容
b1 = tkinter.Button(top, text="播放")
b2 = tkinter.Button(top, text="导入音乐")
b3 = tkinter.Button(top, text="删除音乐")
# 设置按钮显示位置(row表示放在哪一行,column表示放在哪一列,pad表示距离边框的内边距,单位为像素)
b1.grid(row=1,column=1,padx=10,pady=10)
b2.grid(row=1,column=2,padx=10,pady=10)
b3.grid(row=1,column=3,padx=10,pady=10)
# 为导入音乐的按钮添加点击事件,bind方法的第一个参数是事件名称,第二个参数是点击事件(点击按钮后触发的函数)
b2.bind("<Button-1>",self.importMusic)
# 创建播放列表
lisbox = tkinter.Listbox(top)
# 设置播放列表位置,columnspan表示垮了多少列
lisbox.grid(row=2,column=0,columnspan=4,padx=10,pady=10)
# 进入消息循环
top.mainloop()
# 导入音乐的点击事件
def importMusic(self,event):
# 弹出选择框(返回的结果是元组)(一定要通过filetypes限制文件类型,否则什么文件都能加入进来)
filenames = tkinter.filedialog.askopenfilenames(filetypes=[("mp3",".mp3"),("flac",".flac"),("mgg",".mgg")])
# 创建服务对象
ser = Music()
# 调用增加音乐的功能(将前端的数据发送给后端处理)
ser.add_music(filenames)
if __name__=="__main__":
# 获取用户名和密码
uname = input("请输入用户名:")
password = input("请输入密码:")
# 创建Music类的实例对象
ser = Music()
# 利用实例对象调用实例方法(由于会返回布尔值,所以直接进行判断)
if ser.login(uname,password):
Ui()
else:
print("用户名或密码错误!")
完整service.py文件如下:
from tools import DBUtil
class Music:
def login(self, uname: str, password: str) -> bool:
"""
:param uname:用户名
:param password:密码
:return: 登录成功返回True,登录失败返回False
"""
# 准备要执行的sql语句
sql = "select * from user_info where uname=%s and password=%s"
# 准备sql语句需要的参数
args = (uname, password)
# 创建工具对象(实际时获取数据库的链接对象和游标对象)
db = DBUtil()
# 利用游标对象调用对应的单条查询方法
re = db.query_one(sql, args)
# 由于query_one函数运行成功后是有返回值的,可以通过返回值判断是否查询成功,进而判断是否有该用户
if re:
print("登录成功")
return True
else:
print("登录失败")
return False
def add_music(self,files:tuple[str]) -> None:
"""
该函数用于将前台返回的文件路径存储到数据库中
:param file:音乐文件的路径,默认是多个,元素类型为字符串
:return: None
"""
# 编写sql语句
sql = "insert into music_info(name,path) values(%s,%s)"
# 遍历数据
for f in files:
print(f)
# 根据路径获取歌曲名
name = f[f.rfind("/")+1:f.rfind(".")]
print(name)
# 创建数据库链接对象
db = DBUtil()
# 准备参数
args=(name,f)
# 执行插入语句
db.dml(sql,args)
# 测试代码
if __name__ == "__main__":
# 创建Music类的实例对象
service = Music()
# 利用实例对象调用实例方法
re = service.login("muxikeqi", "123321")
print(re)
7、实现音乐列表和用户绑定
概述:实现音乐列表和用户的绑定主要是为play_info表添加数据即可,play_info表包含了数据库id和用户id,契合用户和音乐的对应关系。
7.1、获取用户id
思路:为service.py文件下的Music类添加一个构造方法,构造方法用于放置一个user变量,用于保存用户id,默认为空。结合login函数中变量re是数据库进行查询后的返回的查询结果,通过判断re是否为空来判断用户是否登录。当用户不为空时(用户登录成功),我们将返回的结果re赋值给构造方法中的user变量,此时,user就拿到返回的用户信息,然后获取用户id在user_info表中对应位置的值就拿到了用户id。
def __init__(self):
# 用户默认为空
self. User = None
def login(self, uname: str, password: str) -> bool:
"""
:param uname:用户名
:param password:密码
:return: 登录成功返回True,登录失败返回False
"""
# 准备要执行的sql语句
sql = "select * from user_info where uname=%s and password=%s"
# 准备sql语句需要的参数
args = (uname, password)
# 创建工具对象(实际时获取数据库的链接对象和游标对象)
db = DBUtil()
# 利用游标对象调用对应的单条查询方法
re = db.query_one(sql, args)
# 由于query_one函数运行成功后是有返回值的,可以通过返回值判断是否查询成功,进而判断是否有该用户
if re:
print("登录成功")
self.user=re
# 查看内容是否包含u_id对应的内容
# print(self.user)
return True
else:
print("登录失败")
return False
7.2、获取音乐id
思路:在service.py文件中的有一个add_music函数,我们可以在修改music_info表的同时为play_info表添加数据,而add_music函数中通过db.dml(sql,args)对music_info表添加了数据,如果我们能让dml方法告诉我们它添加的id为多少那么获取音乐id的问题就解决了,因此这里可以直接将工具类中的dml函数重写一份,添加一个获取添加id的方法并返回,这里我为这个函数取名为dml_back_id。(写完本小节还是存在问题的,需要看下一小节)
工具类重写的dml_back_id函数如下:
# 重写上面的dml函数,增加返回id的操作
def dml_back_id(self, sql, args):
"""
本函数用于封装Mysql的DML语句,用于实现数据的增删改
"""
# 进行DML语句操作时一定要注意报错导致无法正常关闭链接
try:
# 执行sql中的DML语句
self.cursor.execute(sql, args)
# 获取添加的id
id = self.con.insert_id()
# DML操作一定要通过链接对象提交事务
self.con.commit()
# 返回id
return id
except Exception as e:
print("存在错误,错误信息如下:", e)
# 回滚前先判断链接还是否存在
if self.con:
# 回滚到原状态
self.con.rollback()
# 使用try...except...finally...最重要的作用就是保证链接正常关闭
finally:
print("即将关闭链接")
self.close()
service.py文件的add_music函数修改如下:
def add_music(self,files:tuple[str]) -> None:
"""
该函数用于将前台返回的文件路径存储到数据库中
:param file:音乐文件的路径,默认是多个,元素类型为字符串
:return: None
"""
# 编写sql语句
sql = "insert into music_info(name,path) values(%s,%s)"
# 遍历数据
for f in files:
print(f)
# 根据路径获取歌曲名
name = f[f.rfind("/")+1:f.rfind(".")]
print(name)
# 创建数据库链接对象
db = DBUtil()
# 准备参数
args=(name,f)
# 将音乐信息添加到music_info表中
m_id = db.dml_back_id(sql,args)
# 实现音乐与用户绑定
musicBindId_sql = "insert into play_info(u_id,m_id) values(%s,%s)"
args=(self.user[0],m_id)
db.dml(musicBindId_sql,args)
7.3、问题解决
问题1:无法获取到用户id。
原因分析:用户是从前端文件进行登录的,在ui.py文件的测试内容中我们创建了一个实例对象,用于调用service.py文件中的login函数,判断用户能否登录成功,但登录成功后就进入了Ui类的构造方法,构造方法为导入音乐按钮添加了一个名为importMusic的点击事件,在importMusic函数中又创建了一个实例对象,用于调用service.py文件中的add_music方法,我们是通过第二个对象去获取用户id,但用户id保存到了第一个实例对象。
解决办法:将第二个实例对象删除,再用第一个实例对象调用add_music函数即可。
import tkinter
from service import Music
import tkinter.filedialog
class Ui:
def __init__(self):
# 主窗口
top = tkinter.Tk()
# 创建按钮对象,第一个参数是父容器,text表示显示的内容
b1 = tkinter.Button(top, text="播放")
b2 = tkinter.Button(top, text="导入音乐")
b3 = tkinter.Button(top, text="删除音乐")
# 设置按钮显示位置(row表示放在哪一行,column表示放在哪一列,pad表示距离边框的内边距,单位为像素)
b1.grid(row=1,column=1,padx=10,pady=10)
b2.grid(row=1,column=2,padx=10,pady=10)
b3.grid(row=1,column=3,padx=10,pady=10)
# 为导入音乐的按钮添加点击事件,bind方法的第一个参数是事件名称,第二个参数是点击事件(点击按钮后触发的函数)
b2.bind("<Button-1>",self.importMusic)
# 创建播放列表
lisbox = tkinter.Listbox(top)
# 设置播放列表位置,columnspan表示垮了多少列
lisbox.grid(row=2,column=0,columnspan=4,padx=10,pady=10)
# 进入消息循环
top.mainloop()
# 导入音乐的点击事件
def importMusic(self,event):
# 弹出选择框(返回的结果是元组)(一定要通过filetypes限制文件类型,否则什么文件都能加入进来)
filenames = tkinter.filedialog.askopenfilenames(filetypes=[("mp3",".mp3"),("flac",".flac"),("mgg",".mgg")])
# 创建服务对象(这里如果不干掉,绑定用户和音乐时就拿不到u_id,因为创建了两个实例对象)
# ser = Music()
# 调用增加音乐的功能(将前端的数据发送给后端处理)
ser.add_music(filenames)
if __name__=="__main__":
# 获取用户名和密码
uname = input("请输入用户名:")
password = input("请输入密码:")
# 创建Music类的实例对象
ser = Music()
# 利用实例对象调用实例方法(由于会返回布尔值,所以直接进行判断)
if ser.login(uname,password):
Ui()
else:
print("用户名或密码错误!")
问题2:报错说数据库已经关闭。
问题分析:在获取音乐id时,我们通过重构工具类中dml函数使其返回新加的id,但执行完sql语句并提交事务后就返回了数据,返回数据后就直接运行了finally中关闭数据库的语句。
解决办法:重新链接一下数据库即可。
def add_music(self,files:tuple[str]) -> None:
"""
该函数用于将前台返回的文件路径存储到数据库中
:param file:音乐文件的路径,默认是多个,元素类型为字符串
:return: None
"""
# 编写sql语句
sql = "insert into music_info(name,path) values(%s,%s)"
# 遍历数据
for f in files:
print(f)
# 根据路径获取歌曲名
name = f[f.rfind("/")+1:f.rfind(".")]
print(name)
# 创建数据库链接对象
db = DBUtil()
# 准备参数
args=(name,f)
# 将音乐信息添加到music_info表中
m_id = db.dml_back_id(sql,args)
# 上一句调用的函数中由于需要执行return语句,所以会直接执行finally语句中关闭数据库的操作,因此需要重新链接数据库
db = DBUtil()
# 实现音乐与用户绑定
musicBindId_sql = "insert into play_info(u_id,m_id) values(%s,%s)"
args=(self.user[0],m_id)
db.dml(musicBindId_sql,args)
完整service.py文件内容如下:
from tools import DBUtil
class Music:
def __init__(self):
# 用户默认为空
self.user = None
def login(self, uname: str, password: str) -> bool:
"""
:param uname:用户名
:param password:密码
:return: 登录成功返回True,登录失败返回False
"""
# 准备要执行的sql语句
sql = "select * from user_info where uname=%s and password=%s"
# 准备sql语句需要的参数
args = (uname, password)
# 创建工具对象(实际时获取数据库的链接对象和游标对象)
db = DBUtil()
# 利用游标对象调用对应的单条查询方法
re = db.query_one(sql, args)
# 由于query_one函数运行成功后是有返回值的,可以通过返回值判断是否查询成功,进而判断是否有该用户
if re:
print("登录成功")
self.user=re
# 查看内容是否包含u_id对应的内容
print(self.user)
print(self.user[0])
return True
else:
print("登录失败")
return False
def add_music(self,files:tuple[str]) -> None:
"""
该函数用于将前台返回的文件路径存储到数据库中
:param file:音乐文件的路径,默认是多个,元素类型为字符串
:return: None
"""
# 编写sql语句
sql = "insert into music_info(name,path) values(%s,%s)"
# 遍历数据
for f in files:
print(f)
# 根据路径获取歌曲名
name = f[f.rfind("/")+1:f.rfind(".")]
print(name)
# 创建数据库链接对象
db = DBUtil()
# 准备参数
args=(name,f)
# 将音乐信息添加到music_info表中
m_id = db.dml_back_id(sql,args)
# 上一句调用的函数中由于需要执行return语句,所以会直接执行finally语句中关闭数据库的操作,因此需要重新链接数据库
db = DBUtil()
# 实现音乐与用户绑定
musicBindId_sql = "insert into play_info(u_id,m_id) values(%s,%s)"
args=(self.user[0],m_id)
db.dml(musicBindId_sql,args)
# 测试代码
if __name__ == "__main__":
# 创建Music类的实例对象
service = Music()
# 利用实例对象调用实例方法
re = service.login("muxikeqi", "123321")
print(re)
完整ui.py文件内容如下:
import tkinter
from service import Music
import tkinter.filedialog
class Ui:
def __init__(self):
# 主窗口
top = tkinter.Tk()
# 创建按钮对象,第一个参数是父容器,text表示显示的内容
b1 = tkinter.Button(top, text="播放")
b2 = tkinter.Button(top, text="导入音乐")
b3 = tkinter.Button(top, text="删除音乐")
# 设置按钮显示位置(row表示放在哪一行,column表示放在哪一列,pad表示距离边框的内边距,单位为像素)
b1.grid(row=1,column=1,padx=10,pady=10)
b2.grid(row=1,column=2,padx=10,pady=10)
b3.grid(row=1,column=3,padx=10,pady=10)
# 为导入音乐的按钮添加点击事件,bind方法的第一个参数是事件名称,第二个参数是点击事件(点击按钮后触发的函数)
b2.bind("<Button-1>",self.importMusic)
# 创建播放列表
lisbox = tkinter.Listbox(top)
# 设置播放列表位置,columnspan表示垮了多少列
lisbox.grid(row=2,column=0,columnspan=4,padx=10,pady=10)
# 进入消息循环
top.mainloop()
# 导入音乐的点击事件
def importMusic(self,event):
# 弹出选择框(返回的结果是元组)(一定要通过filetypes限制文件类型,否则什么文件都能加入进来)
filenames = tkinter.filedialog.askopenfilenames(filetypes=[("mp3",".mp3"),("flac",".flac"),("mgg",".mgg")])
# 创建服务对象(这里如果不干掉,绑定用户和音乐时就拿不到u_id,因为创建了两个实例对象)
# ser = Music()
# 调用增加音乐的功能(将前端的数据发送给后端处理)
ser.add_music(filenames)
if __name__=="__main__":
# 获取用户名和密码
uname = input("请输入用户名:")
password = input("请输入密码:")
# 创建Music类的实例对象
ser = Music()
# 利用实例对象调用实例方法(由于会返回布尔值,所以直接进行判断)
if ser.login(uname,password):
ui=Ui()
else:
print("用户名或密码错误!")
运行结果如下:
运行后的play_info表数据如下:
8、实现加载播放列表
概述:为了后续顺利的完成功能开发,先通过navicat的查询窗口尝试写出一个查询语句,通过play_info表的u_id找出其对应的音乐名(即music_info表中m_id对应的name)(既然涉及到两个表之间不相关列的查询就可以考虑sql99标准下的左(右)外连接查询)。
SELECT name FROM play_info p LEFT JOIN music_info m ON p.m_id=m.id WHERE u_id=1;
运行结果如下:
接下来为后端的service.py文件添加一个函数用于查询用户对应的歌曲列表。
def find_user_music(self) -> list[str]:
"""
本函数用于查询特定用户id对应的音乐列表
"""
# 准备sql语句(前面已经准备好了)
sql = "SELECT name FROM play_info p LEFT JOIN music_info m ON p.m_id=m.id WHERE u_id=%s;"
# 创建工具类对象
db = DBUtil();
# 执行sql语句(这里使用和上一章同样的方法获取用户id)
music_list = db.query_many(sql,self.user[0])
# 将结果返回
return music_list
然后参考菜鸟教程中关于Tkinter的教程,了解添加列表的玩法:
最后,为前端的ui.py文件调用find_user_music函数,只要有歌曲被添加或进入窗口都会显示该用户对应的歌曲列表。
import tkinter
from service import Music
import tkinter.filedialog
class Ui:
def __init__(self):
# 主窗口
top = tkinter.Tk()
# 创建按钮对象,第一个参数是父容器,text表示显示的内容
b1 = tkinter.Button(top, text="播放")
b2 = tkinter.Button(top, text="导入音乐")
b3 = tkinter.Button(top, text="删除音乐")
# 设置按钮显示位置(row表示放在哪一行,column表示放在哪一列,pad表示距离边框的内边距,单位为像素)
b1.grid(row=1,column=1,padx=10,pady=10)
b2.grid(row=1,column=2,padx=10,pady=10)
b3.grid(row=1,column=3,padx=10,pady=10)
# 为导入音乐的按钮添加点击事件,bind方法的第一个参数是事件名称,第二个参数是点击事件(点击按钮后触发的函数)
b2.bind("<Button-1>",self.importMusic)
# 创建播放列表(为了让importMusic函数能够使用,所有为变量传入了对象self)
self.lisbox = tkinter.Listbox(top)
# 设置播放列表位置,columnspan表示垮了多少列
self.lisbox.grid(row=2,column=0,columnspan=4,padx=10,pady=10)
self.music_list()
# 进入消息循环
top.mainloop()
# 导入音乐的点击事件
def importMusic(self,event):
# 弹出选择框(返回的结果是元组)(一定要通过filetypes限制文件类型,否则什么文件都能加入进来)
filenames = tkinter.filedialog.askopenfilenames(filetypes=[("mp3",".mp3"),("flac",".flac"),("mgg",".mgg")])
# 创建服务对象(这里如果不干掉,绑定用户和音乐时就拿不到u_id,因为创建了两个实例对象)
# ser = Music()
# 调用增加音乐的功能(将前端的数据发送给后端处理)
ser.add_music(filenames)
# 获取用户的音乐列表
self.music_list()
def music_list(self) -> list[str]:
# 调用获取列表的函数
m_lis = ser.find_user_music()
print(m_lis)
for m in m_lis:
self.lisbox.insert(0, m[0])
if __name__=="__main__":
# 获取用户名和密码
uname = input("请输入用户名:")
password = input("请输入密码:")
# 创建Music类的实例对象
ser = Music()
# 利用实例对象调用实例方法(由于会返回布尔值,所以直接进行判断)
if ser.login(uname,password):
ui=Ui()
else:
print("用户名或密码错误!")
运行后的窗口显示如下:
运行结果如下:
9、实现通过列表播放音乐
概述:本章就做两件事,首先确定用户点击的是列表中哪一首歌曲,其次,用户点击播放按钮后能播放对应的歌曲。
9.1、前端获取歌名
①、首先为播放按钮添加点击事件
b1.bind("<ButtonRelease-1>", self.play_music)
②、书写对应的点击事件
def play_music(self,event):
# 获取当前列表中选中音乐的索引
index = self.lisbox.curselection()
# 根据索引索取音乐的名称
music_name = self.lisbox.get(index)
print(music_name)
运行程序后,点击列表中的任意歌曲再点击播放就能顺利的打印歌曲信息,此时,已经正确地拿到了音乐名。
9.2、后端逻辑实现
①、将获取的歌曲名传给后端service.py文件中play_music函数
def play_music(self,event):
# 获取当前列表中选中音乐的索引
index = self.lisbox.curselection()
# 根据索引索取音乐的名称
music_name = self.lisbox.get(index)
# print(music_name)
# 将音乐名称传递给服务对象
ser.play_music(music_name)
②、实现play_music函数中的sql语句(这里采用左外连接,关联了music_info表和play_info表,关联的字段是m表的id和p表的m_id,条件同时限制p表中的用户名和m表的歌曲名)
select path from music_info m left join play_info p on m.id=p.m_id where m.name=%s and p.u_id=%s
③、补全play_music函数
def play_music(self,music_name:str) -> None:
"""
播放音乐
:param music_name:音乐名称
:return: None
"""
print("进入play_music函数")
# 编写sql
sql = "select path from music_info m left join play_info p on m.id=p.m_id where m.name=%s and p.u_id=%s;"
# 创建工具类(链接数据库)
db = DBUtil()
# 运行sql并将返回的结果保存到变量path中
args=(music_name,self.user[0])
path = db.query_one(sql,args)[0]
print(path)
print(len(path))
# 调用播放器播放音乐(拷贝play.py文件的代码)
# 初始化加载音乐的混合器
pygame.mixer.init()
# 加载音乐(路径可以是相对路径也可以是绝对路径)
pygame.mixer.music.load(path)
# 播放音乐
pygame.mixer.music.play()
运行结果如下:
注意:Pygame不支持播放.mgg格式的音乐文件。
9.3、修改bug
问题描述:只要点击了导入音乐,就会将重新获取的列表添加到旧列表的下面。
为ui.py文件中的music_list函数清空原有列表m_lis
def music_list(self) -> list[str]:
"""
本函数用于获取音乐列表
"""
# 调用获取列表的函数
m_lis = ser.find_user_music()
# 清空列表
self.lisbox.delete(0,tkinter.END)
# 重新加载列表
for m in m_lis:
self.lisbox.insert(0, m[0])
10、实现删除音乐
①、为ui.py文件中的删除按钮添加点击事件
b3.bind("<ButtonRelease-1>", self.delete_music)
②、实现点击事件
def delete_music(self,event):
"""
本函数用于删除用户指定的音乐
"""
# 获取当前列表中选中音乐的索引
index = self.lisbox.curselection()
# 根据索引索取音乐的名称
music_name = self.lisbox.get(index)
# 调用删除功能
ser.delete_music(music_name);
# 重新加载播放列表
self.music_list()
③、实现delete_music函数
def delete_music(self,music_name:str) -> None:
# 编写SQL
sql_query_m_id = "select m.id from music_info m left join play_info p on m.id=p.m_id where m.name=%s and p.u_id=%s;"
sql_delete_music = "delete from music_info where id=%s"
sql_delete_play = "delete from play_info where m_id=%s and u_id=%s"
# 创建工具类(链接数据库)
db = DBUtil()
args = (music_name, self.user[0])
# 运行sql
m_id = db.query_one(sql_query_m_id, args)[0]
# 准备参数
args2 = (m_id,self.user[0])
DBUtil().dml(sql_delete_play,args2)
# 注意:有外键约束的列,要先删除有外键关联列的数据,再删除其他数据
DBUtil().dml(sql_delete_music,m_id)
运行结果如下:
附件:完整文件源码(需要自己创建数据库和表)
完整工具类tools.py文件如下:
import pymysql
class DBUtil:
"""
工具类用于简化链接和关闭数据库的操作以及对数据的操作
"""
# 单独保存链接的参数,可以将其保存到特定文件中,直接调用文件获取也可
config = {
'host': "localhost",
'user': "root",
'passwd': "root",
'db': "db_music",
'charset': "utf8",
'port': 3306
}
def __init__(self) -> None:
"""
构造函数用于获取链接和游标
"""
# **指字典对象
self.con = pymysql.connect(**DBUtil.config)
self.cursor = self.con.cursor()
def close(self) -> None:
"""
该函数用于关闭链接和游标(关闭前需要判断是否存在)
"""
# 存在游标就关闭
if self.cursor:
self.cursor.close()
# 存在链接就关闭
if self.con:
self.con.close()
def dml(self, sql, args):
"""
本函数用于封装Mysql的DML语句,用于实现数据的增删改
"""
# 进行DML语句操作时一定要注意报错导致无法正常关闭链接
try:
# 执行sql中的DML语句
self.cursor.execute(sql, args)
# DML操作一定要通过链接对象提交事务
self.con.commit()
except Exception as e:
print("存在错误,错误信息如下:", e)
# 回滚前先判断链接还是否存在
if self.con:
# 回滚到原状态
self.con.rollback()
# 使用try...except...finally...最重要的作用就是保证链接正常关闭
finally:
print("即将关闭链接")
self.close()
# 重写上面的dml函数,增加返回id的操作
def dml_back_id(self, sql, args):
"""
本函数用于封装Mysql的DML语句,用于实现数据的增删改
"""
# 进行DML语句操作时一定要注意报错导致无法正常关闭链接
try:
# 执行sql中的DML语句
self.cursor.execute(sql, args)
# 获取添加的id
id = self.con.insert_id()
print(id)
# DML操作一定要通过链接对象提交事务
self.con.commit()
# 返回id
return id
except Exception as e:
print("存在错误,错误信息如下:", e)
# 回滚前先判断链接还是否存在
if self.con:
# 回滚到原状态
self.con.rollback()
# 使用try...except...finally...最重要的作用就是保证链接正常关闭
finally:
print("即将关闭链接")
self.close()
def query_one(self, sql, args):
"""
本函数用于查询单条数据
"""
try:
self.cursor.execute(sql, args)
re = self.cursor.fetchone()
return re
except Exception as e:
print("存在错误,错误信息如下:", e)
finally:
print("即将关闭链接")
self.close()
def query_many(self, sql, args):
"""
本函数用于查询所有数据
"""
try:
self.cursor.execute(sql,args)
# 获取结果并返回数据
return self.cursor.fetchall()
except Exception as e:
print("存在错误,错误信息如下:", e)
finally:
print("即将关闭链接")
self.close()
if __name__ == "__main__":
# # 获取链接对象
# db = DBUtil()
# # 准备sql语句及其对应的参数
# sql = "select * from user_info where uname=%s and password=%s;"
# args =["muxikeqi","123321"]
# # 运行sql语句并关闭链接
# re = db.query_one(sql,args)
# print(re)
pass
完整play.py文件如下:
import pygame
import time
# 初始化加载音乐的混合器
pygame.mixer.init()
# 加载音乐(路径可以是相对路径也可以是绝对路径)
pygame.mixer.music.load(f".\music\c.flac")
# 播放音乐
pygame.mixer.music.play()
# 程序进入等待(不要立即关闭程序),单位为秒
time. Sleep(20)
完整ui.py文件内容如下:
# import tkinter
from tkinter import *
from service import Music
import tkinter.filedialog
class Ui:
def __init__(self):
# 主窗口
top = tkinter.Tk()
# top.withdraw()
# 创建按钮对象,第一个参数是父容器,text表示显示的内容
b1 = tkinter.Button(top, text="播放")
b2 = tkinter.Button(top, text="导入音乐")
b3 = tkinter.Button(top, text="删除音乐")
# 设置按钮显示位置(row表示放在哪一行,column表示放在哪一列,pad表示距离边框的内边距,单位为像素)
b1.grid(row=0,column=1,padx=10,pady=10)
b2.grid(row=0,column=2,padx=10,pady=10)
b3.grid(row=0,column=3,padx=10,pady=10)
# 为导入音乐的按钮添加点击事件,bind方法的第一个参数是事件名称,第二个参数是点击事件(点击按钮后触发的函数)
b2.bind("<ButtonRelease-1>",self.importMusic)
# ButtonRelease表示点击并释放了(第一个参数写法固定,不要更改)
b1.bind("<ButtonRelease-1>", self.play_music)
b3.bind("<ButtonRelease-1>", self.delete_music)
# 创建播放列表(为了让importMusic函数能够使用,所有为变量传入了对象self)
self.lisbox = tkinter.Listbox(top)
# 设置播放列表位置,columnspan表示垮了多少列
self.lisbox.grid(row=1,column=0,columnspan=4,padx=5,pady=5)
self.music_list()
# 进入消息循环
top.mainloop()
# 导入音乐的点击事件
def importMusic(self,event):
# 弹出选择框(返回的结果是元组)(一定要通过filetypes限制文件类型,否则什么文件都能加入进来)
filenames = tkinter.filedialog.askopenfilenames(filetypes=[("mp3",".mp3"),("flac",".flac")])
# 创建服务对象(这里如果不干掉,绑定用户和音乐时就拿不到u_id,因为创建了两个实例对象)
# ser = Music()
# 调用增加音乐的功能(将前端的数据发送给后端处理)
ser.add_music(filenames)
# 获取用户的音乐列表
self.music_list()
def music_list(self) -> list[str]:
"""
本函数用于获取音乐列表
"""
# 调用获取列表的函数
m_lis = ser.find_user_music()
# 清空列表
self.lisbox.delete(0,tkinter.END)
# 重新加载列表
for m in m_lis:
self.lisbox.insert(0, m[0])
def play_music(self,event):
# 获取当前列表中选中音乐的索引
index = self.lisbox.curselection()
# 根据索引索取音乐的名称
music_name = self.lisbox.get(index)
# 将音乐名称传递给服务对象
ser.play_music(music_name)
def delete_music(self,event):
"""
本函数用于删除用户指定的音乐
"""
# 获取当前列表中选中音乐的索引
index = self.lisbox.curselection()
# 根据索引索取音乐的名称
music_name = self.lisbox.get(index)
# 调用删除功能
ser.delete_music(music_name);
# 重新加载播放列表
self.music_list()
if __name__=="__main__":
# 获取用户名和密码
uname = input("请输入用户名:")
password = input("请输入密码:")
# 创建Music类的实例对象
ser = Music()
# 利用实例对象调用实例方法(由于会返回布尔值,所以直接进行判断)
if ser.login(uname,password):
ui=Ui()
else:
print("用户名或密码错误!")
完整service.py文件如下:
from tools import DBUtil
import pygame
class Music:
def __init__(self):
# 用户默认为空
self.user = None
def login(self, uname: str, password: str) -> bool:
"""
:param uname:用户名
:param password:密码
:return: 登录成功返回True,登录失败返回False
"""
# 准备要执行的sql语句
sql = "select * from user_info where uname=%s and password=%s"
# 准备sql语句需要的参数
args = (uname, password)
# 创建工具对象(实际时获取数据库的链接对象和游标对象)
db = DBUtil()
# 利用游标对象调用对应的单条查询方法
re = db.query_one(sql, args)
# 由于query_one函数运行成功后是有返回值的,可以通过返回值判断是否查询成功,进而判断是否有该用户
if re:
print("登录成功")
self.user=re
# 查看内容是否包含u_id对应的内容
# print(self.user)
# print(self.user[0])
return True
else:
print("登录失败")
return False
def add_music(self,files:tuple[str]) -> None:
"""
该函数用于将前台返回的文件路径存储到数据库中
:param file:音乐文件的路径,默认是多个,元素类型为字符串
:return: None
"""
# 编写sql语句
sql = "insert into music_info(name,path) values(%s,%s)"
# 遍历数据
for f in files:
# 根据路径获取歌曲名
name = f[f.rfind("/")+1:f.rfind(".")]
# 创建数据库链接对象
db = DBUtil()
# 准备参数
args=(name,f)
# 将音乐信息添加到music_info表中
m_id = db.dml_back_id(sql,args)
# 上一句调用的函数中由于需要执行return语句,所以会直接执行finally语句中关闭数据库的操作,因此需要重新链接数据库
db = DBUtil()
# 实现音乐与用户绑定
musicBindId_sql = "insert into play_info(u_id,m_id) values(%s,%s)"
args=(self.user[0],m_id)
db.dml(musicBindId_sql,args)
def find_user_music(self) -> list[str]:
"""
本函数用于查询特定用户id对应的音乐列表
"""
# 准备sql语句(前面已经准备好了)
sql = "SELECT name FROM play_info p LEFT JOIN music_info m ON p.m_id=m.id WHERE u_id=%s;"
# 创建工具类对象
db = DBUtil();
# 执行sql语句(这里使用和上一章同样的方法获取用户id)
music_list = db.query_many(sql,self.user[0])
# 将结果返回
return music_list
def play_music(self,music_name:str) -> None:
"""
播放音乐
:param music_name:音乐名称
:return: None
"""
# 编写sql
sql = "select path from music_info m left join play_info p on m.id=p.m_id where m.name=%s and p.u_id=%s;"
# 创建工具类(链接数据库)
db = DBUtil()
args=(music_name,self.user[0])
# 运行sql并将返回的结果保存到变量path中
path = db.query_one(sql,args)[0]
# 调用播放器播放音乐(拷贝play.py文件的代码)
# 初始化加载音乐的混合器
pygame.mixer.init()
# 加载音乐(路径可以是相对路径也可以是绝对路径)
pygame.mixer.music.load(path)
# 播放音乐
pygame.mixer.music.play()
def delete_music(self,music_name:str) -> None:
# 编写SQL
sql_query_m_id = "select m.id from music_info m left join play_info p on m.id=p.m_id where m.name=%s and p.u_id=%s;"
sql_delete_music = "delete from music_info where id=%s"
sql_delete_play = "delete from play_info where m_id=%s and u_id=%s"
# 创建工具类(链接数据库)
db = DBUtil()
args = (music_name, self.user[0])
# 运行sql
m_id = db.query_one(sql_query_m_id, args)[0]
# 准备参数
args2 = (m_id,self.user[0])
DBUtil().dml(sql_delete_play,args2)
# 注意:有外键约束的列,要先删除有外键关联列的数据,再删除其他数据
DBUtil().dml(sql_delete_music,m_id)
# 测试代码
if __name__ == "__main__":
# 创建Music类的实例对象
service = Music()
# 利用实例对象调用实例方法
re = service.login("muxikeqi", "123321")
print(re)