OceanBase Connector/ODBC による OB Cloud クラウドデータベース接続サンプルプログラム

本記事では、OceanBase Connector/ODBC と OB Cloud クラウドデータベースを使用してアプリケーションを構築し、テーブルの作成、データの挿入、クエリなどの基本的な操作を実現する方法を紹介します。

c-oceanbase-odbc サンプルプロジェクトをダウンロード OceanBase Connector/ODBC による OceanBase データベース接続サンプルプログラム（Oracleモード）

前提条件

• OB Cloudデータベースアカウントに登録し、クラスタインスタンスとOB CloudのOracleモードテナントを作成していること。詳細については、クラスタインスタンスの作成およびテナントの作成を参照してください。

• Visual Studioがインストール済みであること。

• OceanBase Connector/ODBCドライバーがインストール済みであること。

  説明

  OceanBase公式サイトのリソース > ダウンロードセンター > エンタープライズ版ページのドライバーとミドルウェアモジュールから、OceanBase ODBCドライバーWindows版のインストールパッケージをダウンロードしてください。Windows版OceanBase Connector/ODBCドライバーのインストールパッケージはワンクリックでデプロイできる形式です。デフォルトの手順に従ってインストールしてください。

手順

1. c-oceanbase-odbc プロジェクトを開きます。
2. c-oceanbase-odbc プロジェクトのプロパティを設定します。
3. OB Cloudデータベース接続情報を取得します。
4. c-oceanbase-odbc プロジェクト内のデータベース接続情報を修正します。
5. プロジェクトをビルドします。
6. アプリケーションを実行します。
7. 出力結果を確認します。

ステップ１：c-oceanbase-odbcプロジェクトを開く

1. Visual Studio Community 2019を起動します。

2. 既存のプロジェクトを開きます。

   1. Visual Studio Community 2019の開始画面で、使用を開始する前に プロジェクトまたはソリューションを開く(P) ボタンをクリックします。または、Visual Studio Community 2019の開始画面で、使用を開始する前に コードなしで続行(W) ボタンをクリックするか、上部メニューバーから ファイル -> 開く -> プロジェクト/ソリューション(P) を選択します。

   2. c-oceanbase-odbc プロジェクト フォルダに移動し、プロジェクトファイル（c-oceanbase-odbc.sln または c-oceanbase-odbc.vcxproj）を選択して 開く をクリックします。

ステップ2：c-oceanbase-odbcプロジェクトのプロパティを設定する

1. プロジェクトのプロパティページを開きます。

   ソリューションエクスプローラーで 選択したプロジェクトを右クリックし、コンテキストメニューで プロパティ を選択するか、Visual Studioの上部メニューバーで プロジェクト -> プロパティ を選択するか、ショートカットキー Alt + Enter を使用します。

2. 設定マネージャーの設定を行います。

   1. プロパティページで、上部にある 設定(C) のドロップダウンメニューを選択します。ドロップダウンメニューで、Debug を選択します。

   2. プロパティページで、上部にある プラットフォーム(P) のドロップダウンメニューを選択します。ドロップダウンメニューで、x64 を選択します。

3. 文字セットの設定を行います。

   プロパティページで 詳細設定 タブを選択し、文字セット 項目を見つけます。ドロップダウンメニューで、マルチバイト文字セットを使用する を選択します。

ステップ3：OB Cloudデータベース接続情報を取得する

1. OB Cloudコンソールにログインします。インスタンス一覧ページで、対象インスタンスの情報を展開し、対象テナントで、接続 > 接続文字列の取得 を選択します。

   詳細な操作については、接続文字列の取得を参照してください。

2. 作成済みのOB Cloudデータベースに基づいて、以下のURLの該当する情報を入力します。

   例：

   obclient -h t********.********.oceanbase.cloud -P 1521 -u oracle001 -p******
   

   パラメータ説明：

   • -h：OB Cloudデータベースの接続アドレスを指定します。例：t********.********.oceanbase.cloud
   • -P：OB Cloudデータベースの接続ポートを指定します。デフォルトは1521です。
   • -u：データベースへのアクセスアカウントを指定します。
   • -p：アカウントのパスワードを指定します。

   接続文字列の詳細については、OBClientを使用してOceanBaseテナントに接続するを参照してください。

