python操作MySQL資料庫

堅持每天學一點，每天積累一點點，作為自己每天的業餘收獲，這個文章是我在吃飯的期間寫的，利用自己零散的時間學了一下python操作mysql，是以整理一下。

我采用的是mysqldb操作的mysql資料庫。先來一個簡單的例子吧：

1

2

3

4

5

6

7

8

9

10

<code>import</code> <code>mysqldb</code>

<code>try</code><code>:</code>

<code>    </code><code>conn</code><code>=</code><code>mysqldb.connect(host</code><code>=</code><code>'localhost'</code><code>,user</code><code>=</code><code>'root'</code><code>,passwd</code><code>=</code><code>'root'</code><code>,db</code><code>=</code><code>'test'</code><code>,port</code><code>=</code><code>3306</code><code>)</code>

<code>    </code><code>cur</code><code>=</code><code>conn.cursor()</code>

<code>    </code><code>cur.execute(</code><code>'select * from user'</code><code>)</code>

<code>    </code><code>cur.close()</code>

<code>    </code><code>conn.close()</code>

<code>except</code> <code>mysqldb.error,e:</code>

<code>     </code><code>print</code> <code>"mysql error %d: %s"</code> <code>%</code> <code>(e.args[</code><code>0</code><code>], e.args[</code><code>1</code><code>])</code>

　　請注意修改你的資料庫，主機名，使用者名，密碼。

下面來大緻示範一下插入資料，批量插入資料，更新資料的例子吧：

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

<code>    </code><code>conn</code><code>=</code><code>mysqldb.connect(host</code><code>=</code><code>'localhost'</code><code>,user</code><code>=</code><code>'root'</code><code>,passwd</code><code>=</code><code>'root'</code><code>,port</code><code>=</code><code>3306</code><code>)</code>

<code>    </code> 

<code>    </code><code>cur.execute(</code><code>'create database if not exists python'</code><code>)</code>

<code>    </code><code>conn.select_db(</code><code>'python'</code><code>)</code>

<code>    </code><code>cur.execute(</code><code>'create table test(id int,info varchar(20))'</code><code>)</code>

<code>    </code><code>value</code><code>=</code><code>[</code><code>1</code><code>,</code><code>'hi rollen'</code><code>]</code>

<code>    </code><code>cur.execute(</code><code>'insert into test values(%s,%s)'</code><code>,value)</code>

<code>    </code><code>values</code><code>=</code><code>[]</code>

<code>    </code><code>for</code> <code>i </code><code>in</code> <code>range</code><code>(</code><code>20</code><code>):</code>

<code>        </code><code>values.append((i,</code><code>'hi rollen'</code><code>+</code><code>str</code><code>(i)))</code>

<code>        </code> 

<code>    </code><code>cur.executemany(</code><code>'insert into test values(%s,%s)'</code><code>,values)</code>

<code>    </code><code>cur.execute(</code><code>'update test set info="i am rollen" where id=3'</code><code>)</code>

<code>    </code><code>conn.commit()</code>

　　請注意一定要有conn.commit()這句來送出事務，要不然不能真正的插入資料。

運作之後我的mysql資料庫的結果就不上圖了。

28

29

30

31

32

33

<code>    </code><code>count</code><code>=</code><code>cur.execute(</code><code>'select * from test'</code><code>)</code>

<code>    </code><code>print</code> <code>'there has %s rows record'</code> <code>%</code> <code>count</code>

<code>    </code><code>result</code><code>=</code><code>cur.fetchone()</code>

<code>    </code><code>print</code> <code>result</code>

<code>    </code><code>print</code> <code>'id: %s info %s'</code> <code>%</code> <code>result</code>

<code>    </code><code>results</code><code>=</code><code>cur.fetchmany(</code><code>5</code><code>)</code>

<code>    </code><code>for</code> <code>r </code><code>in</code> <code>results:</code>

<code>        </code><code>print</code> <code>r</code>

<code>    </code><code>print</code> <code>'=='</code><code>*</code><code>10</code>

<code>    </code><code>cur.scroll(</code><code>0</code><code>,mode</code><code>=</code><code>'absolute'</code><code>)</code>

<code>    </code><code>results</code><code>=</code><code>cur.fetchall()</code>

<code>        </code><code>print</code> <code>r[</code><code>1</code><code>]</code>

　　運作結果就不貼了，太長了。

查詢後中文會正确顯示，但在資料庫中卻是亂碼的。經過我從網上查找，發現用一個屬性有可搞定：

在python代碼 

conn = mysqldb.connect(host='localhost', user='root', passwd='root', db='python') 中加一個屬性：

 改為：

conn = mysqldb.connect(host='localhost', user='root', passwd='root', db='python',charset='utf8') 

charset是要跟你資料庫的編碼一樣，如果是資料庫是gb2312 ,則寫charset='gb2312'。

下面貼一下常用的函數：

然後,這個連接配接對象也提供了對事務操作的支援,标準的方法

commit() 送出

rollback() 復原

cursor用來執行指令的方法:

callproc(self, procname, args):用來執行存儲過程,接收的參數為存儲過程名和參數清單,傳回值為受影響的行數

execute(self, query, args):執行單條sql語句,接收的參數為sql語句本身和使用的參數清單,傳回值為受影響的行數

executemany(self, query, args):執行單挑sql語句,但是重複執行參數清單裡的參數,傳回值為受影響的行數

nextset(self):移動到下一個結果集

cursor用來接收傳回值的方法:

fetchall(self):接收全部的傳回結果行.

fetchmany(self, size=none):接收size條傳回結果行.如果size的值大于傳回的結果行的數量,則會傳回cursor.arraysize條資料.

fetchone(self):傳回一條結果行.

scroll(self, value, mode='relative'):移動指針到某一行.如果mode='relative',則表示從目前所在行移動value條,如果 mode='absolute',則表示從結果集的第一行移動value條.