python數據庫(mysql)操作

一、軟件環境

　　python環境默認安裝了sqlite3，如果需要使用sqlite3我們直接可以在python代碼模塊的頂部使用import sqlite3來導入該模塊。本篇文章我是記錄了python操作mysql數據庫，mysql數據庫下載

　　由於我之前安裝的是wampserver，默認安裝了php、mysql和apache這3個環境，因此我沒有在單獨安裝mysql數據庫，只是下載了一個mysql管理工具Navicat for MySQL。在使用Navicat for MySQL連接本地mysql數據庫時，發生連接失敗問題，經過網上查詢得知是mysql服務沒有啟動，如何啟動mysql服務請看如何單獨啟動wamp 中自帶的MySQL。其實很簡單，就是打開命令行，選擇目錄到mysql數據庫的bin目錄下，執行mysqld命令即可。

　　mysql 和mysqld 的區別：

　　mysqld 是服務端程序
　　mysql是命令行客戶端程序

二、數據庫操作

　　python操作mysql數據庫，新增、修改和刪除比較簡單，都是執行一個簡單的sql語句。查詢除了執行sql語句外還需要使用fetchone和fetchall來獲取數據條目

# -*- coding: UTF-8 -*-

__author__ = 'Administrator'

import MySQLdb

# 打開數據庫連接
db = MySQLdb.connect("localhost","root","123456","test" )

# 使用cursor()方法獲取操作游標
cursor = db.cursor()

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

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

print "Database version : %s " % data

# 如果數據表已經存在使用 execute() 方法刪除表。
cursor.execute("DROP TABLE IF EXISTS EMPLOYEE")

# 創建數據表SQL語句
sql = """CREATE TABLE EMPLOYEE (
         FIRST_NAME  CHAR(20) NOT NULL,
         LAST_NAME  CHAR(20),
         AGE INT,
         SEX CHAR(1),
         INCOME FLOAT )"""

cursor.execute(sql)

# SQL 插入語句
sql = """INSERT INTO EMPLOYEE(FIRST_NAME,
         LAST_NAME, AGE, SEX, INCOME)
         VALUES ('Mac', 'Mohan', 20, 'M', 2000)"""
try:
   # 執行sql語句
   cursor.execute(sql)
   # 提交到數據庫執行
   db.commit()
except:
   # Rollback in case there is any error
   db.rollback()

# SQL 查詢語句
sql = "SELECT * FROM EMPLOYEE \
       WHERE INCOME > '%d'" % (1000)
try:
   # 執行SQL語句
   cursor.execute(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=%d,sex=%s,income=%d" % \
             (fname, lname, age, sex, income )
except:
   print "Error: unable to fecth data"

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

三、事務

　　事務機制可以確保數據一致性。

　　事務應該具有4個屬性：原子性、一致性、隔離性、持久性。這四個屬性通常稱為ACID特性。

• 原子性（atomicity）。一個事務是一個不可分割的工作單位，事務中包括的諸操作要么都做，要么都不做。
• 一致性（consistency）。事務必須是使數據庫從一個一致性狀態變到另一個一致性狀態。一致性與原子性是密切相關的。
• 隔離性（isolation）。一個事務的執行不能被其他事務干擾。即一個事務內部的操作及使用的數據對並發的其他事務是隔離的，並發執行的各個事務之間不能互相干擾。
• 持久性（durability）。持續性也稱永久性（permanence），指一個事務一旦提交，它對數據庫中數據的改變就應該是永久性的。接下來的其他操作或故障不應該對其有任何影響。

　　Python DB API 2.0 的事務提供了兩個方法 commit 或 rollback。

# SQL刪除記錄語句
sql = "DELETE FROM EMPLOYEE WHERE AGE > '%d'" % (20)
try:
   # 執行SQL語句
   cursor.execute(sql)
   # 向數據庫提交
   db.commit()
except:
   # 發生錯誤時回滾
   db.rollback()

　　對於支持事務的數據庫， 在Python數據庫編程中，當游標建立之時，就自動開始了一個隱形的數據庫事務。commit()方法游標的所有更新操作，rollback（）方法回滾當前游標的所有操作。每一個方法都開始了一個新的事務。

 

如果您覺得文章不錯，不妨給個 打賞，寫作不易，感謝各位的支持。您的支持是我最大的動力，謝謝！！！ 

---

 

  

---

很重要--轉載聲明

1. 本站文章無特別說明，皆為原創，版權所有，轉載時請用鏈接的方式，給出原文出處。同時寫上原作者：朝十晚八 or Twowords
2. 如要轉載，請原文轉載，如在轉載時修改本文，請事先告知，謝絕在轉載時通過修改本文達到有利於轉載者的目的。 

---

奮斗中的無名小卒。。。