Python 數據處理擴展包： pandas 模塊的DataFrame介紹（讀寫數據庫的操作）

1、讀取表中的內容，如下例子：

import MySQLdb
try:
    conn = MySQLdb.connect(host='127.0.0.1',user='root',passwd='root',db='mydb',port=3306)
    df = pd.read_sql('select * from test;', con=conn) 
    conn.close()
    print "finish load db"
except MySQLdb.Error,e:
    print e.args[1]

注意，上面read_sql方法返回的數據的類型是DataFrame

 

2、寫入數據到表中，如下例子

df = pd.DataFrame([[1,'xxx'],[2,'yyy']],columns=list('ab'))

try:
    conn = MySQLdb.connect(host='127.0.0.1',user='root',passwd='root',db='mydb',port=3306)
    df.to_sql('test1',conn,flavor='mysql') 
    conn.close()
    print "finish load db"
except MySQLdb.Error,e:
    print e.args[1]

說明：上面代碼要求表test1不能存在