ステップ4：c-oceanbase-odbcプロジェクト内のデータベース接続情報を修正する

ステップ3：OB Cloudデータベース接続情報を取得する の情報に基づいて、test_tbl1.cpp ファイル内のデータベース接続情報を修正します。

例：

char* mydriver = (char*)"Driver={OceanBase ODBC 2.0 Driver};Server=t********.********.oceanbase.cloud;Port=1521;Database=sys;User=oracle001;Password=******;Option=3;";

ステップ5：プロジェクトをビルドする

ビルド メニューを選択し、ソリューションのビルド を選択します。ビルド中、コンパイラの出力およびエラーや警告情報が表示されます。

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

デバッグ メニューを選択し、デバッグの開始 または 実行の開始(デバッグなし) を選択してアプリケーションを実行します。

ステップ7：出力結果を確認する

出力結果はデバッグコンソールに表示されます。プログラムの設計ロジックとコードに基づいて、出力の処理方法を判断できます。

プロジェクトコードについて

c-oceanbase-odbc をクリックして、プロジェクトコードをダウンロードします。これは、c-oceanbase-odbc.zip という名前の圧縮ファイルです。

解凍すると、c-oceanbase-odbc という名前のフォルダが作成されます。ディレクトリ構造は以下のとおりです：

c-oceanbase-odbc
├─ c-oceanbase-odbc.sln
├─ c-oceanbase-odbc.vcxproj
├─ c-oceanbase-odbc.vcxproj.filters
├─ c-oceanbase-odbc.vcxproj.user
└─ test_tbl1.cpp

ファイルの説明：

• c-oceanbase-odbc.sln：Visual Studioのソリューションファイルで、1つまたは複数のプロジェクトを管理するために使用されます。
• c-oceanbase-odbc.vcxproj：Visual Studioのプロジェクトファイルで、C/C++プロジェクトの構造と設定を記述するために使用されます。
• c-oceanbase-odbc.vcxproj.filters：Visual Studioのプロジェクトフィルターファイルで、プロジェクト内のファイルのディレクトリ構造と編成方法を定義するために使用されます。
• c-oceanbase-odbc.vcxproj.user：ユーザー固有のプロジェクト設定を格納するファイルです。
• test_tbl1.cpp：データテーブルの構造を定義し、データテーブル操作を実装したソースコードファイルです。

test_tbl1.cppファイルのコード紹介

test_tbl1.cpp ファイルは、test_tbl1 という名前のデータテーブルを定義するために使用され、データテーブルの作成、データの挿入、クエリ操作を実装しています。

この test_tbl1.cpp ファイルのコードは、主に以下の部分で構成されています：

1. ヘッダーファイルのインポート。

   ヘッダーファイル stdio.h、assert.h、windows.h、sql.h、および sqlext.h をインポートします。

   コード：

   #include <stdio.h>
   #include <assert.h>
   #include <windows.h>
   #include <sql.h>
   #include <sqlext.h>
   

2. 関数 odbc_print_error の定義。

   この関数の役割は、プログラムの実行中にODBC関連のエラーが発生した場合に呼び出し、エラーメッセージを出力することです。具体的な手順は以下のとおりです：

   1. 関数名を odbc_print_error と定義し、パラメータ SQLSMALLINT HandleType と SQLHANDLE Handle を指定します。これらは、エラーメッセージに対応するハンドルタイプとハンドルを指定するために使用されます。
   2. ODBCから取得したエラー情報を格納する変数を定義します。これらの変数の型と名前は、ODBC APIで定義されたデータ型と名前です。
   3. SQLGetDiagRec() を使用して、ODBCで最後に生成されたエラー情報を取得します。この関数の呼び出し後、SQLState、NativeError、SQLMessage 配列にエラー情報の関連内容が格納されます。
   4. fprintf 関数を使用して、エラー情報を標準出力ストリームに出力します。[%s] (%d) %s\n は出力フォーマットであり、printf 関数のフォーマット文字列に似ています。%s は文字列型データの出力に、%d は整数型データの出力に使用され、\n は改行を表します。SQLState、NativeError、SQLMessage はそれぞれフォーマット文字列内の3つのパラメータに対応し、出力するエラー情報の内容を表します。

   コード：

   static void odbc_print_error(SQLSMALLINT HandleType, SQLHANDLE Handle)
   {
       SQLCHAR SQLState[6];
       SQLINTEGER NativeError;
       SQLCHAR SQLMessage[SQL_MAX_MESSAGE_LENGTH] = { 0 };
       SQLSMALLINT TextLengthPtr;
       SQLGetDiagRec(HandleType, Handle, 1, SQLState, &NativeError, SQLMessage, SQL_MAX_MESSAGE_LENGTH, &TextLengthPtr);
       fprintf(stdout, "[%s] (%d) %s\n", SQLState, NativeError, SQLMessage);
   }
   

