码迷,mamicode.com
首页 > 数据库 > 详细

python & pandas链接mysql数据库

时间:2016-06-08 10:27:56      阅读:575      评论:0      收藏:0      [点我收藏+]

标签:

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)

 

 技术分享

python & pandas链接mysql数据库

标签:

原文地址:http://www.cnblogs.com/huiyang865/p/5569087.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!