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

c 调用远程数据库

admin
行业动态
2025-01-31
2

### C语言调用远程数据库方法：该程序通过ODBC接口连接远程数据库，利用SQL语句实现数据查询、插入、更新和删除等操作，并处理结果集。

在C语言中调用远程数据库，通常需要依赖特定的数据库连接库或API，以下是使用MySQL Connector/C来连接远程MySQL数据库的详细步骤：

1、安装MySQL Connector/C：

在Linux系统上，可以使用包管理工具安装，例如sudo apt-get install libmysqlclient-dev。

在Windows系统上，可以从MySQL官方网站下载并安装相应的驱动程序。

2、包含必要的头文件：

   #include <mysql/mysql.h>

3、初始化MySQL对象：

   MYSQL *conn = mysql_init(NULL);
   if (conn == NULL) {
       fprintf(stderr, "%s
", mysql_error(conn));
       exit(EXIT_FAILURE);
   }

4、连接到远程数据库：

   const char *host = "remote_host";
   const char *user = "username";
   const char *password = "password";
   const char *database = "database_name";
   unsigned int port = 3306; // 默认端口号
   if (mysql_real_connect(conn, host, user, password, database, port, NULL, 0) == NULL) {
       fprintf(stderr, "%s
", mysql_error(conn));
       mysql_close(conn);
       exit(EXIT_FAILURE);
   }

5、执行查询：

   if (mysql_query(conn, "SELECT * FROM table_name")) {
       fprintf(stderr, "%s
", mysql_error(conn));
       mysql_close(conn);
       exit(EXIT_FAILURE);
   }

6、处理结果集：

   MYSQL_RES *result = mysql_store_result(conn);
   if (result == NULL) {
       fprintf(stderr, "%s
", mysql_error(conn));
       mysql_close(conn);
       exit(EXIT_FAILURE);
   }
   int num_fields = mysql_num_fields(result);
   MYSQL_ROW row;
   while ((row = mysql_fetch_row(result))) {
       for(int i = 0; i < num_fields; i++) {
           printf("%s ", row[i] ? row[i] : "NULL");
       }
       printf("
");
   }
   mysql_free_result(result);

7、关闭连接：

   mysql_close(conn);

8、完整示例代码：

   #include <mysql/mysql.h>
   #include <stdio.h>
   #include <stdlib.h>
   void finish_with_error(MYSQL *con) {
       fprintf(stderr, "%s
", mysql_error(con));
       mysql_close(con);
       exit(1);
   }
   int main() {
       MYSQL *con = mysql_init(NULL);
       if (con == NULL) {
           fprintf(stderr, "%s
", mysql_error(con));
           exit(1);
       }
       if (mysql_real_connect(con, "remote_host", "username", "password", "database_name", 0, NULL, 0) == NULL) {
           finish_with_error(con);
       }
       if (mysql_query(con, "SELECT * FROM table_name")) {
           finish_with_error(con);
       }
       MYSQL_RES *result = mysql_store_result(con);
       if (result == NULL) {
           finish_with_error(con);
       }
       int num_fields = mysql_num_fields(result);
       MYSQL_ROW row;
       while ((row = mysql_fetch_row(result))) {
           for(int i = 0; i < num_fields; i++) {
               printf("%s ", row[i] ? row[i] : "NULL");
           }
           printf("
");
       }
       mysql_free_result(result);
       mysql_close(con);
       exit(0);
   }