3. 関数 ASSERT_CHECK の定義。

   この関数の役割は、ODBC関数呼び出しの戻り値をチェックし、処理することです。つまり、ODBC API関数の戻り値にエラーが発生したかどうかをチェックし、エラーがあった場合はエラーメッセージを出力してプログラムを終了します。具体的な手順は以下のとおりです：

   1. マクロ名を ASSERT_CHECK と定義し、パラメータ SQLSMALLINT HandleType、SQLHANDLE Handle、SQLRETURN rcode を指定します。これらはそれぞれODBCハンドルタイプ、ODBCハンドル、ODBC API関数呼び出しの戻り値です。
   2. if 文を使用してODBC API関数の戻り値を判断します。戻り値が SQL_SUCCESS または SQL_SUCCESS_WITH_INFO と等しくない場合、関数呼び出しにエラーが発生したことを意味します。
   3. odbc_print_error 関数を呼び出して、ODBCエラー情報を出力します。
   4. assert 関数を呼び出して、プログラムの実行中にアサーションチェックを行います。ODBC関数呼び出しでエラーが発生した場合、プログラムは中断されます。

   コード：

   static void ASSERT_CHECK(SQLSMALLINT HandleType, SQLHANDLE Handle, SQLRETURN rcode)
   {
       if (rcode != SQL_SUCCESS && rcode != SQL_SUCCESS_WITH_INFO) {
           odbc_print_error(HandleType, Handle);
           assert(0);
       }
   }
   

4. 関数 main の定義。

   プログラムのエントリ関数 main を定義し、整数値を返します。main 関数内では、データベース接続やデータ操作に関連するコードを記述します。

   コード：

   int main() {
       // 環境ハンドルの申請
       // ODBCバージョンの環境属性の設定
       // 接続ハンドルの割り当て
       // データソースへの接続
       // テーブルの作成
       // データの挿入
       // データのクエリ
       // クリーンアップ作業、具体的なリソースハンドルの解放
   }
   

5. 変数の定義。

   変数 henv を定義します。これはODBC環境ハンドル型のオブジェクトであり、ODBC接続とリソースの割り当てを管理するために使用されます。OutConnStr と OutConnStrLen は、接続文字列とその長さを格納するために使用されます。これらのパラメータはデータベースに接続する際に SQLDriverConnect 関数に渡され、データベースへの正常な接続時の戻り値やその他の接続情報を取得します。

   コード：

       HENV henv;
       SQLCHAR OutConnStr[255];
       SQLSMALLINT OutConnStrLen;
   

6. 環境ハンドルの申請。

   SQLAllocHandle 関数を使用してODBC環境ハンドルを割り当て、ASSERT_CHECK 関数を使用して割り当て結果をチェックし、割り当てが成功したことを確認します。具体的な手順は以下のとおりです：

   1. SQLAllocHandle 関数の実行後、SQLRETURN 型の値を返します。この値は関数の実行結果を示します。コードでは、この戻り値は rcode 変数に格納されます。SQLAllocHandle 関数のパラメータは以下のとおりです：
   • SQL_HANDLE_ENV：割り当てるハンドルのタイプを指定します。ここでは SQL_HANDLE_ENV で、環境ハンドルを割り当てることを示します。
   • SQL_NULL_HANDLE：親ハンドルを指定します。ここでは SQL_NULL_HANDLE で、親ハンドルがないことを示します。
   • &henv：割り当てられたハンドルを格納する変数へのポインタです。ここでは henv、つまり環境ハンドルの変数です。
   2. ASSERT_CHECK 関数を使用して、SQLAllocHandle 関数の戻り値 rcode をチェックします。rcode が SQL_SUCCESS または SQL_SUCCESS_WITH_INFO でない場合、つまりハンドルの割り当てに失敗した場合、ASSERT_CHECK 関数は odbc_print_error 関数を呼び出してエラーメッセージを出力し、assert マクロを使用してプログラムの実行を終了します。

   コード：

       SQLRETURN rcode = SQLAllocHandle(SQL_HANDLE_ENV, SQL_NULL_HANDLE, &henv);
       ASSERT_CHECK(SQL_HANDLE_ENV, henv, rcode);
   

