pymysql模塊

pymysql是一個連接mysql數據庫的第三方模塊，可作為連接mysql數據庫的客戶端，對數據庫進行增刪改查操作

# 下載第三方模塊：pip3 install pymysql

如何連接數據庫并對數據庫進行操作：

import pymysql # 連接mysql數據庫的模塊# 1.連接數據庫'''需要傳入的參數： host=None, user=None, password='', database=None, port=0, charset=’’, autocommit=True'''client = pymysql.connect( host='127.0.0.1', port=3306, user='root', password='123', database='test', charset=’utf8’, # 一定不要寫utf-8 # 針對增刪改操作，執行重要程度高，若要執行，必須要有一步確認的操作，autocommit=True默認對數據庫進行增刪改操作時自動提交至數據庫；若此處不寫，在下面代碼 cursor_obj.execute(sql) 后面手動需要添加 client.commit()操作 autocommit=True)# print(client) # 打印結果：<pymysql.connections.Connection object at 0x00000000028A8B88># 2.獲取游標對象。游標：可以用來提交sql命令# pymysql.cursors.DictCursor：將查詢出來的結果制作成字典的形式返回cursor_obj = client.cursor(pymysql.cursors.DictCursor)# 3.通過execute可以提交sql語句(增刪改查都可以，可以使用try來捕獲異常)try: # 1.1）查數據 sql = 'select * from books' # 不用寫分號 # 1.2）插入數據 # sql = 'insert into student(id, name, sex, birthday, class) values(’110’, ’張芳’, ’男’, ’1946’, ’95030’)' # 不用寫分號 # 2）提交sql語句 res = cursor_obj.execute(sql) # print(res) # execute返回的是當前sql語句所影響的行數 # client.commit() # 上面連接數據庫的代碼處已寫了autocommit=True，此處注釋掉 # 3.1）提交后，通過cursor_obj對象.fetchall() 獲取所有查詢到的結果 data = cursor_obj.fetchall() for i in data: print(i) # 3.2）.fetchone() 只獲取查詢結果中的一條 # print(cursor_obj.fetchone()) # 3.3）.fetchmany() 可以指定獲取幾條數據 # print(cursor_obj.fetchmany(4)) # 獲取四條數據except Exception as e: print(e)# 關閉游標cursor_obj.close()# 關閉客戶端連接client.close()

執行結果（以下為我本地數據庫的數據）：

{’BookID’: 11425, ’BookTitle’: ’Python’, ’Copyright’: 1984}{’BookID’: 12786, ’BookTitle’: ’Java’, ’Copyright’: 1934}{’BookID’: 13331, ’BookTitle’: ’MySQL’, ’Copyright’: 1919}{’BookID’: 14356, ’BookTitle’: ’PHP’, ’Copyright’: 1966}{’BookID’: 15729, ’BookTitle’: ’PERL’, ’Copyright’: 1932}{’BookID’: 16284, ’BookTitle’: ’Oracle’, ’Copyright’: 1996}

以上就是pymysql模塊使用簡介與示例的詳細內容，更多關于pymysql模塊的資料請關注好吧啦網其它相關文章！