【文章內(nèi)容簡介】 on, cmd1)。 if(send(client_fd, True, sizeof(True), 0) == 1) { fprintf(stderr, send in book_ticket failed %s\n, strerror(errno))。 } } else { if(send(client_fd, False, sizeof(False), 0) == 1) { fprintf(stderr, send in book_ticket failed %s\n, strerror(errno))。 } } } mysql_free_result(res_ptr)。 } } else { fprintf(stderr, book_ticket error %d: %s\n, mysql_errno(amp。my_connection), mysql_error(amp。my_connection))。 } close(client_fd)。 return NULL。}void *drop_ticket(void *arg){ if (arg == NULL) { return NULL。 } arg_attr arg_ = *(arg_attr*)arg。 MYSQL my_connection。 my_connection = *()。 int client_fd = 。 int cmd[1024] = {0}。 char studentId[20] = {0}。 char startplace[50]= {0}。 char year[6] = {0}。 char month[3] = {0}。 char day[4] = {0}。 char weekend[3] = {0}。 strcpy(cmd, )。 strcpy(studentId, [0])。 strcpy(startplace, [1])。 strcpy(year, [2])。 strcpy(month, [3])。 strcpy(day, [4])。 strcpy(weekend, [5])。 int retval = mysql_query(amp。my_connection, cmd)。 if (!retval) { if (mysql_affected_rows(amp。my_connection)) { char cmd[1024] = {0}。 sprintf(cmd, update TicketsLeft set ticketsno = ticketsno + 1 where busno = (select busno from SchoolBus where startplace = 39。%s39。 and weekend = 39。%s39。) and busdate = 39。%s%s%s39。, startplace, weekend, year, month, day)。 mysql_query(amp。my_connection, cmd)。 if (mysql_affected_rows(amp。my_connection)) { if(send(client_fd, True, sizeof(True), 0) == 1) { fprintf(stderr, send in drop_ticket failed %s\n, strerror(errno))。 } } else { printf(update in drop_ticket failed\n)。 } } } close(client_fd)。 return NULL。}void *check_account(void *arg){ if (arg == NULL) { return NULL。 } arg_attr arg_ = *(arg_attr*)arg。 MYSQL my_connection。 my_connection = *()。 int client_fd = 。 int cmd[1024] = {0}。 strcpy(cmd, )。 int retval。 //mysql_query(, set names 39。utf839。)。 retval = mysql_query(amp。my_connection, cmd)。 printf(%s\n, cmd)。 if (!retval) { MYSQL_RES *res_ptr = mysql_use_result(amp。my_connection)。 if (res_ptr) { MYSQL_ROW sqlrow = mysql_fetch_row(res_ptr)。 if (sqlrow) { if(send(client_fd, True, sizeof(True), 0) == 1) { fprintf(stderr, send in check_account failed %s\n, strerror(errno))。 } } else { if(send(client_fd, False, sizeof(False), 0) == 1) { fprintf(stderr, send in check_account failed %s\n, strerror(errno))。 } } mysql_free_result(res_ptr)。 } } else { fprintf(stderr, check_account error %d: %s\n, mysql_errno(amp。my_connection), mysql_error(amp。my_connection))。 } close(client_fd)。 return NULL。}void *modify_passwd(void *arg){ if (arg == NULL) { return NULL。 } arg_attr arg_ = *(arg_attr*)arg。 MYSQL my_connection。 my_connection = *()。 int client_fd = 。 int cmd[1024] = {0}。 strcpy(cmd, )。 int retval。 //mysql_query(, set names 39。utf839。)。 retval = mysql_query(amp。my_connection, cmd)。 if (!retval) { if (mysql_affected_rows(amp。my_connection)) { if(send(client_fd, True, sizeof(True), 0) == 1) { fprintf(stderr, send in modify_passwd failed %s\n, strerror(errno))。 } } else { if(send(client_fd, FALSE, sizeof(FALSE), 0) == 1) { fprintf(stderr, send in modify_passwd failed %s\n, strerror(errno))。 } } } else { fprintf(stderr, modify_passwd error %d: %s\n, mysql_errno(amp。my_connection), mysql_error(amp。my_connection))。 if(send(client_fd, FALSE, sizeof(FALSE), 0) == 1) { fprintf(stderr, send in modify_passwd failed %s\n, strerror(errno))。 } } close(client_fd)。 return NULL。}void *query(void *arg){ if (arg == NULL) { return NULL。 } arg_attr arg_ = *(arg_attr*)arg。 MYSQL my_connection。 my_connection = *()。 int client_fd = 。 int cmd[1024] = {0}。 strcpy(cmd, )。 //sleep(10)。 int retval。 //mysql_query(, set names 39。utf839。)。 retval = mysql_query(amp。my_connection, cmd)。 if (!retval) { MYSQL_RES *res_ptr = mysql_use_result(amp。my_connection)。 if (res_ptr) { MYSQL_ROW sqlrow。 char buf[4*1024]。 memset(buf, 0, sizeof(buf))。 while((sqlrow = mysql_fetch_row(res_ptr))) { unsigned int field_count = 0。 while (field_count mysql_field_count(amp。my_connection)) { if (!strcat(buf, sqlrow[field_count])) { return NULL。 } //printf(%s\n, sqlrow[field_count])。 if (field_count != mysql_field_count(amp。my_connection) 1) { if (!strcat(buf, ,)) { return NULL。 } } else { if (!strcat(buf, )) { return NULL。 } } field_count++。 } } if (mysql_errno(amp。my_connection)) { fprintf(stderr, retrieve in query error:%s\n, mysql_error(amp。my_connection))。 } if (strlen(buf) 0) { strcat(buf, )。 printf(%s\n, buf)。 if (send(client_fd, buf, strlen(buf), 0) == 1) { fprintf(stderr, send in query failed %s\n, strerror(errno))。 } } else { printf(nothing\n)。 if (send(client_fd, , strlen(,), 0) == 1) { fprintf(stderr, send in query failed %s\n, strerror(errno))。 } } mysql_free_result(res_ptr)。 } } else { fprintf(stderr, query %d: %s\n, mysql_errno(amp。my_connection), mysql_error(amp。my_connection))。 } close(client_fd)。 return NULL。} 自動(dòng)更新余票include include include include include include sys/include sys/include netinet/include arpa/include include sys/include include include include define MAXEVENTS 64define QUERY_PRE_SALE 2 //查詢預(yù)售期define QUERY_TICKETS 3 //查詢車票define BOOK_TICKETS 4 //訂票define QUERY_ORDERS_TODAY 5 //查詢今日訂單define QUERY_ORDERS 6 //查詢訂單define PUSH_MESSAGE 7 //推送消息