Connecteur C / MariaDB

Connecteur C / MariaDB - C - Programmation

Marsh Posté le 18-07-2019 à 15:15:01    

Salut, je galère...
 
Je souhaite faire une application en C qui récupère des données d'un broker MQTT pour les stocker dans une bdd MariaDB.
Je m'en sors globalement, sauf au moment de l'insertion du DATETIME.
 
Il m'a fallut déjà un jour pour comprendre que je ne pouvais pas mettre un simple string correctement formaté mais qu'il fallait une structure MYSQL_TIME. :o
Maintenant, le programme plante sans explication. Par d'erreur SQL, rien, ça sort du programme avec l'erreur suivante :  
 

Citation :

Program received signal SIGSEGV, Segmentation fault.
In mysql_stmt_warning_count () (C:\Users\c.dutriez\Documents\Programmation_EVO2\usage_evo2\bin\Debug\libmariadb.dll)
#3  0x00401f30 in main (argc=1, argv=0xd2ef0) at C:\Users\c.dutriez\Documents\Programmation_EVO2\usage_evo2\main.c:375
C:\Users\c.dutriez\Documents\Programmation_EVO2\usage_evo2\main.c:375:10954:beg:0x401f30
At C:\Users\c.dutriez\Documents\Programmation_EVO2\usage_evo2\main.c:375
#3  0x00401f30 in main (argc=1, argv=0xd2ef0) at C:\Users\c.dutriez\Documents\Programmation_EVO2\usage_evo2\main.c:375
C:\Users\c.dutriez\Documents\Programmation_EVO2\usage_evo2\main.c:375:10954:beg:0x401f30


 
 
voici une partie du programme :
 

