Forum |  HardWare.fr | News | Articles | PC | S'identifier | S'inscrire | Shop Recherche
1220 connectés 

  FORUM HardWare.fr
  Programmation
  C

  Connecteur C / MariaDB

 
 


 Mot :   Pseudo :  
 
Bas de page
Auteur Sujet :

Connecteur C / MariaDB

n°2336916
_pollux_
Pan ! t'es mort
Posté le 18-07-2019 à 15:15:01  profilanswer
 

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 !
mood
Publicité
Posté le 18-07-2019 à 15:15:01  profilanswer
 

n°2336966
rat de com​bat
attention rongeur méchant!
Posté le 19-07-2019 à 18:51:38  profilanswer
 

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.

n°2336975
gilou
Modérateur
Modzilla
Posté le 20-07-2019 à 09:10:09  profilanswer
 

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é!  --
n°2336976
_pollux_
Pan ! t'es mort
Posté le 20-07-2019 à 09:41:51  profilanswer
 

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 !
n°2336980
rat de com​bat
attention rongeur méchant!
Posté le 20-07-2019 à 14:13:14  profilanswer
 

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

n°2336991
_pollux_
Pan ! t'es mort
Posté le 20-07-2019 à 18:16:08  profilanswer
 

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 !
n°2337029
_pollux_
Pan ! t'es mort
Posté le 22-07-2019 à 10:48:49  profilanswer
 

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 !
n°2337030
_pollux_
Pan ! t'es mort
Posté le 22-07-2019 à 10:52:27  profilanswer
 

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 !
n°2337033
gilou
Modérateur
Modzilla
Posté le 22-07-2019 à 11:49:18  profilanswer
 

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é!  --
n°2337034
_pollux_
Pan ! t'es mort
Posté le 22-07-2019 à 12:26:56  profilanswer
 

ç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 !
mood
Publicité
Posté le 22-07-2019 à 12:26:56  profilanswer
 

n°2337040
rat de com​bat
attention rongeur méchant!
Posté le 22-07-2019 à 16:35:37  profilanswer
 

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
n°2337041
_pollux_
Pan ! t'es mort
Posté le 22-07-2019 à 16:49:35  profilanswer
 

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 !
n°2337042
_pollux_
Pan ! t'es mort
Posté le 22-07-2019 à 17:08:12  profilanswer
 

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 !
n°2337053
_pollux_
Pan ! t'es mort
Posté le 22-07-2019 à 18:24:11  profilanswer
 

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 !
n°2337054
rat de com​bat
attention rongeur méchant!
Posté le 22-07-2019 à 18:32:11  profilanswer
 

_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.

n°2337055
_pollux_
Pan ! t'es mort
Posté le 22-07-2019 à 18:34:53  profilanswer
 

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 !
n°2337153
_pollux_
Pan ! t'es mort
Posté le 24-07-2019 à 14:25:16  profilanswer
 

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 !

Aller à :
Ajouter une réponse
  FORUM HardWare.fr
  Programmation
  C

  Connecteur C / MariaDB

 

Sujets relatifs
Header C dans prog cppC++ calcul d'un nombre prmier
[C#] Charger un combobox plus rapidementRécupération adresse IP de ma Passerelle en C
MariaDB Requête UPDATE JSON_SET sur une colonne NULLDébutant en C rencontre quelques soucis...
codage en language CLogiciel pour développer en C++
[STM32]Implémentation afficheur oled NHD0420CW en I²C 
Plus de sujets relatifs à : Connecteur C / MariaDB

Forum MesDiscussions.Net, Version 2010.2
(c) 2000-2011 Doctissimo
Page générée en 0.125 secondes

Copyright © 1997-2022 Hardware.fr SARL (Signaler un contenu illicite / Données personnelles) / Groupe LDLC / Shop HFR