數據庫中pymysql模塊的使用

pymysql 模塊

使用步驟:mysql

  核心類Connect連接用和Cursor讀寫用sql

  1. 與數據庫服務器創建連接數據庫

  2. 獲取遊標對象(用於發送和接收數據)服務器

  3. 用遊標執行sql語句ide

  4. 使用fetch 方法來獲取執行的結果fetch

  5. 關閉連接 ,先關閉遊標,再關連接編碼

遊標的經常使用方法:spa

  1.建立遊標 conn.cursor(指定查詢結果的數據類型)code

  2.excute 執行sql對象

  3. fetchone(當sql只有一條記錄時) many(sql有多條而且須要指定條數) all(多條)

  4.scroll  用於修改遊標的當前位置。

  注意:pymysql  默認不提交修改,可是注意(指的是對錶中記錄的操做不提交),像刪除庫和刪除表是沒法撤銷的。

""" # 建立連接獲得一個連接對象 conn = pymysql.Connect( host="127.0.0.1", # 數據庫服務器主機地址 user="root", # 用戶名 password="admin", # 密碼 database="day42", #數據庫名稱 port=3306, # 端口號 可選 整型 charset="utf8" # 編碼 可選 ) # 獲取遊標對象 pymysql.cursors.DictCursor指定 返回的結果類型 爲字典 默認是元祖類型 cursor = conn.cursor(pymysql.cursors.DictCursor) # 查詢數據 sql = "select *from emp" # 執行sql 若是是select 語句返回的是 查詢的條數 res = cursor.execute(sql) print(res) # 獲取查詢的結果 # print(cursor.fetchall()) # print(cursor.fetchone()) # print(cursor.fetchone()) # print(cursor.fetchmany(1)) # print(cursor.fetchall()) # scroll print(cursor.fetchone()) cursor.scroll(-1) print(cursor.fetchall()) # 關閉連接 cursor.close() conn.close()

添加,刪除數據庫中的內容

import pymysql # 建立連接獲得一個連接對象
conn = pymysql.Connect( host="127.0.0.1",    # 數據庫服務器主機地址
    user="root",  # 用戶名
    password="admin", # 密碼
    database="day42", #數據庫名稱
    port=3306, # 端口號 可選 整型
    charset="utf8" # 編碼 可選
) # 獲取遊標對象 pymysql.cursors.DictCursor指定 返回的結果類型 爲字典 默認是元祖類型
cursor = conn.cursor(pymysql.cursors.DictCursor) # # 添加數據 # res = cursor.execute("insert into emp values(100,'胡歌','男',30,1,'job',60000)") # if res: # print("插入成功") # else: # print("插入失敗")


# 提交修改 由於pymysql 模塊默認是啓用事務的 你的sql語句 若是不提交 至關於沒有執行

# conn.commit() # res = cursor.execute("drop database day42")


# res = cursor.execute("delete from t1 where id = 1") # print(res)

try: cursor.execute("update moneyTable set money = money - 50 where name = '小明'") #若是小花的帳戶出問題了 沒法更新數據 那就須要回滾
    cursor.execute("update moneyTable set money = money + 50 where name = '小花'") conn.commit() except: conn.rollback() cursor.close() conn.close() # 小明有100塊 準備給小花轉50 # update moneyTable set money = money - 50 where name = "小明"; # 發生一些別錯誤 若是發生了錯誤 就執行撤銷操做 rollback; # update moneyTable set money = money + 50 where name = "小花";
View Code
相關文章
相關標籤/搜索