Code :
  1. #include <stdio.h>
  2. #include <stdlib.h>
  3. #include <string.h>
  4. #include <mosquitto.h>
  5. #include <usage_evo2.h>
  6. #include <mysql.h>
  7. #include <time.h>
  10. char evo2msg[16];
  11. char evo2tps[20];
  12. int evo2grille;
  13. int evo2coiffe;
  14. int evo2ddv;
  15. int evo2vitessemoteur;
  16. int evo2consigne;
  17. int evo2cartouche;
  18. int evo2omron;
  20. MYSQL_TIME timestamp;
  22. char* getPayload (char *message);
  23. char* getTimestamp (char *message);
  24. void my_message_callback(struct mosquitto *mosq, void *userdata, const struct mosquitto_message *message);
  25. void my_connect_callback(struct mosquitto *mosq, void *userdata, int result);
  26. void my_subscribe_callback(struct mosquitto *mosq, void *userdata, int mid, int qos_count, const int *granted_qos);
  27. void my_log_callback(struct mosquitto *mosq, void *userdata, int level, const char *str);
  28. static void show_mysql_error(MYSQL *mysql);
  29. static void show_stmt_error(MYSQL_STMT *stmt);
  31. int main(int argc, char *argv[]){
  33.     MYSQL *mysql;
  34.     MYSQL_STMT *stmt;
  35.     MYSQL_BIND bind[10];
  37.     timestamp.year = 2002;
  38.     timestamp.month = 10;
  39.     timestamp.day = 5;
  40.     timestamp.hour = 11;
  41.     timestamp.minute = 57;
  42.     timestamp.second = 34;
  43.     timestamp.
  45. /* MQTT parameters */
  46. char *host = "localhost";
  47. int port = 1883;
  48. int keepalive = 10;
  49. bool clean_session = true;
  50. struct mosquitto *mosq = NULL;
  52.  /* MYSQL parameters */
  54.     char *payload[] = {"0123456789ABCDEF"};
  55.     int omron[] = {0};
  56.     int coiffe[] = {0};
  57.     int grille[] = {0};
  58.     int vitesse_moteur[] = {0};
  59.     int ddv[] = {0};
  60.     int consigne[] = {0};
  61.     int defaut[] = {0};
  62.     unsigned long payload_length[]= {16};
  64.     char forename_ind[]= {STMT_INDICATOR_NTS};
  65.     char id_ind[]= {STMT_INDICATOR_NULL};
  67.     unsigned int array_size= 1;
  69. /* clock parameters */
  70. clock_t t1,t2;
  71. clock_t t_intervalle = 5000;
  73. mosquitto_lib_init();
  74. mosq = mosquitto_new("timestamp456", clean_session, NULL);
  75.  if(!mosq){
  76.  fprintf(stderr, "Error: Out of memory.\n" );
  77.  return 1;
  78. }
  80. /* callback fonctions */
  82. mosquitto_username_pw_set(mosq, "application", "timestamp456" );
  83. mosquitto_log_callback_set(mosq, my_log_callback);
  84. mosquitto_connect_callback_set(mosq, my_connect_callback);
  85. mosquitto_message_callback_set(mosq, my_message_callback);
  86. mosquitto_subscribe_callback_set(mosq, my_subscribe_callback);
  88. if(mosquitto_connect(mosq, host, port, keepalive)){
  89.  fprintf(stderr, "Unable to connect.\n" );
  90.  return 1;
  91. }
  93. mysql= mysql_init(NULL);
  95.     t2 = clock();
  97.     if (!mysql_real_connect(mysql, "localhost", "nom", "mdp","usage_db", 0, "/tmp/mysql.sock", 0)) show_mysql_error(mysql);
  99.     if (mysql_query(mysql, "DROP TABLE IF EXISTS bulk_example3" )) show_mysql_error(mysql);
  101.     if (mysql_query(mysql, "CREATE TABLE IF NOT EXISTS evo2_usage (\
  102.         id INT NOT NULL AUTO_INCREMENT PRIMARY KEY,\
  103.         datemsg CHAR(20),\
  104.         message CHAR(16),\
  105.         omron SMALLINT,\
  106.         coiffe SMALLINT,\
  107.         grille SMALLINT,\
  108.         vitesse_moteur SMALLINT,\
  109.         ddv SMALLINT,\
  110.         consigne SMALLINT,\
  111.         cart SMALLINT)" )) show_mysql_error(mysql);
  113.     while(1){
  115.     t1 = clock();
  118.         if (t1-t2 > t_intervalle){
  119.             t2 = t1;
  120.             mosquitto_loop(mosq,-1,1);
  122.             payload[0]= evo2msg;
  123.             //timestamp[0]= evo2tps;
  124.             omron[0] = evo2omron;
  125.             coiffe[0] = evo2coiffe;
  126.             grille[0] = evo2grille;
  127.             vitesse_moteur[0] = evo2vitessemoteur;
  128.             ddv[0] = evo2ddv;
  129.             consigne[0] = evo2consigne;
  130.             defaut[0] = evo2cartouche;
  133.                 stmt= mysql_stmt_init(mysql);
  135.                 if (mysql_stmt_prepare(stmt, "INSERT INTO evo2_usage VALUES (?,?,?,?,?,?,?,?,?,?)", -1)){
  136.                     show_stmt_error(stmt);
  137.                     printf("ca plante la\n" );
  138.                 }
  140.                 memset(bind, 0, sizeof(MYSQL_BIND) * 10);
  142.                 /* We autogenerate id's, so all indicators are STMT_INDICATOR_NULL */
  143.                 bind[0].u.indicator= id_ind;
  144.                 bind[0].buffer_type= MYSQL_TYPE_LONG;
  146.                 bind[1].buffer= (char *)&timestamp;          //datetime
  147.                 bind[1].buffer_type= MYSQL_TYPE_DATETIME;
  148.                 bind[1].is_null= 0;
  149.                 bind[1].length= 0;
  151.                 bind[2].buffer= payload;                        // msg entier
  152.                 bind[2].buffer_type= MYSQL_TYPE_STRING;
  153.                 bind[2].length= payload_length;
  155.                 bind[3].buffer = omron;                         // OMRON (vent)
  156.                 bind[3].buffer_type= MYSQL_TYPE_LONG;
  157.                 bind[3].u.indicator= forename_ind;
  159.                 bind[4].buffer = coiffe;                        // coiffe
  160.                 bind[4].buffer_type= MYSQL_TYPE_LONG;
  161.                 bind[4].u.indicator= forename_ind;
  163.                 bind[5].buffer = grille;                        // grille
  164.                 bind[5].buffer_type= MYSQL_TYPE_LONG;
  165.                 bind[5].u.indicator= forename_ind;
  167.                 bind[6].buffer = vitesse_moteur;                // vitesse_moteur
  168.                 bind[6].buffer_type= MYSQL_TYPE_LONG;
  169.                 bind[6].u.indicator= forename_ind;
  171.                 bind[7].buffer = ddv;                           // ddv
  172.                 bind[7].buffer_type= MYSQL_TYPE_LONG;
  173.                 bind[7].u.indicator= forename_ind;
  175.                 bind[8].buffer = consigne;                      // consigne
  176.                 bind[8].buffer_type= MYSQL_TYPE_LONG;
  177.                 bind[8].u.indicator= forename_ind;
  179.                 bind[9].buffer = defaut;                        // défaut
  180.                 bind[9].buffer_type= MYSQL_TYPE_LONG;
  181.                 bind[9].u.indicator= forename_ind;
  184.                 /* set array size */
  185.                 mysql_stmt_attr_set(stmt, STMT_ATTR_ARRAY_SIZE, &array_size);
  187.                 /* bind parameter */
  188.                 mysql_stmt_bind_param(stmt, bind);
  189.                 printf("ERREUR" );
  190.                
  191.                 /* execute */
  192.                 if (mysql_stmt_execute(stmt))
  193.                 show_stmt_error(stmt);
  195.                 printf("INSCRIPTION" );
  196.             }
  199.     }
  201. mosquitto_destroy(mosq);
  202. mosquitto_lib_cleanup();
  205.     mysql_stmt_close(stmt);
  206.     mysql_close(mysql);
  208.     return 0;
  210. }


 
