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

c查询字符串数据库

admin
行业动态
2025-02-21
1

要查询字符串数据库，可以使用SQL语句中的 SELECT语句，结合 LIKE关键字进行模糊匹配。 SELECT * FROM table_name WHERE column_name LIKE '%string%';

在C语言中查询字符串数据库是一个涉及多个步骤的过程，包括选择合适的数据库库、配置连接参数、执行SQL查询以及处理查询结果等，以下是详细的介绍：

选择合适的数据库库

1、MySQL：

MySQL是一种广泛使用的开源关系数据库管理系统，适用于中小型应用，它支持多用户、多线程，性能较好，适合需要高并发的应用。

2、SQLite：

SQLite是一个轻量级的嵌入式数据库，广泛应用于移动应用和小型应用中，SQLite的优点是无需服务器配置，直接将数据库存储在一个文件中。

3、PostgreSQL：

PostgreSQL是一个功能强大的开源对象关系数据库管理系统，适用于大型应用，它支持复杂的查询、事务和扩展性，适合需要高可靠性和高性能的应用。

正确配置连接

1、配置SQLite连接：

SQLite无需服务器配置，只需包含SQLite库头文件并链接相应的库文件即可。

示例代码：

“`c

#include <sqlite3.h>

int main() {

sqlite3 *db;

char *err_msg = 0;

int rc = sqlite3_open("test.db", &db);

if (rc != SQLITE_OK) {

fprintf(stderr, "Cannot open database: %s

", sqlite3_errmsg(db));

sqlite3_close(db);

return 1;

} else {

fprintf(stderr, "Opened database successfully

");

}

// …

sqlite3_close(db);

return 0;

}

2、配置MySQL连接：
   使用MySQL时，需要安装MySQL客户端库，并包含mysql.h头文件。
   示例代码：
     ```c
       #include <mysql/mysql.h>
       int main() {
           MYSQL *conn;
           MYSQL_RES *res;
           MYSQL_ROW row;
           conn = mysql_init(NULL);
           if (conn == NULL) {
               fprintf(stderr, "mysql_init() failed
");
               return EXIT_FAILURE;
           }
           if (mysql_real_connect(conn, "host", "user", "password", "database", 0, NULL, 0) == NULL) {
               fprintf(stderr, "mysql_real_connect() failed
");
               mysql_close(conn);
               return EXIT_FAILURE;
           }
           // ...
           mysql_close(conn);
           return EXIT_SUCCESS;
       }

3、配置PostgreSQL连接：

使用PostgreSQL时，需要安装PostgreSQL客户端库，并包含libpq-fe.h头文件。

示例代码：

“`c

#include <libpq-fe.h>

int main() {

PGconn *conn = PQconnectdb("user=username dbname=mydb");

if (PQstatus(conn) == CONNECTION_BAD) {

fprintf(stderr, "Connection to database failed: %s

", PQerrorMessage(conn));

PQfinish(conn);

return EXIT_FAILURE;

}

// …

PQfinish(conn);

return EXIT_SUCCESS;

}

执行查询
1、执行SQLite查询：
   使用sqlite3_exec函数执行查询，并通过回调函数处理结果集。
   示例代码：
     ```c
       static int callback(void *NotUsed, int argc, charargv, charazColName) {
           for (int i = 0; i < argc; i++) {
               printf("%s = %s
", azColName[i], argv[i] ? argv[i] : "NULL");
           }
           printf("
");
           return 0;
       }
       int main() {
           sqlite3 *db;
           char *err_msg = 0;
           int rc = sqlite3_open("test.db", &db);
           if (rc != SQLITE_OK) {
               fprintf(stderr, "Cannot open database: %s
", sqlite3_errmsg(db));
               sqlite3_close(db);
               return 1;
           }
           const char *sql = "SELECT * FROM test_table";
           rc = sqlite3_exec(db, sql, callback, 0, &err_msg);
           if (rc != SQLITE_OK) {
               fprintf(stderr, "Failed to select data: %s
", err_msg);
               sqlite3_free(err_msg);
               sqlite3_close(db);
               return 1;
           }
           sqlite3_close(db);
           return 0;
       }

2、执行MySQL查询：

使用mysql_query函数执行查询，并通过mysql_store_result和mysql_fetch_row函数处理结果集。

示例代码：

“`c

int main() {

MYSQL *conn;

MYSQL_RES *res;

MYSQL_ROW row;

conn = mysql_init(NULL);

if (conn == NULL) {

fprintf(stderr, "mysql_init() failed

");

return EXIT_FAILURE;

}

if (mysql_real_connect(conn, "host", "user", "password", "database", 0, NULL, 0) == NULL) {

fprintf(stderr, "mysql_real_connect() failed

");

mysql_close(conn);

return EXIT_FAILURE;

}

if (mysql_query(conn, "SELECT column_name FROM table_name")) {

fprintf(stderr, "%s

", mysql_error(conn));

mysql_close(conn);

return EXIT_FAILURE;

}

res = mysql_store_result(conn);

if (res == NULL) {

fprintf(stderr, "%s

", mysql_error(conn));

mysql_close(conn);

return EXIT_FAILURE;

}

while ((row = mysql_fetch_row(res)) != NULL) {

printf("%s

", row[0]);

}

mysql_free_result(res);

mysql_close(conn);

return EXIT_SUCCESS;

}

3、执行PostgreSQL查询：
   使用PQexec函数执行查询，并通过PQgetvalue函数获取结果集中的数据。
   示例代码：
     ```c
       int main() {
           PGconn *conn = PQconnectdb("user=username dbname=mydb");
           if (PQstatus(conn) == CONNECTION_BAD) {
               fprintf(stderr, "Connection to database failed: %s
", PQerrorMessage(conn));
               PQfinish(conn);
               return EXIT_FAILURE;
           }
           PGresult *res = PQexec(conn, "SELECT column_name FROM table_name");
           if (PQresultStatus(res) != PGRES_TUPLES_OK) {
               fprintf(stderr, "SELECT failed: %s
", PQerrorMessage(conn));
               PQclear(res);
               PQfinish(conn);
               return EXIT_FAILURE;
           }
           int nrows = PQntuples(res);
           for (int i = 0; i < nrows; i++) {
               printf("Column value: %s
", PQgetvalue(res, i, 0));
           }
           PQclear(res);
           PQfinish(conn);
           return EXIT_SUCCESS;
       }