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

【C/C++学院】(22)Mysql数据库编程--C语言操作数据库

简介: <p>makefile</p> <p></p> <pre code_snippet_id="613565" snippet_file_name="blog_20150306_1_3096831" name="code" class="cpp">.SUFFIXES: .c .o CC=gcc SRCS=mysql1.c OBJS=$(SRCS:.c=.o) EXEC=mys
+关注继续查看

makefile

.SUFFIXES: .c .o

CC=gcc
SRCS=mysql1.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*

mysql1.c

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <string.h>
#include <errno.h>
#include <termios.h>
#include <mysql/mysql.h>

#define BUFSIZE 1024

MYSQL mysql, *connection;

void deletename(char *SQL)
{
	memset(SQL, 0, BUFSIZE);
	sprintf(SQL, "%s", "请输入要干掉的名字>:");
	write(STDOUT_FILENO, SQL, strlen(SQL)); //这句话是替代printf函数的,这样写就不需要\n也能向屏幕输出了
	char name[1024];
	memset(name, 0, sizeof(name));
	read(STDIN_FILENO, name, sizeof(name)); //等待 用户输入要删除的名字,假设用户输入的是"饭岛爱"
	name[strlen(name) - 1] = 0; //将字符串最后一位\n替换为0,最后放的是整数0,而不是字符'0'

	memset(SQL, 0, BUFSIZE);
	sprintf(SQL, "DELETE FROM table1 WHERE name = '%s'", name); //
	//SQL = DELETE FROM table1 WHERE name = '饭岛爱'
	printf("'%s'\n", SQL);
}

void insertname(char *SQL)
{
	memset(SQL, 0, BUFSIZE);
	sprintf(SQL, "%s", "请输入要插入的名字>:");
	write(STDOUT_FILENO, SQL, BUFSIZE); //这句话是替代printf函数的,这样写就不需要\n也能向屏幕输出了
	char name[1024];
	memset(name, 0, sizeof(name));
	read(STDIN_FILENO, name, sizeof(name)); //等待 用户输入要插入的名字,假设用户输入的是"饭岛爱"
	name[strlen(name) - 1] = 0; //将字符串最后一位\n替换为0,最后放的是整数0,而不是字符'0'

	memset(SQL, 0, BUFSIZE);
	sprintf(SQL, "%s", "请输入要插入的性别>:");
	write(STDOUT_FILENO, SQL, strlen(SQL));
	char sex[1024];
	memset(sex, 0, sizeof(sex));
	read(STDIN_FILENO, sex, sizeof(sex)); //等待 用户输入要插入的性别,
	sex[strlen(sex) - 1] = 0; //将字符串最后一位\n替换为0,最后放的是整数0,而不是字符'0'

	memset(SQL, 0, BUFSIZE);
	sprintf(SQL, "%s", "请输入要插入的年龄>:");
	write(STDOUT_FILENO, SQL, strlen(SQL));
	char age[1024];
	memset(age, 0, sizeof(age));
	read(STDIN_FILENO, age, sizeof(age)); //等待 用户输入要插入的年龄
	age[strlen(age) - 1] = 0; //将字符串最后一位\n替换为0,最后放的是整数0,而不是字符'0'

	memset(SQL, 0, BUFSIZE);
	sprintf(SQL, "%s", "请输入要插入的班级>:");
	write(STDOUT_FILENO, SQL, strlen(SQL));
	char classes[1024];
	memset(classes, 0, sizeof(classes));
	read(STDIN_FILENO, classes, sizeof(classes)); //等待 用户输入要插入的班级
	classes[strlen(classes) - 1] = 0; //将字符串最后一位\n替换为0,最后放的是整数0,而不是字符'0'

	memset(SQL, 0, BUFSIZE);
	sprintf(SQL,
			"INSERT INTO table1 (name, sex, age, class) VALUES ('%s', '%s', %s, '%s')",
			name, sex, age, classes); //
	//SQL = DELETE FROM table1 WHERE name = '饭岛爱'
	printf("'%s'\n", SQL);
}

