pymysql的简单封装代码实例

数据库  /  管理员 发布于 6年前   265

这篇文章主要介绍了pymysql的简单封装代码实例,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下

#coding=utf-8 #!/usr/bin/pythonimport pymysqlclass MYSQL:  """  对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()    """    if not self.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()    if not cur:      raise(NameError,"连接数据库失败")    else:      return cur  def ExecQuery(self,sql):    """    执行查询语句    返回的是一个包含tuple的list，list的元素是记录行，tuple的元素是每行记录的字段    调用示例：        ms = MYSQL(host="localhost",user="sa",pwd="123456",db="PythonWeiboStatistics")        resList = ms.ExecQuery("SELECT id,NickName FROM WeiBoUser")        for (id,NickName) in resList:          print str(id),NickName    """    cur = self.__GetConnect()    cur.execute(sql)    resList = cur.fetchall()    #查询完毕后必须关闭连接    self.conn.close()    return resList  def ExecNonQuery(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()def main():  mysql = MYSQL(host="192.168.163.36",user="wisdomhr",pwd="wisdomhr",db="WISDOMHR")  resList = mysql.ExecQuery("SELECT CITY FROM RES_SCHOOL")  for inst in resList:    print(inst)if __name__ == '__main__':  main()

用法如下:

#!/usr/bin/python#version 3.4import wispymysqlmysql = wispymysql.MYSQL(host="192.168.163.36",user="wisdomhr",pwd="wisdomhr",db="WISDOMHR")selectsql = "SELECT ID, CITY FROM RES_SCHOOL WHERE CITY LIKE '%\r\n%'"result = mysql.ExecQuery(selectsql)for (dbid, city) in result:  rightcity = city.replace('\r\n','')  updatesql= "UPDATE RES_SCHOOL SET CITY = '" + rightcity + "' WHERE ID = " + str(dbid)  print(updatesql)  mysql.ExecNonQuery(updatesql)

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。