python 操作數據庫
import pymysql # 第一步：連接到數據庫 conn = pymysql.connect(host="120.78.128.25", port=3306, user="future", password="123456", charset="utf8", cursorclass = pymysql.cursors.DictCursor ) # 第二步：創建一個游標對象 cur = conn.cursor() sql = "SELECT * FROM futureloan.member LIMIT 10" # 第三步：執行sql語句 res = cur.execute(sql) print(res) # 第四步：獲取查詢到的結果 # fetchone:獲取查詢到的一條數據 data = cur.fetchone() print(data) # data1 = cur.fetchone() # print(data1) # 連接db進行增刪查改 sql = "SELECT * FROM futureloan.member LIMIT 10" # 第三步：執行sql cur.execute(sql) # 第四步：提交事務 conn.commit() # fetchall:獲取查詢到的所有數據 # datas = cur.fetchall() # print(datas)
操作DB代碼封裝
""" 封裝的需求： 1、查詢數據的方法 2、增刪改的方法 3、init方法：建立連接 """ import pymysql class HandleMysql: def __init__(self): """初始化方法中，連接到數據庫""" # 建立連接 self.con = pymysql.connect(host="120.78.128.25", port=3306, user="future", password="123456", charset="utf8", cursorclass=pymysql.cursors.DictCursor ) # 創建一個游標對象 self.cur = self.con.cursor() def find_all(self, sql): """ 查詢sql語句返回的所有數據 :param sql: 查詢的sql :return: 查詢到的所有數據 """ self.cur.execute(sql) return self.cur.fetchall() def find_one(self, sql): """ 查詢sql語句返回的第一條數據 :param sql: 查詢的sql :type sql:str :return: sql語句查詢到的第一條數據 """ self.cur.execute(sql) return self.cur.fetchone() def update(self, sql): """ 增刪改操作的方法 :param sql: 增刪改的sql語句