void updatename(char *SQL)
{
	memset(SQL, 0, BUFSIZE);
	sprintf(SQL, "%s", "请输入要修改的名字>:");
	write(STDOUT_FILENO, SQL, strlen(SQL)); //这句话是替代printf函数的,这样写就不需要\n也能向屏幕输出了
	char name[1024];
	memset(name, 0, sizeof(name));
	read(STDIN_FILENO, name, sizeof(name)); //等待 用户输入要插入的名字,假设用户输入的是"饭岛爱"
	name[strlen(name) - 1] = 0; //将字符串最后一位\n替换为0,最后放的是整数0,而不是字符'0'

	memset(SQL, 0, BUFSIZE);
	sprintf(SQL, "%s", "请输入要性别的性别>:");
	write(STDOUT_FILENO, SQL, strlen(SQL));
	char sex[1024];
	memset(sex, 0, sizeof(sex));
	read(STDIN_FILENO, sex, sizeof(sex)); //等待 用户输入要插入的性别,
	sex[strlen(sex) - 1] = 0; //将字符串最后一位\n替换为0,最后放的是整数0,而不是字符'0'

	memset(SQL, 0, BUFSIZE);
	sprintf(SQL, "%s", "请输入要年龄的年龄>:");
	write(STDOUT_FILENO, SQL, strlen(SQL));
	char age[1024];
	memset(age, 0, sizeof(age));
	read(STDIN_FILENO, age, sizeof(age)); //等待 用户输入要插入的年龄
	age[strlen(age) - 1] = 0; //将字符串最后一位\n替换为0,最后放的是整数0,而不是字符'0'

	memset(SQL, 0, BUFSIZE);
	sprintf(SQL, "%s", "请输入要修改的班级>:");
	write(STDOUT_FILENO, SQL, strlen(SQL));
	char classes[1024];
	memset(classes, 0, sizeof(classes));
	read(STDIN_FILENO, classes, sizeof(classes)); //等待 用户输入要插入的班级
	classes[strlen(classes) - 1] = 0; //将字符串最后一位\n替换为0,最后放的是整数0,而不是字符'0'

	memset(SQL, 0, BUFSIZE);
	sprintf(SQL,
			"UPDATE table1 SET sex = '%s', age = %s, class = '%s' WHERE name = '%s'",
			sex, age, classes, name); //
	//SQL = DELETE FROM table1 WHERE name = '饭岛爱'
	printf("'%s'\n", SQL);
}

void selectname(const char *SQL)
{
	/*
	char SQL[1024];
	memset(SQL, 0, BUFSIZE);
	sprintf(SQL, "%s", "请输入要查询的名字>:");
	write(STDOUT_FILENO, SQL, strlen(SQL)); //这句话是替代printf函数的,这样写就不需要\n也能向屏幕输出了
	char name[1024];
	memset(name, 0, sizeof(name));
	read(STDIN_FILENO, name, sizeof(name)); //等待 用户输入要删除的名字,假设用户输入的是"饭岛爱"
	name[strlen(name) - 1] = 0; //将字符串最后一位\n替换为0,最后放的是整数0,而不是字符'0'
	memset(SQL, 0, BUFSIZE);
	if (strlen(name) == 0) //用户没有任何输入,只是敲了回车,长度为0了
	{
		sprintf(SQL, "SELECT * FROM table2"); //
	} else
	{
		sprintf(SQL, "SELECT * FROM table2 where name = '%s'", name); //
	}

	*/
	if (mysql_query(connection, SQL) != 0)
	{
		printf("query error, %s\n", mysql_error(&mysql));
	}

	//调用mysql_store_result得到查询结果,结果放到MYSQL_RES结构当中
	MYSQL_RES *result = mysql_store_result(connection);
	//要知道返回数据集有多少列才能自由的使用各种SELECT语句
	MYSQL_FIELD *field;
	int iFieldCount = 0;
	while (1)
	{
		field = mysql_fetch_field(result); //循环得到列名,如果循环到了列的最后,函数返回NULL
		if (field == NULL)
			break;
		printf("%s\t", field->name);
		iFieldCount++;
	}
	printf("\n");

	//循环遍历每一行
	MYSQL_ROW row;
	while (1)
	{
		row = mysql_fetch_row(result);
		if (row == NULL)
			break;
		int i = 0;
		for (; i < iFieldCount; i++)
		{
			printf("%s\t", (const char *) row[i]);
		}
		printf("\n");
	}
	mysql_free_result(result);
}

