python 操作数据库
import pymysql
# 第一步：连接到数据库
conn = pymysql.connect(host="120.78.128.25",
port=3306,
user="future",
password="123456",
charset="utf8",
cursorclass = pymysql.cursors.DictCursor
)
# 第二步：创建一个游标对象
cur = conn.cursor()
sql = "SELECT * FROM futureloan.member LIMIT 10"
# 第三步：执行sql语句
res = cur.execute(sql)
print(res)
# 第四步：获取查询到的结果
# fetchone:获取查询到的一条数据
data = cur.fetchone()
print(data)
# data1 = cur.fetchone()
# print(data1)
# 连接db进行增删查改
sql = "SELECT * FROM futureloan.member LIMIT 10"
# 第三步：执行sql
cur.execute(sql)
# 第四步：提交事务
conn.commit()
# fetchall:获取查询到的所有数据
# datas = cur.fetchall()
# print(datas)
操作DB代码封装
"""
封装的需求：
1、查询数据的方法
2、增删改的方法
3、init方法：建立连接
"""
import pymysql
class HandleMysql:
def __init__(self):
"""初始化方法中，连接到数据库"""
# 建立连接
self.con = pymysql.connect(host="120.78.128.25",
port=3306,
user="future",
password="123456",
charset="utf8",
cursorclass=pymysql.cursors.DictCursor
)
# 创建一个游标对象
self.cur = self.con.cursor()
def find_all(self, sql):
"""
查询sql语句返回的所有数据
:param sql: 查询的sql
:return: 查询到的所有数据
"""
self.cur.execute(sql)
return self.cur.fetchall()
def find_one(self, sql):
"""
查询sql语句返回的第一条数据
:param sql: 查询的sql
:type sql:str
:return: sql语句查询到的第一条数据
"""
self.cur.execute(sql)
return self.cur.fetchone()
def update(self, sql):
"""
增删改操作的方法
:param sql: 增删改的sql语句