C语言的数据库交互

九天猎人  金牌会员 | 2025-1-17 13:20:45 | 显示全部楼层 | 阅读模式
打印 上一主题 下一主题
楼主

主题 873|帖子 873|积分 2619

C语言的数据库交互

引言

在当代的软件开发中，数据库是应用步伐的重要构成部分。无论是小型的个人项目照旧大型的企业级应用，数据的存储、查询和管理都必要有效的数据库系统。在浩繁编程语言中，C语言以其高效、灵活和底层操作的特性，被广泛应用于系统编程、嵌入式开发等领域。当然，C语言在数据库交互方面也黑白常强盛的。本文将深入探讨C语言与数据库的交互，包罗常用的数据库及其驱动，数据库操作的基本流程，常见的数据库操作示例等。
C语言简介

C语言是一种通用的编程语言，最初由丹尼斯·里奇（Dennis Ritchie）在1972年开发。由于其高效性和可移植性，C语言广泛应用于系统软件、应用步伐以及嵌入式系统的开发。C语言的核心特点包罗：

  • 低级操作：C语言允许直接操作内存，这在与数据库的交互中提供了高度的灵活性。
  • 高效性：相较于许多其他高级语言，C语言的实行速度更快，恰当对性能要求较高的应用。
  • 丰富的库支持：尽管C语言本身并不直接提供数据库接口，但可以通过第三方库与各种数据库举行交互。
常用数据库系统

在与C语言交互时，开发者可以选择多种数据库系统，常见的包罗：

  • MySQL：开源关系型数据库，广泛应用于Web开发。
  • PostgreSQL：开源对象关系型数据库，支持复杂的数据类型和变乱处置惩罚。
  • SQLite：轻型数据库，恰当嵌入式应用。
  • MongoDB：开源的NoSQL数据库，恰当大数据和非结构化数据的处置惩罚。
  • Oracle：广泛使用的商业关系型数据库，恰当大型企业。
本文将主要以MySQL和SQLite为例，分析怎样使用C语言举行数据库交互。
数据库驱动

为了让C语言与数据库举行交互，必要使用相应的数据库驱动。数据库驱动是实现步伐与数据库之间有效通讯的中介。对于C语言，主要有以下几种驱动：

  • MySQL C API：MySQL官方提供的C语言接口，允许开发者实行SQL语句，管理毗连等。
  • SQLite C API：SQLite自带的C语言API，提供了轻量级的数据库管理功能。
  • PostgreSQL C API：PostgreSQL官方提供的C语言接口，支持复杂查询和变乱。
  • ODBC：开放数据库毗连（Open Database Connectivity），提供通用的API接口，可以或许与多种数据库系统举行交互。
在这篇文章中，我们将主要使用MySQL和SQLite的C语言API举行数据库交互的演示。
数据库的基本操作流程

与数据库交互的基本流程通常包罗以下步骤：

  • 毗连数据库：创建一个到数据库的链接。
  • 实行SQL语句：通过链接实行各种数据库操作，如查询、插入、更新和删除。
  • 处置惩罚效果：根据实行的操作处置惩罚返回的效果。
  • 关闭毗连：操作完成后，关闭数据库链接，开释资源。
以下将对这各个步骤举行具体教学，并提供示例代码。
毗连数据库

毗连数据库的第一步是初始化数据库毗连。以MySQL为例，毗连的基本步骤如下：

  • 引入 mysql/mysql.h 头文件。
  • 创建并初始化MYSQL对象。
  • 使用 mysql_real_connect 函数建立到数据库的毗连。
示例代码：
```c
include  

include  

include  

MYSQL *conn;
void connect_to_database() { conn = mysql_init(NULL); if (conn == NULL) { fprintf(stderr, "mysql_init() failed\n"); exit(EXIT_FAILURE); }
  1. if (mysql_real_connect(conn, "localhost", "user", "password", "testdb", 0, NULL, 0) == NULL) {
  2.     fprintf(stderr, "mysql_real_connect() failed\n");
  3.     mysql_close(conn);
  4.     exit(EXIT_FAILURE);
  5. }
  7. printf("Connected to the database successfully!\n");
复制代码
} ```
实行SQL语句

毗连到数据库后，就可以开始实行SQL语句了。差别的数据库操作可以使用差别的mysql函数来完成。
示例代码：
查询操作

