MySQL 使用 REPLACE INTO 语句根据第一列值判断并替换数据

如果你想使用第一列的值来判断是否有相同的记录，并进行替换操作，可以使用 MySQL 的 'REPLACE INTO' 语句配合 'SELECT' 子查询来实现。以下是修改后的代码示例：

import mysql.connector

table_name = "mytable"
columns = ["station_num INT", "'employeer_name' VARCHAR(255)",  "dist FLOAT", "'station_time' DATETIME", "'result' VARCHAR(255)"]
mydata = [(12145217, "王二麻子-李四", 17.23, "2023-12-23 12:56", "合格")]

# 连接数据库
conn = mysql.connector.connect(host="localhost", user="your_username", password="your_password", database="your_database")
cursor = conn.cursor()

# 遍历数据列表，根据第一列的值判断是否存在相同记录并进行替换
for data in mydata:
    select_query = f"SELECT * FROM {table_name} WHERE station_num = {data[0]}"
    cursor.execute(select_query)
    result = cursor.fetchone()
    
if result:
        replace_query = f"REPLACE INTO {table_name} ({', '.join([column.split()[0] for column in columns])}) VALUES ({', '.join(['%s'] * len(columns))})"
        cursor.execute(replace_query, data)
    else:
        insert_query = f"INSERT INTO {table_name} ({', '.join([column.split()[0] for column in columns])}) VALUES ({', '.join(['%s'] * len(columns))})"
        cursor.execute(insert_query, data)

conn.commit()
print("数据插入成功或已替换现有数据")

# 关闭数据库连接
cursor.close()
conn.close()

在上述示例中，我们遍历数据列表，并根据第一列的值执行 'SELECT' 查询来判断是否存在相同的记录。如果存在相同记录，我们使用 'REPLACE INTO' 语句进行替换操作；如果不存在相同记录，我们使用常规的 'INSERT INTO' 语句进行插入操作。

请注意，使用 'REPLACE INTO' 语句进行替换时，将替换整行记录，而不是单独替换某个列的值。因此，如果你只想替换某个列的值而保持其他列的值不变，可以使用 'UPDATE' 语句来实现。