1. 程式人生 > >python3用pymysql連線mysql資料庫進行操作

python3用pymysql連線mysql資料庫進行操作

原創文章,轉載請註明出處

pymysql是python3特有的,python2沒有,只能用mysqldb

需提前建好資料庫和對應的表

第一步,安裝pymysql

pip install PyMySQL

第二步,資料庫連線及獲得遊標物件 cursor

# 開啟資料庫連線
db = pymysql.connect("localhost","root","123456","TESTDB" )
# 使用 cursor() 方法建立一個遊標物件 cursor
cursor = db.cursor()

connect的引數分別是(連線地址,資料庫使用者名稱,資料庫密碼,資料庫名稱,埠(預設3306可省略))

第三步,增刪改除了sql語句其它都一樣,即插入,更新,刪除的操作步驟是一樣的,只是對應的sql語句不同而已

# 插入操作的sql語句1
sql = """INSERT INTO EMPLOYEE(FIRST_NAME,
         LAST_NAME, AGE, SEX, INCOME)
         VALUES ('Bai', 'LI', 24, 'M', 9000)"""
也可以這樣寫
#插入操作的sql語句2
sql = "INSERT INTO EMPLOYEE(FIRST_NAME, \
       LAST_NAME, AGE, SEX, INCOME) \
       VALUES (%s, %s,  %s,  %s,  %s )" % \
       ('Bai', 'LI', 24, 'M', 9000)

#更新操作的sql語句
sql = "UPDATE EMPLOYEE SET AGE = AGE + 1 WHERE SEX = '%c'" % ('M')

#刪除操作的sql語句
sql = "DELETE FROM EMPLOYEE WHERE AGE > %s" % (24)

然後下面步驟是一樣的

try:
   # 執行sql語句
   cursor.execute(sql)
   # 提交到資料庫執行
   db.commit()
except:
   # 如果發生錯誤則回滾
   db.rollback()

第三步如果是查詢,跟增刪改不太一樣

# SQL 查詢語句
sql = "SELECT * FROM EMPLOYEE \
       WHERE INCOME > %s" % (9000)
try:
   # 執行SQL語句
   cursor.execute(sql)
   # 獲取所有記錄列表
   results = cursor.fetchall()
   for row in results:
      id= row[0]
      fname = row[1]
      income= row[4]
       # 列印結果
      print ("id=%s,fname=%s,income=%s" % \
             (id, fname, income ))
except:
   print ("Error: unable to fetch data")

補充:

        1、fetchone():獲取查詢結果的第1條資料
  2、fetchmany(n):獲取n條資料
  3、fetchall():獲取所有的資料
        4、rowcount: 這是一個只讀屬性,並返回執行execute()方法後影響的行數
        ##fetchmany(n)和fetchall()得到的結果一定是一個大元組套著小元組((),(),()...)

最後第四步也是都一樣也是最重要記得的,就是關閉資料庫連線

db.close()