MariaDB Connector/C を使用して C/C++ プログラミングから MariaDB データベースに接続する方法

2024-04-02

埋め込み MariaDB C/C++ API プログラミング入門

MariaDB は、MySQL と互換性のあるオープンソースのデータベース管理システムです。C/C++ プログラミング言語で MariaDB を使用するには、2 つの方法があります。

MariaDB Connector/C: これは、MariaDB サーバーへの接続とクエリの実行に使用できるクライアントライブラリです。
埋め込み MariaDB C/C++ API: これは、アプリケーションに MariaDB データベースを直接埋め込むための API です。

このチュートリアルでは、埋め込み MariaDB C/C++ API の使用方法について説明します。

必要なもの

C/C++ コンパイラ
MariaDB 開発ヘッダーファイル
MariaDB ライブラリ

始める

まず、MariaDB 開発ヘッダーファイルとライブラリをインストールする必要があります。インストール方法は、使用しているオペレーティングシステムによって異なります。

Linux の場合

sudo apt install libmariadb-dev

Mac の場合

brew install mariadb

Windows の場合

MariaDB 公式サイトからダウンロードしてインストールする必要があります。

Hello World プログラム

以下のコードは、埋め込み MariaDB C/C++ API を使用して "Hello World" を出力するプログラムです。

#include <mariadb/mysql.h>

int main() {

  // データベースへの接続
  MYSQL *conn = mysql_init(NULL);
  if (mysql_real_connect(conn, "localhost", "root", "", "test", 0, NULL, 0) == NULL) {
    fprintf(stderr, "Error connecting to database: %s\n", mysql_error(conn));
    return 1;
  }

  // クエリの実行
  if (mysql_query(conn, "SELECT 'Hello World'")) {
    fprintf(stderr, "Error executing query: %s\n", mysql_error(conn));
    return 1;
  }

  // 結果の取得
  MYSQL_RES *result = mysql_store_result(conn);
  if (result == NULL) {
    fprintf(stderr, "Error getting results: %s\n", mysql_error(conn));
    return 1;
  }

  // 結果の出力
  MYSQL_ROW row = mysql_fetch_row(result);
  printf("%s\n", row[0]);

  // データベースとの接続を閉じる
  mysql_close(conn);

  return 0;
}

埋め込み MariaDB C/C++ API の詳細については、以下のリソースを参照してください。

埋め込み MariaDB C/C++ API は、C/C++ プログラミング言語で MariaDB データベースを使用するための強力なツールです。このチュートリアルでは、基本的な使用方法について説明しました。詳細については、上記のリンクを参照してください。

データベースへの接続と切断

MYSQL *conn = mysql_init(NULL);
if (mysql_real_connect(conn, "localhost", "root", "", "test", 0, NULL, 0) == NULL) {
  fprintf(stderr, "Error connecting to database: %s\n", mysql_error(conn));
  return 1;
}

// ...

mysql_close(conn);

クエリの実行

if (mysql_query(conn, "SELECT * FROM users")) {
  fprintf(stderr, "Error executing query: %s\n", mysql_error(conn));
  return 1;
}

結果の取得

MYSQL_RES *result = mysql_store_result(conn);
if (result == NULL) {
  fprintf(stderr, "Error getting results: %s\n", mysql_error(conn));
  return 1;
}

// ...

mysql_free_result(result);

データの挿入

if (mysql_query(conn, "INSERT INTO users (name, email) VALUES ('John Doe', '[email protected]')")) {
  fprintf(stderr, "Error inserting data: %s\n", mysql_error(conn));
  return 1;
}

if (mysql_query(conn, "UPDATE users SET name = 'Jane Doe' WHERE id = 1")) {
  fprintf(stderr, "Error updating data: %s\n", mysql_error(conn));
  return 1;
}

if (mysql_query(conn, "DELETE FROM users WHERE id = 1")) {
  fprintf(stderr, "Error deleting data: %s\n", mysql_error(conn));
  return 1;
}

トランザクションの開始とコミット

// トランザクションの開始
mysql_begin_transaction(conn);

// ...

// トランザクションのコミット
mysql_commit(conn);

エラー処理

if (mysql_query(conn, "SELECT * FROM users")) {
  fprintf(stderr, "Error executing query: %s\n", mysql_error(conn));
  return 1;
}

// エラーコードを取得
int errcode = mysql_errno(conn);

// エラーメッセージを取得
const char *errmsg = mysql_error(conn);

// ...