Pour info, j'ai bien le message ERREUR qui s'affiche, mais pas celui ISNCRIPTION, ça plante donc bien après le paramétrage de stmt, mais pendant son exécution.
Si vous avez une piste, je suis preneur. PS : si à la place de datetime, je remplace par n'importe quelle autre type de données (string, ....), la donnée s'inscrit dans la BDD sans problème.


Message édité par _pollux_ le 18-07-2019 à 15:26:50

---------------
Le topic du sport électronique@hfr : watch the l33t !
Reply

Marsh Posté le 18-07-2019 à 15:15:01   

Reply

Marsh Posté le 19-07-2019 à 18:51:38    

Je suppose que tu compiles déjà avec -Wall -Werror ou un truc semblable et que ça ne sors rien?
C'est quoi usage_evo2.h? Le moteur de recherche ne connaît pas...
Essaye de simplifier ton problème en virant la partie MQTT et si possible le evo_mystère, ça sera plus facile (même déjà possible) pour nous de compiler et débugger ce truc.

Reply

Marsh Posté le 20-07-2019 à 09:10:09    

bind[1].is_null= 0;
 bind[1].length= 0;
 [:sovxx]  
Si je lis bien la doc, https://dev.mysql.com/doc/refman/8. [...] tures.html
is_null is a pointer to a boolean scalar, not a boolean scalar,  
donc ça fait un premier truc qui me semble plantogène, et
For input parameter data binding, set *length to indicate the actual length of the parameter value stored in *buffer.
donc on devrait avoir  
size_t timesize = sizeof(MYSQL_TIME);
bind[1].buffer_type= MYSQL_TYPE_DATETIME;
bind[1].length=&timesize;  
bind[1].buffer_length=timesize;  
bind[1].buffer= (char *)&timestamp;
et ça devrait suffire, non?
 
A+,


Message édité par gilou le 20-07-2019 à 11:35:33

---------------
There's more than what can be linked! --    Iyashikei Anime Forever!    --  AngularJS c'est un framework d'engulé!  --
Reply

Marsh Posté le 20-07-2019 à 09:41:51    

J'ai pas la main là dessus tout de suite, mais je promets de regarder ça de plus prêt :D

 

Comme je débute en C, je maitrise pas forcément très bien les pointeurs : par exemple, (char *)&timestamp, j'ai pas encore compris comment ça marche :D


Message édité par _pollux_ le 20-07-2019 à 13:18:51

---------------
Le topic du sport électronique@hfr : watch the l33t !
Reply

Marsh Posté le 20-07-2019 à 14:13:14    

Tu compiles bien avec -Wall -Werror? Indispensable pour un débutant, surtout quand on bricole les pointeurs! :o

Reply

Marsh Posté le 20-07-2019 à 18:16:08    

Oui, j'utilise code block et gcc. C'est par défaut et je n'ai aucune erreur. Mais j'ai pas encore eu le temps de tester les propositions de gilou. J'étais sur la doc de Maria DB, bien moins complète que celle de mysql.


Message édité par _pollux_ le 20-07-2019 à 18:16:28

---------------
Le topic du sport électronique@hfr : watch the l33t !
Reply

Marsh Posté le 22-07-2019 à 10:48:49    

