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