7. ODBCバージョンの環境属性の設定。

   SQLSetEnvAttr 関数を使用してODBC環境の属性を設定します。これにより、データベース接続とドライバーの動作に影響を与える環境レベルの属性を設定できます。また、ASSERT_CHECK 関数を使用して属性設定の結果をチェックし、設定が成功したことを確認します。具体的な手順は以下のとおりです：

   1. SQLSetEnvAttr 関数の実行後、SQLRETURN 型の値を返します。この値は関数の実行結果を示します。コードでは、この戻り値は rcode 変数に格納されます。SQLSetEnvAttr 関数のパラメータは以下のとおりです：
   • henv：ODBC環境ハンドルで、属性を設定する環境オブジェクトを指定します。
   • SQL_ATTR_ODBC_VERSION：設定する環境属性タイプを指定します。ここでは SQL_ATTR_ODBC_VERSION で、ODBCバージョンの属性を設定することを示します。
   • (void*)SQL_OV_ODBC3：属性値へのポインタです。ここでは SQL_OV_ODBC3 で、ODBCバージョンをODBC 3.xに設定することを示します。
   • 0：属性値の長さです。ここでは、属性値が列挙定数であるため、長さは 0 です。
   2. ASSERT_CHECK 関数を使用して、SQLSetEnvAttr 関数の戻り値 rcode をチェックします。rcode が SQL_SUCCESS または SQL_SUCCESS_WITH_INFO でない場合、つまり属性の設定に失敗した場合、ASSERT_CHECK 関数は odbc_print_error 関数を呼び出してエラーメッセージを出力し、assert マクロを使用してプログラムの実行を終了します。

   コード：

       rcode = SQLSetEnvAttr(henv, SQL_ATTR_ODBC_VERSION, (void*)SQL_OV_ODBC3, 0);
       ASSERT_CHECK(SQL_HANDLE_ENV, henv, rcode);
   

8. 接続ハンドルの割り当て。

   SQLAllocHandle 関数を使用して ODBC 接続ハンドルを割り当て、ASSERT_CHECK 関数を使用してハンドル割り当ての結果をチェックし、割り当てが成功したことを確認します。具体的な手順は以下のとおりです：

   1. SQLAllocHandle 関数の実行後、SQLRETURN 型の値を返します。この値は関数の実行結果を示します。コードでは、この戻り値は rcode 変数に格納されます。SQLAllocHandle 関数のパラメータは以下のとおりです：
   • SQL_HANDLE_DBC：割り当てるハンドルのタイプを指定します。ここでは SQL_HANDLE_DBC で、接続ハンドルを割り当てることを示します。
   • henv：既に割り当てられたODBC環境ハンドルで、親ハンドルとして使用され、接続ハンドルと関連付けられます。
   • &hdbc：割り当てられた接続ハンドルを格納する変数へのポインタです。
   2. ASSERT_CHECK 関数を使用して、SQLAllocHandle 関数の戻り値 rcode をチェックします。rcode が SQL_SUCCESS または SQL_SUCCESS_WITH_INFO でない場合、つまりハンドルの割り当てに失敗した場合、ASSERT_CHECK 関数は odbc_print_error 関数を呼び出してエラーメッセージを出力し、assert マクロを使用してプログラムの実行を終了します。

   コード：

       SQLHDBC hdbc;
       rcode = SQLAllocHandle(SQL_HANDLE_DBC, henv, &hdbc);
       ASSERT_CHECK(SQL_HANDLE_DBC, hdbc, rcode);
   

