【正文】 } case MODIFY_PASSWD: { char fid[3]。 memset(fid, 0, sizeof(fid))。 char studentId[20]。 memset(studentId, 0, sizeof(studentId))。 char passwd[20]。 memset(passwd, 0, sizeof(passwd))。 char new_passwd[20]。 memset(passwd, 0, sizeof(passwd))。 int retval = str_split(buf, fid, studentId, passwd, new_passwd)。 sprintf(cmd, update Account set accountkey = 39。%s39。 where accountno = 39。%s39。 and accountkey = 39。%s39。, new_passwd, studentId, passwd)。 = cmd。 pthread_create(amp。thr, NULL, modify_passwd, amp。arg)。 break。 } case QUERY_PERSON_INFO: { char fid[3]。 memset(fid, 0, sizeof(fid))。 char studentId[20]。 memset(studentId, 0, sizeof(studentId))。 int retval = str_split(buf, fid, studentId)。 sprintf(cmd, select * from Student where stuno = 39。%s39。, studentId)。 = cmd。 pthread_create(amp。thr, NULL, query, amp。arg)。 break。 } case QUERY_TICKETS: { char fid[3] = {0}。 char startpos[50] = {0}。 char year[6] = {0}。 char month[3] = {0}。 char day[4] = {0}。 int retval = str_split(buf, fid, startpos, year, month, day)。 sprintf(cmd, select ticketsno from TicketsLeft where busno in (select busno from SchoolBus where startplace = 39。%s39。) and busdate = 39。%s%s%s39。, startpos, year, month, day)。 = cmd。 pthread_create(amp。thr, NULL, query, amp。arg)。 break。 } case QUERY_ORDERS: { char fid[3] = {0}。 char studentId[20] = {0}。 int retval = str_split(buf, fid, studentId)。 sprintf(cmd, select ,stuno,busdate,bustime from TicketsReservation, SchoolBus where = and stuno = 39。%s39。 order by busdate DESC, studentId)。 = cmd。 pthread_create(amp。thr, NULL, query, amp。arg)。 break。 } case BOOK_TICKETS: { char fid[3] = {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}。 int retval = str_split(buf, fid, studentId, startplace, year, month, day, weekend)。 [0] = studentId。 [1] = startplace。 [2] = year。 [3] = month。 [4] = day。 [5] = weekend。 sprintf(cmd, select 1 from TicketsReservation where busno = (select busno from SchoolBus where startplace = 39。%s39。 and weekend = 39。%s39。) and stuno = 39。%s39。 and busdate = 39。%s%s%s39。 limit 1, startplace, weekend, studentId, year, month, day)。 = cmd。 pthread_create(amp。thr, NULL, book_ticket, amp。arg)。 break。 } case QUERY_ORDERS_TODAY: { char fid[3]= {0}。 char studentId[20] = {0}。 char year[6] = {0}。 char month[3] = {0}。 char day[4] = {0}。 int retval = str_split(buf, fid, studentId, year, month, day)。 // sprintf(cmd, select * from TicketsReservation where stuno = 39。%s39。 and busdate = 39。%s%s%s39。, studentId, year, month, day)。 sprintf(cmd, select ,stuno,busdate,bustime from TicketsReservation, SchoolBus where = and stuno = 39。%s39。 and busdate = 39。%s%s%s39。, studentId, year, month, day)。 = cmd。 pthread_create(amp。thr, NULL, query, amp。arg)。 break。 } case QUERY_SCHOOL_BUS: { char fid[3] = {0}。 int retval = str_split(buf, fid)。 sprintf(cmd, select * from SchoolBus)。 = cmd。 pthread_create(amp。thr, NULL, query, amp。arg)。 break。 } case DROP_TICKETS: { char fid[3] = {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}。 int retval = str_split(buf, fid, studentId, startplace, year, month, day, weekend)。 [0] = studentId。 [1] = startplace。 [2] = year。 [3] = month。 [4] = day。 [5] = weekend。 sprintf(cmd, delete from TicketsReservation where busno = (select busno from SchoolBus where startplace = 39。%s39。 and weekend = 39。%s39。) and stuno = 39。%s39。 and busdate = 39。%s%s%s39。, startplace, weekend, studentId, year, month, day)。 = cmd。 pthread_create(amp。thr, NULL, drop_ticket, amp。arg)。 break。 } } } if (done) { printf(closed connection on descriptor %d\n, events[i].)。 //closing the descriptor will make epoll remove it from the set //of descriptors which are monitored //close(events[i].)。 } } } } free(events)。 close(st)。 return EXIT_SUCCESS。}static int str_split(char *str1, ...){ int num = 0。 va_list ap。 const char delim[] = {,}。 char *t = NULL。 char *p = NULL。 va_start(ap, str1)。 t = strtok(str1, delim)。 while (t != NULL amp。amp。 (p = va_arg(ap, char *)) != NULL) { num++。 strcpy(p, t)。 t = strtok(NULL, delim)。 } va_end(ap)。 return num。}static int get_first_field(const char *str){ char *p = strchr(str, 39。,39。)。 char id[3]。 memset(id, 0, sizeof(id))。 strncpy(id, str, p str)。 int retval = atoi(id)。 return retval。} 響應(yīng)客戶端實(shí)現(xiàn)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 //推送消息define CHECK_ACCOUNT 9 //驗(yàn)證賬戶define QUERY_PERSON_INFO 10 //查詢個(gè)人信息define MODIFY_PASSWD 11