AI 助理
备案控制台
开发者社区 开发与运维 文章 正文

linux下如何增量增量传输mysql binlog日志

2016-07-13 1023
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
本文涉及的产品
RDS MySQL Serverless 基础系列，0.5-2RCU 50GB
推荐场景：
学生管理系统数据库设计 搭建个人博客
云数据库 RDS MySQL，集群系列 2核4GB
推荐场景：
搭建个人博客
云数据库 RDS MySQL，高可用系列 2核4GB
简介： 在实际的工作中我们遇到了一个问题，MYSQL 5.5 我们备份使用的mysqldump，然后每天传输的备份到备份机器，但是binlog却不好传输主要要考虑几个问题： 1、binlog 没法取时间，按照什么规则来传？ 2、binlog的传输并不是每次都全部传输过去，而是需要增量的。
在实际的工作中我们遇到了一个问题，MYSQL 5.5 我们备份使用的mysqldump，然后每天传输的备份到备份机器，但是binlog却不好传输主要要考虑几个问题：
1、binlog 没法取时间，按照什么规则来传？
2、binlog的传输并不是每次都全部传输过去，而是需要增量的。
3、binlog的最后一个日志是在使用的是不能传输的。
4、为了更通用需要使用一个前缀，因为每个数据库的binlog前缀是可以自己指定的
如 mysqlbin.000001

那么有了上面的问题，如何解决？也许shell脚本能够完成，但是我选择使用C/C++ 和LINUX系统函数 opendir readdir lstat来完成
这是我最后挂载的脚本
#!/bin/sh
TIME_TAG=`date +%Y%m%d`
/root/ftptool/tool  /dbdata/data/  /root/ftptool/ mysql-bin > tool_${TIME_TAG}.log
if [ $? != 0  ]; then
    echo "tool failed"
    exit
else
    echo "tool sucess!"
fi
cat /root/ftptool/ftphead > /root/ftptool/ftp_${TIME_TAG}.sh
cat /root/ftptool/${TIME_TAG} >> /root/ftptool/ftp_${TIME_TAG}.sh
cat /root/ftptool/ftptail >> /root/ftptool/ftp_${TIME_TAG}.sh

chmod 755 /root/ftptool/ftp_${TIME_TAG}.sh
sh /root/ftptool/ftp_${TIME_TAG}.sh
实际上 ftp_${TIME_TAG}.sh来自3个部分
1、 ftphead --这个很简单自己写明白ip 用户名密码就好了，如下：
#!/bin/sh

ftp -i -v -n<< EOF
open 192.168.*.*
user mysql ****
cd /backup/mysql
bin
2、 ftptail  这个更简单
quit
EOF
就这点
3、cat ${TIME_TAG}
这部分是我自己写的工具 tool 生成的
工具使用如下：
Usage:./tool binlogdir ftpdir binlogprefix
需要一个binlog目录 一个ftp目录和binlong的前缀
binlog目录不用多说是binlog的所在目录，需要以/结尾比如 /mysql/data/不能是/mysql/data 否则抛错error 20 binlogdir Must End With /

ftp目录下存放两个东西一个tmp文件和生成的ftp脚本，ftp脚本生成和当前时间一致比如20160713
tmp文件用于存放当前取到的最大的binlog序号,如果不存在可以新建一个，如果不新建抛错error 15 tmp file not found
如果想再次全部传输删除tmp文件新建一个空的就可以比如touch tmp
这个ftp目录同样必须使用/结尾 否则抛错error 21 ftpdir Must End With /

binlogprefix 就是你的前缀比如mysql-bin

使用就是这么简单，有了这3部分就能够通过shell
cat ftphead > ftp_${TIME_TAG}.sh
cat ${TIME_TAG} >> ftp_${TIME_TAG}.sh
cat ftptail >> ftp_${TIME_TAG}.sh
生成一个全部的脚本。然后运行了。
另外tool工具会输出一些信息，当然可以关闭，这些输出信息我重定向到了 tool_${TIME_TAG}.log
可以查看下面就是一份：
WARNING:Ftpdir Less Than 1000 Char!
PROCESS:Create Chain Now:
INFO:Current Binog Dir Is :/dbdata/
PROCESS:Checkbin Binlogprefix: mysql-bin
................. 这里省略很多
PROCESS:Print chain info
................. 这里省略很多
PROCESS:Now Acc Ftpdir:
INFO:Ftp_scirpt fun time:
Wed Jul 13 14:44:13 2016
20160713
INFO:Ftp_scirpt Fun Tmpfile :/root/ftptool/tmp
INFO:Tmpfile Write Mode Succ!
INFO:Ftp_Scirpt Fun Tmp_max_st:0 Max_st_1:2028:
INFO:Scan Put Counter :163
INFO:Current Max Binlog-1 is:2028
PROCESS:Free Node Is:164

