我就廢話不多說了，大家還是直接看代碼吧~

import pymysql class DB: __host = ’localhost’ # 服務器地址 __username = ’root’ # 用戶名 __password = ’’ # 密碼 __database = ’test’ # 數據庫 __field = ’*’ # 查詢字段 __where = ’’ # 條件 __sql = False # 是否返回sql __join = ’’ # 聯表 __order = ’’ # 排序 __limit = ’’ # 數量 # 構造函數，在生成對象時調用 def __init__(self, table): try: # 打開數據庫連接 host, username, password, database self.db = pymysql.connect(self.__host, self.__username, self.__password, self.__database) except Exception as e: print(e) exit() # 使用 cursor() 方法創建一個游標對象 cursor self.cursor = self.db.cursor() self.table = table # 析構函數，釋放對象時使用 def __del__(self): try: # 關閉數據庫連接 self.db.close() except Exception as e: print(e) # 得到當前sql語句 def getSql(self): self.__sql = True return self # 字段 def field(self, str): self.__field = str return self # 聯表 def join(self, table, where): self.__join = ’ LEFT JOIN ’ + table + ’ ON ’ + where + ’ ’ return self # 條件 def where(self, param): self.__where = ’ WHERE ’ if isinstance(param, list): for i in param: if isinstance(i[2], list): tmp = ’(’ for j in i[2]: tmp += str(j) + ’,’ tmp += ’)’ self.__where += ’`’ + i[0] + ’` ’ + i[1] + ’ ’ + tmp + ’ AND ’ else: self.__where += ’`’ + i[0] + ’` ’ + i[1] + ’ ’ + str(i[2]) + ’ AND ’ else: self.__where = self.__where[0:-4] else: self.__where += param return self # 排序 def order(self, str): self.__order = ’ ORDER BY ’ + str return self # 數量 def limit(self, str): self.__limit = ’ LIMIT ’ + str return self # 增加 def insert(self, dict): key = value = ’’ for k, v in dict.items(): key += ’`’ + k + ’`,’ value += ’'’ + v + ’',’ key = key[0:-1] value = value[0:-1] sql = ’INSERT INTO ’ + self.table + ’ (’ + key + ’) VALUES (’ + value + ’)’ if self.__sql: return sql try: # 執行sql語句 ret = self.cursor.execute(sql) # 提交到數據庫執行 self.db.commit() return ret except Exception as e: # 如果發生錯誤則回滾 self.db.rollback() print(e) return 0 # 刪除 def delete(self): if self.__where: sql = 'DELETE FROM ' + self.table + self.__where if self.__sql: return sql try: # 執行sql語句 ret = self.cursor.execute(sql) # 提交到數據庫執行 self.db.commit() return ret except Exception as e: # 如果發生錯誤則回滾 self.db.rollback() print(e) return 0 else: raise BaseException(’沒有條件’) # 拋異常 # 修改 def update(self, dict): str = ’’ for k, v in dict.items(): str += ’`’ + k + ’`='’ + v + ’',’ str = str[0:-1] sql = ’UPDATE ’ + self.table + ’ SET ’ + str if self.__where: sql += self.__where if self.__sql: return sql try: # 執行sql語句 ret = self.cursor.execute(sql) # 提交到數據庫執行 self.db.commit() return ret except Exception as e: # 如果發生錯誤則回滾 self.db.rollback() print(e) return 0 # 查詢 def select(self): sql = 'SELECT ' + self.__field + ' FROM ' + self.table if self.__join: sql += self.__join if self.__where: sql += self.__where if self.__order: sql += self.__order if self.__limit: sql += self.__limit if self.__sql: return sql # 使用 execute() 方法執行 SQL 查詢 self.cursor.execute(sql) # 使用 fetchall() 方法獲取所有數據. data = self.cursor.fetchall() return data’’’DROP TABLE IF EXISTS `people`;CREATE TABLE `people` ( `id` int(11) unsigned NOT NULL AUTO_INCREMENT, `name` varchar(20) CHARACTER SET utf8mb4 COLLATE utf8mb4_bin NOT NULL COMMENT ’名字’, `sex` varchar(7) DEFAULT ’’ COMMENT ’性別’, `job` varchar(6) DEFAULT ’’ COMMENT ’工作’, `age` varchar(6) DEFAULT ’’ COMMENT ’年齡’, `height` varchar(6) DEFAULT ’’ COMMENT ’身高’, `weight` varchar(6) DEFAULT ’’ COMMENT ’體重’, PRIMARY KEY (`id`)) ENGINE=InnoDB AUTO_INCREMENT=5 DEFAULT CHARSET=utf8;INSERT INTO `people` VALUES (’1’, ’趙一’, ’男’, ’學生’, ’8’, ’120’, ’35’);INSERT INTO `people` VALUES (’2’, ’錢二’, ’女’, ’學生’, ’9’, ’111’, ’31’);INSERT INTO `people` VALUES (’3’, ’孫三’, ’男’, ’學生’, ’10’, ’123’, ’34’);INSERT INTO `people` VALUES (’4’, ’李四’, ’女’, ’學生’, ’11’, ’100’, ’30’);’’’db = DB(’people’) # 增加dict = {’name’: ’周五’, ’sex’: ’男’, ’job’: ’學生’, ’age’: ’8’, ’height’: ’121’, ’weight’: ’32’}data = db.insert(dict)print(data) # 刪除# data = db.where(’id=6’).delete()# print(data) # 修改# dict = {’age’: ’9’, ’height’: ’121’, ’weight’: ’31’}# data = db.where(’id=7’).update(dict)# print(data) # 查詢 優化where條件 ’id<11’# data = db.field(’id,name,age,job’).where([[’id’, ’>’, 1]]).order(’id desc’).limit(’3’).select()# print(data)

補充知識：python DB API cursor 常用接口

1. description

如果 cursor 執行了查詢的 sql 代碼。那么讀取 cursor.description 屬性的時候，將返回一個列表，這個列表中裝的是元組，元組中裝的分別

是 (name,type_code,display_size,internal_size,precision,scale,null_ok) ，其中 name 代表的是查找出來的數據的字段名稱，其他參數暫時用處不大。

2. rowcount

代表的是在執行了 sql 語句后受影響的行數。

3. close

關閉游標。關閉游標以后就再也不能使用了，否則會拋出異常。

4. execute(sql[,parameters])

執行某個 sql 語句。如果在執行 sql 語句的時候還需要傳遞參數，那么可以傳給 parameters 參數。示例代碼如下：

cursor.execute('select * from article where id=%s',(1,))

5. fetchone

在執行了查詢操作以后，獲取第一條數據。

6. fetchmany(size)

在執行查詢操作以后，獲取多條數據。具體是多少條要看傳的 size 參數。如果不傳 size 參數，那么默認是獲取第一條數據。

7. fetchall

獲取所有滿足 sql 語句的數據。

以上這篇python db類用法說明就是小編分享給大家的全部內容了，希望能給大家一個參考，也希望大家多多支持好吧啦網。