-1

以下のようなCコードがあります。これは、gcc -o get1Receive $(mysql_config --cflags) get1ReceiveSource.c $(mysql_config --libs) -lrt をコンパイルした方法です。ターミナルから実行すると正常に動作します。次に、cron ジョブを使用して実行しようとしましたが、この 2 行を確認すると、printf("\nNumf of fields : %d",num_fields); および printf("\n行数 : %lu",mysql_num_rows(localRes1));. 最初の行は値として 4 を示し、2 行目は値を与えず、常に 0 です。同じ選択クエリを取得してデータベースで実行し、値があることを確認しましたが、cron ジョブを介して実行すると配信されません。 script にも実行権限が与えられます。

#include <stdlib.h>
#include <unistd.h>
#include <pthread.h>
#include <stdio.h>
#include <time.h>
#include <signal.h>
#include <mysql.h>
#include <string.h>

int flag = 0;



int main () {
                  MYSQL *localConn;
                  MYSQL_RES *localRes1;
                  MYSQL_ROW localRow1;
                  char *server = "localhost";
                  char *user = "user1";
                  char *password = "*****"; 
                  char *database = "test1";
                  localConn = mysql_init(NULL);
                  if (!mysql_real_connect(localConn, server,
                         user, password, database, 0, NULL, 0)) {
                      fprintf(stderr, "%s\n", mysql_error(localConn));
                      exit(1);
                  }

            struct timeval tv;
          char queryBuf1[500],queryBuf2[500];
          char buff1[20] = {0};
          char buff2[20] = {0};
          gettimeofday (&tv, NULL);
          //fprintf (stderr, "[%d.%06d] Flag set to 1 on ", tv.tv_sec, tv.tv_usec);
          //tv.tv_sec -= 5;
          strftime(buff1, 20, "%Y-%m-%d %H:%M:00", localtime(&tv.tv_sec));
          strftime(buff2, 20, "%Y-%m-%d %H:%M:59", localtime(&tv.tv_sec));
          printf("\nTime from %s", buff1);
          printf("\nTime to %s", buff2);

          sprintf(queryBuf1,"SELECT ipDest, macDest,portDest, sum(totalBits) FROM dataReceive WHERE timeStampID between '%s' And '%s'  GROUP BY ipDest, macDest, portDest ",buff1,buff2);
                printf("\nQuery receive %s",queryBuf1);


                if(mysql_query(localConn, queryBuf1))
                {
                    printf("Error in first query of select %s\n",mysql_error(localConn));
                    exit(1);
                }

                localRes1 = mysql_store_result(localConn);
                int num_fields = mysql_num_fields(localRes1);

                printf("\nNumf of fields : %d",num_fields);
                printf("\nNof of row : %lu",mysql_num_rows(localRes1));

                while((localRow1 = mysql_fetch_row(localRes1)) !=NULL)
                {
                  int totalBits = atoi(localRow1[3]);

                  printf("totalBits %d\n", totalBits);
                  printf("RECEIVE %s,%s\n", localRow1[0], localRow1[1]);
                  if(totalBits>5000)
                  {
                    sprintf(queryBuf1,"INSERT INTO alertReceive1 (timeStampID,ipDest, macDest, portDest, totalBits)VALUES ('%s','%s','%s','%s',%s)",buff1, localRow1[0],localRow1[1],localRow1[2],localRow1[3]);
                    printf("Query 1 before executing %s\n",queryBuf1);
                    if (mysql_real_query(localConn,queryBuf1,strlen(queryBuf1))) {
                   printf("Error in first insert %s\n",mysql_error(localConn));
                   fprintf(stderr, "%s\n", mysql_error(localConn));
                   exit(1);
                   }
                    //printf("Query 1 after executing %s\n",queryBuf1);*/
                   }    
                } 


          mysql_free_result(localRes1); 
          mysql_close(localConn);


}

このコマンド ファイル get1Receive を実行した結果、

file get1Receive
get1Receive.c: ELF 64-bit LSB executable, x86-64, version 1 (SYSV), dynamically linked (uses shared libs), for GNU/Linux 2.6.18, not stripped

このコマンドも実行しました * * * * * set > /tmp/myvars 以下は結果です。

GROUPS=()
HOME=/root
HOSTNAME=capture
HOSTTYPE=x86_64
IFS='
'
LOGNAME=root
MACHTYPE=x86_64-redhat-linux-gnu
OPTERR=1
OPTIND=1
OSTYPE=linux-gnu
PATH=/usr/bin:/bin
POSIXLY_CORRECT=y
PPID=11086
PS4='+ '
PWD=/root
SHELL=/bin/sh
SHELLOPTS=braceexpand:hashall:interactive-comments:posix
SHLVL=1
TERM=dumb
UID=0
USER=root
_=/bin/sh
4

1 に答える 1

4

一般的なヒント (私のコメントも参照してください):

  • 時間を取って、特にAdvanced Linux Programmingman ページ(入力または端末などで取得することもできます)、およびMySQL 5.5 リファレンスからドキュメントを読んでください。または意味を理解してください。man manman 2 introGIYFSTFW

  • をフォーマット文字列の先頭ではなく\n末尾に置きます。printf

  • また、fflush(NULL)必要に応じて、特に MySQL クエリの前に呼び出します。たとえば、呼び出しの前やループmysql_real_queryの最後に呼び出します。while

  • gcc -Wall -gたとえば、ターミナルで次のコマンドを使用してコンパイルします

    gcc -Wall -g $(mysql_config --cflags) get1ReceiveSource.c \
               $(mysql_config --libs) -lrt -o get1Receive
    
  • 警告が出なくなるまでコードを改善します。-Wall -Wextra(ただの代わりに持っていたいかもしれません-Wall)。のようなバージョン管理システムを使用することを忘れないでくださいgit

  • デバッガーを使用します (使用方法を学ぶgdb必要があります)。

    (コードにバグがないと確信した場合のみ、コンパイルコマンドで置き換えます-g-O2 -g

  • 使用しsizeofます。のほとんどの出現は である20必要がありsizeof、少なくとも使用#define SMALLSIZE 20してから使用しSMALLSIZEないで20ください。

  • snprintfnotを使用しますsprintf(そして、収まるはずの結果サイズをテストします!)。snprintf(3)は追加のサイズ引数を取ります。

     if (snprintf(querybuf, sizeof querybuf,
                  "SELECT ipDest, macDest, portDest, sum(totalBits)"
                  " FROM dataReceive"
                  " WHERE timeStampID between '%s' And '%s' "
                  " GROUP BY ipDest, macDest, portDest ",
                  buff1, buff2) >= (int) (sizeof querybuf))
         abort();
    
  • でsyslog(3)を使用することを検討openlogし、システム ログを調べてください。

queryBuf1どのように宣言されているかわかりません。(あなたのコードは、投稿されているように、おそらくコンパイルさえしないでしょう!)。あなたは次のようなものが欲しいかもしれませんchar querybuf[512];...

そして最も重要なことは、ループmysql_real_query内での呼び出しが間違っていることです。次の MySQL クエリを発行する前に、すべての行をフェッチしておく必要があります。MySQL C APIの詳細をお読みください。mysql_fetch_row

localRes1また、mysql_store_result(localConn);の結果をテストするのを忘れていました。どういうわけか(おそらくを通じてsyslogmysql_error(localConn)いつlocalRes1NULL....

于 2013-03-17T09:44:50.003 に答える