Untitled

// Connect to database
       if

 (!mysql_real_connect(conn, server,
         user, password, database, 0, NULL, 0)) {
      fprintf(stderr, "%sn", mysql_error(conn));
      exit(1);
    }
      if (mysql_query(conn, "SELECT stan FROM controlers WHERE mikrokontroler=1")) {
    fprintf(stderr, "%sn", mysql_error(conn));
    exit(1);
    }

       res = mysql_use_result(conn);
       //output row value
       printf("Value in row 1 equals=:n");
       while ((row = mysql_fetch_row(res)) != NULL)
       printf("%s n", row[0]);

// Connect to database
       if

 (!mysql_real_connect(conn, server,
         user, password, database, 0, NULL, 0)) {
      fprintf(stderr, "%sn", mysql_error(conn));
      exit(1);
    }
      if (mysql_query(conn, "SELECT stan FROM controlers WHERE mikrokontroler=1")) {
    fprintf(stderr, "%sn", mysql_error(conn));
    exit(1);
    }

       res = mysql_use_result(conn);
       //output row value
       printf("Value in row 1 equals=:n");
       while ((row = mysql_fetch_row(res)) != NULL)
       printf("%s n", row[0]);

1 ??  house
controlers
controlers??stan??sta ??   ?      pkp??!ihouse mysql_native_password

1 ??  house
controlers
controlers??stan??sta ??   ?      pkp??!ihouse mysql_native_password

#define BUFLEN 512
#define NPACK 10
#define PORT 9050


  //gcc -o output-file $(mysql_config --cflags) udp_mysql.c $(mysql_config --libs)

 void diep(char *s)
 {
    perror(s);
    exit(1);
 }

 int main(void)
 {
    MYSQL *conn;
    MYSQL_RES *res;
    MYSQL_ROW row;
    char *server = "localhost";
    char *user = "user";
    char *password = "password"; /* set me first */
    char *database = "database";
    conn = mysql_init(NULL);

    // Connect to database
    if (!mysql_real_connect(conn, server, user, password, database, 0, NULL, 0)) {
    fprintf(stderr, "%sn", mysql_error(conn));
    exit(1);
    }
    //if (mysql_query(conn, "SELECT * FROM controlers")) {
    if (mysql_query(conn, "SELECT stan FROM controlers WHERE mikrokontroler=1")) {
    fprintf(stderr, "%sn", mysql_error(conn));
    exit(1);
    }

    res = mysql_use_result(conn);
    // output table name
    printf("MySQL Tables in mysql database:n");
    while ((row = mysql_fetch_row(res)) != NULL)
    // printf("%s %s %s n", row[0],row[1],row[2]);
    printf("%s n", row[0]);
    /* close connection */
    //mysql_free_result(res);
    //mysql_close(conn);

    struct sockaddr_in si_me, si_other;
    int s, i, slen=sizeof(si_other);
    char buf[BUFLEN];

    char mysql_data[BUFLEN];

    char a[BUFLEN];


    if ((s=socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP))==-1)
         diep("socket");

    memset((char *) &si_me, 0, sizeof(si_me));
    si_me.sin_family = AF_INET;
    si_me.sin_port = htons(PORT);
    si_me.sin_addr.s_addr = htonl(INADDR_ANY);
    if (bind(s, &si_me, sizeof(si_me))==-1)
        diep("bind");

    for (i=0; i<NPACK; i++)
    {

       if (recvfrom(s, buf, BUFLEN, 0,(struct sockaddr *) &si_other, &slen)==-1)
          diep("recvfrom()");
          printf("Received packet from %s:%dnData: %snn", inet_ntoa(si_other.sin_addr), ntohs(si_other.sin_port), buf);
          //memset(buf, 0, sizeof buf);
          //sprintf(data,"%s",buf);
          sprintf(mysql_data,"UPDATE controlers SET stan=%s WHERE mikrokontroler=1",buf);
          mysql_query(conn, mysql_data);

          if (mysql_query(conn, "SELECT stan FROM controlers WHERE mikrokontroler=1"))
         {
             fprintf(stderr, "%sn", mysql_error(conn));
             exit(1);
         }

         res = mysql_use_result(conn);

         if((row = mysql_fetch_row(res)) != NULL)
         {
            sprintf(a,"%s",row[0]);
            //this is how i was trying to send
            //if (sendto(s, row[0], BUFLEN, 0, (struct sockaddr*) &si_other, slen)==-1)
           if (sendto(s, a, BUFLEN, 0, (struct sockaddr*) &si_other, slen)==-1)
           diep("sendto()");
           printf("a equals %snn", a);
         }


          mysql_free_result(res);


        }

        close(s);
        return 0;
        }

