使用pymysql運算元據庫

2022-06-08 11:54:09 字數 3798 閱讀 4789

學習如何使用python的pymysql模組來操作mysql資料庫

這裡的基本用法主要借鑑了該篇部落格:

因為這個作者總結的很全面,也很簡潔,看完很容易上手

pymysql.connect()引數說明:(連線資料庫時需要新增的引數)

host(str): mysql伺服器位址

port(int): mysql伺服器端口號

user(str): 使用者名稱

passwd(str): 密碼

db(str): 資料庫名稱

charset(str): 連線編碼connect()物件支援的方法:cursor() 使用該連線建立並返回游標

commit() 提交當前事務

rollback() 回滾當前事務

close() 關閉連線cursor物件支援的方法:execute(op) 執行乙個資料庫的查詢命令

fetchone() 取得結果集的下一行

fetchmany(size) 獲取結果集的下幾行

fetchall() 獲取結果集中的所有行

rowcount() 返回資料條數或影響行數

close() 關閉游標物件

# coding: utf-8

# author: hmk

import pymysql.cursors

# 連線資料庫

conn = pymysql.connect(host='localhost',

user='root',

password='123456',

db='test',

charset='utf8')

# 建立乙個游標

cursor = conn.cursor()

# 查詢資料

sql = "select * from maoyan_movie"

cursor.execute(sql) # 執行sql

# 查詢所有資料,返回結果預設以元組形式,所以可以進行迭代處理

for i in cursor.fetchall():

print(i)

print('共查詢到:', cursor.rowcount, '條資料。')

# 獲取第一行資料

result_1 = cursor.fetchone()

print(result_1)

# 獲取前n行資料

result_3 = cursor.fetchmany(3)

print(result_3)

cursor.close() # 關閉游標

conn.close()# 關閉連線

# coding: utf-8

# author: hmk

import pymysql.cursors

# 連線資料庫

conn = pymysql.connect(host='localhost',

user='root',

password='123456',

db='test',

charset='utf8')

# 建立乙個游標

cursor = conn.cursor()

# 插入資料

# 資料直接寫在sql後面

sql = "insert into maoyan_movie(ranking,movie,release_time,score) values(%s, %s, %s, %s)" # 注意是%s,不是s%

# 資料單獨賦給乙個物件

sql = "insert into maoyan_movie values(%s,%s,%s,%s)"

cursor.execute(sql, data) #sql和data之間以","隔開

cursor.execute(sql % data) #sql和data之間以"%"隔開,此時它的sql中注意要給中文字元對應的佔位符加上引號,即"%s",不然會報錯:unsupported format character 

conn.commit() # 提交,不然無法儲存插入或者修改的資料(這個一定不要忘記加上)

cursor.close()  # 關閉游標

conn.close()# 關閉連線

# coding: utf-8

# author: hmk

import pymysql.cursors

# 連線資料庫

conn = pymysql.connect(host='localhost',

user='root',

password='123456',

db='test',

charset='utf8')

# 建立乙個游標

cursor = conn.cursor()

# 修改資料

sql = "update maoyan_movie set movie='%s' where ranking=%s" #注意%s什麼時候加引號,什麼時候不加

data = ('返老還童', 1)

cursor.execute(sql % data)

sql = "update maoyan_movie set movie=%s where ranking=%s"

data = ('寂靜之地', 1)

cursor.execute(sql, data)

conn.commit()   # 提交,不然無法儲存插入或者修改的資料
cursor.close()  # 關閉游標

conn.close()# 關閉連線

# coding: utf-8

# author: hmk

import pymysql.cursors

# 連線資料庫

conn = pymysql.connect(host='localhost',

user='root',

password='123456',

db='test',

charset='utf8')

# 建立乙個游標

cursor = conn.cursor()

# 刪除資料

sql = "delete from maoyan_movie where ranking=%s"

data = (2)

cursor.execute(sql, data)

conn.commit() # 提交,不然刪除操作不生效

cursor.close()  # 關閉游標

conn.close()# 關閉連線

附上使用的表:

Python使用PyMysql運算元據庫

pip install u pymysql連線資料庫有兩種不同的格式 如下 import pymysql.cursors connection pymysql.connect host 127.0.0.1 port 3306,user root password root db spider cha...

pytyon運算元據庫pymysql

模組安裝 pip install pymysqlimport pymysql 新增資料 conn pymysql.connect host 127.0.0.1 port 3306,user root password 123456 db lesson54 游標 cursor conn.cursor ...

pymysql原生運算元據庫

python運算元據庫 import pymysql pymysql.connect 此物件為pymysql連線資料庫的類 建立connection連線物件例項 conn connect host localhost port 3306 user root password mysql databa...