可以清楚看到将会生成163个put脚本信息，最高的传输是2028，实际最大是2029，我在编码的时候做了-1操作,目的在于不要传输当前的binlog，
因为当前的binlog正在使用
最后释放了链表节点164个.同事你的tmp文件目录也会输出,binglog 的目录也会输出.

下面是全部分出错码：
error 10 open bindbr error
error 11 argv parameter error
eroor 12 not find binlog
error 14 fptdir open error
error 15 tmp file not found
error 16 lstat tmp file error
error 18 tmp file write error
error 20 binlogdir Must End With /
error 21 ftpdir Must End With /
当然成功放回 0

编译好的我放到了百度云盘
http://pan.baidu.com/s/1i4WuBB3
下面是全部的源代码
编译使用 g++ main.cpp mybin.cpp -o tool 即可 注意本工具使用了LINUX系统函数所以必须是LINUX系统或者其他满足posix标准的系统不包含windows
在LINUX下编译没有问题。有什么问题可以联系QQ 22389860.

点击(此处)折叠或打开

  1. /*************************************************************************
  2.   > File Name: mbin.h
  3.   > Author: gaopeng
  4.   > Mail: gaopp_200217@163.com
  5.   > Created Time: Tue 02 Aug 2016 05:57:27 PM CST
  6.  ************************************************************************/

  8. #include<iostream>
  9. #define _DEG
  10. using namespace std;
  11. typedef unsigned char uchar;
  12. typedef unsigned long ulong;
  13. typedef unsigned int uint;
  14. typedef unsigned short ushort;


  17. typedef struct data
  18. {

  20.     char* file_name;
  21.     char* path_name;
  22.     char* full_name;
  23.     ulong file_st;
  24.     uint nuse;
  25. } DATA;

  27. typedef struct f_node
  28. {

  30.     struct f_node *next;
  31.     DATA* data;
  32. } F_NODE;

  34. typedef struct quence
  35. {

  37.     F_NODE* first;
  38.     F_NODE* last;
  39.     int items;
  40. } QUE;

  42. uint checkbin(const char* file_name,const char* binprefix);
  43. F_NODE* create_que(const char *bindir,const char* binprefix);
  44. QUE* ini_que(void);
  45. void show( F_NODE* const frs_nd);
  46. void ins_chan(const char* f_name,const char* p_name,const char* ful_name,QUE * que);
  47. ulong char_to_num(const char* file_name);
  48. void time_to_time(char* ltime,char* mytime);
  49. void ftp_script(const char* ftp_dir,F_NODE* frs_nd);
  50. int get_max_st(F_NODE* const frs_nd);
  51. ulong readtmp(FILE *fd,const char* tmpdir);
  52. int myfree(F_NODE* const frs_nd);
  53. uint checkdir(const char* mychar);


点击(此处)折叠或打开

  1. /*************************************************************************
  2.   > File Name: main.cpp
  3.   > Author: gaopeng
  4.   > Mail: gaopp_200217@163.com
  5.   > Created Time: Tue 02 Aug 2016 05:58:15 PM CST
  6.  ************************************************************************/

  8. #include<iostream>
  9. #include<iostream>
  10. #include<stdio.h>
  11. #include <sys/types.h>
  12. #include <dirent.h>
  13. #include <string.h>
  14. #include"mbin.h"
  15. #include <stdlib.h>

  17. using namespace std;



  21. int main(int argc,char *argv[])
  22. {
  23.     F_NODE* frs_nd=0;
  24.     int freeno =0;
  25.     printf("%s\n","Usage:./tool binlogdir ftpdir binlogprefix");
  26.     if(argc<4)
  27.     {
  28.         cout<<"ERROR(9):Parameter Error Like:"<<endl;
  29.         printf("%s\n","Usage:./tool binlogdir ftpdir binlogprefix");
  30.         exit(9);
  31.     }
  32.     if(checkdir(argv[1]) == 1)
  33.     {
  34.         cout<<"ERROR(20):binlogdir Must End With /"<<endl;
  35.         exit(20);
  36.     }
  37.     if(checkdir(argv[2]) == 1)
  38.     {
  39.         cout<<"ERROR(21):ftpdir Must End With /"<<endl;
  40.         exit(21);
  41.     }
  42.     printf("WARNING:Ftpdir Less Than 1000 Char!\n");
  43.     printf("PROCESS:Create Chain Now:\n");
  44.     frs_nd = create_que(argv[1],argv[3]);
  45.     cout<<"PROCESS:Print chain info"<<endl;
  46.     show(frs_nd);
  47.     cout<<"PROCESS:Now Acc Ftpdir:"<<endl;
  48.     ftp_script(argv[2], frs_nd);
  49.     
  50.     freeno = myfree(frs_nd);
  51.     cout<<"PROCESS:Free Node Is:"<<freeno<<endl;

  53. return 0;
  54. }


