数据库的增删改查

一、命令行操作

1、启动/重启数据库

1. service mysql restart

复制代码

2.2 登陆mysql（必要输入暗码）

1. mysql -u root -p

复制代码

2.3 创建数据库

1. 指令格式：create database 数据库名字;
2. 例子：create database CD2401;

复制代码

2.4 查看数据库

1. show databases;

复制代码

2.5 切换到使用的数据库

1. 指令格式：use 数据库名;
2. 案例 ：  use CD2401;

复制代码

2.6查看目前所在数据库

1. select database();

复制代码

2.7 删除数据库

1. 指令格式：DROP database 数据库名;
2. 案例 ：  DROP database CD2401;

复制代码

2.8 创建数据表

1. 指令格式 ：create table 表名（字段1 字段类型,字段2 字段类型……）;
2. 案例:      create table hum(value int,data time);

复制代码

2.9 查看数据库中所有的表

1. show tables;

复制代码

2.10 查看表中字段

1. 指令格式 ：DESC 表名;
2. 案例:     DESC hum;

复制代码

2.11 增加表中信息（重点）

1. 指令格式 ：INSERT INTO 表名（数据列1，数据列2） VALUES(数据1，数据2);
2. 案例1:     INSERT INTO hum(value,data) VALUES(50,NOW());
3. 案例2:     INSERT INTO hum(value,data) VALUES(50,'2024-06-19 10:38:00');

复制代码

2.12 查看表中信息（重点）

1. 指令格式 ：SELECT * FROM 表名;  （查看所有数据）
2. 案例1:    SELECT * FROM hum;

复制代码

1. 案例2：SELECT value FROM hum; 查看特定的列
2. 案例3：SELECT value,data FROM hum; 查看特定的列

复制代码

1. 案例4：SELECT * FROM hum WHERE value > 45; 查看指定条件
2. 案例5：SELECT * FROM hum WHERE data > "2024-06-19 10:37:00"; 查看指定条件

复制代码

1. 案例6：SELECT * FROM hum ORDER BY data ASC;(时间排序，从早到晚)
2. 案例7：SELECT * FROM hum ORDER BY data DESC;(时间排序，从晚到早)

复制代码

2.13 修改表中信息（重点）

1. 2.13 修改表中信息（重点）
2. 命令格式：UPDATE 表名 SET column1 =value1,column2 =value2,…… WHERE condition;
3. 案例:    UPDATE hum SET value =40 WHERE data ='2024-06-19 10:37:00';

复制代码

2.14 删除表中信息（重点）

1. 命令格式 DELETE FROM 表名 WHERE 条件；
2. 案例1：  DELETE FROM hum WHERE data ='2024-06-19 10:38:00';
3. 案例2：  DELETE FROM hum;删除表中所有信息

复制代码

二、c语言操作数据库

2.1设置情况

1. sudo apt-get install libmysqld-dev

复制代码

2.2 设置远程登陆

1. mysql> use mysql;

复制代码

1. UPDATE user set host ='%' where user = 'root'

复制代码

1. flush privileges;

复制代码

1. quit;

复制代码

1. sudo vim /etc/mysql/mysql.conf.d/mysqld.cnf

复制代码

44行修改设置为0.0.0.0

保存退出，重启MySQL。

1. service mysql restart

复制代码

2.3 使用c连接数据库

1. #include <stdio.h> //包含头文件stdio.h，功能是输入输出函数。
2. #include <mysql/mysql.h> //包含头文件mysql.h，功能是访问MySQL数据库。
3. #include <stdlib.h> //包含头文件stdlib.h，功能是提供常用函数。
4. #include <string.h> //包含头文件string.h，功能是字符串处理函数。
6. int main(int argc, char const *argv[])
7. {
8.     MYSQL *ret; //定义MYSQL指针变量ret
9.     MYSQL mysql; //定义mysql结构体
10.     mysql_init(&mysql);//初始化mysql结构体
12.     //连接数据库
13.     ret=mysql_real_connect(&mysql,"10.7.164.82","root","123456","CD2401",3306,NULL,0);
14.     if(ret==NULL)
15.     {
16.         printf("Connect MySQL failed\n");
17.         return 0;
18.     }
19.     printf("Connect MySQL success\n");
20.     return 0;
21. }

复制代码

编译指令

1. gcc MYSQL_0.c -lmysqlclient

复制代码

2.4使用C执行sql语句

