开发者社区> 吴英强> 正文
阿里云
为了无法计算的价值
打开APP
阿里云APP内打开

【C/C++学院】(23)Mysql数据库编程--C语言编程实现mysql客户端

简介: <div class="markdown_views"> <p><font color="blue" size="3"> <br><strong><em>【送给在路上的程序员】</em></strong> <br><font color="red"> <br><strong>对于一个开发者而言,能够胜任系统中任意一个模块的开发是其核心价值的体现。</strong> <br><f
+关注继续查看


【送给在路上的程序员】

对于一个开发者而言,能够胜任系统中任意一个模块的开发是其核心价值的体现。

对于一个架构师而言,掌握各种语言的优势并可以利运用到系统中,由此简化系统的开发,是其架构生涯的第一步。

对于一个开发团队而言,能够在短期内开发出用户满意的软件系统是其核心竞争力的体现。

每一个程序员都不能固步自封,要多接触新的行业,新的技术领域,突破自我。


makefile

.SUFFIXES: .c .o

CC=gcc
SRCS=mysql1.c\
            mydb.c

OBJS=$(SRCS:.c=.o)
EXEC=mysql1

all: $(OBJS)
    $(CC) -o $(EXEC) $(OBJS) -lmysqlclient
    @echo '-------------ok--------------'

.c.o:
    $(CC) -Wall -g -o $@ -c $< 

clean:
    rm -f $(OBJS)
    rm -f core*

mydb.h

#ifndef MYDB_H_
#define MYDB_H_


void init_db();
int conn_db(const char *hostname, const char *username, const char *password,
        const char *dbname);
void disconn_db();
int open_db(const char *SQL);
int exec_db(const char *SQL);

#endif /* MYDB_H_ */

mydb.c

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <mysql/mysql.h>
#include "mydb.h"

MYSQL *connection = NULL;
MYSQL mysql;

void init_db()
{
    mysql_init(&mysql);//初始化mysql
}

int conn_db(const char *hostname, const char *username, const char *password,
        const char *dbname)
{
    if (connection)
        mysql_close(connection);
    connection = mysql_real_connect(&mysql, hostname, username, password,
            dbname, 0, 0, 0);//连接到mysql

    if (connection == NULL)
    {
        printf("%s\n", mysql_error(&mysql));
        return -1;//连接失败,返回-1
    }

    printf("success connect to mysql\n");
    return 0;
}

void disconn_db()//断开数据库连接
{
    if (connection)
    {
        mysql_close(connection);
        connection = NULL;
    }
}

int open_db(const char *SQL)//执行有返回数据集的SQL语句
{
    int state = mysql_query(connection, SQL);//执行SQL语句
    if (state != 0)
    {
        printf("%s\n", mysql_error(connection));
        return -1;//执行失败,返回-1
    }

    MYSQL_RES *result = mysql_store_result(connection);//得到查询结果
    if (result == (MYSQL_RES *) NULL)
    {
        printf("%s\n", mysql_error(connection));
        return -1;//执行失败,返回-1
    } else
    {
        MYSQL_FIELD *sqlField;
        int iFieldCount = 0;
        while (1)//循环遍历所有字段
        {
            sqlField = mysql_fetch_field(result);
            if (sqlField == NULL)
                break;
            printf("%s\t", sqlField->name);//向屏幕打印字段名
            iFieldCount++;
        }
        printf("\n");//每一行结尾打印一个\n字符

        MYSQL_ROW sqlRow;
        while (1)//循环到每一行
        {
            sqlRow = mysql_fetch_row(result);
            if (sqlRow == NULL)
                break;
            int i;
            for (i = 0; i < iFieldCount; i++)//循环得到每一行中的每个字段
            {
                if (sqlRow[i] == NULL)
                    printf("NULL\t");//如果值为NULL,屏幕打印为"NULL"
                else
                    printf("%s\t", (const char *)sqlRow[i]);//屏幕打印为字段内容
            }
            printf("\n");//每一行结尾打印一个\n字符
        }
        printf("query is ok, %u rows affected\n", (unsigned int)mysql_affected_rows(connection));
        mysql_free_result(result);
    }
    return 0;
}

int exec_db(const char *SQL)//执行没有返回数据集的SQL语句
{
    int state = mysql_query(connection, SQL);//执行SQL语句
    if (state != 0)
    {
        printf("%s\n", mysql_error(connection));
        return -1;
    }
    printf("query is ok, %u rows affected\n", (unsigned int)mysql_affected_rows(connection));
    return 0;
}

mysql1.c

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <string.h>
#include <sys/types.h>
#include <errno.h>
#include <termios.h>
#include "mydb.h"


void sqldb(const char *src)//参数src为要执行的SQL语句
{
    if ((strncmp(src, "select", 6) == 0) || (strncmp(src, "SELECT", 6) == 0)
            || (strncmp(src, "show", 4) == 0) || (strncmp(src, "SHOW", 4) == 0)
            || (strncmp(src, "desc", 4) == 0) || (strncmp(src, "DESC", 4) == 0))
    {
        open_db(src);//如果src为有返回数据集SQL语句,那么调用open_db函数
    } else
    {
        exec_db(src);//如果src为没有有返回数据集SQL语句,那么调用exec_db函数
    }
}



void work(const char *userid, const char *password)
{
    init_db();
    if (conn_db("localhost", userid, password, "test") != 0)//连接到数据库
    {
        return;//连接数据库失败,函数退出
    }
    char buf[2048];
    while (1)//循环从键盘读取
    {
        write(STDOUT_FILENO, "mysql1>", strlen("mysql1>"));//屏幕输出命令提示符mysql1>
        memset(buf, 0, sizeof(buf));
        read(STDIN_FILENO, buf, sizeof(buf));//等待用户从键盘输入
        if (strncmp(buf, "quit", 4) == 0)
            break;//用户输入quit,循环break;
        sqldb(buf);
    }
    disconn_db();//断开数据库连接
}


