from music_project.dbutil import dbutil

class Myservice:

    def myuser(self):
        self.user = None

    def login(self,uname,password):
        sql = "select * from t_user where uname=%s and password=%s"
        user = dbutil().query_one(sql,uname,password)
        if user:
            self.user = user
            return True
        else:
            return False
    # 添加音乐的方法，有可能是一首，有可能是多首，所以可以进行遍历
    def add_music(self,files):
        for f in files:
            start = f.rfind(r"/")+1
            end = f.rfind(".mp3")
            music_name = f[start:end]
            print(music_name)
            # # 查询歌曲是否已经存在进行判断
            sql = 'select * from t_music where music_name = %s'
            music = dbutil.query_one(sql,music_name)
            if music:
                # 查询关联表t_list是否已经存在歌曲
                sql = "select * from t_list where uid = %s and mid = %s"
                t_list = dbutil().query_one(sql,self.user[0],music[0])
                if not t_list:
                    sql = 'insert into t_list(mid,uid) values(%s,%s)'
                    dbutil.DMLsql(sql,music[0],self.user[0])
            else:
                # 将音乐保存到t_musict表中
                sql = 'insert into t_music(music_name,path) values(%s,%s)'
                mid = dbutil().DMLsql(sql, music_name, f)
                # 用户选择的音乐保存到t_list
                sql = 'insert into t_list(mid,uid) values(%s,%s)'
                dbutil().DMLsql(sql, mid, self.user[0])

老师，请问下，我在执行到进行判断添加的歌曲是否已经存在数据库中的这一步，出现这个错误代码，是怎么回事

老师没有管理员权限咋办用管理员权限打开也不行

老师，这是怎么回事，我电脑里面现在没有数据库吗

这节课视频无法观看，反复刷新或重新登录都不行

import  numpy as np
import pymysql
 
def insertData(numpy_bytes,shape_str):
    db = pymysql.connect(host="localhost", user="root", password="19950127", db="test", port=3306)
    #连接数据库对象
 
    cur = db.cursor()
    #游标对象
 
    sql = "insert into face_data(numpy_data,shape) values(%s,%s)"
    #定义好sql语句，%s是字符串的占位符
 
    try:
        cur.execute(sql,(numpy_bytes,shape_str))
        #执行sql语句
        db.commit()
        #提交到数据库中
    except Exception as e:
        #捕获异常
        raise e
    finally:
        db.close()  # 关闭连接

def upData(numpy_bytes,shape_str):    
    db = pymysql.connect(host="localhost", user="root", password="19950127", db="test", port=3306)
    #连接数据库对象
     
    # 使用cursor()方法获取操作游标
    cur = db.cursor()
     
    sql_update1 ="update face_data set numpy_data = %s where id = %d"
    sql_update2 ="update face_data set shape = %s where id = %d"
    try:
        cur.execute(sql_update2 % (shape_str,12))  #像sql语句传递参数
    	cur.execute(sql_update1 % (numpy_bytes,12))  #像sql语句传递参数
    	#提交
    	db.commit()
    except Exception as e:
    	#错误回滚
    	db.rollback() 
    finally:
    	db.close()
        
    

def readData():
    db = pymysql.connect(host="localhost", user="root", password="19950127", db="test", port=3306)
    #连接数据库对象
 
    cur = db.cursor()
    #游标对象
 
    sql = "select * from face_data"
    #定义好sql语句，%s是字符串的占位符
 
    try:
        cur.execute(sql)
        #执行sql语句
        results = cur.fetchall()
        #获取所有结果集
        for row in results:
            numArr = np.fromstring(string=row[1], dtype=int)
            #将读取到的字节流转化为ndarray数组
 
            shape = tuple(eval(row[2]))
            #将读取到的shape转换为元组的格式，这里的eval（），由于我们元组里面的数据是int的所以，这里eval（）的作用就是把本该是数字的转化回来
            numArr.shape = shape
            #设置维度，设置的数值为元组
            print(numArr)
        db.commit()
        #提交到数据库中
    except Exception as e:
        #捕获异常
        raise e
    finally:
        db.close()  # 关闭连接
 