```c void query_database() { if (mysql_query(conn, "SELECT * FROM users")) { fprintf(stderr, "SELECT * failed. Error: %s\n", mysql_error(conn)); return; }
  1. MYSQL_RES *result = mysql_store_result(conn);
  2. if (result == NULL) {
  3.     fprintf(stderr, "mysql_store_result() failed. Error: %s\n", mysql_error(conn));
  4.     return;
  5. }
  7. int num_fields = mysql_num_fields(result);
  8. MYSQL_ROW row;
  10. while ((row = mysql_fetch_row(result))) {
  11.     for (int i = 0; i < num_fields; i++) {
  12.         printf("%s ", row[i] ? row[i] : "NULL");
  13.     }
  14.     printf("\n");
  15. }
  17. mysql_free_result(result);
复制代码
} ```
插入操作

```c void insert_into_database(const char* name, int age) { char query[256]; snprintf(query, sizeof(query), "INSERT INTO users(name, age) VALUES('%s', %d)", name, age);
  1. if (mysql_query(conn, query)) {
  2.     fprintf(stderr, "INSERT failed. Error: %s\n", mysql_error(conn));
  3. } else {
  4.     printf("Inserted %s, %d into users table successfully!\n", name, age);
  5. }
复制代码
} ```
处置惩罚效果

在查询操作之后，我们会得到一个效果集，可以通过函数 mysql_fetch_row 循环读取每一行的数据。每一行的数据以数组的情势返回，数组的每个元素都对应数据库表的每一列。
关闭毗连

操作完成后，要确保关闭数据库毗连，防止资源泄漏。
示例代码：
c void close_connection() { mysql_close(conn); printf("Connection closed.\n"); }
完整的示例

将上述代码整合成一个完整的示例步伐：
```c
include  

include  

include  

MYSQL *conn;
void connect_to_database() { conn = mysql_init(NULL); if (conn == NULL) { fprintf(stderr, "mysql_init() failed\n"); exit(EXIT_FAILURE); }
  1. if (mysql_real_connect(conn, "localhost", "user", "password", "testdb", 0, NULL, 0) == NULL) {
  2.     fprintf(stderr, "mysql_real_connect() failed\n");
  3.     mysql_close(conn);
  4.     exit(EXIT_FAILURE);
  5. }
  7. printf("Connected to the database successfully!\n");
复制代码
}
void query_database() { if (mysql_query(conn, "SELECT * FROM users")) { fprintf(stderr, "SELECT * failed. Error: %s\n", mysql_error(conn)); return; }
  1. MYSQL_RES *result = mysql_store_result(conn);
  2. if (result == NULL) {
  3.     fprintf(stderr, "mysql_store_result() failed. Error: %s\n", mysql_error(conn));
  4.     return;
  5. }
  7. int num_fields = mysql_num_fields(result);
  8. MYSQL_ROW row;
  10. while ((row = mysql_fetch_row(result))) {
  11.     for (int i = 0; i < num_fields; i++) {
  12.         printf("%s ", row[i] ? row[i] : "NULL");
  13.     }
  14.     printf("\n");
  15. }
  17. mysql_free_result(result);
复制代码
}
void insert_into_database(const char* name, int age) { char query[256]; snprintf(query, sizeof(query), "INSERT INTO users(name, age) VALUES('%s', %d)", name, age);
  1. if (mysql_query(conn, query)) {
  2.     fprintf(stderr, "INSERT failed. Error: %s\n", mysql_error(conn));
  3. } else {
  4.     printf("Inserted %s, %d into users table successfully!\n", name, age);
  5. }
复制代码
}
void close_connection() { mysql_close(conn); printf("Connection closed.\n"); }
int main() { connect_to_database(); insert_into_database("Alice", 30); query_database(); close_connection(); return 0; } ```
SQLite的数据库交互

SQLite是一种轻型的数据库系统，嵌入式特性使其非常恰当于小型应用步伐和移动装备。与MySQL类似，SQLite也提供了C语言的API，使用方法也大体相似。以下是使用SQLite的基本示例。
毗连数据库

```c
include  

sqlite3 *db;
void connect_to_sqlite() { int rc = sqlite3_open("test.db", &db); if (rc) { fprintf(stderr, "Can't open database: %s\n", sqlite3_errmsg(db)); return; } printf("Opened database successfully!\n"); } ```
实行SQL语句

查询操作

```c void query_sqlite() { const char sql = "SELECT * FROM users"; sqlite3_stmt stmt;
  1. int rc = sqlite3_prepare_v2(db, sql, -1, &stmt, 0);
  2. if (rc != SQLITE_OK) {
  3.     fprintf(stderr, "Failed to prepare statement: %s\n", sqlite3_errmsg(db));
  4.     return;
  5. }
  7. while (sqlite3_step(stmt) == SQLITE_ROW) {
  8.     const unsigned char *name = sqlite3_column_text(stmt, 0);
  9.     int age = sqlite3_column_int(stmt, 1);
  10.     printf("%s %d\n", name, age);
  11. }
  13. sqlite3_finalize(stmt);
复制代码
} ```
插入操作

