python写入mysql数据库代码

下面是一个简单的 Python 代码示例，用于将数据写入 MySQL 数据库：

import mysql.connector

# 连接 MySQL 数据库
mydb = mysql.connector.connect(
  host="localhost",
  user="yourusername",
  password="yourpassword",
  database="yourdatabase"
)

# 创建一个游标对象
mycursor = mydb.cursor()

# 编写 SQL 插入语句
sql = "INSERT INTO customers (name, address) VALUES (%s, %s)"
val = ("John", "Highway 21")

# 执行 SQL 插入语句
mycursor.execute(sql, val)

# 提交事务
mydb.commit()

# 输出插入的数据行数
print(mycursor.rowcount, "record inserted.")

需要注意的是，在执行 SQL 语句之前，需要先连接到 MySQL 数据库并创建游标对象。然后，使用游标对象执行 SQL 语句，并确保在执行 INSERT、UPDATE 或 DELETE 语句后提交事务。最后，可以使用 `mycursor.rowcount` 属性输出插入的数据行数。

相关问题

写入MySQL数据库的python代码

以下是Python写入MySQL数据库的示例代码：

import mysql.connector

# 连接数据库
cnx = mysql.connector.connect(user='root', password='password',
                              host='localhost',
                              database='mydatabase')

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

# 插入数据
add_data = ("INSERT INTO mytable "
            "(name, age, email) "
            "VALUES (%s, %s, %s)")
data = ('John', 25, 'john@example.com')
cursor.execute(add_data, data)

# 提交更改
cnx.commit()

# 关闭游标和数据库连接
cursor.close()
cnx.close()

上述代码连接到名为`mydatabase`的本地MySQL数据库，并在名为`mytable`的表中插入一行数据。`%s`是占位符，它将在执行`execute()`方法时被`data`元组的值替换。在执行更改后，必须调用`commit()`方法来保存更改。最后，关闭游标和数据库连接。

如何使用Python将MySQL数据读取并写入MySQL数据库？

可以使用Python中的MySQL Connector模块来实现从MySQL数据库读取数据和写入数据到MySQL数据库。

以下是一个简单的示例代码，说明如何使用Python连接到MySQL数据库，读取数据并将其写入另一个MySQL数据库：

import mysql.connector

# 设置源数据库连接参数
src_db_config = {
    'host': 'localhost',
    'user': 'root',
    'password': 'password',
    'database': 'source_db'
}

# 设置目标数据库连接参数
dest_db_config = {
    'host': 'localhost',
    'user': 'root',
    'password': 'password',
    'database': 'destination_db'
}

# 连接源数据库
src_db = mysql.connector.connect(**src_db_config)

# 连接目标数据库
dest_db = mysql.connector.connect(**dest_db_config)

# 获取源数据库游标
src_cursor = src_db.cursor()

# 获取目标数据库游标
dest_cursor = dest_db.cursor()

# 查询源数据库中的数据
src_cursor.execute("SELECT * FROM source_table")

# 读取查询结果
results = src_cursor.fetchall()

# 将查询结果写入目标数据库
for result in results:
    dest_cursor.execute("INSERT INTO destination_table (col1, col2, col3) VALUES (%s, %s, %s)", result)

# 提交目标数据库更改
dest_db.commit()

# 关闭游标和数据库连接
src_cursor.close()
dest_cursor.close()
src_db.close()
dest_db.close()

在上面的代码中，首先设置源数据库和目标数据库的连接参数，然后使用`mysql.connector.connect`方法连接到两个数据库。接下来，使用源数据库游标执行查询，并使用`fetchall`方法读取查询结果。最后，使用目标数据库游标执行插入语句将结果写入目标数据库，并使用`commit`方法提交更改。最后，关闭游标和数据库连接。

请注意，上面的示例代码仅供参考。在实际使用中，您可能需要根据自己的需求进行调整。