python操作mysql 数据查询

安装pymysql模块：pip install pymysq

 

from pymysql import *

def main():
    # 第一步 创建connect连接
    conn = connect(host="localhost",port=3306,user="root",password="",database="jing_dong",charset="utf8")
    # 第二部获取cursor对象（游标对象）
    cs1 = conn.cursor()
 8     

　　　　中间是自由操作，上面两句和下面两句是必须创建的，通过execute执行mysql语句：
　　　cs1.execute('select * from jing_dong')
　　　如果是一个查询语句，查询结果就保存在游标对象中，用fetch*获取
　　　cs1.fetch* 取得查询返回数据 fetch有几种：
　　　fetchone()、fetchmany()、fetchall()
　　　fetchone()每次返回一条记录，以元组的形式，fetchmany()是自定义返回记录数目，返回的每一个元组包含在一个大元组中
　　　获取记录时，无论用什么fetch，获取记录就像读取文件那个指针一样，第二次执行，会接着上一次fetch结束的位置开始，当把所有
　　　记录获取之后，再fetch就获取不到记录了


    #g关闭cursor对象
    cs1.close()
    conn.close()


if __name__ == "__main__":
    main()

 

下面是一个查询示例：

from pymysql import *

def main():
    # 创建connect连接
    conn = connect(host="localhost",port=3306,user="root",password="",database="jing_dong",charset="utf8")
    #获取cursor对象
    cs1 = conn.cursor()

    # count 返回的是表的行数，查询结果保存在游标对象cs1中
    count = cs1.execute("select * from goods")

    for i in range(count):
        print(cs1.fetchone())


    #g关闭cursor对象
    cs1.close()
    conn.close()


if __name__ == "__main__":
    main()

 

下面又是一个代码演练：

from pymysql import connect

class JD(object):
    def __init__(self):
        self.conn = connect(host="localhost",port=3306,user="root",password="",database="jing_dong",charset="utf8")
        self.cs1 = self.conn.cursor()

    @staticmethod
    def print_msg():
        print("-------JING DONG---------")
        print("1 查询所有数据")
        print("2、查询所有品牌")
        print("3、查询所有分类")
        return input("请选择：")
　　 
　　　　#当程序死掉的时候会自动调用此方法
    def __del__(self):
        self.cs1.close()
        self.conn.close()

    def exe_sql(self,sql):
        self.cs1.execute(sql)
        for i in self.cs1.fetchall():
            print(i)

    def show_cate(self):
        sql = "select name from goods_cates"
        self.exe_sql(sql)

    def show_brand(self):
        sql = "select name from goods_brands"
        self.exe_sql(sql)

    def show_all(self):
        sql = "select * from goods"
        self.exe_sql(sql)

    def run(self):
        while True:
            num = self.print_msg()
            if num == "1":
                self.show_all()
            elif num == "2":
                self.show_brand()
            elif num == "3":
                self.show_cate()
            else:
                print("wrong input...try again....")

def main():
    jd = JD()
    jd.run()
if __name__ == "__main__":
    main()