您的位置:首页 > 编程语言 > Python开发

python操作mysql

2016-02-27 00:00 1046 查看
摘要: 需要安装 mysql fro python 上链接 https://sourceforge.net/projects/mysql-python/?source=typ_redirect 选择合适的版本。我的是win32 若是安装找不到路径,上一篇博客有处理 http://my.oschina.net/u/2411815/blog/625031执行python文件即可
#测试模块安装
# -*- coding: UTF-8 -*-

import MySQLdb
print MySQLdb
#打印正常安装成功

测试连接mysql

# -*- coding: UTF-8 -*-

import MySQLdb
# print MySQLdb

conn = MySQLdb.Connect(host='127.0.0.1',port=3306,user='username',passwd='pwd',db='your_db',charset='utf8')
cursor = conn.cursor()

print conn
print cursor
cursor.close()
conn.close()
#输出正常

查询数据测试

#!/usr/bin/python
# -*- coding: UTF-8 -*-
import MySQLdb

conn = MySQLdb.Connect(host='xx',port=3306,user='xx',passwd='xx',db='xx',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()

#事务部分
try:
cursor.execute(insert_sql)
print cursor.rowcount
cursor.execute(delete_sql)
print cursor.rowcount

conn.commit()
exception Exception as e:
print e
conn.rollback()

#!/usr/bin/env python
#coding:utf-8

import MySQLdb

'''
conn = MySQLdb.connect(host='127.0.0.1',user='root',passwd='1234',db='07day05db')

cur = conn.cursor()

reCount = cur.execute('insert into UserInfo(Name,Address) values(%s,%s)',('alex','usa'))

conn.commit()

cur.close()
conn.close()

print reCount
'''

'''
conn = MySQLdb.connect(host='127.0.0.1',user='root',passwd='1234',db='07day05db')

cur = conn.cursor()

reCount = cur.execute('delete from UserInfo')

conn.commit()

cur.close()

conn.close()

print reCount
'''

'''
conn = MySQLdb.connect(host='127.0.0.1',user='root',passwd='1234',db='07day05db')
cur = conn.cursor()

li =[
('alex','usa'),
('sb','usa'),
]
reCount = cur.executemany('insert into UserInfo(Name,Address) values(%s,%s)',li)

conn.commit()
cur.close()
conn.close()

print reCount
'''

'''
conn = MySQLdb.connect(host='127.0.0.1',user='root',passwd='1234',db='07day05db')
cur = conn.cursor()

reCount = cur.execute('update UserInfo set Name = %s',('alin',))

conn.commit()
cur.close()
conn.close()

print reCount
'''

'''
#fetchone/fetchmany(num)
conn = MySQLdb.connect(host='127.0.0.1',user='root',passwd='1234',db='07day05db')
cur = conn.cursor()

reCount = cur.execute('select * from UserInfo')

print cur.fetchone()
print cur.fetchone()
cur.scroll(-1,mode='relative')
print cur.fetchone()
print cur.fetchone()
cur.scroll(0,mode='absolute')
print cur.fetchone()
print cur.fetchone()

cur.cl
3fe8
ose()
conn.close()

print reCount
'''

#fetchall

conn = MySQLdb.connect(host='127.0.0.1',user='root',passwd='1234',db='07day05db')
#cur = conn.cursor(cursorclass = MySQLdb.cursors.DictCursor)
cur = conn.cursor()

reCount = cur.execute('select Name,Address from UserInfo')

nRet = cur.fetchall()

cur.close()
conn.close()

print reCount
print nRet
for i in nRet:
print i[0],i[1]
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: