# -*- coding: UTF-8 -*-
#安裝 MYSQL DB for python
import MySQLdb as mdb
con = None
try:
 #連接 mysql 的方法： connect('ip','user','password','dbname')
 con = mdb.connect('localhost', 'root','root', 'test');

 #所有的查詢，都在連接 con 的一個(gè)模塊 cursor 上面運(yùn)行的
 cur = con.cursor()

 #執(zhí)行一個(gè)查詢
 cur.execute("SELECT VERSION()")
 #取得上個(gè)查詢的結(jié)果，是單個(gè)結(jié)果

 data = cur.fetchone()
 print "Database version : %s " % data
finally:
 if con:
 #無論如何，連接記得關(guān)閉
 con.close()

import MySQLdb as mdb
import sys

#將 con 設(shè)定為全局連接
con = mdb.connect('localhost', 'root', 'root', 'test');
with con:

#獲取連接的 cursor，只有獲取了 cursor，我們才能進(jìn)行各種操作
cur = con.cursor()

#創(chuàng)建一個(gè)數(shù)據(jù)表 writers(id,name)
cur.execute("CREATE TABLE IF NOT EXISTS \
Writers(Id INT PRIMARY KEY AUTO_INCREMENT, Name VARCHAR(25))")

#以下插入了 5 條數(shù)據(jù)
cur.execute("INSERT INTO Writers(Name) VALUES('Jack London')")
cur.execute("INSERT INTO Writers(Name) VALUES('Honore de Balzac')")
cur.execute("INSERT INTO Writers(Name) VALUES('Lion Feuchtwanger')")
cur.execute("INSERT INTO Writers(Name) VALUES('Emile Zola')")
cur.execute("INSERT INTO Writers(Name) VALUES('Truman Capote')")

import MySQLdb as mdb
import sys

#連接 mysql，獲取連接的對(duì)象
con = mdb.connect('localhost', 'root', 'root', 'test');
with con:

#仍然是，第一步要獲取連接的 cursor 對(duì)象，用于執(zhí)行查詢
cur = con.cursor()

#類似于其他語(yǔ)言的 query 函數(shù)， execute 是 python 中的執(zhí)行查詢函數(shù)
cur.execute("SELECT * FROM Writers")

#使用 fetchall 函數(shù)，將結(jié)果集（多維元組）存入 rows 里面
rows = cur.fetchall()

#依次遍歷結(jié)果集，發(fā)現(xiàn)每個(gè)元素，就是表中的一條記錄，用一個(gè)元組來顯示
for row in rows:
print row

import MySQLdb as mdb
import sys

#獲取 mysql 的鏈接對(duì)象
con = mdb.connect('localhost', 'root', 'root', 'test');
with con:
#獲取執(zhí)行查詢的對(duì)象
cur = con.cursor()
#執(zhí)行那個(gè)查詢，這里用的是 select 語(yǔ)句
cur.execute("SELECT * FROM Writers")
#使用 cur.rowcount 獲取結(jié)果集的條數(shù)
numrows = int(cur.rowcount)
#循環(huán) numrows 次，每次取出一行數(shù)據(jù)
for i in range(numrows):
#每次取出一行，放到 row 中，這是一個(gè)元組(id,name)
row = cur.fetchone()
#直接輸出兩個(gè)元素
print row[0], row[1]

import MySQLdb as mdb
import sys
#獲得 mysql 查詢的鏈接對(duì)象
con = mdb.connect('localhost', 'root', 'root', 'test')
with con:
#獲取連接上的字典 cursor，注意獲取的方法，
#每一個(gè) cursor 其實(shí)都是 cursor 的子類
cur = con.cursor(mdb.cursors.DictCursor)
#執(zhí)行語(yǔ)句不變
cur.execute("SELECT * FROM Writers")
#獲取數(shù)據(jù)方法不變
rows = cur.fetchall()
#遍歷數(shù)據(jù)也不變（比上一個(gè)更直接一點(diǎn)）
for row in rows:
#這里，可以使用鍵值對(duì)的方法，由鍵名字來獲取數(shù)據(jù)
print "%s %s" % (row["Id"], row["Name"])

