微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

python操作sql

from pyMysqL import connect


class JD(object):
    def __init__(self):
        # 创建connect连接
        self.conn = connect(host='127.0.0.1',port=3306,user='root',password='123456',database='jing_dong',charset='utf8')
        # 获得cursor对象
        self.cursor = self.conn.cursor()

    def __del__(self):
        # 关闭corser对象
        self.cursor.close()
        self.conn.close()

    def execute_sql(self,sql):
        self.cursor.execute(sql)
        for temp in self.cursor.fetchall():
            print(temp)

    def show_all_item(self):
        """显示所有商品"""
        sql = 'SELECT * FROM goods'
        self.execute_sql(sql)

    def show_cates(self):
        """显示所有商品"""
        sql = 'SELECT name FROM goods_cates'
        self.execute_sql(sql)

    def show_brand(self):
        """显示所有的商品的品牌分类"""
        sql = 'SELECT name FROM goods_brand'
        self.execute_sql(sql)

    @staticmethod
    def print_menu():
        print('-----京东-----')
        print('1.所有的商品')
        print('2.所有的商品的分类')
        print('3.所有的商品的品牌分类')
        return input('请输入功能对应的序号: ')

    def run(self):
        while True:
            op = self.print_menu()
            if op == '1':
                # 查询所有商品
                self.show_all_item()
            elif op == '2':
                # 查询所有的商品的分类
                self.show_cates()
            elif op == '3':
                # 查询所有的商品的品牌分类
                self.show_brand()
            else:
                print('输入有误,请重新输入...')


def main():
    # 1.创建一个JD对象
    jd = JD()
    # 2.调用JD对象的run方法
    jd.run()


if __name__ == '__main__':
    main()

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。

相关推荐