int main(int arg, char *args[])
{
	if (arg < 4)
		return -1;

	mysql_init(&mysql);		//相当于SQL内部初始化了一个TCP的socket,同时初始化了SQL必须的内存和一些结构

	//连接到mysql server
	connection = mysql_real_connect(&mysql, args[1], args[2], args[3], args[4],
			0, 0, 0);
	if (connection == NULL)
	{
		printf("connect error, %s\n", mysql_error(&mysql));
		return -1;
	}

	if (mysql_query(connection, "SET NAMES utf8") != 0)		//设置字符集为UTF8
	{
		printf("设置字符集错误, %s\n", mysql_error(&mysql));
	}

	char buf[BUFSIZE];
	memset(buf, 0, sizeof(buf));
	strcpy(buf, "请选择\n1:插入\n2:删除\n3:修改\n4:查询\n");
	write(STDOUT_FILENO, buf, strlen(buf));
	memset(buf, 0, sizeof(buf));
	read(STDIN_FILENO, buf, sizeof(buf));
	if (strncmp(buf, "4", 1) == 0)		//输入用户输入的是4
	{
		memset(buf, 0, sizeof(buf));
		strcpy(buf, "请输入任意SELECt语句");
		write(STDOUT_FILENO, buf, strlen(buf));
		memset(buf, 0, sizeof(buf));
		read(STDIN_FILENO, buf, sizeof(buf));
		selectname(buf);
	} else
	{
		if (strncmp(buf, "1", 1) == 0)		//输入用户输入的是1
		{
			insertname(buf);
		}

		if (strncmp(buf, "2", 1) == 0)		//输入用户输入的是2
		{
			deletename(buf);
		}

		if (strncmp(buf, "3", 1) == 0)		//输入用户输入的是3
		{
			updatename(buf);
		}
		mysql_query(connection, buf);
	}

	mysql_close(connection);		//断开与SQL server的连接

	puts("!!!Hello World!!!"); /* prints !!!Hello World!!! */
	return EXIT_SUCCESS;
}



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

相关文章
【MySQL】你还不会在Docker下安装MySQL主备吗?
那什么时候就要开始考虑搭建主备架构呢, 一方面是随着业务增长,读写请求已经到达了一定的瓶颈时,我们需要考虑,另一方面为了保证数据的完整性,以保证主宕机的时候,可以快速切换。
12 0
MySQL安装+配置
首先在MySQL官网上下载安装包Mysql官网下载 解压后选择合适的安装路径一路next安装
20 0
Linux 使用rpm方式安装最新mysql(5.7.22)步骤以及常见问题解决
Linux 使用rpm方式安装最新mysql(5.7.22)步骤以及常见问题解决
17 0
Linux安装MYSQL 并使用图形化界面连接
Linux安装MYSQL 并使用图形化界面连接
31 0
MySql的详细安装说明
MySql的详细安装说明
27 0
Docker 安装 MySQL | 学习笔记
快速学习 Docker 安装 MySQL
17 0
Linux (centos8)安装 MySQL 8 数据库(图文详细教程)
今天2021年4月23日。我买了阿里云centos服务器,安装mysql8.0,做一笔记,以供大家使用。 本教程手把手教你如何在 Linux 安装 MySQL 数据库,以 CentOS 8为例。
398 0
Linux (centos8)安装 MySQL 8 数据库(图文详细教程)
本教程手把手教你如何在 Linux 安装 MySQL 数据库,以 CentOS 7为例。
84 0
+关注
文章
问答
文章排行榜
最热
最新
相关电子书
更多
MySQL 开发规约实战
立即下载
PostgresChina2018_张启程_为什么我们抛弃MongoDB和MySQL,选择PgSQL
立即下载
高效MySQL的N个习惯
立即下载