【Python3】pymysql模塊

Drummor 發(fā)布于2019-07-30 14:22 / 2062人閱讀

摘要：模塊什么是是在版本中用于連接服務(wù)器的一個(gè)庫(kù)，中則使用。遵循數(shù)據(jù)庫(kù)規(guī)范，并包含了客戶端庫(kù)。

【Python3】pymysql模塊 1. 什么是 PyMySQL？

PyMySQL 是在 Python3.x 版本中用于連接 MySQL 服務(wù)器的一個(gè)庫(kù)，Python2中則使用mysqldb。

PyMySQL 遵循 Python 數(shù)據(jù)庫(kù) API v2.0 規(guī)范，并包含了 pure-Python MySQL 客戶端庫(kù)。

2. PyMySQL 安裝

pip3 install PyMySQL

3. 使用操作

#!/usr/bin/env python
# -*- coding:utf-8 -*-
import pymysql
  
# 創(chuàng)建連接
conn = pymysql.connect(host="127.0.0.1", port=3306, user="root", passwd="123", db="t1")
# 創(chuàng)建游標(biāo)
cursor = conn.cursor()
  
# 執(zhí)行SQL，并返回收影響行數(shù)
effect_row = cursor.execute("update hosts set host = "1.1.1.2"")
  
# 執(zhí)行SQL，并返回受影響行數(shù)
#effect_row = cursor.execute("update hosts set host = "1.1.1.2" where nid > %s", (1,))
  
# 執(zhí)行SQL，并返回受影響行數(shù)
#effect_row = cursor.executemany("insert into hosts(host,color_id)values(%s,%s)", [("1.1.1.11",1),("1.1.1.11",2)])
  
  
# 提交，不然無(wú)法保存新建或者修改的數(shù)據(jù)
conn.commit()
  
# 關(guān)閉游標(biāo)
cursor.close()
# 關(guān)閉連接
conn.close()

注：當(dāng)使用字符串格式化時(shí)容易引起sql注入

sql = "select * from userinfo where username="%s" and password="%s" " %(user,pwd,)      #不推薦使用

sql = "select * from userinfo where username=%s and password=%s",[user,pwd]    #推薦使用，mysql會(huì)自動(dòng)格式化，避免SQL注入

import pymysql

user = input("請(qǐng)輸入用戶名:")
pwd = input("請(qǐng)輸入密碼:")

# 獲取數(shù)據(jù)
conn = pymysql.Connect(host="192.168.12.89",port=3306,user="root",password="123",database="s17day11db",charset="utf8")
cursor = conn.cursor()

v = cursor.execute("select * from userinfo where username=%s and password=%s",[user,pwd])
result = cursor.fetchone()
cursor.close()
conn.close()

print(result)

獲取新創(chuàng)建數(shù)據(jù)自增ID

new_class_id = cursor.lastrowid # 獲取新增數(shù)據(jù)自增ID
復(fù)制代碼
import pymysql

# 獲取數(shù)據(jù)
conn = pymysql.Connect(host="192.168.12.89",port=3306,user="root",password="123",database="s17day11db",charset="utf8")
cursor = conn.cursor()

cursor.execute("insert into class(caption) values(%s)",["新班級(jí)"])
conn.commit()
new_class_id = cursor.lastrowid # 獲取新增數(shù)據(jù)自增ID

cursor.execute("insert into student(sname,gender,class_id) values(%s,%s,%s)",["李杰","男",new_class_id])
conn.commit()

cursor.close()
conn.close()

查詢語(yǔ)句

#!/usr/bin/env python
# -*- coding:utf-8 -*-
import pymysql
  
conn = pymysql.connect(host="127.0.0.1", port=3306, user="root", passwd="123", db="t1")
cursor = conn.cursor()
cursor.execute("select * from hosts")
  
# 獲取第一行數(shù)據(jù)
row_1 = cursor.fetchone()
  
# 獲取前n行數(shù)據(jù)
# row_2 = cursor.fetchmany(3)
# 獲取所有數(shù)據(jù)
# row_3 = cursor.fetchall()
  
conn.commit()
cursor.close()
conn.close()

注：
在fetch數(shù)據(jù)時(shí)按照順序進(jìn)行，可以使用cursor.scroll(num,mode)來(lái)移動(dòng)游標(biāo)位置，如：

cursor.scroll(1,mode="relative") # 相對(duì)當(dāng)前位置移動(dòng)

cursor.scroll(2,mode="absolute") # 相對(duì)絕對(duì)位置移動(dòng)

更改fetch數(shù)據(jù)類型
默認(rèn)獲取的數(shù)據(jù)是元祖類型，如果想要或者字典類型的數(shù)據(jù)

cursor = conn.cursor(cursor=pymysql.cursors.DictCursor)

#!/usr/bin/env python
# -*- coding:utf-8 -*-
import pymysql
  
conn = pymysql.connect(host="127.0.0.1", port=3306, user="root", passwd="123", db="t1")
  
# 游標(biāo)設(shè)置為字典類型
cursor = conn.cursor(cursor=pymysql.cursors.DictCursor)
v = cursor.execute("SELECT * FROM score")
result = cursor.fetchall()
# result = cursor.fetchone()
# result = cursor.fetchmany()
print(result)



cursor.close()
conn.close()