# -*- coding:utf-8 -*-# Author:Hy# @Time :2018/2/1610:24import pymysql # 封装类class MysqlHelp(object): # 构造 def __init__(self, host, user, passwd, db, port=3306): self.host = host self.user = user self.port = port self.passwd = passwd self.db = db # 创建连接 def open_coon(self): self.coon = pymysql.connect(host=self.host, port=self.port, user=self.user, passwd=self.passwd, db=self.db) self.cursor = self.coon.cursor() # 关闭连接 def close(self): self.cursor.close() self.coon.cursor() # 调用语句 def insert_delete_update(self, sql, params): try: self.open_coon() self.cursor.execute(sql, params=[]) print("OK") self.coon.commit() self.close() except Exception as erorr: print(erorr) # 查询 接收全部的返回结果行 def select_fetchall(self, sql, params=[]): try: self.open_coon() self.cursor.execute(sql, params) results = self.cursor.fetchall() self.coon.commit() self.close() return results except Exception as erorr: print(erorr)
原文地址:https://www.cnblogs.com/hyn934/p/8874245.html
时间: 2024-07-29 13:27:30