【正文】 return retval。 strncpy(id, str, p str)。 char id[3]。,39。 return num。 t = strtok(NULL, delim)。 (p = va_arg(ap, char *)) != NULL) { num++。 while (t != NULL amp。 va_start(ap, str1)。 char *t = NULL。 va_list ap。 return EXIT_SUCCESS。 } } } } free(events)。 } } } if (done) { printf(closed connection on descriptor %d\n, events[i].)。arg)。 pthread_create(amp。, startplace, weekend, studentId, year, month, day)。 and busdate = 39。) and stuno = 39。 and weekend = 39。 sprintf(cmd, delete from TicketsReservation where busno = (select busno from SchoolBus where startplace = 39。 [4] = day。 [2] = year。 [0] = studentId。 char weekend[3] = {0}。 char month[3] = {0}。 char startplace[50]= {0}。 } case DROP_TICKETS: { char fid[3] = {0}。arg)。 pthread_create(amp。 sprintf(cmd, select * from SchoolBus)。 } case QUERY_SCHOOL_BUS: { char fid[3] = {0}。arg)。 pthread_create(amp。, studentId, year, month, day)。 and busdate = 39。 sprintf(cmd, select ,stuno,busdate,bustime from TicketsReservation, SchoolBus where = and stuno = 39。%s%s%s39。%s39。 int retval = str_split(buf, fid, studentId, year, month, day)。 char month[3] = {0}。 char studentId[20] = {0}。 break。thr, NULL, book_ticket, amp。 = cmd。%s%s%s39。%s39。%s39。%s39。 [5] = weekend。 [3] = month。 [1] = startplace。 int retval = str_split(buf, fid, studentId, startplace, year, month, day, weekend)。 char day[4] = {0}。 char year[6] = {0}。 char studentId[20] = {0}。 break。thr, NULL, query, amp。 = cmd。%s39。 int retval = str_split(buf, fid, studentId)。 } case QUERY_ORDERS: { char fid[3] = {0}。arg)。 pthread_create(amp。, startpos, year, month, day)。) and busdate = 39。 sprintf(cmd, select ticketsno from TicketsLeft where busno in (select busno from SchoolBus where startplace = 39。 char day[4] = {0}。 char year[6] = {0}。 } case QUERY_TICKETS: { char fid[3] = {0}。arg)。 pthread_create(amp。, studentId)。 sprintf(cmd, select * from Student where stuno = 39。 memset(studentId, 0, sizeof(studentId))。 memset(fid, 0, sizeof(fid))。 break。thr, NULL, modify_passwd, amp。 = cmd。%s39。%s39。%s39。 int retval = str_split(buf, fid, studentId, passwd, new_passwd)。 char new_passwd[20]。 char passwd[20]。 char studentId[20]。 } case MODIFY_PASSWD: { char fid[3]。arg)。 pthread_create(amp。, studentId, passwd)。 and accountkey = 39。 sprintf(cmd, select * from Account where accountno = 39。 memset(passwd, 0, sizeof(passwd))。 memset(studentId, 0, sizeof(studentId))。 memset(fid, 0, sizeof(fid))。 break。 pthread_t thr。my_connection。 arg_attr arg。 memset(cmd, 0, sizeof(cmd))。 break。 } break。 if (count == 1) { //if errno==EAGAIN, that means we have read all data. //so go back to the main loop if (errno != EAGAIN) { printf(read %s\n, strerror(errno))。 memset(buf, 0, sizeof(buf))。 while (1) { ssize_t count。 } else { //we have data on the fd waiting to be read. read and display it. //we must read whatever data is available pletely, as we are //running in edgetriggered mode and won39。 return EXIT_FAILURE。event)。 = EPOLLIN | EPOLLET。 return EXIT_FAILURE。 ret = ftl(infd, F_SETFL, flags)。 return EXIT_FAILURE。 } //make the ining socket nonblocking and add it to the list of fds to monitor flags = ftl(infd, F_GETFL, 0)。in_addr, in_len, hbuf, sizeof(hbuf), sbuf, sizeof(sbuf), NI_NUMERICHOST | NI_NUMERICHOST)。 break。 if (infd == 1) { if ((errno == EAGAIN) || (errno == EWOULDBLOCK)) { //we have processed all ining connections break。in_addr, amp。 in_len = sizeof(in_addr)。 int infd。 } else if(st == events[i].) { //we have a notification on the listening socket, //which means one or more ining connections while (1) { struct sockaddr in_addr。 close(events[i].)。 EPOLLHUP) || \ (!(events[i].events amp。 i++) { if ((events[i].events amp。//沒有事件發(fā)生時一直阻塞 for (i = 0。 //the event loop while (1) { int n, i。 return EXIT_FAILURE。event)。 = EPOLLIN | EPOLLET。 struct epoll_event *events。 return EXIT_FAILURE。 } //創(chuàng)建一個epoll對象 int efd = epoll_create1(0)。my_connection))。my_connection)) { fprintf(stderr, connection error %d: %s\n, mysql_errno(amp。 } else { fprintf(stderr, connection failed\n)。)。my_connection, set names 39。 if (mysql_real_connect(amp。 mysql_init(amp。 return EXIT_FAILURE。 } //監(jiān)聽客戶端的連接請求 ret = listen(st, SOMAXCONN)。 if (ret == 1) { printf(ftl %s\n, strerror(errno))。 } flags |= O_NONBLOCK。 if (flags == 1) { printf(ftl %s\n, strerror(errno))。 } //設置socket為非阻塞的 int flags, ret。addr, sizeof(addr)) == 1) { printf(bind failed %s\n, strerror(errno))。//將本地字節(jié)順序轉(zhuǎn)化位網(wǎng)論字節(jié)順序 = htonl(INADDR_ANY)。 = AF_INET。//定義一個ip地址結(jié)構(gòu) memset(amp。 int st = socket(AF_INET, SOCK_STREAM, 0)。int main(int arg, char *args[]){ if (arg 2) { return 1。} 自動更新余票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 //查詢預售期define QUERY_TICKETS 3 //查詢車票define BOOK_TICKETS 4 //訂票define QUERY_ORDERS_TODAY 5 //查詢今日訂單define QUERY_ORDERS