Pour repartir sur de bonnes bases, la version épurée :

 
Code :
  1. #include <stdio.h>
  2. #include <stdlib.h>
  3. #include <string.h>
  4. #include <mysql.h>
  8. static void show_mysql_error(MYSQL *mysql)
  9. {
  10.   printf("Error(%d) [%s] \"%s\"", mysql_errno(mysql),
  11.                                   mysql_sqlstate(mysql),
  12.                                   mysql_error(mysql));
  13.   exit(-1);
  14. }
  16. static void show_stmt_error(MYSQL_STMT *stmt)
  17. {
  18.   printf("Error(%d) [%s] \"%s\"", mysql_stmt_errno(stmt),
  19.                                   mysql_stmt_sqlstate(stmt),
  20.                                   mysql_stmt_error(stmt));
  23.   exit(-1);
  24. }
  26. int main(int argc, char *argv[])
  27. {
  28.   MYSQL *mysql;
  29.   MYSQL_STMT *stmt;
  30.   MYSQL_BIND bind[4];
  31.   MYSQL_TIME timestamp;
  33.   timestamp.year = 2000;
  34.   timestamp.month = 4;
  35.   timestamp.day = 21;
  36.   timestamp.hour = 5;
  37.   timestamp.minute = 23;
  38.   timestamp.second = 59;
  40.   /* Data for insert */
  41.   const char *surnames[]= {"pollux"};
  42.   unsigned long surnames_length[]= {10};
  43.   const char *forenames[]= {"dog"};
  44.   char forename_ind[]= {STMT_INDICATOR_NTS};
  45.   char id_ind[]= {STMT_INDICATOR_NULL};
  46.   unsigned int array_size= 1;
  48.   mysql= mysql_init(NULL);
  50.   /* connect to MariaDB server */
  51.   if (!mysql_real_connect(mysql, "localhost", "root", "wesh","usage_db", 0, "/tmp/mysql.sock", 0)) show_mysql_error(mysql);
  53.   if (mysql_query(mysql, "DROP TABLE IF EXISTS bulk_example1" ))
  54.     show_mysql_error(mysql);
  56.   if (mysql_query(mysql,"CREATE TABLE bulk_example1 (\
  57.                         id INT NOT NULL AUTO_INCREMENT PRIMARY KEY,\
  58.                         forename CHAR(30) NOT NULL DEFAULT 'unknown',\
  59.                         surname CHAR(30),\
  60.                         date DATETIME)" ))
  61.     show_mysql_error(mysql);
  63.   stmt= mysql_stmt_init(mysql);
  64.   if (mysql_stmt_prepare(stmt, "INSERT INTO bulk_example1 VALUES (?,?,?,?)", -1))
  65.     show_stmt_error(stmt);
  67.   memset(bind, 0, sizeof(MYSQL_BIND) * 4);
  69.   /* We autogenerate id's, so all indicators are STMT_INDICATOR_NULL */
  70.   bind[0].u.indicator= id_ind;
  71.   bind[0].buffer_type= MYSQL_TYPE_LONG;
  73.   bind[1].buffer= forenames;
  74.   bind[1].buffer_type= MYSQL_TYPE_STRING;
  75.   bind[1].u.indicator= forename_ind;
  77.   bind[2].buffer_type= MYSQL_TYPE_STRING;
  78.   bind[2].buffer= surnames;
  79.   bind[2].length= surnames_length;
  81.   bind[3].buffer_type= MYSQL_TYPE_DATETIME;
  82.   bind[3].buffer = (char *)&timestamp;
  83.   bind[3].length = 0;
  84.   bind[3].is_null = 0;
  87.   /* set array size */
  88.   mysql_stmt_attr_set(stmt, STMT_ATTR_ARRAY_SIZE, &array_size);
  90.   /* bind parameter */
  91.   mysql_stmt_bind_param(stmt, bind);
  93.   /* execute */
  94.   if (mysql_stmt_execute(stmt))
  95.     show_stmt_error(stmt);
  97.   mysql_stmt_close(stmt);
  98.   mysql_close(mysql);
  101.   return 0;
  102. }


Message édité par _pollux_ le 22-07-2019 à 10:54:29

---------------
Le topic du sport électronique@hfr : watch the l33t !
Reply

Marsh Posté le 22-07-2019 à 10:52:27    

En corrigeant avec la proposition de Gilou,

 


j'ai une erreur de type sur le &timesize. :

Code :
  1. size_t timesize = sizeof(MYSQL_TIME);
  2.     bind[3].buffer_type= MYSQL_TYPE_DATETIME;
  3.     bind[3].length=&timesize;
  4.     bind[3].buffer_length=timesize;
  5.     bind[3].buffer= (char *)&timestamp;
 


C:\C\test2\main.c|3|warning: assignment from incompatible pointer type.


Message édité par _pollux_ le 22-07-2019 à 10:55:09

---------------
Le topic du sport électronique@hfr : watch the l33t !
Reply

Marsh Posté le 22-07-2019 à 11:49:18    

Tu remplaces 1 par  
unsigned long timesize = sizeof(MYSQL_TIME);
et ça devrait coller.
 