9. データソースへの接続。

   SQLDriverConnect 関数を使用して、指定されたODBCデータソースに接続します。そして、ASSERT_CHECK 関数を使用して接続操作の結果をチェックし、接続が成功したことを確認します。具体的な手順は以下のとおりです：

   1. 接続データベースに必要な詳細情報を記述する接続文字列 mydriver を定義します。この文字列には以下の部分が含まれます：

      • Driver={OceanBase ODBC 2.0 Driver}：使用するODBCドライバーをOceanBase ODBC 2.0 Driverと指定します。
      • Server=your_ip：データベースの接続アドレスを指定します。
      • Port=your_port：データベース接続時に使用するポート番号を指定します。
      • Database=your_schema：接続するデータベース名を指定します。
      • User=your_use：データベース接続時に使用するユーザー名を指定します。
      • Password=your_password：データベース接続時に使用するパスワードを指定します。
      • Option=3：接続オプションを指定します。その値は 3 で、TCP/IP接続を使用することを示します。

   2. SQLDriverConnect 関数を使用して、指定されたODBCデータソースに接続します。関数の実行後、SQLRETURN型の値を返します。この値は関数の実行結果を示します。コードでは、この戻り値はrcode変数に格納されます。この関数のパラメータは以下のとおりです：

   • hdbc：ODBC接続ハンドルで、データソースとの接続を確立するために使用されます。
   • NULL：予約済みのパラメータで、使用されません。
   • mydriver：接続文字列で、ドライバー名、データベースアドレス、ポート番号、データベース名、ユーザー名、パスワードなど、データベース接続に必要なすべての情報が含まれます。
   • strlen((char*)mydriver) + 1：接続文字列の長さです。
   • OutConnStr：SQLCHAR型のバッファで、接続文字列を格納するために使用されます。
   • 255：バッファの長さです。
   • &OutConnStrLen：接続文字列の実際の長さを格納する変数へのポインタです。
   • SQL_DRIVER_NOPROMPT：接続フラグで、接続時にプロンプトボックスを表示しないよう指示します。
   3. ASSERT_CHECK 関数を使用して、SQLDriverConnect 関数の戻り値 rcode をチェックします。rcode が SQL_SUCCESS または SQL_SUCCESS_WITH_INFO でない場合、つまり接続に失敗した場合、ASSERT_CHECK 関数は odbc_print_error 関数を呼び出してエラーメッセージを出力し、assert マクロを使用してプログラムの実行を終了します。

   コード：

       char* mydriver = (char*)"Driver={OceanBase ODBC 2.0 Driver};Server=your_ip;Port=your_port;Database=your_schema;User=your_use;Password=your_password;Option=3;";
       rcode = SQLDriverConnect(hdbc, NULL, (SQLCHAR*)mydriver, strlen((char*)mydriver) + 1, OutConnStr, 255, &OutConnStrLen, SQL_DRIVER_NOPROMPT);
       ASSERT_CHECK(SQL_HANDLE_DBC, hdbc, rcode);
   

   OB Cloudデータベース接続に必要なパラメータの説明：

   • your_ip：接続文字列の -h パラメータから取得したOB Cloudデータベースの接続アドレスです。
   • your_port：接続文字列の -P パラメータから取得したOB Cloudデータベースの接続ポートです。
   • your_schema：アクセスするSchema名です。
   • your_user：接続文字列の -u パラメータから取得したアカウント名です。
   • your_password：接続文字列の -p パラメータから取得したアカウントのパスワードです。

