TCP Socket и прием смешанных данных, работа с текстом

    
#include <sys/types.h>
#include <sys/socket.h>
#include <sys/time.h>
#include <netinet/in.h>
#include <stdio.h>
#include <unistd.h>
#include <fcntl.h>
#include <algorithm>
#include <set>
using namespace std;
int main()
{
    int listener;
    struct sockaddr_in addr;
    char buf[1024];
    char buf_wright[1024];
    int bytes_read;
    int bytes_wright;
    
    listener = socket(AF_INET, SOCK_STREAM, 0); //создаем интернет потоковый сокет
    if(listener < 0)
    {
        perror("socket");
        exit(1);
    }
    
    fcntl(listener, F_SETFL, O_NONBLOCK);
    
    addr.sin_family = AF_INET;
    addr.sin_port = htons(25565);
    addr.sin_addr.s_addr = INADDR_ANY;
    if(bind(listener, (struct sockaddr *)&addr, sizeof(addr)) < 0)
    {
        perror("bind");
        exit(2);
    }
    listen(listener, 2);
    
    set<int> clients;
    clients.clear();
    while(1)
    {
        // Заполняем множество сокетов
        fd_set readset;
        FD_ZERO(&readset);
        FD_SET(listener, &readset);
        for(set<int>::iterator it = clients.begin(); it != clients.end(); it++)
            FD_SET(*it, &readset);
        // Задаем таймаут
        timeval timeout;
        timeout.tv_sec = 200;
        timeout.tv_usec = 0;
        // Ждем события в одном из сокетов
        int mx = max(listener, *max_element(clients.begin(), clients.end()));
        if(select(mx+1, &readset, NULL, NULL, &timeout) <= 0)
        {
                printf("NET_ERROR_MSG: Порт отвалился\n");
            exit(3);
        }
        
        // Определяем тип события и выполняем соответствующие действия
        if(FD_ISSET(listener, &readset))
        {
            // Поступил новый запрос на соединение, используем accept
            int sock = accept(listener, NULL, NULL);
            if(sock < 0)
            {
                perror("accept");
                exit(3);
            }
            
            fcntl(sock, F_SETFL, O_NONBLOCK);
            clients.insert(sock);
        }
        for(set<int>::iterator it = clients.begin(); it != clients.end(); it++)
        {
            if(FD_ISSET(*it, &readset))
            {
                // Поступили данные от клиента, читаем их
                bytes_read = recv(*it, buf, 1024, 0);
                printf("=======================\n");
                printf("NET_MSG_PORT: %d\nNET_MSG_BYTES: %d\nNET_MSG:", addr.sin_port, bytes_read);
                if(bytes_read <= 0)
                {
                    // Соединение разорвано, удаляем сокет из множества
                    printf("Соединение разорвано");
                    printf("\n=======================\n");
                    close(*it);
                    clients.erase(*it);
                    continue;
                }
                else
                {
                    //выводим на экран все байты буфера
                    for (int i = 0; i<bytes_read; i++) 
                    {
                        printf("%x   ", buf[i]);
                    }
                    printf("\n=======================\n");
                }
            }
        }
    }
   
    return 0;
}

    
// для правильной работы библиотеки необходим: sudo apt-get install mysql-server mysql-client libmysqlclient12-dev
#include <stdio.h>
#include <stdlib.h>
#include <mysql/mysql.h>
#include <iostream>
using namespace std;
//задаем переменные MySQL
MYSQL mysql;
MYSQL_RES *res;
MYSQL_ROW row;
void exiterr(int exitcode);
int main(){
     //инициализируем обращение к mysql
    mysql_init(&mysql);    
     //прописываем логин и пароль
    if(!mysql_real_connect(&mysql, "localhost", "%username%", "%passwrd%", "%database%", 0, 0, 0))
        exiterr(1);
         //выбираем базу данных
    if (mysql_select_db(&mysql,"%database%")) exiterr(2); 
   //выбираем столбцы для таблицы
   if (mysql_query(&mysql,"SELECT login FROM login_table"))   
      exiterr(3);
   
   if (!(res = mysql_store_result(&mysql)))
      exiterr(4);
   //выводим значения таблицы в цикле
   while((row = mysql_fetch_row(res))) {                        
      for (int i=0 ; i < mysql_num_fields(res); i++)
         printf("%s\n",row[i]);
   }
   
   if (!mysql_eof(res))
      exiterr(5);
   mysql_free_result(res);
   //закрываем обращение к mysql
    mysql_close(&mysql);         
    return 0;
}
//===============================================================================
void exiterr(int exitcode){
// fprintf(stderr, "%s\n", mysql_error(&mysql)); Си вариант
std::cout << mysql_error(&mysql)<<"\n";
exit(exitcode);
}