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()