struct termios oldterm;
void setstty()//设置输入退格键,不回显
{
    //system("stty erase ^H");//执行shell命令,也可以 用来设置读取用户键盘输入的时候,退格键不回显
    struct termios term;
    if(tcgetattr(STDIN_FILENO, &term) == -1)//得到系统termion的设置
    {
        printf("tcgetattr error is %s\n", strerror(errno));
        return;
    }

    oldterm = term;//保留当前termios设置,以便程序退出的时候可以恢复termios

    /*
    term.c_lflag &= ~ICANON;//取消ICANON选项(不规范输入)
    term.c_lflag |= ICANON;//设置ICANON选项(规范输入)
    term.c_cc字段为要设置的具体特殊输入字符,如c_cc[VERASE]代表退格键,
    term.c_cc[VERASE] = '\b';意思为把退格键修改为'\b'
    VERASE代表向前擦出一个字符,VINTR代表发送ctrl + C中断信号,ctrl + c的ASCII码为3
    例如:term.c_cc[VINTR] = '\t';意思为将tab键设置为终端信号
    tcsetattr中,第二个参数说明,TCSAFLUSH:发送了所有输出后更改才生效,在更改发生时,未读取的所有输入数据都被删除
    TCSANOW:更改立即生效
    TCSADRAIN:发送了所有输出后更改才发生,如果更改输出参数则应该使用该选项
    */
    term.c_cc[VERASE] = '\b';//'\b'为退格键的ASCII码
    if (tcsetattr(STDIN_FILENO, TCSANOW, &term) == -1)//设置系统termion
    {
        printf("tcsetattr error is %s\n", strerror(errno));
    }
    return;
}

void returnstty()//恢复系统的termios设置
{
    if (tcsetattr(STDIN_FILENO, TCSAFLUSH, &oldterm) == -1)//设置系统termion
    {
        printf("tcsetattr error is %s\n", strerror(errno));
    }
    return;
}


int main(int arg, char *args[])
{
    if (arg < 4)//如果没有参数,main函数退出
    {
        return EXIT_FAILURE;
    }

    if (strncmp(args[1], "-u", 2) != 0)//如果第二个参数不是-u,main函数退出
    {
        return EXIT_FAILURE;
    }

    if (strncmp(args[3], "-p", 2) != 0)//如果第四个参数不是-p,main函数退出
    {
        return EXIT_FAILURE;
    }

    const char *passwd = getpass("please input password:");//输入密码,屏幕不回显

    setstty();//设置输入退格键,不回显
    work(args[2], passwd);
    returnstty();//恢复系统的termios设置
    return EXIT_SUCCESS;
}


|========== 吴英强CSDN博客专栏==========|

|== C/C++学院 专栏文章的内容(不定期更新)===|

|== linux驱动开发 探索linux底层的奥秘 ========|

|== Java基础学习篇 掌握java语言的基础知识=====|

|====== 每天进步一点点,健康快乐每一天 ======|

版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。

相关文章
安装 MySql | 学习笔记
快速学习安装 MySql。
55 0
windows 10 下 mysql的安装
win10下 mysql的安装 今天在win10下装Mysql,总结一下安装详细过程: 1、下载【先进入官网: https://www.mysql.com/】(按照如下截图一步一步执行即可)           2、安装 下载出来的会是一个压缩包,解压到你打算安装的目录下边(不像图形化界面安装那样还需要点击一系列【next】),但是离完全安装成功,现在才是刚刚开始。
1565 0
mac下安装mysql
mac下安装mysql 根据我的自身经验来看,windows、liunx、mac这三个平台来看,mac上安装到正常运行是最耗我时间的。因此纪录下来,下次遇到有地方可查。 1、mysql下载安装: https://dev.mysql.com/downloads/mysql/ 这里要注意的是,最好安装和你系统匹配的版本,不然后续可能会遇到一些奇怪的错误。
4281 0
Mac上安装MySQL
版权声明:欢迎转载,请注明沉默王二原创。 https://blog.csdn.net/qing_gee/article/details/73824618 本篇文章没有技术含量,重在传播。
591 0
Windows 10下mysql 64位 安装(mysql-5.7.11-winx64安装)
Windows下mysql 64位 安装(mysql-5.7.11-winx64安装) 系统Windows10 安装包mysql-5.7.11-winx64.zip 安装过程中遇到的问题,请留意4.0常见问题汇总,常见问题都可解决。 附上最近一次完成安装记录,给大忙人看的只有两张图和完整的命令。 完成的命令 C:\Windows\syst
2564 0
Mac下安装MySQL
2015-07-13 15:10:32 Mac下用homebrew安装软件还是很方便的 brew install mysql 等待一会儿安装完毕后到安装目录:  /usr/local/Cellar/mysql/5.
760 0
MAC下homebre安装mysql
1.执行安装命令 brew install mysql 2.执行完输入mysql会有如下bug ERROR 2002 (HY000): Can not connect to local MySQL server through socket '/tmp/mysql.sock' (2) 3.bug解决方案 unset TMPDIR 4.然后 mysql_install_db --verbos
847 0
+关注
329
文章
0
问答
文章排行榜
最热
最新
相关电子书
更多
低代码开发师(初级)实战教程
立即下载
阿里巴巴DevOps 最佳实践手册
立即下载
冬季实战营第三期:MySQL数据库进阶实战
立即下载