C/C++でSQLiteデータベースに接続する方法【初心者向け完全ガイド】

このセクションでは、C/C++プログラムでSQLiteを使用する方法について学習します。データベース接続の基本から、テーブル作成、レコードの挿入・取得まで、実用的なサンプルコードとともに順を追って解説していきます。

インストール

C/C++プログラムでSQLiteを使い始める前に、マシンにSQLiteライブラリがセットアップされていることを確認する必要があります。インストール手順については、SQLiteのインストールに関する章を参照してください。

C/C++インターフェースAPI

以下は、C/C++プログラムからSQLiteデータベースを操作する際に必要となる重要なインターフェースルーチンです。より高度なアプリケーションを開発したい場合は、SQLiteの公式ドキュメントも併せて参照することをおすすめします。

sqlite3_open(const char *filename, sqlite3 **ppDb)

sqlite3_exec(sqlite3*, const char *sql, sqlite_callback, void *data, char **errmsg)

sqlite3_close(sqlite3*)

データベースへの接続

以下のCコードは、既存のデータベースに接続する方法を示しています。データベースが存在しない場合は新しく作成され、最終的にデータベースオブジェクトが返されます。

サンプルコード

#include <stdio.h>
#include <sqlite3.h>
int main(int argc, char* argv[]) {
    sqlite3 *db;
    char *zErrMsg = 0;
    int rc;
    rc = sqlite3_open("test.db", &db);
    if( rc ) {
        fprintf(stderr, "Can't open database: %s\n", sqlite3_errmsg(db));
        return(0);
    } else {
        fprintf(stderr, "Opened database successfully\n");
    }
    sqlite3_close(db);
}

実行結果

$gcc test.c -l sqlite3
$./a.out
Opened database successfully

テーブルの作成

次のCコードは、先ほど作成したデータベース内にテーブルを作成する例です。CREATE TABLE文をsqlite3_exec()で実行することで、COMPANYテーブルが生成されます。

サンプルコード

#include <stdio.h>
#include <stdlib.h>
#include <sqlite3.h>
static int callback(void *NotUsed, int argc, char **argv, char **azColName) {
    int i;
    for(i = 0; i<argc; i++) {
        printf("%s = %s\n", azColName[i], argv[i] ? argv[i] : "NULL");
    }
    printf("\n");
    return 0;
}
int main(int argc, char* argv[]) {
    sqlite3 *db;
    char *zErrMsg = 0;
    int rc;
    char *sql;
    /* データベースを開く */
    rc = sqlite3_open("test.db", &db);
    if( rc ) {
        fprintf(stderr, "Can't open database: %s\n", sqlite3_errmsg(db));
        return(0);
    } else {
        fprintf(stdout, "Opened database successfully\n");
    }
    /* SQLステートメントを作成 */
    sql = "CREATE TABLE COMPANY(" \
        "ID INT PRIMARY KEY NOT NULL," \
        "NAME TEXT NOT NULL," \
        "AGE INT NOT NULL," \
        "ADDRESS CHAR(50)," \
        "SALARY REAL );";
    /* SQLステートメントを実行 */
    rc = sqlite3_exec(db, sql, callback, 0, &zErrMsg);
    if( rc != SQLITE_OK ) {
        fprintf(stderr, "SQL error: %s\n", zErrMsg);
        sqlite3_free(zErrMsg);
    } else {
        fprintf(stdout, "Table created successfully\n");
    }
    sqlite3_close(db);
    return 0;
}

実行結果（データベースファイルの状態確認）：

-rwxr-xr-x. 1 root root 9567 May 8 02:31 a.out
-rw-r--r--. 1 root root 1207 May 8 02:31 test.c
-rw-r--r--. 1 root root 3072 May 8 02:31 test.db

INSERT操作（レコードの挿入）

次のCコードは、上記の例で作成したCOMPANYテーブルにレコードを挿入する方法を示しています。複数のINSERT文を一度にsqlite3_exec()へ渡して実行できます。

サンプルコード