```c void insert_into_sqlite(const char name, int age) { const char sql = "INSERT INTO users (name, age) VALUES (?, ?)"; sqlite3_stmt *stmt;
  1. int rc = sqlite3_prepare_v2(db, sql, -1, &stmt, 0);
  2. if (rc != SQLITE_OK) {
  3.     fprintf(stderr, "Failed to prepare statement: %s\n", sqlite3_errmsg(db));
  4.     return;
  5. }
  7. sqlite3_bind_text(stmt, 1, name, -1, SQLITE_STATIC);
  8. sqlite3_bind_int(stmt, 2, age);
  10. rc = sqlite3_step(stmt);
  11. if (rc != SQLITE_DONE) {
  12.     fprintf(stderr, "Execution failed: %s\n", sqlite3_errmsg(db));
  13. } else {
  14.     printf("Inserted %s, %d into users table successfully!\n", name, age);
  15. }
  17. sqlite3_finalize(stmt);
复制代码
} ```
关闭毗连

操作完成后，也要确保关闭SQLite毗连。
c void close_sqlite_connection() { sqlite3_close(db); printf("SQLite connection closed.\n"); }
整合示例

将SQLite的部分整合成一个完整的示例步伐：
```c
include  

include  

sqlite3 *db;
void connect_to_sqlite() { int rc = sqlite3_open("test.db", &db); if (rc) { fprintf(stderr, "Can't open database: %s\n", sqlite3_errmsg(db)); return; } printf("Opened database successfully!\n"); }
void query_sqlite() { const char sql = "SELECT * FROM users"; sqlite3_stmt stmt;
  1. int rc = sqlite3_prepare_v2(db, sql, -1, &stmt, 0);
  2. if (rc != SQLITE_OK) {
  3.     fprintf(stderr, "Failed to prepare statement: %s\n", sqlite3_errmsg(db));
  4.     return;
  5. }
  7. while (sqlite3_step(stmt) == SQLITE_ROW) {
  8.     const unsigned char *name = sqlite3_column_text(stmt, 0);
  9.     int age = sqlite3_column_int(stmt, 1);
  10.     printf("%s %d\n", name, age);
  11. }
  13. sqlite3_finalize(stmt);
复制代码
}
void insert_into_sqlite(const char name, int age) { const char sql = "INSERT INTO users (name, age) VALUES (?, ?)"; sqlite3_stmt *stmt;
  1. int rc = sqlite3_prepare_v2(db, sql, -1, &stmt, 0);
  2. if (rc != SQLITE_OK) {
  3.     fprintf(stderr, "Failed to prepare statement: %s\n", sqlite3_errmsg(db));
  4.     return;
  5. }
  7. sqlite3_bind_text(stmt, 1, name, -1, SQLITE_STATIC);
  8. sqlite3_bind_int(stmt, 2, age);
  10. rc = sqlite3_step(stmt);
  11. if (rc != SQLITE_DONE) {
  12.     fprintf(stderr, "Execution failed: %s\n", sqlite3_errmsg(db));
  13. } else {
  14.     printf("Inserted %s, %d into users table successfully!\n", name, age);
  15. }
  17. sqlite3_finalize(stmt);
复制代码
}
void close_sqlite_connection() { sqlite3_close(db); printf("SQLite connection closed.\n"); }
int main() { connect_to_sqlite(); insert_into_sqlite("Bob", 25); query_sqlite(); close_sqlite_connection(); return 0; } ```
总结

在与数据库举行交互时，C语言通过数据库驱动可以实现多种复杂的操作。虽然C语言在语法和使用上比某些高级语言更为繁琐，但它提供的高效性和底层控制本领使得其在系统级开发中依然占据重要角色。通过本文的示例，开发者可以初步相识C语言怎样与常见的数据库（如MySQL和SQLite）举行交互，并举行简单的数据库操作。
借助C语言强盛的尺度库和第三方库，开发者可以构建出高效、稳定的大型系统应用。在未来的开发中，掌握C语言的数据库交互无疑会为开发者打开更广阔的技能视野。无论是小型应用照旧复杂系统，理解数据库操作的基本流程和方法都是极为重要的技能。希望本文能为广大C语言开发者提供一些有价值的参考和帮助。

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。
回复

使用道具 举报

0 个回复

倒序浏览
返回列表

快速回复

高级模式
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 or 立即注册

本版积分规则

九天猎人

金牌会员
这个人很懒什么都没写!

楼主热帖

标签云

挺好的 服务器
微信订阅号
微信服务号
微信客服
小程序
H5
关于我们 商务合作 网站地图
©Copyright 2022-2024 杭州祥升科技有限公司 版权所有 浙ICP备20004199号
快速回复 返回顶部 返回列表