# 1. 導(dǎo)入模塊
import pymysql

# 創(chuàng)建自定義上下文管理器對(duì)象
class MyDatabase(object):
 # 接收參數(shù)并創(chuàng)建數(shù)據(jù)庫(kù)連接對(duì)象
 def __init__(self, host, port, user, passwd, database):
  self.__db = pymysql.Connection(host, port, user, passwd, database, charset='utf8')

 # 返回?cái)?shù)據(jù)庫(kù)連接對(duì)象
 def __enter__(self):
  return self.__db

 # 關(guān)閉數(shù)據(jù)庫(kù)連接
 def __exit__(self, exc_type, exc_val, exc_tb):
  self.__db.close()


def main():
 # 使用with關(guān)鍵字接收enter返回的對(duì)象給db
 with MyDatabase('localhost', 3306, 'root', 'mysql', 'JDDB') as db:
  # 利用db創(chuàng)建游標(biāo)
  cur = db.cursor()
  sql = '''select * from %s'''
  cur.execute(sql, (goods,))
  result = cur.fetchall()
  for i in result:
   print(i)
  # 關(guān)閉游標(biāo)
  cur.close()

# 程序入口
if __name__ == '__main__':
 main()

# 1.導(dǎo)入socket模塊
import socket


class MySocket(object):
 # 2.編寫(xiě)init方法接收port參數(shù)
 def __init__(self, port):
  self.__port = port
  # 3.創(chuàng)建socket對(duì)象
  self.__sk = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

 # 4.編寫(xiě)enter方法返回套接字對(duì)象
 def __enter__(self):
  # 設(shè)置端口復(fù)用
  self.__sk.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, True)
  # 綁定端口
  self.__sk.bind(self.__port)
  # 設(shè)置端口監(jiān)聽(tīng)
  self.__sk.listen(128)
  # 返回套接字對(duì)象
  return self.__sk

 # 5.編寫(xiě)exit方法關(guān)閉套接字對(duì)象
 def __exit__(self, exc_type, exc_val, exc_tb):
  self.__sk.close()


def main():
 # 使用with關(guān)鍵字 并接受返回的套接字對(duì)象給sk
 with MySocket(8000) as sk:
  # 等待客戶(hù)端連接
  clicent, ip_port = sk.accept()
  recv_data = clicent.recv(1024)
  print(recv_data.decode('utf-8'))
  # 編寫(xiě)HTTP響應(yīng)報(bào)文
  http_line = 'HTTP/1.1 GET 200 OK\r\n'
  http_header = 'Server PWS/1.0\r\n'
  http_body = 'Welcome to index!\r\n'
  send_data = (http_line + http_header + '\r\n' + http_body).encode('utf-8')
  clicent.send(send_data)
  # 關(guān)閉客戶(hù)端連接
  clicent.close()

# 編寫(xiě)程序入口
if __name__ == '__main__':
 main()