第十节 python操作sql查询数据

import pymysql

'''
    print(cursor.fetchone())
    # 有点类似next，前面取过了后面就调用就不会从头开始取了
    print(cursor.fetchmany(2))
    print(cursor.fetchall())
    conn = pymysql.connect(host='localhost', port='3306', user='root', password='', database='python_test', charset='utf8') 
'''
class JD():

    def __init__(self):
        self.conn = pymysql.connect('localhost','root','','python_test')
        self.cursor = self.conn.cursor()
        # cursor.close()
        # conn.close()
        # cursor.execute('select * from tdb_goods')

    def sql_exe(self,sql):
        self.cursor.execute(sql)
        ret = self.cursor.fetchall()
        return ret

    def show_all_item(self):
        for temp in self.sql_exe('select * from tdb_goods'):
            print(temp)

    def show_goods_cate(self):
        for temp in self.sql_exe('select * from goods_cate'):
            print(temp)

    def show_brand_name(self):
        for temp in self.sql_exe('select * from brand_name'):
            print(temp)

    @staticmethod
    def mue():
        print("......京东商城......")
        print('1:所有的商品')
        print('2：所有商品的分类')
        print('3:所有的商品品牌分类')
        print('0:关闭商城')
        return input('请输入功能相对于的序号:')

    def run(self):
        while True:
            num = self.mue()
            if num == '1':
                self.show_all_item()
            elif num == '2':
                self.show_goods_cate()
            elif num == '3':
                self.show_brand_name()
            elif num == '0':
                break
            else:
                print('输入有误，请重新输入....')
        self.cursor.close()
        self.conn.close()


def main():
    jd = JD()
    jd.run()


if __name__ == '__main__':
    main()