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:
   # 打開數(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語句
 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語句
   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語句
    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('沒有條件') # 拋異常
 
 # 修改
 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語句
   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)