#include <stdio.h>
#include <stdlib.h>
#include <sqlite3.h>
static int callback(void *NotUsed, int argc, char **argv, char **azColName) {
    int i;
    for(i = 0; i<argc; i++) {
        printf("%s = %s\n", azColName[i], argv[i] ? argv[i] : "NULL");
    }
    printf("\n");
    return 0;
}
int main(int argc, char* argv[]) {
    sqlite3 *db;
    char *zErrMsg = 0;
    int rc;
    char *sql;
    /* データベースを開く */
    rc = sqlite3_open("test.db", &db);
    if( rc ) {
        fprintf(stderr, "Can't open database: %s\n", sqlite3_errmsg(db));
        return(0);
    } else {
        fprintf(stderr, "Opened database successfully\n");
    }
    /* SQLステートメントを作成 */
    sql = "INSERT INTO COMPANY (ID,NAME,AGE,ADDRESS,SALARY) " \
        "VALUES (1, 'Paul', 32, 'California', 20000.00 ); " \
        "INSERT INTO COMPANY (ID,NAME,AGE,ADDRESS,SALARY) " \
        "VALUES (2, 'Allen', 25, 'Texas', 15000.00 ); " \
        "INSERT INTO COMPANY (ID,NAME,AGE,ADDRESS,SALARY)" \
        "VALUES (3, 'Teddy', 23, 'Norway', 20000.00 );" \
        "INSERT INTO COMPANY (ID,NAME,AGE,ADDRESS,SALARY)" \
        "VALUES (4, 'Mark', 25, 'Rich-Mond ', 65000.00 );";
    /* SQLステートメントを実行 */
    rc = sqlite3_exec(db, sql, callback, 0, &zErrMsg);
    if( rc != SQLITE_OK ) {
        fprintf(stderr, "SQL error: %s\n", zErrMsg);
        sqlite3_free(zErrMsg);
    } else {
        fprintf(stdout, "Records created successfully\n");
    }
    sqlite3_close(db);
    return 0;
}

実行結果

Opened database successfully
Records created successfully

SELECT操作（レコードの取得）

実際にレコードを取得する例に進む前に、サンプルで使用しているコールバック関数について詳しく見ておきましょう。このコールバックは、SELECT文の結果を受け取るための仕組みです。宣言は以下の通りです。

typedef int (*sqlite3_callback)(
    void*, /* sqlite3_exec() の第4引数で渡されたデータ */
    int,   /* 行内のカラム数 */
    char**, /* 行内のフィールド値を表す文字列配列 */
    char**  /* カラム名を表す文字列配列 */
);

上記のコールバックをsqlite3_exec()の第3引数として渡すと、SQL引数内で実行される各SELECT文において、処理されるレコードごとにSQLiteがこのコールバック関数を呼び出します。

次のCコードは、上記の例で作成したCOMPANYテーブルからレコードを取得して表示する方法を示しています。

サンプルコード

#include <stdio.h>
#include <stdlib.h>
#include <sqlite3.h>
static int callback(void *data, int argc, char **argv, char **azColName) {
    int i;
    fprintf(stderr, "%s: ", (const char*)data);
    for(i = 0; i<argc; i++) {
        printf("%s = %s\n", azColName[i], argv[i] ? argv[i] : "NULL");
    }
    printf("\n");
    return 0;
}
int main(int argc, char* argv[]) {
    sqlite3 *db;
    char *zErrMsg = 0;
    int rc;
    char *sql;
    const char* data = "Callback function called";
    /* データベースを開く */
    rc = sqlite3_open("test.db", &db);
    if( rc ) {
        fprintf(stderr, "Can't open database: %s\n", sqlite3_errmsg(db));
        return(0);
    } else {
        fprintf(stderr, "Opened database successfully\n");
    }
    /* SQLステートメントを作成 */
    sql = "SELECT * from COMPANY";
    /* SQLステートメントを実行 */
    rc = sqlite3_exec(db, sql, callback, (void*)data, &zErrMsg);
    if( rc != SQLITE_OK ) {
        fprintf(stderr, "SQL error: %s\n", zErrMsg);
        sqlite3_free(zErrMsg);
    } else {
        fprintf(stdout, "Operation done successfully\n");
    }
    sqlite3_close(db);
    return 0;
}

実行結果

Opened database successfully
Callback function called: ID = 1
NAME = Paul
AGE = 32
ADDRESS = California
SALARY = 20000.0
Callback function called: ID = 2
NAME = Allen
AGE = 25
ADDRESS = Texas
SALARY = 15000.0
Callback function called: ID = 3
NAME = Teddy
AGE = 23
ADDRESS = Norway
SALARY = 20000.0
Callback function called: ID = 4
NAME = Mark
AGE = 25
ADDRESS = Rich-Mond
SALARY = 65000.0
Operation done successfully