新学Python，在这里分享操作MySQL的全过程
1、安装MySQL-python-1.2.3.win-amd64-py2.7.exe，这是操作mysql数据库的python库，有32位和64位之分，看自机器下载
2、64位机器安装MySQL-python-1.2.3.win-amd64-py2.7.exe出现 which was not found the regidtry，请点这里
3、引入mysql库：
4、获取数据库连接：
- conn=MySQLdb.connect(host='localhost',user='mjy',passwd='123',db='python',port=3306,charset='utf8')
connect连接对象的方法：
close() --关闭的方法
commit() --如果支持事务则提交挂起的事务
rollback() --回滚挂起的事务
cursor() --返回连接的游标对象
5、获取游标：
- #该游标对象执行查询操作返回的结果是序列
- cur=con.cursor()
- #该游标对象执行查询操作返回的结果是字典（字典可以方便我们队查询的结果进行操作，所以我采用这种方法）
- cur=con.cursor(MySQLdb.cursors.DictCursor)
游标对象的方法：
callproc(name,[params]) --用来执行存储过程，接收的参数为存储过程的名字和参数列表，返回受影响的行数
close() --关闭游标
execute(sql,[params])--执行sql语句，可以使用参数，(使用参数时，sql语句中用%s进行站位注值),返回受影响的行数
executemany(sql,params)--执行单挑sql语句，但是重复执行参数列表里的参数，返回受影响的行数
fetchone() --返回结果的下一行
fetchall() --返回结果的 所有行
fetchmany(size)--返回size条记录，如果size大于返回结果行的数量，则会返回cursor.arraysize条记录
nextset() --条至下一行
setinputsizes(size)--定义cursor
游标对象的属性：
description--结果列的描述,只读
rowcount --结果中的行数，只读
arraysize --fetchmany返回的行数，默认为1
6、我自己封装的一些基本操作
- # -*- coding: cp936 -*-
- import MySQLdb
-
- class MysqldbHelper:
- #获取数据库连接
- def getCon(self):
- try:
- conn=MySQLdb.connect(host='localhost',user='mjy',passwd='123',db='python',port=3306,charset='utf8')
- return conn
- except MySQLdb.Error,e:
- print "Mysqldb Error:%s" % e
- #查询方法，使用con.cursor(MySQLdb.cursors.DictCursor),返回结果为字典
- def select(self,sql):
- try:
- con=self.getCon()
- print con
- cur=con.cursor(MySQLdb.cursors.DictCursor)
- count=cur.execute(sql)
- fc=cur.fetchall()
- return fc
- except MySQLdb.Error,e:
- print "Mysqldb Error:%s" % e
- finally:
- cur.close()
- con.close()
- #带参数的更新方法,eg:sql='insert into pythontest values(%s,%s,%s,now()',params=(6,'C#','good book')
- def updateByParam(self,sql,params):
- try:
- con=self.getCon()
- cur=con.cursor()
- count=cur.execute(sql,params)
- con.commit()
- return count
- except MySQLdb.Error,e:
- con.rollback()
- print "Mysqldb Error:%s" % e
- finally:
- cur.close()
- con.close()
- #不带参数的更新方法
- def update(self,sql):
- try:
- con=self.getCon()
- cur=con.cursor()
- count=cur.execute(sql)
- con.commit()
- return count
- except MySQLdb.Error,e:
- con.rollback()
- print "Mysqldb Error:%s" % e
- finally:
- cur.close()
- con.close()
-
- if __name__ == "__main__":
- db=MysqldbHelper()
- def get():
- sql="select * from pythontest"
- fc=db.select(sql)
- for row in fc:
- print row["ptime"]
-
- def ins():
- sql="insert into pythontest values(5,'数据结构','this is a big book',now())"
- count=db.update(sql)
- print count
- def insparam():
- sql="insert into pythontest values(%s,%s,%s,now())"
- params=(6,'C#','good book')
- count=db.updateByParam(sql,params)
- print count
- def delop():
- sql="delete from pythontest where pid=4"
- count=db.update(sql)
- print "the："+str(count)
- def change():
- sql="update pythontest set pcontent='c# is a good book' where pid=6"
- count=db.update(sql)
- print count
-
- #get()
- #ins()
- #insparam()
- #delop()
- #change()
-
-
-
-
-
附查询结果：
本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系:hwhale#tublm.com(使用前将#替换为@)
