python怎么操作pymysql數據庫

本篇內容主要講解“python怎么操作pymysql數據庫”，感興趣的朋友不妨來看看。本文介紹的方法操作簡單快捷，實用性強。下面就讓小編來帶大家學習“python怎么操作pymysql數據庫”吧!

一、安裝

pip install pymysql

二、連接數據庫

• 三種連接數據庫的方式

import pymysql

# 方式一
conn = pymysql.connect('localhost', 'root', 'root')

# 方式二
conn = pymysql.connect(host='127.0.0.1', port=3306, user='root', passwd='root', db='', charset='utf8')

# 方式三
config = {
'host': '127.0.0.1',
'port': 3306,
'user': 'root',
'passwd': 'root',
'charset': 'utf8'
}
conn = pymysql.connect(**config)

三、創建數據庫

• 創建一個test數據庫并進入

import pymysql

db = pymysql.connect("localhost", "root", "root", "test")
# 使用 cursor() 方法創建一個游標對象 cursor
cursor = db.cursor()

cursor.execute('DROP DATABASE IF EXISTS test')
cursor.execute('CREATE DATABASE IF NOT EXISTS test')
conn.select_db('test')

四、創建數據表

• 創建一張user表

import pymysql

db = pymysql.connect("localhost", "root", "root", "test")
cursor = db.cursor()

cursor.execute('CREATE TABLE user(id int primary key,name varchar(30))')

五、插入一條數據

import pymysql

db = pymysql.connect("localhost", "root", "root", "test")
cursor = db.cursor()

try:
# 執行SQL語句
sql = 'INSERT INTO user values("%d","%s")' %(1,"autofelix")
cursor.execute(sql)
# 提交到數據庫執行
db.commit()
except:
# 發生錯誤時回滾
db.rollback()
finally:
# 關閉游標連接
cursor.close()
# 關閉數據庫連接
conn.close()

六、插入多條數據

import pymysql

db = pymysql.connect("localhost", "root", "root", "test")
cursor = db.cursor()

try:
# 執行SQL語句
values = [(1, 'autofelix'), (2, '飛兔小哥')]
cursor.executemany('INSERT INTO user values(%s,%s)', values)
# 提交到數據庫執行
db.commit()
except:
# 發生錯誤時回滾
db.rollback()
finally:
# 關閉游標連接
cursor.close()
# 關閉數據庫連接
conn.close()

七、數據統計

import pymysql

db = pymysql.connect("localhost", "root", "root", "test")
cursor = db.cursor()

count = cursor.execute('SELECT * FROM user')
# 統計數據總數
print('total records: %d' %count)
# 統計字段數
print('total records:', cursor.rowcount)

八、獲取表名信息

import pymysql

db = pymysql.connect("localhost", "root", "root", "test")
cursor = db.cursor()

desc = cursor.description
print("%s %3s" % (desc[0][0], desc[1][0]))

九、獲取單條數據

• 使用 fetchone 方法獲取單條數據

import pymysql


db = pymysql.connect("localhost", "root", "root", "test")
cursor = db.cursor()

# 使用 execute() 方法執行 SQL 查詢
cursor.execute("SELECT VERSION()")

# 使用 fetchone() 方法獲取單條數據.
data = cursor.fetchone()

print("Database version : %s " % data)

# 關閉數據庫連接
db.close()

十、查詢多條數據

import pymysql

db = pymysql.connect("localhost", "root", "root", "test")
cursor = db.cursor()

cursor.execute('SELECT * FROM user')

results = cursor.fetchmany(5)
for r in results:
print (r)

十一、查詢所有數據

import pymysql

db = pymysql.connect("localhost", "root", "root", "test")
cursor = db.cursor()

cursor.execute('SELECT * FROM user')

results = cursor.fetchall()
for r in results:
print (r)

十二、上下文管理

• 每次都連接關閉很麻煩，使用上下文管理，簡化連接過程

import pymysql
import contextlib

# 定義上下文管理器，連接后自動關閉連接
@contextlib.contextmanager
def mysql(host='127.0.0.1', port=3306, user='root', passwd='', db='test',charset='utf8'):
conn = pymysql.connect(host=host, port=port, user=user, passwd=passwd, db=db, charset=charset)
cursor = conn.cursor(cursor=pymysql.cursors.DictCursor)
try:
yield cursor
finally:
conn.commit()
cursor.close()
conn.close()

# 執行sql
with mysql() as cursor:
print(cursor)
count = cursor.execute("select * from user")
row_1 = cursor.fetchone()
print row_count, row_1

到此，相信大家對“python怎么操作pymysql數據庫”有了更深的了解，不妨來實際操作一番吧！這里是億速云網站，更多相關內容可以進入相關頻道進行查詢，關注我們，繼續學習！