Et comme buffer devrait être un void *, au vu de la doc, tu peux aussi tant que tu y es faire pour 5
bind[3].buffer= (void *)&timestamp;
 
A+,


Message édité par gilou le 22-07-2019 à 12:00:52

---------------
There's more than what can be linked! --    Iyashikei Anime Forever!    --  AngularJS c'est un framework d'engulé!  --
Reply

Marsh Posté le 22-07-2019 à 12:26:56    

ça marche mieux ! enfin, j'en reviens au départ, ça compile avec des données sans doute mieux traitées.

 

Par contre :/ :

Citation :

Program received signal SIGSEGV, Segmentation fault.
In mysql_stmt_warning_count () (C:\C\test2\bin\Debug\libmariadb.dll)
#3  0x00401652 in main (argc=1, argv=0x852ee8) at C:\C\test2\main.c:95
C:\C\test2\main.c:95:2658:beg:0x401652
At C:\C\test2\main.c:95
#3  0x00401652 in main (argc=1, argv=0x852ee8) at C:\C\test2\main.c:95
C:\C\test2\main.c:95:2658:beg:0x401652

 

D'autre part, sachant que :

Citation :

length is ignored for numeric and temporal data types because the buffer_type value determines the length of the data value.

 

J'ai carrément viré la ligne 3, mais ça ne change rien au problème.


Message édité par _pollux_ le 22-07-2019 à 16:01:17

---------------
Le topic du sport électronique@hfr : watch the l33t !
Reply

Marsh Posté le 22-07-2019 à 12:26:56   

Reply

Marsh Posté le 22-07-2019 à 16:35:37    

Bon désolé, j'ai finalement réussi à compiler le truc mais je sais pas le faire fonctionner, pourtant j'ai investi du temps...

 

Pour ceux qui veulent tester et qui sont sous Debian faut être sous Debian 10.

Message cité 1 fois
Message édité par rat de combat le 22-07-2019 à 16:37:45
Reply

Marsh Posté le 22-07-2019 à 16:49:35    

Merci d'avoir essayé en tout cas :o

 

J'vais essayer de contacter les dev via IRC, parce que je suis bien coincé là :/
ça fait un peu 4 jours que je suis sur cette connerie.


Message édité par _pollux_ le 22-07-2019 à 16:50:00

---------------
Le topic du sport électronique@hfr : watch the l33t !
Reply

Marsh Posté le 22-07-2019 à 17:08:12    

rat de combat a écrit :

Bon désolé, j'ai finalement réussi à compiler le truc mais je sais pas le faire fonctionner, pourtant j'ai investi du temps...
 
Pour ceux qui veulent tester et qui sont sous Debian faut être sous Debian 10.


pourquoi Debian 10 d'ailleurs ?  
 
(j'suis sous windows  [:cerveau eric] )

Message cité 1 fois

---------------
Le topic du sport électronique@hfr : watch the l33t !
Reply

Marsh Posté le 22-07-2019 à 18:24:11    

sinon, j'ai trouvé cette page là dans la doc de MYSQL :  
 
https://dev.mysql.com/doc/refman/8. [...] dling.html
mais ça m'aide pas trop :/
 


---------------
Le topic du sport électronique@hfr : watch the l33t !
Reply

Marsh Posté le 22-07-2019 à 18:32:11    

_pollux_ a écrit :


pourquoi Debian 10 d'ailleurs ?  
 
(j'suis sous windows  [:cerveau eric] )

Parce que il faut une version assez récente de MariaDB et celle de Debian 9 semble trop ancienne. J'ai pas poussé trop loin, j'ai changé de machine virtuelle.

Reply

Marsh Posté le 22-07-2019 à 18:34:53    

ok.

 

Bon, personne ne répond sur IRC, semblerait qu'il y ait des plages horaires pour les réponses :D ... par désespoir, j'ai laissé un message ici : https://mariadb.zulipchat.com/#narr [...] ew-members
C'est compliqué de joindre les teams de dev maintenant, on est loin de la facilité d'un forum :o


Message édité par _pollux_ le 22-07-2019 à 18:35:28

---------------
Le topic du sport électronique@hfr : watch the l33t !
Reply

Marsh Posté le 24-07-2019 à 14:25:16    

Bon, problème non résolu frontalement. Cependant, d'un strict point de vue fonctionnel, j'ai fait sans "prepared statement functions" et ça marche.


---------------
Le topic du sport électronique@hfr : watch the l33t !
Reply

Sujets relatifs:

Leave a Replay

Make sure you enter the(*)required information where indicate.HTML code is not allowed