#include <sys/types.h>

#include <sys/stat.h>

#include <fcntl.h>
#include <unistd.h>  //write头文件

#include <mysql/mysql.h>//包含MySQL头文件

#include <stdio.h>

#include <string.h>

#include <stdlib.h>

void connect_mysql(MYSQL * mysql ,char * str[],MYSQL **connect);

void insert_mysql(MYSQL * mysql);

void delete_mysql(MYSQL * mysql);

void update_mysql(MYSQL * mysql);

void select_mysql(MYSQL * mysql,MYSQL **connect);

void show_table(MYSQL * mysql,MYSQL **connect);

void set_char(MYSQL * mysql);

void menu();

void quit(MYSQL **connect);

int main(int argc,char *argv[])

{

    MYSQL mysql, *connect = NULL;

    char *str[] = {argv[],argv[],argv[]};

    connect_mysql(&mysql,str,&connect);

    menu();

    quit(&connect);

    return ;

}

void set_char(MYSQL *mysql)//设置数据库的字符集  要先做

{

    int i = mysql_query(mysql,"set names utf8");//向mysql服务器端发送指令

    //成功则返回0，失败则返回非0数据

    if(i != )

    {

        printf("set char fail!!\n");

        return;

    }

}

void select_mysql(MYSQL *mysql,MYSQL **connect)

{

    if(!mysql)

        return;

    else{

    write(,"Input select SQL:\n",strlen("Input select SQL:\n"));

    char select_sql[];

    int n=;

    memset(select_sql,,sizeof(select_sql));

    for(n;;n++)//读取标准输入直到；在去除；

    {

        select_sql[n]=getchar();

        if(select_sql[n] == ';')

        {

            select_sql[n]=;

            break;

        }

    }

    char * SQL = select_sql;

    int i = mysql_query(mysql,SQL);

    if(i !=  )

    {

        printf("Update SQL fail %s \n",mysql_error(mysql));

        return;

    }else

        printf("Update SQL success\n");

    }

    MYSQL_RES *res = mysql_store_result(mysql);//返回结果集放入MYSQL_RES中

    int num_fields = mysql_num_fields(res);//查看结果集中行数

    MYSQL_ROW row;

    while((row = mysql_fetch_row(res)))//检索一个结果集合的下一行。当在mysql_store_result()之后使用时，

    //没有更多的行可检索时，mysql_etch_row()返回NULL

    {

        int i;

        for(i=;i<num_fields;i++)

        {

            printf("%s\n",row[i]);

        }

    }

    mysql_free_result(res);//必须清空结果集########

}

void show_table(MYSQL *mysql,MYSQL **connect)

{

    int i = mysql_query(mysql,"show tables");

    if(i != )

        return;

    else{

        MYSQL_RES * result = mysql_store_result(*connect);

        int num_fields = mysql_num_fields(result);

        MYSQL_ROW row;

        while((row = mysql_fetch_row(result)))

        {

            int i;

            for(i=;i<num_fields;i++)

            {

                char *SQL;

                sprintf(SQL,"desc %s",row[i]);

                int n = mysql_query(mysql,SQL);

            MYSQL_RES * res= mysql_store_result(*connect);

//可以调用mysql_fetch_row()来获取结果集中的行，或调用mysql_row_seek()

//和mysql_row_tell()来获取或设置结果集中的当前行位置。

//一旦完成了对结果集的操作，必须调用mysql_free_result()。

            int table_num = mysql_num_fields(res);

            MYSQL_ROW row1;

            while((row1 = mysql_fetch_row(res)))

            {

                int j;

                for(j=;j<table_num;j++)

                {

                printf("%s\n",row1[j]);

                }

            }

            mysql_free_result(res);

            }

        }

        mysql_free_result(result);

    }

}

void update_mysql(MYSQL *mysql)

{

    if(!mysql)

        return;

    else{

    write(,"Input update SQL:\n",strlen("Input update SQL:\n"));

    char update_sql[];

    int n=;

    memset(update_sql,,sizeof(update_sql));

    for(n;;n++)

    {

        update_sql[n]=getchar();

        if(update_sql[n] == ';')

        {

            update_sql[n]=;

            break;

        }

    }

    char * SQL = update_sql;

    int i = mysql_query(mysql,SQL);

    if(i !=  )

    {

        printf("Update SQL fail %s \n",mysql_error(mysql));

        return;

    }else

        printf("Update SQL success\n");

    }

}

void delete_mysql(MYSQL *mysql)

{

    if(!mysql)

        return;

    else{

    write(,"Input delete SQL:\n",strlen("Input delete SQL:\n"));

    char delete_sql[];

    int n=;

    memset(delete_sql,,sizeof(delete_sql));

    for(n;;n++)

    {

        delete_sql[n]=getchar();

        if(delete_sql[n] == ';')

        {

            delete_sql[n]=;

            break;

        }

    }

    char * SQL = delete_sql;

    int i = mysql_query(mysql,SQL);

    if(i !=  )

    {

        printf("Delete SQL fail %s \n",mysql_error(mysql));

        return;

    }else

        printf("Delete SQL success\n");

    }

}

void insert_mysql(MYSQL *mysql)

{

    if(!mysql)

        return;

    else{

    write(,"Input insert SQL:\n",strlen("Input insert SQL:\n"));

    char insert_sql[];

    int n=;

    memset(insert_sql,,sizeof(insert_sql));

    for(n;;n++)

    {

        insert_sql[n]=getchar();

        if(insert_sql[n] == ';')

        {

            insert_sql[n]=;

            break;

        }

    }

    char * SQL = insert_sql;

    int i = mysql_query(mysql,SQL);

    if(i !=  )

    {

        printf("Insert SQL fail %s \n",mysql_error(mysql));

        return;

    }else

        printf("Insert SQL success\n");

    }

}

void connect_mysql(MYSQL *mysql,char *str[],MYSQL **connect)

{

    char passwd[];

    memset(passwd,,sizeof(passwd));

    write(,"passwd:",strlen("passwd:"));

    scanf("%s",passwd);

    passwd[strlen(passwd)]=;

    mysql_init(mysql);

    *connect = mysql_real_connect(mysql,str[],str[],passwd,str[],,,);

    if(*connect == NULL)

    {

        printf("Connect database fail! %s\n",mysql_error(mysql));

        return;

    }else{

        printf("Connect success!\n");

    }

}

void quit(MYSQL **connect)

{

    mysql_close(*connect);

    *connect = NULL;

    printf("Bye\n");

    exit();

}

void menu()

{

    printf("###########################\n");

    printf("     A -> SELECT:\n");

    printf("     B -> UPDATE:\n");

    printf("     C -> DELETE:\n");

    printf("     D -> INSERT:\n");

    printf("     E -> DESC TABLE:\n");

    printf("     Q -> QUIT:\n");

    printf("###########################\n");

    write(,"Input: ",strlen("Input: "));

}

sudo apt-get install libmysqlclient-dev