C言語のサンプルアプリケーションを作成する

本記事では、MySQL Connector/C (libmysqlclient) ドライバーを使用してOceanBaseデータベースに接続し、操作する方法について説明します。

前提条件

MySQL Connector/C (libmysqlclient) のインストールと使用を開始する前に、基本的なデータベース開発環境が設定されていることを確認してください。要件は以下の通りです：

• GCCバージョンが3.4.6以上であること。4.8.5バージョンの使用を推奨します。

• CMakeバージョンが2.8.12以上であること。

Cアプリケーションの作成

ステップ１：データベース接続文字列の取得

OceanBaseデータベースのデプロイ担当者または管理者から、該当するデータベース接続文字列を取得します。例：

obclient -h100.88.xx.xx -uroot@test -p****** -P2881 -Doceanbase

データベース接続文字列には、データベースへのアクセスに必要なパラメータ情報が含まれています。アプリケーションを作成する前に、データベース接続文字列を使用してデータベースへのログインを検証し、接続文字列のパラメータ情報が正しいことを確認できます。

パラメータ説明：

• -h：OceanBaseデータベースの接続IPアドレス。場合によってはODPのアドレスです。
• -u：テナントの接続ユーザー名。形式はユーザー@テナント#クラスタ名です。クラスタのデフォルトテナントはsys、テナントのデフォルト管理者ユーザーはrootです。データベースに直接接続する場合はクラスタ名を記入せず、ODPを介して接続する場合は記入する必要があります。
• -p：ユーザーパスワード。
• -P：OceanBaseデータベースの接続ポート番号。ODPのリスニングポートでもあります。
• -D：アクセスするデータベース名。

ステップ2：MySQL Connector/Cドライバをインストールする

yumを使用してMariaDBクライアントをインストールする

1. MariaDBクライアントをインストールします。

   sudo yum install mariadb-devel
   

ステップ3：アプリケーションの作成

アプリケーションは、MySQL Connector/Cを使用してデータベースサーバーOBServerノードとやり取りする基本的な手順は以下のとおりです：

1. mysql_library_init() を呼び出してMySQLライブラリを初期化します。

   mysql_library_init(0, NULL, NULL);
   

2. mysql_init() を呼び出して接続ハンドルを初期化します。

   MYSQL *mysql = mysql_init(NULL);
   

3. mysql_real_connect() を呼び出してOBServerノードに接続します。

   mysql_real_connect (mysql, host_name, user_name, password,
   db_name, port_num, socket_name, CLIENT_MULTI_STATEMENTS)
   

4. mysql_real_query() または mysql_query() を呼び出して、OBServerノードにSQLステートメントを送信します。

   mysql_query(mysql,"sql_statement");
   

5. mysql_store_result() または mysql_use_result() を呼び出して、その結果を処理します。

   result=mysql_store_result(mysql);
   

6. mysql_free_result() を呼び出してメモリを解放します。

   mysql_free_result(result);
   

7. mysql_close() を呼び出して、OBServerノードとの接続を閉じます。

   mysql_close(mysql);
   

8. mysql_library_end() を呼び出して、MariaDBクライアントの使用を終了します。

   mysql_library_end();
   

サンプルコード

mysql_test.c ファイルを例に、コードは以下のとおりです：

#include "mysql.h"
#include <stdio.h>
#include <stdlib.h>

