Python連接操作SQLServer\MySQL示例二

本文以MySQL為例，首先需要安裝pymysql包(連接SqlServer安裝pymssql)

　　pip install pymysql

示例1、取得MySQL版本：

# -*- coding: UTF-8 -*-import pymysql as mdb
con = None
try:
    #連接mysql的方法：connect('ip','user','password','dbname')
    con = mdb.connect('localhost', 'root', 'root', 'test');
    #所有的查詢，都在連接con的一個模塊cursor上面運行的
    cur = con.cursor()
    #執行一個查詢
    cur.execute("SELECT VERSION()")
    #取得上個查詢的結果，是單個結果
    data = cur.fetchone()
    print("Database version : %s " % data)
finally:
    if con:
        #無論如何，連接記得關閉
        con.close()

執行結果：
Database version : 5.5.25

示例2、創建一個表並且插入數據

# -*- coding: UTF-8 -*-
import pymysql as mdb
import sys
#將con設定為全局連接
con = mdb.connect('localhost', 'root', 'root', 'test');
with con:
    #獲取連接的cursor，只有獲取了cursor，我們才能進行各種操作
    cur = con.cursor()
    #創建一個數據表 writers(id,name)
    cur.execute("CREATE TABLE IF NOT EXISTS \
        Writers(Id INT PRIMARY KEY AUTO_INCREMENT, Name VARCHAR(25))")
    #以下插入了5條數據
    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')")

示例3、python使用select獲取mysql的數據並遍歷

# -*- coding: UTF-8 -*-
import pymysql as mdb
import sys
#連接mysql，獲取連接的對象
con = mdb.connect('localhost', 'root', 'root', 'test');
with con:
    #仍然是，第一步要獲取連接的cursor對象，用於執行查詢
    cur = con.cursor()
    #類似於其他語言的query函數，execute是python中的執行查詢函數
    cur.execute("SELECT * FROM Writers")
    #使用fetchall函數，將結果集（多維元組）存入rows里面
    rows = cur.fetchall()
    #依次遍歷結果集，發現每個元素，就是表中的一條記錄，用一個元組來顯示
    for row in rows:
        print(row)

執行結果：
(1L, ‘Jack London')
(2L, ‘Honore de Balzac')
(3L, ‘Lion Feuchtwanger')
(4L, ‘Emile Zola')
(5L, ‘Truman Capote')

示例4、使用字典cursor取得結果集（可以使用表字段名字訪問值）

# -*- coding: UTF-8 -*-import pymysql as mdb
import sys
#獲得mysql查詢的鏈接對象
con = mdb.connect('localhost', 'root', 'root', 'test')
#加上cursorclass=DictCursor參數下面的cur = con.cursor()就不用加參數了，兩種方法都可行。
#con = mdb.connect('localhost', 'root', 'root', 'test', cursorclass=DictCursor)
with con:
    #獲取連接上的字典cursor，注意獲取的方法，
    #每一個cursor其實都是cursor的子類
    cur = con.cursor(mdb.cursors.DictCursor)
    #執行語句不變
    cur.execute("SELECT * FROM Writers")
    #獲取數據方法不變
    rows = cur.fetchall()
    #遍歷數據也不變（比上一個更直接一點）
    for row in rows:
        #這里，可以使用鍵值對的方法，由鍵名字來獲取數據
        print("%s %s" % (row["Id"], row["Name"]))

示例5、獲取單個表的字段名和信息的方法

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

示例6、使用Prepared statements執行查詢（更安全方便）

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

執行結果：
Number of rows updated: 1