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

import pymysql class DB: __host = ’localhost’ # 服務(wù)器地址 __username = ’root’ # 用戶名 __password = ’’ # 密碼 __database = ’test’ # 數(shù)據(jù)庫(kù) __field = ’*’ # 查詢字段 __where = ’’ # 條件 __sql = False # 是否返回sql __join = ’’ # 聯(lián)表 __order = ’’ # 排序 __limit = ’’ # 數(shù)量 # 構(gòu)造函數(shù)，在生成對(duì)象時(shí)調(diào)用 def __init__(self, table): try: # 打開(kāi)數(shù)據(jù)庫(kù)連接 host, username, password, database self.db = pymysql.connect(self.__host, self.__username, self.__password, self.__database) except Exception as e: print(e) exit() # 使用 cursor() 方法創(chuàng)建一個(gè)游標(biāo)對(duì)象 cursor self.cursor = self.db.cursor() self.table = table # 析構(gòu)函數(shù)，釋放對(duì)象時(shí)使用 def __del__(self): try: # 關(guān)閉數(shù)據(jù)庫(kù)連接 self.db.close() except Exception as e: print(e) # 得到當(dāng)前sql語(yǔ)句 def getSql(self): self.__sql = True return self # 字段 def field(self, str): self.__field = str return self # 聯(lián)表 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 # 數(shù)量 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: # 執(zhí)行sql語(yǔ)句 ret = self.cursor.execute(sql) # 提交到數(shù)據(jù)庫(kù)執(zhí)行 self.db.commit() return ret except Exception as e: # 如果發(fā)生錯(cuò)誤則回滾 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: # 執(zhí)行sql語(yǔ)句 ret = self.cursor.execute(sql) # 提交到數(shù)據(jù)庫(kù)執(zhí)行 self.db.commit() return ret except Exception as e: # 如果發(fā)生錯(cuò)誤則回滾 self.db.rollback() print(e) return 0 else: raise BaseException(’沒(méi)有條件’) # 拋異常 # 修改 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: # 執(zhí)行sql語(yǔ)句 ret = self.cursor.execute(sql) # 提交到數(shù)據(jù)庫(kù)執(zhí)行 self.db.commit() return ret except Exception as e: # 如果發(fā)生錯(cuò)誤則回滾 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() 方法執(zhí)行 SQL 查詢 self.cursor.execute(sql) # 使用 fetchall() 方法獲取所有數(shù)據(jù). 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’, ’趙一’, ’男’, ’學(xué)生’, ’8’, ’120’, ’35’);INSERT INTO `people` VALUES (’2’, ’錢二’, ’女’, ’學(xué)生’, ’9’, ’111’, ’31’);INSERT INTO `people` VALUES (’3’, ’孫三’, ’男’, ’學(xué)生’, ’10’, ’123’, ’34’);INSERT INTO `people` VALUES (’4’, ’李四’, ’女’, ’學(xué)生’, ’11’, ’100’, ’30’);’’’db = DB(’people’) # 增加dict = {’name’: ’周五’, ’sex’: ’男’, ’job’: ’學(xué)生’, ’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) # 查詢 優(yōu)化where條件 ’id<11’# data = db.field(’id,name,age,job’).where([[’id’, ’>’, 1]]).order(’id desc’).limit(’3’).select()# print(data)

補(bǔ)充知識(shí)：python DB API cursor 常用接口

1. description

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

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

2. rowcount

代表的是在執(zhí)行了 sql 語(yǔ)句后受影響的行數(shù)。

3. close

關(guān)閉游標(biāo)。關(guān)閉游標(biāo)以后就再也不能使用了，否則會(huì)拋出異常。

4. execute(sql[,parameters])

執(zhí)行某個(gè) sql 語(yǔ)句。如果在執(zhí)行 sql 語(yǔ)句的時(shí)候還需要傳遞參數(shù)，那么可以傳給 parameters 參數(shù)。示例代碼如下：

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

5. fetchone

在執(zhí)行了查詢操作以后，獲取第一條數(shù)據(jù)。

6. fetchmany(size)

在執(zhí)行查詢操作以后，獲取多條數(shù)據(jù)。具體是多少條要看傳的 size 參數(shù)。如果不傳 size 參數(shù)，那么默認(rèn)是獲取第一條數(shù)據(jù)。

7. fetchall

獲取所有滿足 sql 語(yǔ)句的數(shù)據(jù)。

以上這篇python db類用法說(shuō)明就是小編分享給大家的全部?jī)?nèi)容了，希望能給大家一個(gè)參考，也希望大家多多支持好吧啦網(wǎng)。