int main(int argc, char** argv)
{
  mysql_library_init(0, NULL, NULL);
  MYSQL *mysql = mysql_init(NULL);
  char* host_name = "xxx.xxx.xxx.xxx";//set your mysql host
  char* user_name = "******"; //set your user_name
  char* password = "******"; //set your password
  char* db_name = "test"; //set your databasename
  int port_num = 2883; //set your mysql port
  char* socket_name = NULL;
  MYSQL_RES* result;
  MYSQL_FIELD* fields;
  MYSQL_ROW row;
  int status = 0;
  /* connect to server with the CLIENT_MULTI_STATEMENTS option */
  if (mysql_real_connect (mysql, host_name, user_name, password,
    db_name, port_num, socket_name, CLIENT_MULTI_STATEMENTS) == NULL)
  {
    printf("mysql_real_connect() failed\n");
    mysql_close(mysql);
    exit(1);
  }

  /* execute multiple statements */
  status = mysql_query(mysql, "DROP TABLE IF EXISTS test_table;");

  if (status)
  {
    printf("Could not execute statement(s)");
    mysql_close(mysql);
    exit(0);
  }

  status = mysql_query(mysql, "CREATE TABLE test_table(id INT,name varchar(24));");
  status = mysql_query(mysql, "INSERT INTO test_table VALUES(10,'hangzhou'),(20,'shanghai');");
  status = mysql_query(mysql, "UPDATE test_table SET id=20 WHERE id=10;");
  status = mysql_query(mysql, "SELECT * FROM test_table;");

  /* did current statement return data? */
  result = mysql_store_result(mysql);

  if (result)
  {
    /* yes; process rows and free the result set */
    //process_result_set(mysql, result);

    int num_fields = mysql_num_fields(result);
    int num_rows = mysql_num_rows(result);

    printf("result: %d rows %d fields\n", num_rows, num_fields);
    printf("---------------------\n");

    fields = mysql_fetch_fields(result);

    for (int i = 0; i < num_fields; ++i)
    {
      printf("%s\t", fields[i].name);
    }

    printf("\n---------------------\n");

    while ((row = mysql_fetch_row(result)))
    {
      for (int i = 0; i < num_fields; ++i)
      {
        printf("%s\t", row[i] ? row[i] : "NULL");
      }

      printf("\n");
    }

    printf("---------------------\n");

    mysql_free_result(result);
  }
  else          /* no result set or error */
  {
    if (mysql_field_count(mysql) == 0)
     {
       printf("%lld rows affected\n",
            mysql_affected_rows(mysql));
     }
     else  /* some error occurred */
     {
       printf("Could not retrieve result set\n");
     }
  }

  status = mysql_query(mysql, "DROP TABLE test_table;");

  mysql_close(mysql);
  return 0;
}

コード内のデータベース接続パラメータを修正します。以下の項目を参照し、対応する値は手順1で取得したデータベース接続文字列から取得します。

• host_name：-h パラメータから取得します。OceanBaseデータベースの接続アドレスで、場合によってはODPのアドレスです。

• user_name：-u パラメータから取得します。テナントの接続ユーザー名で、形式は ユーザー@テナント#クラスタ名 です。クラスタのデフォルトテナントは 'sys'、テナントのデフォルト管理者ユーザーは root です。データベースに直接接続する場合はクラスタ名を記入せず、ODPを介して接続する場合は記入する必要があります。

• password：-p パラメータから取得します。ユーザーパスワードです。

• db_name：-D パラメータから取得します。アクセスするデータベース名です。

• port_num：-P パラメータから取得します。OceanBaseデータベースの接続ポート番号で、ODPのリスニングポートでもあります。

ステップ4：アプリケーションを実行する

1. コードの編集が完了したら、以下のコマンドでコンパイルします。

   g++ -I/usr/include/mysql/ -L/usr/lib64/mysql/ -lmysqlclient mysql_test.c -o mysql_test
   

   オプションの説明：

   • -I オプション：コンパイラがヘッダーファイルを見つけられるように、コンパイラの検索パスを指定します。例えば、mysql.h ヘッダーファイルがあるディレクトリ /usr/include/mysql をコンパイラの検索パスに追加することで、コンパイラは mysql.h ヘッダーファイルを見つけることができます。find / -name mysql.h 2>/dev/null というコマンドを使用して mysql.h ファイルのパスを探すことができます。
   • -L オプション：動的リンクライブラリの検索パスを指定します。
   • -l オプション：リンクするライブラリファイルを指定します。-l オプションを使用する場合、ライブラリファイル名から lib プレフィックスと .so サフィックスを削除する必要があります。例えば、上記のコマンドではライブラリファイル名は libmysqlclient.so ですが、-l オプションを使用する場合は mysqlclient のみを指定する必要があります。

2. 実行パスを指定します。

   export LD_LIBRARY_PATH=/usr/lib64/mysql
   

3. 以下のコマンドでアプリケーションを実行します。

   ./mysql_test
   

   出力結果は以下のとおりです。このような結果が出力された場合、データベースへの接続が成功し、サンプル文が正しく実行されたことを意味します。

   ---------------------
   id      name
   ---------------------
   20      hangzhou
   20      shanghai
   ---------------------