点击(此处)折叠或打开

  1. /*************************************************************************
  2.   > File Name: mybin.cpp
  3.   > Author: gaopeng
  4.   > Mail: gaopp_200217@163.com
  5.   > Created Time: Tue 02 Aug 2016 05:57:34 PM CST
  6.  ************************************************************************/

  8. #include<iostream>
  9. #include "mbin.h"
  10. #include <sys/types.h>
  11. #include <sys/stat.h>
  12. #include <unistd.h>
  13. #include <time.h>
  14. #include <stdio.h>
  15. #include <stdlib.h>
  16. #include <string.h>
  17. #include <dirent.h>
  18. #include <math.h>

  20. using namespace std;

  22. QUE* ini_que(void)
  23. {
  24.     QUE* que = new QUE;
  25.     que->first =0;
  26.     que->last =0;
  27.     que->items =0;
  28.     return que;
  29. }

  31. void ins_chan(const char* f_name,const char* p_name,const char* ful_name,QUE * que)
  32. {
  33.     F_NODE *add = new F_NODE; //inital node pointer
  34.     DATA *name = new DATA; //inital data pointer
  35.     name->file_name = new char[strlen(f_name)+5];
  36.     name->path_name = new char[strlen(p_name)+5];
  37.     name->full_name = new char[strlen(ful_name)+5];

  39.     //init mem

  41.     memset(name->file_name,0,strlen(f_name)+5);
  42.     memset(name->path_name,0,strlen(p_name)+5);
  43.     memset(name->full_name,0,strlen(ful_name)+5);

  45.     name->file_st = char_to_num(f_name);
  46.     name->nuse = 0;
  47.     strcpy(name->file_name,f_name);
  48.     strcpy(name->path_name,p_name);
  49.     strcpy(name->full_name,ful_name);

  51.     add->next =0;
  52.     add->data = name;

  54.     if( que->items==0)
  55.     {
  56.         que->first =add;
  57.         que->last =add;
  58.         que->items++;
  59.     }
  60.     else
  61.     {
  62.         que->last->next = add;
  63.         que->last = add;
  64.         que->items++;
  65.     }
  66. }

  68. F_NODE* create_que(const char *bindir,const char* binprefix)
  69. {
  70.     struct dirent *DirEntry=0;
  71.     DIR* Dir=0;
  72.     QUE* myq=0;
  73.     uint nob=0; //check if binlog find

  75.     myq = ini_que();
  76.     F_NODE* frs_nd =0;

  78.     if( !(Dir = opendir(bindir)))
  79.     {
  80.         perror("ERROR(10):Open Binlog Dir Error:");
  81.         exit(10);
  82.     }
  83.     else
  84.     {
  85.         printf("INFO:Current Binog Dir Is :%s\n",bindir);
  86.         while( DirEntry = readdir(Dir))
  87.         {
  88.             if(DirEntry->d_type == DT_REG && checkbin(DirEntry->d_name,binprefix) == 1)            
  89.             {
  90.                 nob++;

  92. #ifdef _DEG
  93.                 printf("%s%s\n",bindir,DirEntry->d_name);
  94. #endif
  95.                 char *tloop = new char[strlen(bindir) + strlen(DirEntry->d_name)+5];
  96.                 strcat(strcat(tloop,bindir),DirEntry->d_name); //bindir like /test/test/test/ last / is must
  97.                 ins_chan(DirEntry->d_name,bindir,tloop,myq);
  98.                 delete [] tloop;
  99.             }
  100.         }
  101.         closedir(Dir);
  102.         if(nob == 0)
  103.         {
  104.             printf("WARNING:No Bin Log Find!!\n");
  105.             delete myq;
  106.             exit(12);
  107.         }
  108.     }
  109.     frs_nd = myq->first;
  110.     delete myq;
  111.     return frs_nd;
  112. }

  114. uint checkbin(const char* file_name,const char* binprefix)
  115. {
  116.     uint lenprefix = strlen(binprefix); //exp 5
  117.     uint filelen = strlen(file_name);
  118.     uint i;
  119.     uint t;
  120.     char tmpfix[strlen(binprefix)+1]; //exp strlen(binprefix)+1 =6
  121.     memset(tmpfix,0,strlen(binprefix)+1);
  122.     for(i=0;i<=lenprefix-1;i++) //exp lenprefix-1=4
  123.     {
  124.         tmpfix[i]=file_name[i]; //5 char copy tmpfix[0-4]
  125.     }
  126.     tmpfix[lenprefix]='\0'; //tmpfix[5] = '\0'
  127. #ifdef _DEG
  128.     cout<<"PROCESS:Checkbin Binlogprefix: "<<tmpfix<<endl;
  129. #endif
  130.     if(!strcmp(tmpfix,binprefix)) //check prefix eq tmpfix
  131.     {
  132.         for(t=(filelen-1);t>=(filelen-6);t--) //exp filelen-1=10 filelen-6=5
  133.         {
  134.             if(file_name[t]<48 || file_name[t]>57 ) //check 000000
  135.             {
  136.                 return 0;
  137.             }
  138.         }
  139.         if(file_name[filelen-7] !='.') //check . of .000000
  140.         {
  141.             return 0;
  142.         }
  143.     }
  144.     else
  145.     {
  146.         return 0;
  147.     }
  148.     return 1;
  149. }

  151. void show( F_NODE* const frs_nd)
  152. {
  153.     F_NODE* scan_nd = frs_nd;
  154.     do {
  155.         if(!scan_nd->next)
  156.         {
  157.             break;
  158.         }
  159.         printf("INFO:%s,%s,%s,%lu,%u\n",scan_nd->data->file_name,scan_nd->data->path_name,scan_nd->data->full_name,scan_nd->data->file_st,scan_nd->data->nuse);
  160.         scan_nd = scan_nd->next;
  161.     } while(scan_nd->next);
  162.     printf("INFO:%s,%s,%s,%lu,%u\n",scan_nd->data->file_name,scan_nd->data->path_name,scan_nd->data->full_name,scan_nd->data->file_st,scan_nd->data->nuse);
  163. }



  167. ulong char_to_num(const char* file_name)
  168. {
  169.     uint len = strlen(file_name);
  170.     uint i;
  171.     ulong num=0;
  172.     uint chk=0;

  174.     for(i=(len-1);i>0;i--)
  175.     {
  176.         if(file_name[i]>=48 && file_name[i]<=57)
  177.         {
  178.             num = (ulong)(file_name[i] - 48)*(ulong)pow(10,chk)+num;
  179.             chk++;
  180.         }
  181.     }
  182.     return num;
  183. }


  186. void time_to_time(char* ltime,char* mytime)
  187. {
  188.     char buffer[10];
  189.     buffer[0] = ltime[4];
  190.     buffer[1] = ltime[5];
  191.     buffer[2] = ltime[6];
  192.     buffer[3] = '\0';

  194.     mytime[0]=ltime[20];
  195.     mytime[1]=ltime[21];
  196.     mytime[2]=ltime[22];
  197.     mytime[3]=ltime[23];
  198.     if(!strcmp(buffer,"Jan"))
  199.     {

  201.         mytime[4]='0';
  202.         mytime[5]='1';
  203.     }
  204.     if(!strcmp(buffer,"Feb"))
  205.     {

  207.         mytime[4]='0';
  208.         mytime[5]='2';
  209.     }
  210.     if(!strcmp(buffer,"Mar"))
  211.     {

  213.         mytime[4]='0';
  214.         mytime[5]='3';
  215.     }
  216.     if(!strcmp(buffer,"Apr"))
  217.     {

  219.         mytime[4]='0';
  220.         mytime[5]='4';
  221.     }
  222.     if(!strcmp(buffer,"May"))
  223.     {

  225.         mytime[4]='0';
  226.         mytime[5]='5';
  227.     }
  228.     if(!strcmp(buffer,"Jun"))
  229.     {

  231.         mytime[4]='0';
  232.         mytime[5]='6';
  233.     }
  234.     if(!strcmp(buffer,"Jul"))
  235.     {

  237.         mytime[4]='0';
  238.         mytime[5]='7';
  239.     }
  240.     if(!strcmp(buffer,"Aug"))
  241.     {

  243.         mytime[4]='0';
  244.         mytime[5]='8';
  245.     }
  246.     if(!strcmp(buffer,"Sep"))
  247.     {

  249.         mytime[4]='0';
  250.         mytime[5]='9';
  251.     }
  252.     if(!strcmp(buffer,"Oct"))
  253.     {

  255.         mytime[4]='1';
  256.         mytime[5]='0';
  257.     }
  258.     if(!strcmp(buffer,"Nov"))
  259.     {

  261.         mytime[4]='1';
  262.         mytime[5]='1';
  263.     }
  264.     if(!strcmp(buffer,"Dec"))
  265.     {

  267.         mytime[4]='1';
  268.         mytime[5]='2';
  269.     }

  271.     if(ltime[8]<48 ||ltime[8]>57)
  272.     {

  274.         mytime[6]=48;
  275.     }
  276.     else
  277.     {

  279.         mytime[6]=ltime[8];
  280.     }
  281.     mytime[7]=ltime[9];
  282.     mytime[8]='\0';
  283. }



  287. void ftp_script(const char* ftp_dir,F_NODE* frs_nd)
  288. {
  289.     time_t now;
  290.     F_NODE* scan_nd = frs_nd;
  291.     struct tm* nowtm;
  292.     FILE* ftp=0;
  293.     FILE* tmp=0;
  294.     char timebuf[40];
  295.     char mytime[25];
  296.     char myftpdir[1000];
  297.     char tmpdir[1000];
  298.     ulong tmp_max_st;
  299.     ulong max_st_1;
  300.     int i=0;
  301.     int freeno=0;

  303.     memset(timebuf,0,40);
  304.     memset(mytime,0,40);
  305.     time(&now);
  306.     nowtm = localtime(&now);
  307.     asctime_r(nowtm,timebuf);
  308.     time_to_time(timebuf,mytime);
  309. #ifdef _DEG
  310.     printf("INFO:Ftp_scirpt fun time:\n%s%s\n",timebuf,mytime);
  311. #endif
  312.     memset(myftpdir,0,1000);
  313.     if((ftp=fopen(strcat(strcat(myftpdir,ftp_dir),mytime),"w"))==NULL)
  314.     {

  316.         perror("ERROR(14):Ftpdir open error:");
  317.         freeno=myfree(frs_nd);
  318.         cout<<"PROCESS:Free Mem:Free Node Is:"<<freeno<<endl;
  319.         exit(14);
  320.     }
  321.     memset(tmpdir,0,1000);
  322.     if((tmp=fopen(strcat(strcat(tmpdir,ftp_dir),"tmp"),"r"))==NULL)
  323.     {
  324.         printf("ERROR(15):No Tmp File Found,Please Create it frist!\n");
  325.         freeno=myfree(frs_nd);
  326.         cout<<"PROCESS:Free Mem:Free Node Is:"<<freeno<<endl;
  327.         exit(15);
  328.     }
  329.     else
  330.     {
  331. #ifdef _DEG
  332.         printf("INFO:Ftp_scirpt Fun Tmpfile :%s\n",tmpdir);
  333. #endif
  334.         tmp_max_st=readtmp(tmp,tmpdir);    
  335.     }
  336.     memset(tmpdir,0,1000);
  337.     if((tmp=fopen(strcat(strcat(tmpdir,ftp_dir),"tmp"),"w"))==NULL)
  338.     {

  340.         printf("ERROR:Have No Write Privi In %s?\n",tmpdir);
  341.         perror("ERROR(18):Tmpfile Open W Error:");
  342.         freeno=myfree(frs_nd);
  343.         cout<<"PROCESS:Free Mem:Free Node Is:"<<freeno<<endl;
  344.         exit(18);
  345.     }
  346.     else
  347.     {
  348.         printf("INFO:Tmpfile Write Mode Succ!\n");
  349.     }

  351.     max_st_1 = get_max_st(frs_nd) - 1;
  352.     printf("INFO:Ftp_Scirpt Fun Tmp_max_st:%lu Max_st_1:%lu:\n",tmp_max_st,max_st_1);    
  353.     do{
  354.         if(!scan_nd->next)
  355.         {
  356.             break;
  357.         }
  358.         if(scan_nd->data->file_st > tmp_max_st && scan_nd->data->file_st <= max_st_1)
  359.         {
  360.             i++;
  361.             fputs("put ",ftp);
  362.             fputs(scan_nd->data->full_name,ftp);
  363.             fputs(" ",ftp);
  364.             fputs(scan_nd->data->file_name,ftp);
  365.             fputs("\n",ftp);
  366.         }
  367.         scan_nd = scan_nd->next;
  368.     }while(scan_nd->next);
  369.     if(scan_nd->data->file_st > tmp_max_st && scan_nd->data->file_st <= max_st_1)
  370.     {
  371.         i++;
  372.         fputs("put ",ftp);
  373.         fputs(scan_nd->data->full_name,ftp);
  374.         fputs(" ",ftp);
  375.         fputs(scan_nd->data->file_name,ftp);
  376.         fputs("\n",ftp);
  377.     }

  379.     printf("INFO:Scan Put Counter :%d\n",i);
  380.     if(i == 0)
  381.     {
  382.         printf("INFO:Read Max Binlog From Temp is :%lu\n",tmp_max_st);
  383.         fprintf(tmp,"%lu",tmp_max_st);
  384.         fputs("\n",tmp);
  385.     }
  386.     else
  387.     {
  388.         printf("INFO:Current Max Binlog-1 is:%lu\n",max_st_1);
  389.         fprintf(tmp,"%lu",max_st_1);
  390.         fputs("\n",tmp);
  391.     }

  393.     fclose(ftp);
  394.     fclose(tmp);
  395. }

  397. int get_max_st(F_NODE* const frs_nd)
  398. {
  399.     F_NODE* scan_nd = frs_nd;    
  400.     ulong max_st=0;
  401.     do {
  402.         if(!scan_nd->next)
  403.         {
  404.             break;
  405.         }
  406.         if(scan_nd->data->file_st > max_st)
  407.         {
  408.             max_st = scan_nd->data->file_st;
  409.         }
  410.         scan_nd = scan_nd->next;
  411.     }while(scan_nd->next);
  412.     if(scan_nd->data->file_st > max_st)
  413.     {
  414.         max_st = scan_nd->data->file_st;
  415.     }
  416.     return max_st;
  417. }




  422. ulong readtmp(FILE *fd,const char* tmpdir)
  423. {
  424.     struct stat buf;
  425.     ulong max_st = 0;

  427.     if(lstat(tmpdir, &buf) < 0)
  428.     {
  429.         perror("ERROR(16):Lstat Error:");
  430.         exit(16);
  431.     }
  432.     if(buf.st_size == 0)
  433.     {
  434.         max_st = 0;
  435.     }
  436.     else
  437.     {
  438.         fscanf(fd,"%lu",&max_st);
  439.         /*
  440.          if(max_st == 0)
  441.          {
  442.          printf("Tmp File Is Bad ?\n");
  443.          exit(17);
  444.          }
  445.          */
  446.     }
  447.     return max_st;
  448. }



  452. int myfree(F_NODE* const frs_nd)
  453. {

  455.     F_NODE* scan_nd = frs_nd;
  456.     F_NODE* cur_nd = 0;
  457.     int i = 0;
  458.     do{
  459.         cur_nd = scan_nd;
  460.         if(!scan_nd->next)
  461.         {
  462.             free(cur_nd->data->file_name);
  463.             free(cur_nd->data->path_name);
  464.             free(cur_nd->data->full_name);
  465.             free(cur_nd->data);
  466.             free(cur_nd);
  467.             i++;
  468.             return i;
  469.         }
  470.         scan_nd = scan_nd->next;
  471.         free(cur_nd->data->file_name);
  472.         free(cur_nd->data->path_name);
  473.         free(cur_nd->data->full_name);
  474.         free(cur_nd->data);
  475.         free(cur_nd);
  476.         i++;
  477.     }while(scan_nd->next);
  478.     free(scan_nd->data->file_name);
  479.     free(scan_nd->data->path_name);
  480.     free(scan_nd->data->full_name);
  481.     free(scan_nd->data);
  482.     free(scan_nd);
  483.     i++;
  484.     return i;
  485. }

  487. uint checkdir(const char* mychar)
  488. {
  489.     uint len = strlen(mychar);
  490.     if(mychar[len-1] == '/' )
  491.     {
  492.         return 0;
  493.     }
  494.     else
  495.     {
  496.         return 1;
  497.     }
  498. }


