注意：请根据您的实际情况修改连接数据库的参数、表名、列名、插入数据的值等。

1. 使用python连接mysql数据库并通过语句查询数据

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
from pymysql import *

# 打开数据库连接
db = connect(host='127.0.0.1', port=3306, user='root', password='123456', database='flight_archive',charset='utf8')
# 使用cursor()方法获取操作游标
cursor = db.cursor()
# SQL 查询语句
sql = "SELECT * FROM flight_archive.flight;"
# 执行SQL语句
cursor.execute(sql)
# 获取所有记录列表
results = cursor.fetchall()
# 遍历取数据
for i in results:
    ids = i[0]
    print(ids)
db.close()

2. 使用python连接mysql数据库并通过语句插入数据

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
31
32
33
34
35
36
37
import pymysql

# 建立数据库连接
db = pymysql.connect(
    host="localhost",
    user="root",
    password="123456",
    database="test"
)

# 创建游标
cursor = db.cursor()

try:
    # 插入数据的 SQL 查询语句
    insert_query = "INSERT INTO mytable (column1, column2) VALUES (%s, %s)"

    # 要插入的数据值
    values = ("value1", "value2")

    # 执行插入操作
    cursor.execute(insert_query, values)
    print("数据已成功插入到数据库中")

    # 提交事务
    db.commit()
    print("事务已提交")

except pymysql.Error as error:
    # 回滚事务
    db.rollback()
    print("事务已回滚，发生错误:", error)

finally:
    # 关闭游标和数据库连接
    cursor.close()
    db.close()
  1. 首先我们使用 pymysql 库来建立与数据库的连接。在 pymysql.connect() 方法中，我们提供了数据库的主机名、用户名、密码和数据库名。
  2. 然后，我们创建了一个游标对象，它用于执行 SQL 查询和操作。
  3. 接下来，我们定义了插入数据的 SQL 查询语句，即 INSERT INTO mytable (column1, column2) VALUES (%s, %s)，其中 column1 和 column2 是目标表中的列名。
  4. 然后，我们定义了要插入的数据值，即 values = (“value1”, “value2”)。这里可以根据实际需求修改值。
  5. 通过 cursor.execute() 方法，我们执行了插入操作，并将查询语句和值作为参数传递给该方法。
  6. 如果没有发生错误，我们打印出提示信息，表示数据已成功插入到数据库中。
  7. 最后，我们通过 db.commit() 提交事务，将更改永久保存到数据库中。如果发生错误，我们通过 db.rollback() 回滚事务，撤销之前的更改。
  8. 最终，我们关闭了游标和数据库连接，释放相关资源