当前位置：首页 > 行业动态 > 正文

c和数据库主键重复怎么插入

admin
行业动态
2025-02-20
2

若主键重复，需先删除或更新原有记录，再插入新数据。

在处理C语言与数据库交互时，尤其是涉及到主键重复的情况，需要采取一些策略来确保数据能够正确插入数据库，以下是一个详细的步骤指南：

检查主键是否存在

在尝试插入数据之前，首先应该检查要插入的主键是否已经存在于数据库中，这可以通过执行一个SELECT查询来实现，查询语句会根据提供的主键值查找记录。

#include <stdio.h>
#include <stdlib.h>
#include <mysql/mysql.h>
int main() {
    MYSQL *conn;
    MYSQL_RES *res;
    MYSQL_ROW row;
    char *server = "localhost";
    char *user = "root";
    char *password = "yourpassword"; /* set me first */
    char *database = "yourdatabase";
    conn = mysql_init(NULL);
    // Connect to database
    if (!mysql_real_connect(conn, server, user, password, database, 0, NULL, 0)) {
        fprintf(stderr, "%s
", mysql_error(conn));
        exit(1);
    }
    // Check if primary key exists
    char query[256];
    sprintf(query, "SELECT id FROM yourtable WHERE id = %d", primary_key_value);
    if (mysql_query(conn, query)) {
        fprintf(stderr, "%s
", mysql_error(conn));
        exit(1);
    }
    res = mysql_use_result(conn);
    row = mysql_fetch_row(res);
    if (row == NULL) {
        printf("Primary key does not exist. Safe to insert.
");
    } else {
        printf("Primary key already exists. Insertion aborted.
");
    }
    // Cleanup
    mysql_free_result(res);
    mysql_close(conn);
    return 0;
}

2. 使用INSERT IGNORE或ON DUPLICATE KEY UPDATE

如果确定主键可能重复，并且希望在主键重复时不进行插入操作，可以使用INSERT IGNORE语句，如果需要在主键重复时更新现有记录，可以使用ON DUPLICATE KEY UPDATE语句。

c和数据库主键重复怎么插入

使用`INSERT IGNORE`

INSERT IGNORE INTO yourtable (id, column1, column2) VALUES (1, 'value1', 'value2');

使用ON DUPLICATE KEY UPDATE

INSERT INTO yourtable (id, column1, column2) VALUES (1, 'value1', 'value2')
ON DUPLICATE KEY UPDATE column1 = VALUES(column1), column2 = VALUES(column2);

C语言中执行上述SQL语句

在C语言中，可以结合上述SQL语句和MySQL API来执行相应的操作，以下是一个简单的示例：

#include <stdio.h>
#include <stdlib.h>
#include <mysql/mysql.h>
int main() {
    MYSQL *conn;
    char *server = "localhost";
    char *user = "root";
    char *password = "yourpassword"; /* set me first */
    char *database = "yourdatabase";
    conn = mysql_init(NULL);
    // Connect to database
    if (!mysql_real_connect(conn, server, user, password, database, 0, NULL, 0)) {
        fprintf(stderr, "%s
", mysql_error(conn));
        exit(1);
    }
    // Execute SQL statement
    if (mysql_query(conn, "INSERT IGNORE INTO yourtable (id, column1, column2) VALUES (1, 'value1', 'value2')")) {
        fprintf(stderr, "%s
", mysql_error(conn));
        exit(1);
    }
    printf("Query executed successfully.
");
    // Close connection
    mysql_close(conn);
    return 0;
}