0

ネットワーク パケットをシングル ボード コンピュータからデータベース (正確には mysql) に読み込みたいと考えています。シングル ボード コンピュータと mysql の間で通信するコードは c で記述します。オンラインでいくつかの資料への有用なリンクを取得するためにあなたの助けが必要です.有益な情報を探し求めてきましたが、まだ結果が得られていません. ご理解いただきありがとうございます。

4

2 に答える 2

1

最初にlibmysqlclient-devパッケージ（Linuxを使用していると思います）をシステムにインストールする必要があります。その後、必要に応じてこのコードを変更できます。

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

#define BUFFER_SIZE 1024    // Increase this buffer if yoy want

/* This function is used for the database connection */
MYSQL * my_mysql_connection(const char *server, const char *db, const char *user, const char *pwd)
{
    MYSQL *myh;

    /* Some initialisation */ 
    if (NULL == (myh = mysql_init(NULL)))
    {
        fprintf(stdeee, "Fails to allocate memory for MYSQL!\n");

        exit (EXIT_FAILURE);
    }

    /* Connect to the database. */
    if (NULL == mysql_real_connect (myh, server, user, pwd, db, 0, NULL, 0))
    {
        fprintf(stderr, "%s", mysql_error(myh));
        free (myh);

        return NULL;
    }

    return myh;
 }

/* This function is used to perform a query */ 
int my_mysql_query(MYSQL *myh, const char *query)
{
    /* Do the query request */
    if (0 != mysql_query(myh, query))
    {
        fprintf(stderr, "FAIL to perform the query : '%s' %s\n", query, mysql_error(myh));

        exit (EXIT_FAILURE);
    }

    return 0;
}

/*
 * Suppose that your table students_table has this fields : student_number, student_name, 
 * student_address, student_phone
 */
/* This function is used to get and process the result of the query */
void my_mysql_process_query_result(MYSQL * myh)
{
    int num_fields;
    int i;
    MYSQL_RES *query_result;
    MYSQL_FIELD *field;
    MYSQL_ROW row;
    char  *buffer;

    buffer = (char *) calloc(BUFFER_SIZE, sizeof(char));

    /* Select all students present in the students_table */
    if (my_mysql_query(myh, "SELECT student_number, student_name, student_address, student_phone FROM students_table"))
    {
        exit (EXIT_FAILURE);
    }
    query_result = mysql_store_result (myh);

    /* Retreive the number of rows and fields */
    field = mysql_fetch_fields(query_result);
    num_fields = mysql_num_fields(query_result);

    /* construct the buffer containing each row */
    while ((row = mysql_fetch_row (query_result))) 
    {
        /* Init our buffer with fields sperated by ";", modify if you need, it's just an example */
        memset(buffer, '\0', sizeof*buffer);

        for (i = 0; i < num_fields - 1; i++)
        {
            strncat(buffer, row[i], strlen(row[i]) + 1);
            strncat(buffer, ";", 2);            
        }   
        strncat(buffer, row[i], strlen(row[i]) + 1);
        strncat(buffer, "\n", 2);
        // You can process your buffer (row) here
        process_student_row(buffer);
    }
    free(buffer);

    mysql_free_result (query_result);
}

mysqlclientライブラリにリンクすることを忘れないでください：-lmysqlclient。

編集：

libmysqlclient-dev（http://packages.debian.org/squeeze/libmysqlclient-dev）は次のようにdebianにインストールできます：

sudo apt-get update
sudo apt-get install libmysqlclient-dev

次のようにプログラムをコンパイルできます。

gcc -Wall my_msql_program.c -o my_mysql_program -lmysqlclient
于 2012-08-06T10:32:34.133 に答える
0

mySQL が通常の PC で実行されている場合、必要なデータがボードから PC に転送されるように、シングル ボード コンピュータと通常の PC の間で通信する必要があります。PC上に何らかのサーバーが必要です。それが完了すると、PC はデータを取得し、mySQL C API を使用してそれを mySQL データベースにコミットします。

私は間違っているかもしれませんが、あなたは頭がおかしいかもしれません。一般的なデザインはシンプルです。それがわかりにくい場合は、何かをやりすぎている可能性があります。

于 2012-08-06T10:07:25.097 に答える