10. テーブルの作成。

    SQLAllocHandle 関数を使用してODBCステートメントハンドルを割り当て、次に SQLExecDirect 関数を使用してSQLステートメントを実行し、テーブルを作成します。コードでは、ASSERT_CHECK 関数も使用して、ハンドルの割り当てとステートメントの実行の結果をチェックし、操作が成功したことを確認します。最後に、SQLFreeHandle 関数を使用してステートメントハンドルを解放し、リソースを解放します。具体的な手順は以下のとおりです：

    1. ODBCステートメントハンドル stmt を宣言します。

    2. SQLAllocHandle 関数を使用してODBCステートメントハンドルを割り当てます。

    3. ASSERT_CHECK 関数を使用して、SQLAllocHandle 関数の戻り値 rcode をチェックし、ハンドルの割り当てが成功したことを確認します。

    4. SQLExecDirect 関数を使用してSQLステートメントを実行します。ここでは、CREATE TABLE ステートメントを実行して、test_tbl1 という名前のテーブルを作成します。

    5. ASSERT_CHECK 関数を使用して、SQLExecDirect 関数の戻り値 rcode をチェックし、ステートメントの実行が成功したことを確認します。

    6. SQLFreeHandle 関数を使用して ODBC ステートメントハンドルを解放します。

    コード：

        SQLHSTMT stmt;
        rcode = SQLAllocHandle(SQL_HANDLE_STMT, hdbc, &stmt);
        ASSERT_CHECK(SQL_HANDLE_STMT, stmt, rcode);
    
        rcode = SQLExecDirect(stmt, (SQLCHAR*)"CREATE TABLE test_tbl1(id NUMBER PRIMARY KEY, name VARCHAR2(50),age NUMBER NOT NULL)", SQL_NTS);
        ASSERT_CHECK(SQL_HANDLE_STMT, stmt, rcode);
    
        SQLFreeHandle(SQL_HANDLE_STMT, stmt);
    

11. データの挿入。

    SQLAllocHandle 関数を使用してODBCステートメントハンドルを割り当て、次に SQLExecDirect 関数を使用してSQLステートメントを実行し、データベーステーブルにデータを挿入します。コードでは、ASSERT_CHECK 関数も使用して、ハンドルの割り当てとステートメントの実行の結果をチェックし、操作が成功したことを確認します。最後に、SQLFreeHandle 関数を使用してステートメントハンドルを解放し、リソースを解放します。具体的な手順は以下のとおりです：

    1. SQLAllocHandle 関数を使用してODBCステートメントハンドルを割り当てます。

    2. ASSERT_CHECK 関数を使用して、SQLAllocHandle 関数の戻り値 rcode をチェックし、ハンドルの割り当てが成功したことを確認します。

    3. SQLExecDirect 関数を使用してSQLステートメントを実行します。ここでは、INSERT INTO ステートメントを実行して、test_tbl1 テーブルに3行のレコードを挿入します。

    4. ASSERT_CHECK 関数を使用して、SQLExecDirect 関数の戻り値 rcode をチェックし、ステートメントの実行が成功したことを確認します。

    5. SQLFreeHandle 関数を使用してODBCステートメントハンドルを解放します。

    コード：

        rcode = SQLAllocHandle(SQL_HANDLE_STMT, hdbc, &stmt);
        ASSERT_CHECK(SQL_HANDLE_STMT, stmt, rcode);
    
        rcode = SQLExecDirect(stmt, (SQLCHAR*)"INSERT INTO test_tbl1 (id,name,age) VALUES  (1,'Tom', 18),(2,'Jerry', 20),(3,'Bob', 22)", SQL_NTS);
        ASSERT_CHECK(SQL_HANDLE_STMT, stmt, rcode);
    
        SQLFreeHandle(SQL_HANDLE_STMT, stmt);
    

