pymysql的简单封装代码实例
这篇文章主要介绍了pymysql的简单封装代码实例,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
#coding=utf-8
#!/usr/bin/python
importpymysql
classMYSQL:
"""
对pymysql的简单封装
"""
def__init__(self,host,user,pwd,db):
self.host=host
self.user=user
self.pwd=pwd
self.db=db
def__GetConnect(self):
"""
得到连接信息
返回:conn.cursor()
"""
ifnotself.db:
raise(NameError,"没有设置数据库信息")
self.conn=pymysql.connect(host=self.host,user=self.user,password=self.pwd,database=self.db,charset="utf8")
cur=self.conn.cursor()
ifnotcur:
raise(NameError,"连接数据库失败")
else:
returncur
defExecQuery(self,sql):
"""
执行查询语句
返回的是一个包含tuple的list，list的元素是记录行，tuple的元素是每行记录的字段
调用示例：
ms=MYSQL(host="localhost",user="sa",pwd="123456",db="PythonWeiboStatistics")
resList=ms.ExecQuery("SELECTid,NickNameFROMWeiBoUser")
for(id,NickName)inresList:
printstr(id),NickName
"""
cur=self.__GetConnect()
cur.execute(sql)
resList=cur.fetchall()
#查询完毕后必须关闭连接
self.conn.close()
returnresList
defExecNonQuery(self,sql):
"""
执行非查询语句
调用示例：
cur=self.__GetConnect()
cur.execute(sql)
self.conn.commit()
self.conn.close()
"""
cur=self.__GetConnect()
cur.execute(sql)
self.conn.commit()
self.conn.close()
defmain():
mysql=MYSQL(host="192.168.163.36",user="wisdomhr",pwd="wisdomhr",db="WISDOMHR")
resList=mysql.ExecQuery("SELECTCITYFROMRES_SCHOOL")
forinstinresList:
print(inst)
if__name__=='__main__':
main()
用法如下:
#!/usr/bin/python
#version3.4
importwispymysql
mysql=wispymysql.MYSQL(host="192.168.163.36",user="wisdomhr",pwd="wisdomhr",db="WISDOMHR")
selectsql="SELECTID,CITYFROMRES_SCHOOLWHERECITYLIKE'%\r\n%'"
result=mysql.ExecQuery(selectsql)
for(dbid,city)inresult:
rightcity=city.replace('\r\n','')
updatesql="UPDATERES_SCHOOLSETCITY='"+rightcity+"'WHEREID="+str(dbid)
print(updatesql)
mysql.ExecNonQuery(updatesql)
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持毛票票。
声明：本文内容来源于网络，版权归原作者所有，内容由互联网用户自发贡献自行上传，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任。如果您发现有涉嫌版权的内容，欢迎发送邮件至：czq8825#qq.com（发邮件时，请将#更换为@）进行举报，并提供相关证据，一经查实，本站将立刻删除涉嫌侵权内容。