python3用pymysql連線mysql資料庫進行操作
阿新 • • 發佈:2018-12-25
原創文章,轉載請註明出處
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()