Python進行MySQL資料庫操作
阿新 • • 發佈：2019-01-07
最近開始玩Python,慢慢開始喜歡上它了，以前都是用shell來實現一些自動化或者監控的操作，現在用Python來實現，感覺更棒，Python是一門很強大的面嚮物件語言，所以作為一個運維DBA或者運維來說，都應該學會用Python來提高工作效率。下面簡單的介紹一下Python DB API MySQLdb
#獲取所有行的資料 rs = cursor.fetchall() for row in rs: print “userid=%s, username=%s” % row cursor.close() conn.close()
使用Python DB API訪問資料庫的流程圖:
在Centos下安裝MySQLdb模板（為了方便演顯，我用yum安裝，也是最快最省事的安裝）：
yum install MySQL-python -y
如果安裝有ipython，可以看到它有非常多的物件，每個物件這裡就介紹ipython的安裝：
In [1]: import MySQLdb
In [2]: MySQLdb. MySQLdb.BINARY MySQLdb.NotSupportedError MySQLdb.escape_sequence MySQLdb.Binary MySQLdb.OperationalError MySQLdb.escape_string MySQLdb.Connect MySQLdb.ProgrammingError MySQLdb.get_client_info MySQLdb.Connection MySQLdb.ROWID MySQLdb.paramstyle MySQLdb.DATE MySQLdb.STRING MySQLdb.release MySQLdb.DATETIME MySQLdb.TIME MySQLdb.result MySQLdb.DBAPISet MySQLdb.TIMESTAMP MySQLdb.server_end MySQLdb.DataError MySQLdb.Time MySQLdb.server_init MySQLdb.DatabaseError MySQLdb.TimeFromTicks MySQLdb.string_literal MySQLdb.Date MySQLdb.Timestamp MySQLdb.test_DBAPISet_set_equality MySQLdb.DateFromTicks MySQLdb.TimestampFromTicks MySQLdb.test_DBAPISet_set_equality_membership MySQLdb.Error MySQLdb.Warning MySQLdb.test_DBAPISet_set_inequality MySQLdb.FIELD_TYPE MySQLdb.apilevel MySQLdb.test_DBAPISet_set_inequality_membership MySQLdb.IntegrityError MySQLdb.connect MySQLdb.thread_safe MySQLdb.InterfaceError MySQLdb.connection MySQLdb.threadsafety MySQLdb.InternalError MySQLdb.constants MySQLdb.times MySQLdb.MySQLError MySQLdb.debug MySQLdb.version_info MySQLdb.NULL MySQLdb.escape MySQLdb.NUMBER MySQLdb.escape_dict
我們這裡主要說建立資料庫的連線物件connection，建立方法MySQLdb.connect(引數)
主要引數如下：
引數名 型別 說明
host 字串 MySQL伺服器地址
port 數字 MySQL伺服器埠號
user 字串 使用者名稱
passwd 字串 密碼
db 字串 資料庫名稱
charset 字串 連線編碼
connection物件支援的方法：
方法名 說明
cursor() 使用該連線建立並返回遊標
commit() 提交當前事務
rollback() 回滾當前事務
close() 關閉連線
例項講解：編輯connection.py
#!/usr/bin/env python#coding:utf-8 #name: connection.py import MySQLdb #建立連線 conn = MySQLdb.connect( host = ‘127.0.0.1‘, port = 3306, user = ‘root‘, passwd = ‘123456‘, db = ‘python‘, charset = ‘utf8‘ ) #建立一個學遊標物件 cursor = conn.cursor() print conn
執行結果：
[[email protected]server script]#python connection.py <_mysql.connection open to ‘127.0.0.1‘ at 23c1fa0> <MySQLdb.cursors.Cursor object at 0x7f545cbf97d0> [[email protected]-server script]#vim connection.py
可以看到成功連線了MySQL.
下面介紹一下游標物件： 用於執行查詢和獲取結果
cursor物件支援的方法：
引數名 說明
execute(op[,args]) 執行一個數據查詢命令
fetchone() 取的結果集的下一行
fetchmany(size) 獲取結果集的下幾行
fetchall() 獲取結果集中剩下的所有行
rowcount 最近一次execute返回的行數或影響行數
close() 關閉遊標物件
execute方法：執行SQL、將結果從資料為獲取到客戶端：
fetch*（）方法：移動rownumber，返回資料。
例項演示：（select查詢資料）
建立一張測試：
CREATE TABLE `user` ( `userid` int(11) NOT NULL AUTO_INCREMENT, `username` varchar(100) COLLATE utf8_bin DEFAULT NULL, PRIMARY KEY (`userid`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_bin
mysql> select * from user; +--------+----------+ | userid | username | +--------+----------+ | 1 | user1 | | 2 | user2 | | 3 | user3 | | 4 | user4 | | 5 | user5 | | 6 | user6 | | 7 | user7 | | 8 | user8 | | 9 | user9 | +--------+----------+ 9 rows in set (0.00 sec)
編輯cursor.py檔案：
#!/usr/bin/env python#coding:utf-8 #name: cursor.py import MySQLdb conn = MySQLdb.connect( host = ‘127.0.0.1‘, port = 3306, user = ‘root‘, passwd = ‘123456‘, db = ‘python‘, charset = ‘utf8‘ ) cursor = conn.cursor() sql = “select * from user” cursor.execute(sql) #列印所有行資料 print cursor.rowcount #列印第一行資料 rs = cursor.fetchone() print “返回一條資料”,rs #列印從第二行起的三行資料 rs = cursor.fetchmany(3) print “返回從第二條起的三條資料”,rs #列印剩下的所有行數 rs = cursor.fetchall() print “返回剩下的行資料”,rs cursor.close() conn.close()
執行程式：
[[email protected]server script]#python connection.py 9 返回一條資料 (1L, u‘user1‘) 返回從第二條起的三條資料 ((2L, u‘user2‘), (3L, u‘user3‘), (4L, u‘user4‘)) 返回剩下的行資料 ((5L, u‘user5‘), (6L, u‘user6‘), (7L, u‘user7‘), (8L, u‘user8‘), (9L, u‘user9‘))
我們看到，每次使用fetch方法，都是在上一次fetch方法執行的結果的尾部開始。
如果我們想把表裡的資料格式化打印出來，因為從上面的結果我們可以看到返回的是元組的元組，我們通過for方法把它取出：
#!/usr/bin/env python#coding:utf-8 #name: cursor.py import MySQLdb conn = MySQLdb.connect( host = ‘127.0.0.1‘, port = 3306, user = ‘root‘, passwd = ‘123456‘, db = ‘python‘, charset = ‘utf8‘ ) cursor = conn.cursor() sql = “select * from user” cursor.execute(sql)
#獲取所有行的資料 rs = cursor.fetchall() for row in rs: print “userid=%s, username=%s” % row cursor.close() conn.close()
執行程式：
[[email protected]server script]#python cursor.py userid=1, username=user1 userid=2, username=user2 userid=3, username=user3 userid=4, username=user4 userid=5, username=user5 userid=6, username=user6 userid=7, username=user7 userid=8, username=user8 userid=9, username=user9
對MySQL的insert/delete/update的操作演示：
編輯一個增刪改的指令碼iud.py
#!/usr/bin/env python#coding:utf-8 #name: iud.py import MySQLdb conn = MySQLdb.connect( host = ‘127.0.0.1‘, port = 3306, user = ‘root‘, passwd = ‘123456‘, db = ‘python‘, charset = ‘utf8‘ ) cursor = conn.cursor() #插入sql sql_insert = “insert into user (userid,username) values (10,‘user10‘)” #更新sql sql_update = “update user set username= ‘name91‘ where userid=9” #刪除sql sql_delete = “delete from user where userid < 3” #把一個事務放到一個try塊裡，如果出現異常就回滾 try: cursor.execute(sql_insert) print cursor.rowcount cursor.execute(sql_update) print cursor.rowcount cursor.execute(sql_delete) print cursor.rowcount #提交事務 conn.commit() #格式化增刪改後的資料查出來 select_sql = “select * from user” cursor.execute(select_sql) rs = cursor.fetchall() for row in rs: print “userid=%s, username=%s” % row except Exception as e: conn.rollback() #若有異常就回滾
執行程式，結果如下：
[email protected]server script]#python iud.py 1 1 2 userid=3, username=user3 userid=4, username=user4 userid=5, username=user5 userid=6, username=user6 userid=7, username=user7 userid=8, username=user8 userid=9, username=name91 userid=10, username=user10
通過上面的簡單例子說明了通過Python的MySQLdb模組去進行MySQL資料庫操作，網上有很多例子，我是Python菜鳥，通過參加慕課網的一些簡單直接的python課程學習，個人感覺還不錯