Python操作mysql数据库

技术教程gslnedu2025-01-16 10:23:3619A⁺A^-

建立数据连接

其实使用pymysql进行数据库的连接是非常简单的，第一步就是建立数据库连接（在python当中，这其实更像是使用了一个代理）

import pymysql

try:
    #建立连接
    conn=pymysql.connect(
        host='127.0.0.1',port=3306,user='Huterox',
        passwd='passwd',db='huterox',charset='utf8'
    )
except pymysql.Error as err:
    print(err)
复制代码

操作流程

下面为了更好的理解相关操作，请看下面的流程图，它将很好地反映这个pymysql的操作方式。

使用游标执行sql语句

数据增，删除，改

这个数据的查询和这几个是不太一样的，说以下面再说。先展示以先当前的演示环境

现在我们在这里面插入数据


 Sqlcomm = """insert into hello(name,age) value(%s,%s)"""
 cursor.execute(Sqlcomm,("xx",15))

复制代码

import pymysql

#建立连接
conn=pymysql.connect(
    host='127.0.0.1',port=3306,user='Huterox',
    passwd='865989840',db='huterox',charset='utf8'
)
cursor = conn.cursor()

try:

    Sqlcomm = """insert into hello(name) value(%s)"""
    cursor.execute(Sqlcomm,("小刚"))

    conn.commit()#提交
except pymysql.Error as err:
    conn.rollback()#回滚
    print(err)
finally:
    conn.close()
复制代码

现在已经加入了，这一条，那么现在添加age和heigh的值

update hello set age=15,heigh=185 where name=%s
复制代码

import pymysql

#建立连接
conn=pymysql.connect(
    host='127.0.0.1',port=3306,user='Huterox',
    passwd='865989840',db='huterox',charset='utf8'
)
cursor = conn.cursor()

try:

    Sqlcomm = """update hello set age=15,heigh=185 where name=%s"""
    res = cursor.execute(Sqlcomm,（"小刚")）
    if res==1:
        #一条受影响，返回一
        print("修改成功")
    conn.commit()#提交
except pymysql.Error as err:
    conn.rollback()#回滚
    print(err)
finally:
    conn.close()
复制代码

接下来就是删除了，那还不简单

delete from hello where name=’小刚‘
复制代码

数据的查找

这个就有点区别了看代码

import pymysql

#建立连接
conn=pymysql.connect(
    host='127.0.0.1',port=3306,user='Huterox',
    passwd='865989840',db='huterox',charset='utf8'
)
cursor = conn.cursor()

try:

    Sqlcomm = """select name as 名字,age as 年龄, heigh as 身高 from hello"""
    cursor.execute(Sqlcomm)
    for row in cursor.fetchall():
        
        print(row)

    conn.commit()#提交
except pymysql.Error as err:
    conn.rollback()#回滚
    print(err)
finally:
    conn.close()
复制代码

cursor 有三个方法获取结果

这个一目了然，fetchall()就是全部结果这个返回结果是一个大元组，里面都是一个个小元组

那么在这里的化还可以设置为字典，也最好设置为字典。

conn=pymysql.connect(
    host='127.0.0.1',port=3306,user='Huterox',
    passwd='pw',db='huterox',charset='utf8',
    cursorclass=pymysql.cursors.DictCursor
)
复制代码