在python中，使用第三方库pymysql来执行数据库操作
命令行窗口输入 ：pip install pymysql，下载第三方库
数据库查询操作
Python查询Mysql使用 fetchone() 方法获取单条数据, 使用fetchall() 方法获取多条数据。
- fetchone(): 该方法获取下一个结果行
- fetchall():接收全部的返回结果行，
- rowcount: 这是一个只读属性，并返回执行execute()方法后影响的行数。
#1、从第三方库 导入数据库连接
from pymysql import Connection
#2、连接数据库
con=Connection(
host="localhost", #主机地址
port=3306, #端口号 mysql的默认端口3306
user="root", #用户名
password="1234" #密码
)
#3、选择数据库
con.select_db("products")
#4、获取游标对象
cursion=con.cursor()
#5、通过游标对象操作数据库
sql="select * from user"
rowcount=cursion.execute(sql) #执行sql语句
print("受到影响的条数",{rowcount})
result=cursion.fetchone() #查询单条数据
print(result)
#6、关闭数据库
con.close()
#1、从第三方库 导入数据库连接
from pymysql import Connection
#2、连接数据库
con=Connection(
host="localhost", #主机地址
port=3306, #端口号 mysql的默认端口3306
user="root", #用户名
password="1234" #密码
)
#3、选择数据库
con.select_db("products")
#4、获取游标对象
cursion=con.cursor()
#5、通过游标对象操作数据库
sql="select * from user"
rowcount=cursion.execute(sql) #执行sql语句
print("受到影响的条数",{rowcount})
result=cursion.fetchall() #查询所有数据
for x in result:
print(x)
#6、关闭数据库
con.close()
数据库插入操作
pymysql默认要手动提交修改，需要自己提交
在Python数据库编程中，当游标建立之时，就自动开始了一个隐形的数据库事务。
commit()方法游标的所有更新操作，rollback（）方法回滚当前游标的所有操作。
#1、从第三方库 导入数据库连接
from pymysql import Connection
#2、连接数据库
con=Connection(
host="localhost", #主机地址
port=3306, #端口号 mysql的默认端口3306
user="root", #用户名
password="1234" #密码
)
#3、选择数据库
con.select_db("products")
#4、获取游标对象
cursor=con.cursor()
#5、通过游标对象操作数据库
sql="insert user values(%s,%s)" % ("'汪汪'","'123'") #传入内容是字符串 需要携带引号
print(sql)
try:
# 执行sql语句
cursor.execute(sql)
# 提交到数据库执行
con.commit()
except:
# 发生错误时回滚
con.rollback()
rowcount=cursor.execute(sql) #执行sql语句
print("受到影响的条数",{rowcount})
#6、关闭数据库
con.close()
除了手动提交之外，还可以在创建连接时直接说明自动提交
con=Connection(
host="localhost", #主机地址
port=3306, #端口号 mysql的默认端口3306
user="root", #用户名
password="1234", #密码
autocommit=True #设置自动提交
)动态传参
使用占位符来占位，动态填入参数
from pymysql import Connection
class A:
age=0
#1、从第三方库 导入数据库连接
def a(self,name,age):
# 2、连接数据库
con = Connection(
host="localhost", # 主机地址
port=3306, # 端口号 mysql的默认端口3306
user="root", # 用户名
password="1234", # 密码
autocommit=True # 设置自动提交
)
# 3、选择数据库
con.select_db("products")
# 4、获取游标对象
cursor = con.cursor()
#5、通过游标对象操作数据库
sql = "insert user values('%s','%s')" % (name,age) # 传入内容是字符串 需要携带引号
print(sql)
try:
# 执行sql语句
cursor.execute(sql)
# 提交到数据库执行
con.commit()
except:
# 发生错误时回滚
con.rollback()
rowcount = cursor.execute(sql) # 执行sql语句
print("受到影响的条数", {rowcount})
# 6、关闭数据库
con.close()
A().a("糖豆","喵喵")
