如何在C中使用MySQL与2个数据库进行交互？

我目前正在研究一个项目，我必须计算跑步者人数。在某些时候，我必须将数据从本地数据库（mysqlLocal）传输到我正在工作的高中（mysqlLycee）。如何在C中使用MySQL与2个数据库进行交互？

我认为这样做是个好主意，但由于某种原因，我在执行程序时遇到了段错误。

#include <stdio.h> 
#include <stdlib.h> 
#include <sys/socket.h> 
#include <arpa/inet.h> 
#include <netdb.h> 
#include <netinet/in.h> 
#include <unistd.h> 
#include <string.h> 
#include <mysql.h> 


int main(int argc, char *argv[]){ 
    MYSQL mysqlLocal; 
    MYSQL_RES *result = NULL; 
    MYSQL_ROW row; 
    char requete[150]; 
    int num_champs; 
    char noParticipant[5]; 
    char kmParcourus[3]; 
    mysql_init(&mysqlLocal); 
    if(!mysql_real_connect(&mysqlLocal,"127.0.0.1","root","debianCCF","localCCF",0,NULL,0))printf("Error on first connect"); 

    sprintf(requete,"SELECT NO_PARTICIPANT, KMPARCOURUS FROM PARTICIPANTS WHERE NO_COURSE = %s",argv[5]); 
    if(!mysql_query(&mysqlLocal,requete))printf("Error on first query"); 
    result = mysql_use_result(&mysqlLocal); 
    num_champs=mysql_num_fields(result); 
    mysql_close(&mysqlLocal); 

    MYSQL mysqlLycee; 
    mysql_init(&mysqlLycee); 
    if(!mysql_real_connect(&mysqlLycee,argv[1],argv[2],argv[3],argv[4],0,NULL,0))printf("Error on second connect"); 
    int i; 
    while ((row = mysql_fetch_row(result))){ 
     unsigned long *lengths;  
     lengths = mysql_fetch_lengths(result); 
     for(i=0;i<num_champs;i++){ 
      if(i==0)sprintf(noParticipant,"%.*s", (int) lengths[i], row[i] ? row[i] : "NULL"); 
      if(i==1)sprintf(kmParcourus,"%.*s", (int) lengths[i], row[i] ? row[i] : "NULL"); 
     } 
     sprintf(requete,"UPDATE PARTICIPANTS SET KMPARCOURUS=%s WHERE NO_PARTICIPANT=%s",kmParcourus,noParticipant); 
     if(!mysql_query(&mysqlLycee,requete))printf("Error on second query"); 

    } 
    mysql_free_result(result); 
    mysql_close(&mysqlLycee); 
    return 0; 
}

我工作的Debian 8，然后用下面的命令编译：

gcc updateLycee.c -o updateLycee -lmysqlclient -L/usr/lib64/mysql -I/usr/include/mysql;

编辑：添加MySQL的检查，但在启动程序时仍出现段错误。

来源

2016-04-25 T. Roncoli

请为每个MySQL调用添加错误检查。 – fluter

我修改了代码来让mysql检查，但无论如何，当我执行segfault出现的程序时。 –

空格和换行符便宜;使用它们。 –

您关闭与本地数据库的连接，然后尝试从与该连接关联的结果集中获取行。这是行不通的。

如果你想将数据从一个数据库转移到其他然后您必须

第一啜食所有想要从一个DB数据到内存（读取所有行和存储你所需要的内容例如普通阵列），或者
保持与两个数据库同时打开的连接。

来源

2016-04-25 03:33:35

谢谢你的帮助！我试着保持这两种联系，但我也遇到了麻烦。但是，存储数据实际上是我没有考虑的解决方案！ –

如何在C中使用MySQL与2个数据库进行交互？

回答

相关问题