1. #include <stdio.h> //包含头文件stdio.h，功能是输入输出函数。
2. #include <mysql/mysql.h> //包含头文件mysql.h，功能是访问MySQL数据库。
3. #include <stdlib.h> //包含头文件stdlib.h，功能是提供常用函数。
4. #include <string.h> //包含头文件string.h，功能是字符串处理函数。
6. int main(int argc, char const *argv[])
7. {
8.     MYSQL *ret; //定义MYSQL指针变量ret
9.     MYSQL mysql; //定义mysql结构体
10.     mysql_init(&mysql);//初始化mysql结构体
12.     //连接数据库
13.     ret=mysql_real_connect(&mysql,"10.7.164.82","root","123456","CD2401",3306,NULL,0);
14.     if(ret==NULL)
15.     {
16.         printf("Connect MySQL failed\n");
17.         return 0;
18.     }
19.     printf("Connect MySQL success\n");
22.     //执行SQL语句
23.     /*组装SQL语句*/
24.     //char sql[100];
25.     //strcpy(sql,"SELECT * FROM CD2401.student");
26.     char *sql_str="INSERT INTO hum(value,data) VALUES(50,NOW());";
27.     if(mysql_query(&mysql,sql_str))
28.     {
29.         printf("SQL execute failed:%s\n",mysql_error(&mysql));
30.         return 0;
31.     }
32.         printf("SQL execute success\n");
33.    
34.    
35.     //关闭连接
36.     mysql_close(&mysql);
37.     return 0;
38. }

复制代码

2.5 案例

1. #include <stdio.h>   //引入标准输入输出库
2. #include <stdlib.h>  //引入标准库
3. #include <string.h>  //引入字符串处理库
4. #include <unistd.h>  //引入unistd.h库
5. #include <fcntl.h>   //引入fcntl.h库
6. #include <termios.h> //引入termios.h库
7. #include <mysql/mysql.h>
10. int main()
11. {
12.     int fd;          //文件描述符
13.     struct termios options; //终端属性结构体
14.     unsigned char buffer[256]; //接收到的数据缓冲区
15.     int bytes_read; //读取的字节数
16.     char name_type[10];
17.     int value[10];
19.     MYSQL *ret; //定义MYSQL指针变量ret
20.     MYSQL mysql; //定义mysql结构体
21.     mysql_init(&mysql);//初始化mysql结构体
23.     //连接数据库
24.     ret=mysql_real_connect(&mysql,"10.7.164.132","root","1234","hthl",3306,NULL,0);
25.     if(ret==NULL)
26.     {
27.         printf("Connect MySQL failed\n");
28.         return 0;
29.     }
30.     printf("Connect MySQL success\n");
34.     //尝试打开串口
35.     fd = open("/dev/ttyUSB0", O_RDWR | O_NOCTTY | O_NDELAY);//尝试以读写方式打开串行端口/dev/ttyUSB0
36.     if(fd < 0)    //打开失败
37.     {
38.         perror("opaaen");
39.         exit(1);
40.     }
41.     else    //打开成功
42.     {
43.         fcntl(fd,F_SETFL, 0); //设置非阻塞模式
44.         printf("Serial port opened successfully.\n");
45.     }
47.     tcgetattr(fd, &options); //获取终端属性
49.     cfsetispeed(&options, B115200); //设置输入波特率为115200
50.     cfsetospeed(&options, B115200); //设置输出波特率为115200
51.     options.c_cflag &= ~PARENB; //设置无校验位
52.     options.c_cflag &= ~CSTOPB; //设置1位停止位
53.     options.c_cflag &= ~CSIZE; //设置数据位数为8位
54.     options.c_cflag &= ~CRTSCTS;//关闭硬件流控
55.     options.c_cflag |= CS8;
56.     options.c_lflag &= ~(ICANON | ECHO | ECHOE | ISIG); //设置非规范模式
57.     //关闭流控制
58.     options.c_iflag &= ~(IXON | IXOFF | IXANY);
60.     tcsetattr(fd, TCSANOW, &options); //设置终端属性
62.     printf("port set to 115200, 8N1.\n");
64.     while(1)
65.     {
66.         tcflush(fd, TCIFLUSH); //清空输入缓存
67.         bytes_read = read(fd, buffer, 256); //读取串口数据
68.         if(bytes_read > 0) //有数据
69.         {
70.             //   printf("Received %d bytes: ", bytes_read);
71.             //   for(int i = 0; i < bytes_read; i++)
72.             //   {
73.             //       printf("%02X ", buffer[i]); //打印十六进制数据
74.             //   }
75.             //   printf("\n");
77.            
78.             if(strlen(buffer) == 0)
79.             {
80.                 continue;
81.             }
82.             char *table_name;
83.             int value = 0;
84.             table_name  = strtok(buffer,":");
85.             value = atoi(strtok(NULL,":"));
87.             char buf[128] = {0};
89.             sprintf(buf,"INSERT INTO %s(value,data) VALUES(%d,now())",table_name,value);
90.             if(mysql_query(&mysql,buf))
91.             {
92.                 printf("SQL exeute failed:%s\n",mysql_error(&mysql));
93.                 return 0;
94.             }
95.             printf("SQL execute success\n");
96.         }
97.         else if(bytes_read < 0) //读取失败
98.         {
99.             perror("read");
100.             exit(1);
101.         }
102.     }
103.     close(fd); //关闭串口
104.     mysql_close(&mysql);n g
105. }