12. データのクエリ。

    SQLAllocHandle 関数を使用してODBCステートメントハンドルを割り当て、次に SQLExecDirect 関数を使用してSQLステートメントを実行し、結果セットを取得します。その後、SQLBindCol 関数を使用して結果セットの列を変数にバインドし、SQLFetch 関数を使用して結果セットを行ごとに取得します。while ループ内で、rcode の値に基づいて結果セットのデータを出力します。最後に、SQLFreeHandle 関数を使用してステートメントハンドルを解放し、リソースを解放します。具体的な手順は以下のとおりです：

    1. SQLAllocHandle 関数を使用してODBCステートメントハンドルを割り当てます。

    2. ASSERT_CHECK 関数を使用して、SQLAllocHandle 関数の戻り値 rcode をチェックし、ハンドルの割り当てが成功したことを確認します。

    3. SQLExecDirect 関数を使用してSQLステートメントを実行します。ここでは、SELECT ステートメントを実行して、test_tbl1 テーブルからすべての行を取得します。

    4. ASSERT_CHECK 関数を使用して、SQLExecDirect 関数の戻り値 rcode をチェックし、ステートメントの実行が成功したことを確認します。

    5. SQLLEN 型の変数 res を宣言し、列バインド操作の結果を格納します。

    6. SQLINTEGER 型の変数 id と age を宣言し、結果セットの対応する列の値を格納します。

    7. SQLCHAR 型の配列 name を宣言し、結果セットの対応する列の値を格納します。

    8. SQLBindCol 関数を使用して、結果セットの最初の列を変数 id にバインドします。

    9. SQLBindCol 関数を使用して、結果セットの2番目の列を配列 name にバインドします。

    10. SQLBindCol 関数を使用して、結果セットの3番目の列を変数 age にバインドします。

    11. SQLFetch 関数を使用して結果セットの行を取得し、行のデータをバインドされた変数に格納します。while ループは、すべての行が取得されるまで繰り返し実行されます。

    12. while ループ内で、rcode の値を判断して、対応する行のデータを出力します。rcode が SQL_ERROR の場合は、エラーメッセージを出力します。

    13. SQLFreeHandle 関数を使用してODBCステートメントハンドルを解放します。

    コード：

        rcode = SQLAllocHandle(SQL_HANDLE_STMT, hdbc, &stmt);
        ASSERT_CHECK(SQL_HANDLE_STMT, stmt, rcode);
    
        rcode = SQLExecDirect(stmt, (SQLCHAR*)"SELECT * FROM test_tbl1", SQL_NTS);
        ASSERT_CHECK(SQL_HANDLE_STMT, stmt, rcode);
    
        SQLLEN res = SQL_NTS;
        SQLINTEGER id, age;
        SQLCHAR name[255];
        SQLBindCol(stmt, 1, SQL_C_SLONG, &id, sizeof(id), &res);
        SQLBindCol(stmt, 2, SQL_C_CHAR, name, sizeof(name), &res);
        SQLBindCol(stmt, 3, SQL_C_SLONG, &age, sizeof(age), &res);
    
        while ((rcode = SQLFetch(stmt)) != SQL_NO_DATA_FOUND)
        {
            if (rcode == SQL_ERROR) {
                printf("sql error!\n");
            }
            else {
                printf("id:%d, name:%s, age:%ld\n", id, name, age);
            }
        }
    
        SQLFreeHandle(SQL_HANDLE_STMT, stmt);
    

13. クリーンアップ作業、具体的なリソースハンドルの解放。

    データベースとの接続を切断し、関連するODBCハンドルと環境ハンドルを解放してリソースを解放します。SQLDisconnect 関数と SQLFreeHandle 関数を呼び出すことで、プログラムはデータベースとの接続を適切に閉じ、関連するハンドルを解放できます。最後に、0を返すことでプログラムの実行が成功したことを示します。具体的な手順は以下のとおりです：

    1. SQLDisconnect 関数を使用してデータベースとの接続を切断します。

    2. SQLFreeHandle 関数を使用してデータベース接続ハンドルを解放します。

    3. SQLFreeHandle 関数を使用してODBC環境ハンドルを解放します。

    4. 0を返して、プログラムの実行が成功したことを示します。

    コード：

        SQLDisconnect(hdbc);
        SQLFreeHandle(SQL_HANDLE_DBC, hdbc);
        SQLFreeHandle(SQL_HANDLE_ENV, henv);
    
        return 0;
    

全コード表示

#include <stdio.h>
#include <assert.h>
#include <windows.h>
#include <sql.h>
#include <sqlext.h>

static void odbc_print_error(SQLSMALLINT HandleType, SQLHANDLE Handle)
{
    SQLCHAR SQLState[6];
    SQLINTEGER NativeError;
    SQLCHAR SQLMessage[SQL_MAX_MESSAGE_LENGTH] = { 0 };
    SQLSMALLINT TextLengthPtr;
    SQLGetDiagRec(HandleType, Handle, 1, SQLState, &NativeError, SQLMessage, SQL_MAX_MESSAGE_LENGTH, &TextLengthPtr);
    fprintf(stdout, "[%s] (%d) %s\n", SQLState, NativeError, SQLMessage);
}

static void ASSERT_CHECK(SQLSMALLINT HandleType, SQLHANDLE Handle, SQLRETURN rcode)
{
    if (rcode != SQL_SUCCESS && rcode != SQL_SUCCESS_WITH_INFO) {
        odbc_print_error(HandleType, Handle);
        assert(0);
    }
}

