如何将python中的数据存储到mysql中

一、最基本的准备

1.1 本地安装mysql，推荐安装以下其中之一

 1.2 安装python软件

二、建立连接

1.1打开PyCharm编程软件

 1.2 打开mysql软件，否则连接不上

 1.3 在python环境中下载PyMysql库

1.4 连接数据库 

二、创建表格

1.1 在python中创建表格

 1.2 在mysql中查看

 三、Python中MySQL数据库操作

 四、参数说明

1.1 本地安装mysql，推荐安装以下其中之一

 1.2 安装python软件

1.1打开PyCharm编程软件

 1.2 打开mysql软件，否则连接不上

 1.3 在python环境中下载PyMysql库

pip install PyMysql

1.4 连接数据库 

import pymysql.cursors# 连接数据库connect = pymysql.Connect(    host='127.0.0.1',    port=3306,    user='root',    passwd='123456',    db='test_1',    charset='utf8')

运行上述代码不报错则说明连接成功，若不放心，我们可建表试试，如果在数据库中能够看到所建的表，说明连接成功了。

1.1 在python中创建表格

# 获取游标cursor = connect.cursor()#创建表格sql = "CREATE TABLE test_1(id INTEGER PRIMARY KEY,name TEXT)"try:    cursor.execute(sql)    connect.commit()except:    print("表已存在")print('成功创建表格')

 打印结果

 1.2 在mysql中查看

 如图所示证明，python与mysql连接成功了

# 连接数据库connect = pymysql.Connect(    host='127.0.0.1',    port=3306,    user='root',    passwd='123456',    db='note',    charset='utf8')# 获取游标cursor = connect.cursor()#删除表sql = 'DROP TABLE IF EXISTS student'cursor.execute(sql)connect.commit()print('如果存在表就删除表格')#创建表格sql = "CREATE TABLE student(id INTEGER PRIMARY KEY,name TEXT)"try:    cursor.execute(sql)    connect.commit()except:    print("表已存在")print('成功创建表格')# 插入数据sql = "INSERT INTO student VALUES(%d,'%s')"data = (1, 'student1')cursor.execute(sql % data)connect.commit()print('成功插入', cursor.rowcount, '条数据')# 修改数据sql = "UPDATE student SET name = '%s' WHERE id = %d "data = ('student2', 1)cursor.execute(sql % data)connect.commit()print('成功修改', cursor.rowcount, '条数据')# 查询数据sql = "SELECT * FROM student WHERE id=%d"data = (1,)cursor.execute(sql % data)for row in cursor.fetchall():    print("%s" % str(row))print('共查找出', cursor.rowcount, '条数据')# 删除数据sql = "DELETE FROM student WHERE id = %d LIMIT %d"data = (1, 1)cursor.execute(sql % data)connect.commit()print('成功删除', cursor.rowcount, '条数据')# 事务处理sql_1 = "UPDATE student SET name = name + '1' WHERE id = 1 "try:    cursor.execute(sql_1)except Exception as e:    connect.rollback()  # 事务回滚    print('事务处理失败', e)else:    connect.commit()  # 事务提交    print('事务处理成功', cursor.rowcount)# 关闭连接cursor.close()connect.close()

来源地址：https://blog.csdn.net/qq_58546982/article/details/131019960