复制代码

2.6使用c执行插入操作

1. #include <stdio.h>   //引入标准输入输出库
2. #include <stdlib.h>  //引入标准库
3. #include <string.h>  //引入字符串处理库
4. #include <unistd.h>  //引入unistd.h库
5. #include <fcntl.h>   //引入fcntl.h库
6. #include <termios.h> //引入termios.h库
8. int main()
9. {
10.    
11.     int fd;          //文件描述符
12.     struct termios options; //终端属性结构体
13.     unsigned char buffer[256]; //接收到的数据缓冲区
14.     int bytes_read; //读取的字节数
17. //尝试打开串口
18.     fd = open("/dev/ttyUSB0", O_RDWR | O_NOCTTY | O_NDELAY);//尝试以读写方式打开串行端口/dev/ttyUSB0
19.     if(fd < 0)    //打开失败
20.     {
21.         perror("opaaen");
22.         exit(1);
23.     }
24.     else    //打开成功
25.     {
26.         fcntl(fd,F_SETFL, 0); //设置非阻塞模式
27.         printf("Serial port opened successfully.\n");
28.     }
30.     tcgetattr(fd, &options); //获取终端属性
32.     cfsetispeed(&options, B115200); //设置输入波特率为115200
33.     cfsetospeed(&options, B115200); //设置输出波特率为115200
34.     options.c_cflag &= ~PARENB; //设置无校验位
35.     options.c_cflag &= ~CSTOPB; //设置1位停止位
36.     options.c_cflag &= ~CSIZE; //设置数据位数为8位
37.     options.c_cflag &= ~CRTSCTS;//关闭硬件流控
38.     options.c_cflag |= CS8;
39.     options.c_lflag &= ~(ICANON | ECHO | ECHOE | ISIG); //设置非规范模式
40.     //关闭流控制
41.     options.c_iflag &= ~(IXON | IXOFF | IXANY);
42.    
43.     tcsetattr(fd, TCSANOW, &options); //设置终端属性
45.     printf("port set to 115200, 8N1.\n");
46.     while (1)
47.     {
48.         size_t bytes_written = write(fd,"Servo_ON\r\n",10);
49.         if (bytes_written < 0) //发送失败
50.         {
51.             perror("write");
52.             exit(1);
53.         }
54.         else //发送成功
55.         {
56.             printf("Sent %ld bytes.\n", bytes_written);
57.         }
58.         usleep(500000);   
59.     }
60.    
61. }

复制代码

3.5 使用C执行sql查询语句

1. #include <stdio.h> //包含头文件stdio.h，功能是输入输出函数。
2. #include <mysql/mysql.h> //包含头文件mysql.h，功能是访问MySQL数据库。
3. #include <stdlib.h> //包含头文件stdlib.h，功能是提供常用函数。
4. #include <string.h> //包含头文件string.h，功能是字符串处理函数。
6. int main(int argc, char const *argv[])
7. {
8.     MYSQL *ret; //定义MYSQL指针变量ret
9.     MYSQL mysql; //定义mysql结构体
10.     mysql_init(&mysql);//初始化mysql结构体
12.     //连接数据库
13.     ret=mysql_real_connect(&mysql,"10.7.164.82","root","123456","CD2401",3306,NULL,0);
14.     if(ret==NULL)
15.     {
16.         printf("Connect MySQL failed\n");
17.         return 0;
18.     }
19.     printf("Connect MySQL success\n");
22.     //执行SQL语句
23.     /*组装SQL语句*/
24.     char *sql_str="SELECT * FROM hum ORDER BY data DESC LIMIT 1";//查询数据，安装时间降序排列，取第一条数据
25.     if(mysql_query(&mysql,sql_str))
26.     {
27.         printf("SQL execute failed:%s\n",mysql_error(&mysql));
28.         return 0;
29.     }
30.         printf("SQL execute success\n");
32.     //储存查询结果
33.     MYSQL_RES *result=mysql_store_result(&mysql);
34.     if(result==NULL)
35.     {
36.         printf("SQL result failed:%s\n",mysql_error(&mysql));
37.         return 0;
38.     }
39.     printf("SQL result success\n");
41.     //输出查询结果
42.     MYSQL_ROW row;
43.     row=mysql_fetch_row(result);
44.     if(row==NULL)
45.     {
46.         printf("SQL fetch failed:%s\n",mysql_error(&mysql));
47.         return 0;
48.     }
49.     else
50.     {
51.         printf("humidity value :%d,date :%s\n",row[0],row[1]);
52.     }
54.     //释放查询结果
55.     mysql_free_result(result);
56.    
57.     //关闭连接
58.     mysql_close(&mysql);
59.     return 0;
60. }

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。