文章标签：
云数据库 RDS MySQL 版
日志服务
关系型数据库
Linux
监控
MySQL
Shell
关键词：
mysql日志服务
云数据库 RDS MySQL 版日志
binlog日志
binlog日志服务
云数据库 RDS MySQL 版binlog日志
相关实践学习
如何在云端创建MySQL数据库
开始实验后，系统会自动创建一台自建MySQL的 源数据库 ECS 实例和一台 目标数据库 RDS。
全面了解阿里云能为你做什么
阿里云在全球各地部署高效节能的绿色数据中心，利用清洁计算为万物互联的新世界提供源源不断的能源动力，目前开服的区域包括中国（华北、华东、华南、香港）、新加坡、美国（美东、美西）、欧洲、中东、澳大利亚、日本。目前阿里云的产品涵盖弹性计算、数据库、存储与CDN、分析与搜索、云通信、网络、管理与监控、应用服务、互联网中间件、移动服务、视频服务等。通过本课程，来了解阿里云能够为你的业务带来哪些帮助 &nbsp; &nbsp; 相关的阿里云产品：云服务器ECS 云服务器 ECS（Elastic Compute Service）是一种弹性可伸缩的计算服务，助您降低 IT 成本，提升运维效率，使您更专注于核心业务创新。产品详情: https://www.aliyun.com/product/ecs
重庆八怪
目录
相关文章
赵渝强老师
|
1月前
|
存储 Oracle 关系型数据库
【赵渝强老师】MySQL InnoDB的数据文件与重做日志文件
本文介绍了MySQL InnoDB存储引擎中的数据文件和重做日志文件。数据文件包括`.ibd`和`ibdata`文件，用于存放InnoDB数据和索引。重做日志文件（redo log）确保数据的可靠性和事务的持久性，其大小和路径可由相关参数配置。文章还提供了视频讲解和示例代码。
赵渝强老师
135 11
【赵渝强老师】MySQL InnoDB的数据文件与重做日志文件
拉丁解牛说技术
|
12天前
|
SQL 存储 缓存
MySQL进阶突击系列(02)一条更新SQL执行过程 | 讲透undoLog、redoLog、binLog日志三宝
本文详细介绍了MySQL中update SQL执行过程涉及的undoLog、redoLog和binLog三种日志的作用及其工作原理，包括它们如何确保数据的一致性和完整性，以及在事务提交过程中各自的角色。同时，文章还探讨了这些日志在故障恢复中的重要性，强调了合理配置相关参数对于提高系统稳定性的必要性。
拉丁解牛说技术
51 6
Apache_Tomcat_Nignx
|
13天前
|
关系型数据库 MySQL Linux
MySQL数据库下载安装教程（Windows&Linux）
本文档详细介绍了MySQL的安装步骤，包括安装前的准备工作、下载安装包、Windows和Linux系统下的具体安装流程，以及如何配置MySQL服务、设置环境变量、启动服务和连接数据库等关键操作。
Apache_Tomcat_Nignx
231 4
赵渝强老师
|
27天前
|
SQL 关系型数据库 MySQL
【赵渝强老师】MySQL的全量日志文件
MySQL全量日志记录所有操作的SQL语句，默认禁用。启用后，可通过`show variables like %general_log%检查状态，使用`set global general_log=ON`临时开启，执行查询并查看日志文件以追踪SQL执行详情。
赵渝强老师
45 4
赵渝强老师
|
29天前
|
关系型数据库 MySQL 数据库
【赵渝强老师】MySQL的binlog日志文件
MySQL的binlog日志记录了所有对数据库的更改操作（不包括SELECT和SHOW），主要用于主从复制和数据恢复。binlog有三种模式，可通过设置binlog_format参数选择。示例展示了如何启用binlog、设置格式、查看日志文件及记录的信息。
赵渝强老师
76 6
赵渝强老师
|
28天前
|
SQL 关系型数据库 MySQL
【赵渝强老师】MySQL的慢查询日志
MySQL的慢查询日志用于记录执行时间超过设定阈值的SQL语句，帮助数据库管理员识别并优化性能问题。通过`mysqldumpslow`工具可查看日志。本文介绍了如何检查、启用及配置慢查询日志，并通过实例演示了慢查询的记录与分析过程。
赵渝强老师
109 3
赵渝强老师
|
1月前
|
存储 Oracle 关系型数据库
【赵渝强老师】MySQL的撤销日志文件和错误日志文件
本文介绍了MySQL的物理存储结构，重点讲解了InnoDB存储引擎中的撤销日志文件（undo log）和错误日志文件。从MySQL 8.0开始，默认生成两个10MB的undo表空间文件，并支持动态扩容和收缩。错误日志文件记录了MySQL启动、运行、关闭过程中的问题，通过示例展示了如何查看和使用这些日志。
赵渝强老师
39 0
AIweker
|
8天前
|
关系型数据库 MySQL 数据库
Python处理数据库：MySQL与SQLite详解 | python小知识
本文详细介绍了如何使用Python操作MySQL和SQLite数据库，包括安装必要的库、连接数据库、执行增删改查等基本操作，适合初学者快速上手。
AIweker
72 15
1436047922066202
|
2天前
|
SQL 关系型数据库 MySQL
数据库数据恢复—Mysql数据库表记录丢失的数据恢复方案
Mysql数据库故障： Mysql数据库表记录丢失。 Mysql数据库故障表现： 1、Mysql数据库表中无任何数据或只有部分数据。 2、客户端无法查询到完整的信息。
1436047922066202
22 5
1436047922066202
|
9天前
|
关系型数据库 MySQL 数据库
数据库数据恢复—MYSQL数据库文件损坏的数据恢复案例
mysql数据库文件ibdata1、MYI、MYD损坏。 故障表现：1、数据库无法进行查询等操作；2、使用mysqlcheck和myisamchk无法修复数据库。
1436047922066202
41 6

热门文章

最新文章

  • 1
    MySQL的binlog数据如何查看
  • 2
    MySQL · 捉虫动态 · 字符集相关变量介绍及binlog中字符集相关缺陷分析
  • 3
    解析MySQL Binlog：从零开始的入门指南【binlog入门指南】
  • 4
    PolarDB-X 全局Binlog解读之HA篇
  • 5
    通过binlog恢复mysql数据库
  • 6
    mysql的binlog
  • 7
    binlog server还是不靠谱吗？
  • 8
    Mysql的二进制日志---binlog
  • 9
    解析MYSQL BINLOG二进制格式(10)--问题解答
  • 10
    MySQL bin log 处理手段
  • 1
    Linux系统的文本处理
    84
  • 2
    Linux对MySQL语法校验
    89
  • 3
    Linux为新创建的磁盘分区添加文件系统
    66
  • 4
    如何计算 Linux 上文件中的空行数？
    79
  • 5
    服务器Linux系统配置mysql数据库主从自动备份
    214
  • 6
    Linux文件系统
    60
  • 7
    Linux内核基础知识
    76
  • 8
    Linux网络编程 网络基础知识
    69
  • 9
    Linux系统编程之文件编程常用API回顾和文件编程一般步骤
    80
  • 10
    linux静态库，动态库总结
    60

    • 相关课程

    更多
  • Linux用户和组管理
  • Linux服务器运维基本操作
  • Linux基本命令
  • Linux企业运维实战 - 入门及常用命令
  • Linux Shell 编程入门与实战
  • Linux网络进阶 - TCP/IP协议及OSI七层模型

    • 相关电子书

    更多
  • Alibaba Cloud Linux 3 发布
  • ECS系统指南之Linux系统诊断
  • ECS运维指南 之 Linux系统诊断

    • 相关实验场景

    更多
  • Alibaba Cloud Linux操作系统的安装及使用
  • Alibaba Cloud Linux操作系统Shell程序
  • 手动部署MySQL数据库（Alibaba Cloud Linux 2）
  • 部署并使用Docker（Alibaba Cloud Linux 3）
  • 部署并使用Docker（Alibaba Cloud Linux 2）
  • 部署Linux主机管理系统WDCP

    • 推荐镜像

    更多
  • mxlinux-iso
  • archlinuxarm
  • archlinuxcn
    • 下一篇
    fs.oss.accessKeyId和fs.oss.accessKeySecret。