import MySQLdb as mdb
import sys
#獲取數(shù)據(jù)庫(kù)的鏈接對(duì)象
con = mdb.connect('localhost', 'root', 'root', 'test')
with con:
#獲取普通的查詢 cursor
cur = con.cursor()
cur.execute("SELECT * FROM Writers")
rows = cur.fetchall()
#獲取連接對(duì)象的描述信息
desc = cur.description
print 'cur.description:',desc
#打印表頭，就是字段名字
print "%s %3s" % (desc[0][0], desc[1][0])
for row in rows:
#打印結(jié)果
print "%2s %3s" % row

import MySQLdb as mdb
import sys

con = mdb.connect('localhost', 'root', 'root', 'test')
with con:
cur = con.cursor()
#我們看到，這里可以通過寫一個(gè)可以組裝的 sql 語(yǔ)句來進(jìn)行
cur.execute("UPDATE Writers SET Name = %s WHERE Id = %s",
("Guy de Maupasant", "4"))
#使用 cur.rowcount 獲取影響了多少行
print "Number of rows updated: %d" % cur.rowcount

import MySQLdb as mdb
import sys

try:
#用讀文件模式打開圖片
fin = open("../web.jpg")
#將文本讀入 img 對(duì)象中
img = fin.read()
#關(guān)閉文件
fin.close()
except IOError, e:
#如果出錯(cuò)，打印錯(cuò)誤信息
print "Error %d: %s" % (e.args[0],e.args[1])
sys.exit(1)
try:
#鏈接 mysql，獲取對(duì)象
conn = mdb.connect(host='localhost',user='root',passwd='root',
db='test')
#獲取執(zhí)行 cursor
cursor = conn.cursor()
#直接將數(shù)據(jù)作為字符串，插入數(shù)據(jù)庫(kù)
cursor.execute("INSERT INTO Images SET Data='%s'" %
mdb.escape_string(img))
#提交數(shù)據(jù)
conn.commit()
#提交之后，再關(guān)閉 cursor 和鏈接
cursor.close()
conn.close()
except mdb.Error, e:
#若出現(xiàn)異常，打印信息
print "Error %d: %s" % (e.args[0],e.args[1])
sys.exit(1)

import MySQLdb as mdb
import sys

try:
#連接 mysql，獲取連接的對(duì)象
conn = mdb.connect('localhost', 'root', 'root', 'test');
cursor = conn.cursor()
#執(zhí)行查詢?cè)搱D片字段的 SQL
cursor.execute("SELECT Data FROM Images LIMIT 1")
#使用二進(jìn)制寫文件的方法，打開一個(gè)圖片文件，若不存在則自動(dòng)創(chuàng)建
fout = open('image.png','wb')
#直接將數(shù)據(jù)如文件
fout.write(cursor.fetchone()[0])
#關(guān)閉寫入的文件
fout.close()
#釋放查詢數(shù)據(jù)的資源
cursor.close()
conn.close()
except IOError, e:
#捕獲 IO 的異常 ，主要是文件寫入會(huì)發(fā)生錯(cuò)誤
print "Error %d: %s" % (e.args[0],e.args[1])
sys.exit(1)

import MySQLdb as mdb
import sys

try:
#連接 mysql，獲取連接的對(duì)象
conn = mdb.connect('localhost', 'root', 'root', 'test');
cursor = conn.cursor()
#如果某個(gè)數(shù)據(jù)庫(kù)支持事務(wù)，會(huì)自動(dòng)開啟
#這里用的是 MYSQL，所以會(huì)自動(dòng)開啟事務(wù)（若是 MYISM 引擎則不會(huì)）
cursor.execute("UPDATE Writers SET Name = %s WHERE Id = %s",
("Leo Tolstoy", "1"))
cursor.execute("UPDATE Writers SET Name = %s WHERE Id = %s",
("Boris Pasternak", "2"))
cursor.execute("UPDATE Writer SET Name = %s WHERE Id = %s",
("Leonid Leonov", "3"))
#事務(wù)的特性 1、原子性的手動(dòng)提交
conn.commit()
cursor.close()
conn.close()
except mdb.Error, e:
#如果出現(xiàn)了錯(cuò)誤，那么可以回滾，就是上面的三條語(yǔ)句要么執(zhí)行，要么都不執(zhí)行
conn.rollback()
print "Error %d: %s" % (e.args[0],e.args[1])