#define BUFLEN 512
#define NPACK 10
#define PORT 9050


  //gcc -o output-file $(mysql_config --cflags) udp_mysql.c $(mysql_config --libs)

 void diep(char *s)
 {
    perror(s);
    exit(1);
 }

 int main(void)
 {
    MYSQL *conn;
    MYSQL_RES *res;
    MYSQL_ROW row;
    char *server = "localhost";
    char *user = "user";
    char *password = "password"; /* set me first */
    char *database = "database";
    conn = mysql_init(NULL);

    // Connect to database
    if (!mysql_real_connect(conn, server, user, password, database, 0, NULL, 0)) {
    fprintf(stderr, "%sn", mysql_error(conn));
    exit(1);
    }
    //if (mysql_query(conn, "SELECT * FROM controlers")) {
    if (mysql_query(conn, "SELECT stan FROM controlers WHERE mikrokontroler=1")) {
    fprintf(stderr, "%sn", mysql_error(conn));
    exit(1);
    }

    res = mysql_use_result(conn);
    // output table name
    printf("MySQL Tables in mysql database:n");
    while ((row = mysql_fetch_row(res)) != NULL)
    // printf("%s %s %s n", row[0],row[1],row[2]);
    printf("%s n", row[0]);
    /* close connection */
    //mysql_free_result(res);
    //mysql_close(conn);

    struct sockaddr_in si_me, si_other;
    int s, i, slen=sizeof(si_other);
    char buf[BUFLEN];

    char mysql_data[BUFLEN];

    char a[BUFLEN];


    if ((s=socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP))==-1)
         diep("socket");

    memset((char *) &si_me, 0, sizeof(si_me));
    si_me.sin_family = AF_INET;
    si_me.sin_port = htons(PORT);
    si_me.sin_addr.s_addr = htonl(INADDR_ANY);
    if (bind(s, &si_me, sizeof(si_me))==-1)
        diep("bind");

    for (i=0; i<NPACK; i++)
    {

       if (recvfrom(s, buf, BUFLEN, 0,(struct sockaddr *) &si_other, &slen)==-1)
          diep("recvfrom()");
          printf("Received packet from %s:%dnData: %snn", inet_ntoa(si_other.sin_addr), ntohs(si_other.sin_port), buf);
          //memset(buf, 0, sizeof buf);
          //sprintf(data,"%s",buf);
          sprintf(mysql_data,"UPDATE controlers SET stan=%s WHERE mikrokontroler=1",buf);
          mysql_query(conn, mysql_data);

          if (mysql_query(conn, "SELECT stan FROM controlers WHERE mikrokontroler=1"))
         {
             fprintf(stderr, "%sn", mysql_error(conn));
             exit(1);
         }

         res = mysql_use_result(conn);

         if((row = mysql_fetch_row(res)) != NULL)
         {
            sprintf(a,"%s",row[0]);
            //this is how i was trying to send
            //if (sendto(s, row[0], BUFLEN, 0, (struct sockaddr*) &si_other, slen)==-1)
           if (sendto(s, a, BUFLEN, 0, (struct sockaddr*) &si_other, slen)==-1)
           diep("sendto()");
           printf("a equals %snn", a);
         }


          mysql_free_result(res);


        }

        close(s);
        return 0;
        }