python操作mysql数据库封装类


import pymysql

#数据库查询
class QuerySqlData(object):

    def __init__(self):
        self.conn = pymysql.connect(
            host='ip',
            port=3306,
            user='#',
            passwd='#',
            db='#',
            charset='utf8')   # 创建连接

    def find_table(self,sql,bid):
        cursor = self.conn.cursor()   # 创建连接
        try:
            cursor.execute(sql, bid)  # 执行SQL
            results = cursor.fetchall();  # 返回查询数据
            self.conn.commit()  # 提交,不然无法保存新建或者修改的数据
        except:
            print("数据连接错误-find_table")
        finally:
            cursor.close()  # 关闭游标
            self.conn.close()  # 关闭连接
        return resultsif __name__ == '__main__':
    querySqlData = QuerySqlData()
    value = {"userid":"aa"}
    a = querySqlData.find_table('SELECT * from t_user u where u.userid=%(userid)s',value)
    print(a)

 


免责声明!

本站转载的文章为个人学习借鉴使用,本站对版权不负任何法律责任。如果侵犯了您的隐私权益,请联系本站邮箱yoyou2525@163.com删除。



 
粤ICP备18138465号  © 2018-2025 CODEPRJ.COM