目錄

• 一、數據庫的安裝和連接
  • 1.1 PyMySQL的安裝
  • 1.2 python連接數據庫
    • 1.2.1 更多參數版
• 二、創建表操作
• 三、操作數據
  • 3.1 插入操作
  • 3.2 查詢操作
  • 3.3 更新操作
  • 3.4 刪除操作
• 四、數據備份
  • 4.1 數據庫的邏輯備份
  • 4.2 數據恢復
• 五、事務和鎖

一、數據庫的安裝和連接

1.1 PyMySQL的安裝

pip install pymysql

1.2 python連接數據庫

import pymysqldb = pymysql.connect("數據庫ip","用戶","密碼","數據庫" ) # 打開數據庫連接 cursor.execute("SELECT VERSION()") # 使用 execute() 方法執行 SQL 查詢 data = cursor.fetchone() # 使用 fetchone() 方法獲取單條數據 print ("Database version : %s " % data) db.close() # 關閉數據庫連接

1.2.1 更多參數版

import pymysqlconn = pymysql.connect(host='localhost', user='root', password="root",database='db', port=3306, charset='utf-8', )cur = conn.cursor(cursor=pymysql.cursors.DictCursor)

二、創建表操作

import pymysql# 打開數據庫連接 db = pymysql.connect("localhost", "testuser", "test123", "TESTDB")# 使用 cursor() 方法創建一個游標對象 cursor cursor = db.cursor()# 使用 execute() 方法執行 SQL，如果表存在則刪除 cursor.execute("DROP TABLE IF EXISTS EMPLOYEE")# 使用預處理語句創建表 sql = """CREATE TABLE EMPLOYEE (FIRST_NAME CHAR(20) NOT NULL,LAST_NAME CHAR(20),AGE INT, SEX CHAR(1),INCOME FLOAT )"""cursor.execute(sql)# 關閉數據庫連接 db.close()

三、操作數據

3.1 插入操作

import pymysql# 打開數據庫連接 db = pymysql.connect("localhost", "testuser", "test123", "TESTDB")# 使用cursor()方法獲取操作游標 cursor = db.cursor()# SQL 插入語句 sql = """INSERT INTO EMPLOYEE(FIRST_NAME,LAST_NAME, AGE, SEX, INCOME)VALUES ('Mac', 'Mohan', 20, 'M', 2000)""" try:cursor.execute(sql) # 執行sql語句db.commit() # 提交到數據庫執行 except:db.rollback() # 如果發生錯誤則回滾# 關閉數據庫連接 db.close()

3.2 查詢操作

Python查詢Mysql使用 fetchone() 方法獲取單條數據，使用

• fetchall()：方法獲取多條數據。
• fetchone(): 該方法獲取下一個查詢結果集。結果集是一個對象
• fetchall(): 接收全部的返回結果行.
• rowcount(): 這是一個只讀屬性，并返回執行execute()方法后影響的行數。

import pymysql# 打開數據庫連接 db = pymysql.connect("localhost", "testuser", "test123", "TESTDB")# 使用cursor()方法獲取操作游標 cursor = db.cursor()# SQL 查詢語句 sql = "SELECT * FROM EMPLOYEE \WHERE INCOME > %s" % (1000) try:cursor.execute(sql) # 執行SQL語句results = cursor.fetchall() # 獲取所有記錄列表for row in results:fname = row[0]lname = row[1]age = row[2]sex = row[3]income = row[4]# 打印結果print ("fname=%s,lname=%s,age=%s,sex=%s,income=%s" % \(fname, lname, age, sex, income )) except:print("Error: unable to fetch data")# 關閉數據庫連接 db.close()

3.3 更新操作

import pymysql# 打開數據庫連接 db = pymysql.connect("localhost", "testuser", "test123", "TESTDB")# 使用cursor()方法獲取操作游標 cursor = db.cursor()# SQL 更新語句 sql = "UPDATE EMPLOYEE SET AGE = AGE + 1 WHERE SEX = '%c'" % ('M') try:cursor.execute(sql) # 執行SQL語句db.commit() # 提交到數據庫執行 except:db.rollback() # 發生錯誤時回滾# 關閉數據庫連接 db.close()

3.4 刪除操作

import pymysql# 打開數據庫連接 db = pymysql.connect("localhost", "testuser", "test123", "TESTDB")# 使用cursor()方法獲取操作游標 cursor = db.cursor()# SQL 刪除語句 sql = "DELETE FROM EMPLOYEE WHERE AGE > %s" % (20) try:cursor.execute(sql) # 執行SQL語句db.commit() # 提交修改 except:db.rollback() # 發生錯誤時回滾# 關閉連接 db.close()

四、數據備份

4.1 數據庫的邏輯備份

#語法： # mysqldump -h 服務器 -u用戶名 -p密碼 數據庫名 > 備份文件.sql#示例： #單庫備份 mysqldump -uroot -p123 db1 > db1.sql mysqldump -uroot -p123 db1 table1 table2 > db1-table1-table2.sql#多庫備份 mysqldump -uroot -p123 --databases db1 db2 mysql db3 > db1_db2_mysql_db3.sql#備份所有庫 mysqldump -uroot -p123 --all-databases > all.sql

4.2 數據恢復

#方法一： [root@nick backup]# mysql -uroot -p123 < /backup/all.sql#方法二： mysql> use db1; mysql> SET SQL_LOG_BIN=0; #關閉二進制日志，只對當前session生效 mysql> source /root/db1.sql

五、事務和鎖

begin; # 開啟事務 select * from emp where id = 1 for update; # 查詢id值，for update添加行鎖； update emp set salary=10000 where id = 1; # 完成更新 commit; # 提交事務

轉載于:https://www.cnblogs.com/TankJam/p/11163370.html

總結

以上是生活随笔為你收集整理的使用Python操作MySQL数据库的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。