局域网聊天系统（lanqq）

/*==================================================================== * Copyright (C) 2014 All rights reserved. * * filename：test-mysql.c * Author：dongsongz * Date：2014/06/06 *Description： * * Update Log： * ====================================================================*/ #include <stdio.h> #include <my_global.h> #include <mysql.h> #include <string.h> #include "lanqq.h" #define HOST "127.0.0.1" #define USER "dongsongz" #define PASS "123" #define DATABASE "test" int mysql_user_insert(char *name, char *password, int sd, char *user_id) { MYSQL *conn; //printf("MySQL client version:%s\n", mysql_get_client_info()); conn = mysql_init(NULL); if(conn == NULL) { printf("Error %u: %s\n", mysql_errno(conn), mysql_error(conn)); return 1; } if(mysql_real_connect(conn, HOST,USER, PASS,DATABASE, 0, NULL, 0) == NULL) { printf("Error %u: %s\n", mysql_errno(conn), mysql_error(conn)); return 1; } //user(user_id int,name varchar(20),password varchar(20),status enum('offline','online'),logintimes int, purview int,password_question varchar(100),password_answer varchar(100),group_id varchar(100),sd int); char sql[2000]; sprintf(sql, "insert into user values('%s','%s','%s','0','1','1','NULL','NULL','NULL','%d','0')",user_id, name, password,sd); printf("%s\n",sql); mysql_query(conn, sql); #if 0 mysql_query(conn, "SELECT * FROM user"); MYSQL_RES *result = mysql_store_result(conn); if(result == NULL) { printf("Error %u: %s\n", mysql_errno(conn), mysql_error(conn)); return 1; } int num_fields = mysql_num_fields(result); MYSQL_ROW row; while(row = mysql_fetch_row(result)) { int i; for(i = 0; i < num_fields; i++) { //printf("%s\t", row[i] ? row[i] : "NULL"); } //printf("\n"); } mysql_free_result(result); #endif mysql_close(conn); return 0; } #if 1 int mysql_message_insert(char *message, int is_read) { printf("message:%s\n", message); char timestr[30]; //char msg[1050]; char send_id[5],recv_id[5]; int num_off_msg; MYSQL *conn; //printf("MySQL client version:%s\n", mysql_get_client_info()); conn = mysql_init(NULL); if(conn == NULL) { printf("Error %u: %s\n", mysql_errno(conn), mysql_error(conn)); return 1; } if(mysql_real_connect(conn, HOST,USER, PASS,DATABASE, 0, NULL, 0) == NULL) { printf("Error %u: %s\n", mysql_errno(conn), mysql_error(conn)); return 1; } if ( mysql_set_character_set(conn, "utf8" ) ) { printf("error:%s\n", mysql_error(conn)); } char sql[2000]; num_off_msg = 1; bzero(send_id, sizeof(send_id)); strncpy(send_id, message + 1, 4); //printf("send_id:%s\n", send_id); bzero(recv_id, sizeof(recv_id)); strncpy(recv_id, message + 5, 4); //printf("recv_id:%s\n", recv_id); bzero(timestr, sizeof(timestr)); strncpy(timestr, message + 9, 25); //printf("timestr:%s\n", timestr); sprintf(sql, "insert into message values('%s','%s','%s','%s','%d','%d')",timestr, message, send_id, recv_id, is_read, num_off_msg); printf("%s\n",sql); mysql_query(conn, sql); mysql_close(conn); return 0; } int mysql_select(char *tablename,char *str1, char *str2, char *fileld_name, char **res_str, int *res_int, int flag) { //char tmp; MYSQL *conn; //mysql_set_character_set(conn, "utf8"); //printf("MySQL client version:%s\n", mysql_get_client_info()); conn = mysql_init(NULL); if(conn == NULL) { printf("Error %u: %s\n", mysql_errno(conn), mysql_error(conn)); return 1; } printf("prepare to connect\n"); if(mysql_real_connect(conn, HOST,USER, PASS,DATABASE, 0, NULL, 0) == NULL) { printf("Error %u: %s\n", mysql_errno(conn), mysql_error(conn)); return 1; } #if 1 if(strcmp(tablename, "message") == 0) { printf("this is select in message\n"); //int ret = mysql_real_query(conn, "SET message UTF8;", //(unsigned long) strlen ("SET message UTF8;")); int ret = mysql_set_character_set(conn, "utf8"); printf("finish set character utf8\n"); } #endif //user(user_id int,name varchar(20),password varchar(20),status enum('offline','online'),logintimes int, purview int,password_question varchar(100),password_answer varchar(100),group_id varchar(100),sd int); char sql[2000]; //if(strcmp(str1, "name") == 0) //{ printf("prepare to compare flag\n"); if(flag == 0) { sprintf(sql, "select %s from %s where %s='%s'", fileld_name,tablename, str1, str2); printf("%s\n", sql); //mysql_query(conn, "set character set utf8"); mysql_query(conn,sql); MYSQL_RES *result = mysql_store_result(conn); if(result == NULL) { printf("Error %u: %s\n", mysql_errno(conn), mysql_error(conn)); return 1; } int num_fields = mysql_num_fields(result); MYSQL_ROW row; while(row = mysql_fetch_row(result)) { int i; for(i = 0; i < num_fields; i++) { printf("\nsql row[i]:%s\n", row[i] ? row[i] : "NULL"); //*res_str = row[i] ? row[i] : "NULL"; printf("strlen(row[i]) = %d\n", strlen(row[i])); //*res_str = row[i] ? row[i] : "NULL"; bzero(*res_str, sizeof(*res_str)); strcpy(*res_str, (row[i] ? row[i] : "NULL")); printf("\nsql *res_str:%s\n", *res_str); } //printf("\n"); } mysql_free_result(result); mysql_close(conn); } else if(flag == 1) { sprintf(sql, "select %s from %s where %s='%s'", fileld_name, tablename, str1, str2); printf("%s\n", sql); mysql_query(conn,sql); MYSQL_RES *result = mysql_store_result(conn); if(result == NULL) { printf("Error %u: %s\n", mysql_errno(conn), mysql_error(conn)); return 1; } int num_fields = mysql_num_fields(result); MYSQL_ROW row; while(row = mysql_fetch_row(result)) { int i; for(i = 0; i < num_fields; i++) { //printf("%s\t", row[i] ? row[i] : "0"); //tmp = row[i] ? row[i] : "0"; *res_int = (int)(row[i][0] - '0'); //printf("*res_int = %d\n", *res_int); } //printf("\n"); } mysql_free_result(result); mysql_close(conn); } // } return 0; } #endif int mysql_off_msg_select(char *tablename,char *str1, char *str2, char *fileld_name, int socket_fd, int num) { char msgrecv[1050],msgsend[1050]; MYSQL *conn; conn = mysql_init(NULL); if(conn == NULL) { printf("Error %u: %s\n", mysql_errno(conn), mysql_error(conn)); return 1; } printf("prepare to connect\n"); if(mysql_real_connect(conn, HOST,USER, PASS,DATABASE, 0, NULL, 0) == NULL) { printf("Error %u: %s\n", mysql_errno(conn), mysql_error(conn)); return 1; } #if 1 if(strcmp(tablename, "message") == 0) { printf("this is select in message\n"); int ret = mysql_set_character_set(conn, "utf8"); printf("finish set character utf8\n"); } #endif char sql[2000]; if(num == 1) sprintf(sql, "select %s from %s where %s='%s'", fileld_name,tablename, str1, str2); else sprintf(sql, "select %s from %s where %s='%s'and is_read='%d'", fileld_name,tablename, str1, str2, num); printf("%s\n", sql); //mysql_query(conn, "set character set utf8"); mysql_query(conn,sql); MYSQL_RES *result = mysql_store_result(conn); if(result == NULL) { printf("Erro