int main()
{
    HENV henv;
    SQLCHAR OutConnStr[255];
    SQLSMALLINT OutConnStrLen;

    SQLRETURN rcode = SQLAllocHandle(SQL_HANDLE_ENV, SQL_NULL_HANDLE, &henv);
    ASSERT_CHECK(SQL_HANDLE_ENV, henv, rcode);

    rcode = SQLSetEnvAttr(henv, SQL_ATTR_ODBC_VERSION, (void*)SQL_OV_ODBC3, 0);
    ASSERT_CHECK(SQL_HANDLE_ENV, henv, rcode);

    SQLHDBC hdbc;
    rcode = SQLAllocHandle(SQL_HANDLE_DBC, henv, &hdbc);
    ASSERT_CHECK(SQL_HANDLE_DBC, hdbc, rcode);

    char* mydriver = (char*)"Driver={OceanBase ODBC 2.0 Driver};Server=your_ip;Port=your_port;Database=your_schema;User=your_use;Password=your_password;Option=3;";
    rcode = SQLDriverConnect(hdbc, NULL, (SQLCHAR*)mydriver, strlen((char*)mydriver) + 1, OutConnStr, 255, &OutConnStrLen, SQL_DRIVER_NOPROMPT);
    ASSERT_CHECK(SQL_HANDLE_DBC, hdbc, rcode);

    SQLHSTMT stmt;
    rcode = SQLAllocHandle(SQL_HANDLE_STMT, hdbc, &stmt);
    ASSERT_CHECK(SQL_HANDLE_STMT, stmt, rcode);

    rcode = SQLExecDirect(stmt, (SQLCHAR*)"CREATE TABLE test_tbl1(id NUMBER PRIMARY KEY, name VARCHAR2(50),age NUMBER NOT NULL)", SQL_NTS);
    ASSERT_CHECK(SQL_HANDLE_STMT, stmt, rcode);

    SQLFreeHandle(SQL_HANDLE_STMT, stmt);

    rcode = SQLAllocHandle(SQL_HANDLE_STMT, hdbc, &stmt);
    ASSERT_CHECK(SQL_HANDLE_STMT, stmt, rcode);

    rcode = SQLExecDirect(stmt, (SQLCHAR*)"INSERT INTO test_tbl1 (id,name,age) VALUES  (1,'Tom', 18),(2,'Jerry', 20),(3,'Bob', 22)", SQL_NTS);
    ASSERT_CHECK(SQL_HANDLE_STMT, stmt, rcode);

    SQLFreeHandle(SQL_HANDLE_STMT, stmt);

    rcode = SQLAllocHandle(SQL_HANDLE_STMT, hdbc, &stmt);
    ASSERT_CHECK(SQL_HANDLE_STMT, stmt, rcode);

    rcode = SQLExecDirect(stmt, (SQLCHAR*)"SELECT * FROM test_tbl1", SQL_NTS);
    ASSERT_CHECK(SQL_HANDLE_STMT, stmt, rcode);

    SQLLEN res = SQL_NTS;
    SQLINTEGER id, age;
    SQLCHAR name[255];
    SQLBindCol(stmt, 1, SQL_C_SLONG, &id, sizeof(id), &res);
    SQLBindCol(stmt, 2, SQL_C_CHAR, name, sizeof(name), &res);
    SQLBindCol(stmt, 3, SQL_C_SLONG, &age, sizeof(age), &res);

    while ((rcode = SQLFetch(stmt)) != SQL_NO_DATA_FOUND)
    {
        if (rcode == SQL_ERROR) {
            printf("sql error!\n");
        }
        else {
            printf("id:%d, name:%s, age:%ld\n", id, name, age);
        }
    }

    SQLFreeHandle(SQL_HANDLE_STMT, stmt);

    SQLDisconnect(hdbc);
    SQLFreeHandle(SQL_HANDLE_DBC, hdbc);
    SQLFreeHandle(SQL_HANDLE_ENV, henv);

    return 0;
}

関連ドキュメント

• OB Cloudデータベースへの接続方法の詳細については、接続方法の概要を参照してください。

• OceanBase Connector/ODBCの詳細については、OceanBase Connector/ODBCを参照してください。