python操作mysql（增删改查），一遍就过

112 阅读 0 评论 74 点赞

我是靠谱客的博主忐忑水池，这篇文章主要介绍python操作mysql（增删改查），一遍就过，现在分享给大家，希望可以做个参考。

python连接mysql数据库

1、创建一个专门用于存放数据库的包（我在pycharm上创建了一个叫python mysql文件夹）
2、在python mysql文件夹创建.py文件，目录像这样
在这里插入图片描述 3、开始代码编写

创建数据库表（create table.py）

复制代码

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
# 创建表
#导入pymysql模块
import pymysql
#创建连接
#host和port一般默认localhost、3306
con=pymysql.connect(host='localhost',user='用户名',password='密码',database='数据库名',port=3306)
#创建游标对象
cur=con.cursor()
#创建表的sql语句
sql="""
    create table students(
     sno int primary key auto_increment,
     sname varchar(30) not null,
     age int(2),
     score float(3,1)
    )
"""
try:
    # 执行创建表的sql
    cur.execute(sql)
    print('创建表成功')
except Exception as e:
    print(e)
    print('创建表失败')
finally:
    #关闭连接
    con.close()

插入数据（insert.py）

复制代码

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
# 插入数据
import pymysql
#创建连接
con=pymysql.connect(host='localhost',user='用户名',password='密码',database='数据库名',port=3306)
#创建游标对象
cur=con.cursor()
#编写插入数据的sql语句
sql='insert into students(sname,age,score) values(%s,%s,%s)'
try:
    # 执行sql
    cur.execute(sql, ('小黑', 18, 99))
    #插入多条
    #cur.executemany(sql, [('小明', 19, 99.8), ('小红', 18, 99.9), ('晓丽', 18, 99.8), ('小花', 19, 99.6)])
    #提交事务
    con.commit()
    print('插入成功')
except Exception as e:
    print(e)
    con.rollback()
    print('插入失败')
finally:
    #关闭连接
    con.close()

删除数据（delete.py）

复制代码

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
# 删除数据
import pymysql
#创建连接
con=pymysql.connect(host='localhost',user='用户名',password='密码',database='数据库名',port=3306)
#创建游标对象
cur=con.cursor()
#编写删除的sql语句
sql='delete from students where sname=%s'
#执行sql语句
try:
    cur.execute(sql,('小黑'))
    con.commit()
    print('删除成功')
except Exception as e:
    print(e)
    con.rollback()
    print('删除失败')
finally:
    #关闭连接
    con.close()

修改数据（change.py）

复制代码

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
# 修改数据
import pymysql
#创建连接
con=pymysql.connect(host='localhost',user='用户名',password='密码',database='数据库名',port=3306)
#创建游标对象
cur=con.cursor()
#编写修改的sql语句
sql='update students set sno=%s where sname=%s'
#执行sql语句
try:
    cur.execute(sql,(6,'小李'))
    con.commit()
    print('修改成功')
except Exception as e:
    print(e)
    con.rollback()
    print('修改失败')
finally:
    #关闭连接
    con.close()

查找数据（find.py）

复制代码

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
# 查询所有数据
import pymysql
#创建连接
con=pymysql.connect(host='localhost',user='用户名',password='密码',database='数据库名',port=3306)
#创建游标对象
cur=con.cursor()
#编写查询的sql语句
sql='select * from students where age=18'
#执行sql
try:
    cur.execute(sql)
    #处理结果集
    #查询所有数据
    '''students=cur.fetchall()
    for student in students:'''
        #查询一条数据
    student = cur.fetchone()
    print(student)
    sno=student[0]
    sname=student[1]
    age=student[2]
    score=student[3]
    print('sno:',sno,'sname:',sname,'age:',age,'score:',score)
except Exception as e:
    print(e)
    print('查询所有数据失败')
finally:
    #关闭连接
    con.close()