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

c数据库增删改查

admin
行业动态
2025-02-21
2

c语言操作数据库增删改查可通过对应SQL语句结合C API函数实现对数据库记录的增加、删除、修改与查询。

在数据库管理中，增删改查（CRUD）是最基本的操作，C语言虽然不是专门的数据库操作语言，但通过与数据库的接口库（如ODBC、MySQL C API等），我们可以用C语言实现对数据库的增删改查操作，下面以MySQL数据库为例，介绍如何使用C语言进行数据库的增删改查操作。

环境配置

确保你的系统上已经安装了MySQL数据库，并且创建了相应的数据库和表，创建一个名为students的数据库和一个名为student的表：

CREATE DATABASE students;
USE students;
CREATE TABLE student (
    id INT AUTO_INCREMENT PRIMARY KEY,
    name VARCHAR(50),
    age INT,
    grade VARCHAR(10)
);

安装MySQL C API库，以便在C程序中使用。

连接数据库

在进行任何数据库操作之前，需要先连接到数据库，以下是一个简单的连接函数示例：

#include <mysql/mysql.h>
#include <stdio.h>
#include <stdlib.h>
MYSQL *connect_db() {
    MYSQL *conn = mysql_init(NULL);
    if (conn == NULL) {
        fprintf(stderr, "MySQL initialization failed
");
        exit(EXIT_FAILURE);
    }
    if (mysql_real_connect(conn, "localhost", "your_username", "your_password", "students", 0, NULL, 0) == NULL) {
        fprintf(stderr, "Failed to connect to database: Error: %s
", mysql_error(conn));
        mysql_close(conn);
        exit(EXIT_FAILURE);
    }
    return conn;
}

增（Insert）

插入数据到表中：

c数据库增删改查

void insert_student(MYSQL *conn, const char *name, int age, const char *grade) {
    char query[256];
    sprintf(query, "INSERT INTO student (name, age, grade) VALUES ('%s', %d, '%s')", name, age, grade);
    if (mysql_query(conn, query)) {
        fprintf(stderr, "Failed to insert data: Error: %s
", mysql_error(conn));
    } else {
        printf("Record inserted successfully
");
    }
}

删（Delete）

根据ID删除学生记录：

void delete_student(MYSQL *conn, int id) {
    char query[256];
    sprintf(query, "DELETE FROM student WHERE id = %d", id);
    if (mysql_query(conn, query)) {
        fprintf(stderr, "Failed to delete data: Error: %s
", mysql_error(conn));
    } else {
        printf("Record deleted successfully
");
    }
}

改（Update）

更新学生信息：

void update_student(MYSQL *conn, int id, const char *name, int age, const char *grade) {
    char query[256];
    sprintf(query, "UPDATE student SET name = '%s', age = %d, grade = '%s' WHERE id = %d", name, age, grade, id);
    if (mysql_query(conn, query)) {
        fprintf(stderr, "Failed to update data: Error: %s
", mysql_error(conn));
    } else {
        printf("Record updated successfully
");
    }
}

查（Select）

查询所有学生记录：

c数据库增删改查

void select_all_students(MYSQL *conn) {
    if (mysql_query(conn, "SELECT * FROM student")) {
        fprintf(stderr, "Failed to retrieve data: Error: %s
", mysql_error(conn));
    } else {
        MYSQL_RES *result = mysql_store_result(conn);
        MYSQL_ROW row;
        printf("IDtNametAgetGrade
");
        while ((row = mysql_fetch_row(result))) {
            printf("%st%st%st%s
", row[0], row[1], row[2], row[3]);
        }
        mysql_free_result(result);
    }
}

主函数示例

将所有功能整合到主函数中：

int main() {
    MYSQL *conn = connect_db();
    insert_student(conn, "John Doe", 20, "Sophomore");
    select_all_students(conn);
    update_student(conn, 1, "Jane Doe", 21, "Senior");
    delete_student(conn, 1);
    select_all_students(conn);
    mysql_close(conn);
    return 0;
}