就像Java連接數據庫需要JDBC一樣,連接數據庫的時候,Python也需要相應的支持.

Python2的話,一般用mysqldb；而Python3的時候,就需要使用PyMySQL這個組件了,本文我們選擇PyMySQL進行簡單講解.安裝的話,使用Pycharm來弄的話非常簡單,具體辦法可以參照前文,再次不贅述.

• 準備工作

  與數據庫連接之前,需要了解數據庫的基本信息,這其中包含：

1. 數據庫服務器的IP,端口(mysql默認3306)

2. 訪問的用戶名/暗碼

3. 數據庫的名稱

本文使用的信息如下：localhost(本機)、admin/123456、home.下面請大家跟著這些例子來體會一下python進行數據庫的增刪改查.至于commit和rollback的概念,這里面有利用到,后續的篇章中會詳細講解.

1.創建用戶表(user)

import pymysql# 打開數據庫連接db = pymysql.connect("localhost", "admin", "123456", "home")# 使用 cursor() 辦法創建一個游標對象 cursorcursor = db.cursor()# 使用 execute() 辦法執行 SQL,如果表存在則刪除cursor.execute("DROP TABLE IF EXISTS USER")# 使用預處理語句創建表sql = """CREATE TABLE USER (NAME CHAR(20) NOT NULL,AGE INT, SEX CHAR(1) )"""cursor.execute(sql)# 關閉數據庫連接db.close()

2.INSERT/UPDATE/DELETE操作

import pymysql# 打開數據庫連接db = pymysql.connect("localhost", "admin", "123456", "home")# 使用 cursor() 辦法創建一個游標對象 cursorcursor = db.cursor()# SQL 插入語句sql = """INSERT INTO USER(NAME, AGE, SEX) VALUES ('Andy', 20, 'M')""" try:# 執行sql語句cursor.execute(sql)# 提交到數據庫執行db.commit()except:# 如果發生錯誤則回滾db.rollback()# 關閉數據庫連接db.close()

注：update和delete操作留給大家去思考.

3.SELECT操作

import pymysql# 打開數據庫連接db = pymysql.connect("localhost", "admin", "123456", "home")# 使用 cursor() 辦法創建一個游標對象 cursorcursor = db.cursor()# SQL 查詢語句sql = "SELECT * FROM USER \ WHERE NAME like 'A%'" try:# 執行SQL語句cursor.execute(sql)# 獲取所有記錄列表results = cursor.fetchall()for row in results:name = row[0]age = row[1]sex = row[2]# 打印結果print ("name=%s,age=%d,sex=%s" % \(name, age, sex ))except:print ("Error: unable to fetch data")# 關閉數據庫連接db.close()