if __name__ == '__main__':
    arr =np.arange(5, 50).reshape(3,5,3)
    #生产0-45数字的维度=（3,5,3）的三维数组
 
    shape_ = arr.shape
    #获取数组的维度
 
    numpy_bytes = arr.tostring()
    #将数组转化为二进制流
 
    shape_str = "".join(str(shape_))
    #将shape元组转化为字符串
 
    #insertData(numpy_bytes, shape_str)
    #插入数据库
    upData(numpy_bytes, shape_str)
    #更新数据库
    readData()
    #读取数据库

老师您好，我想尝试着储存np数组。将数组转化为bytes格式的二进制流后，在插入和读取部分都没有问题，但是在更新数据库时遇到了很大的问题，是占位符不对吗？您能帮我看下吗，麻烦了！

老师，我们这个数据库好像没讲到索引最左前缀问题，这个我也查了资料看的不是很懂，你这边有什么通俗易懂的解释吗？

老师，这样子写应该也是没问题的吧，效果也是一样的。

老师，这里有两个“/”，怎么确定代码中的就是第二个“/”？

vscode默认路径“python”可以执行，设置成安装路径“C:\Program Files (x86)\Python36-32\”就会报错。

import pymysql
class MYdb:
    config = {
        "host":"localhost",
        "user":"root",
        "password":"123456",
        "db":"music_project",
        "charset":"utf8"
    }

    def __init__(self):
        self.connection = pymysql.connect(**MYdb.config)
        self.cursor = self.connection.cursor()
    def close(self):
        if self.cursor:
            self.cuesor.close()
        if self.connection:
            self.connection.close()

      #插入  修改  删除调用
    def exeDML(self,sql,*args):
        try:
         #执行sql
            count = self.cursor.execute(sql,args)
            #提交事务
            self.connection.commit()
            return count
        except Exception as e:
            print(e)
            if self.connection:
                self.connection.rollback()
        finally:
           self.close()

    def query_one(self,sql,*args):
        try:
           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:
           self.cursor.execute(sql,args)
           return self.cursor.fetchall()
        except Exception as e:
            print(e)
        finally:
            self.close()

if __name__ == "__main__":
    dbutil = MYdb()

from dbutil import MYdb
class MyService:
    def login(self,uname,password):
        sql = "select * from t_user where uname = %s and password = %s"
        user = MYdb().query_one(sql,uname,password)
        if user:
            return True
        else:
            return False

老师这块总是显示这个错误，跟着视频上的代码敲的，麻烦老师看看有什么问题？上次说不要建在子目录下，现在也改过来了。

老师，字段被隐藏起来，那怎样才能让他重新显示呢？

问题：老师为什么这里求最高平均月薪的时候必须要有别名，不取别名我就会报错。

# 查询平均月薪最高的部门的编号和平均月薪
# 1.每个部门平均月薪
select deptno,avg(sal) from emp group by deptno ;
# 2.最高平均月薪
select max(avg_sal)
from (select avg(sal) avg_sal,deptno from emp group by deptno) e_sal;

报错内容：

from dbutil import MYdb
class MyService:
    def login(self,uname,password):
        sql = "select * from t_user where uname = %s and password = %s"
        user = MYdb().query_one(sql,uname,password)
        if user:
            return True
        else:
            return False

老师，这块会显示导入错误，可是我是照着视频来的，是哪儿有误吗？麻烦老师帮忙看一下，看了很久没看出来

老师为啥我这个和视频里面 的不一样，不是说应该会报错吗，ename应该没法显示的，因为没法代表一整个部门呀（上面的图是视频里面的，下面的图是我自己的代码）