当前位置：首页 > news >正文

python---数据库操作

news 来源：原创 2024/11/18 2:20:02

在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("糖豆","喵喵")