python & pandas链接mysql数据库

Python&pandas与mysql连接

1、python 与mysql 连接及操作，直接上代码，简单直接高效：

 1 import MySQLdb
 2
 3 try:
 4
 5     conn = MySQLdb.connect(host=‘localhost‘,user=‘root‘,passwd=‘××××ב,db=‘test‘,charset=‘utf8‘)
 6
 7     cur = conn.cursor()
 8
 9     cur.execute(‘create table user(id int,name varchar(20))‘ )
10
11
12
13     value = [1,‘jkmiao‘]
14
15     cur.execute("insert into user values(%s,%s)",value)
16
17
18
19     users = []
20
21
22
23     for i in range(20):
24
25         users.append((i,"user"+str(i)))
26
27
28
29     cur.executemany("insert into user values(%s,%s)",users)
30
31
32
33     cur.execute("update user set name="test" where id=2")
34
35
36
37     res = cur.fetchone()
38
39     print res
40
41
42
43     res = cur.fetchmany(10)
44
45     print res
46
47
48
49     print cur.fetchall()
50
51
52
53     conn.commit()
54
55     cur.close()
56
57     conn.close()
58
59     cur.execute(‘select * from user‘)
60
61     cur.close()
62
63     conn.close()
64
65 except MySQLdb.Error,e:
66
67      print "Mysql Error %d: %s" % (e.args[0], e.args[1])  

2、pandas 连接操作mysql：

 1 import pandas as pd
 2
 3 import MySQLdb
 4
 5
 6
 7 conn = MySQLdb.connect(host="localhot",user="root",passwd="*****",db="test",charset="utf8")
 8
 9
10
11 # read
12
13 sql = "select * from user limit 3"
14
15 df = pd.read_sql(sql,conn,index_col="id")
16
17 print df
18
19
20
21 # write
22
23 cur = conn.cursor()
24
25 cur.execute("drop table if exists user")
26 cur.execute(‘create table user(id int,name varchar(20))‘ )
27 pd.io.sql.write_frame(df,"user",conn)