安装
Windows : pip install pymysql -i https://pypi.douban.com/simple
mac :python3 -m pip install pymysql -i https://pypi.douban.com/simple
mysql示例
import pymysql
connect = pymysql.Connect(host='82.156.74.26',port=3306,user='root',password='Testfan#123',charset='utf8mb4', cursorclass=pymysql.cursors.DictCursor) # 创建游标
cursor = connect.cursor()
# 执行sql语句
cursor.execute('select id from table')
# # 获取查询所有结果
data = cursor.fetchall()
# 关闭游标
cursor.close()
# 关闭数据库连接
connect.close()
也可以直接封装数据库,下次可以直接调用方法,更方便一点
import pymysqlconnect = pymysql.Connect(host='127.0.0.1',port=3306,user='root',password='123456',charset='utf8mb4',cursorclass=pymysql.cursors.DictCursor)
# 创建游标对象
cursor = connect.cursor()
# sql执行 查询 根据order_id 查询trade_sn
cursor.execute('select id from table1')
# 获取查询结果
data = cursor.fetchall()
# 关闭游标
cursor.close()
# 提交数据
connect.commit()
# 关闭连接
connect.close()# 封装数据库的方法
class DBUtil:def __init__(self,host,user,password,port=3306):#self.connect = pymysql.Connect(host=host,port=port,user=user,password=password,charset='utf8mb4',cursorclass=pymysql.cursors.DictCursor)# 创建查询方法 sqldef select(self,sql):# 创建游标对象cursor = self.connect.cursor()#sql执行cursor.execute(sql)#获取查询数据data = cursor.fetchall()# 提交数据 下次有可能查不到新数据self.connect.commit()cursor.close()return data# 关闭连接def close(self):if self.connect != None:self.connect.close()