SQLite - C / C ++

W tym rozdziale dowiesz się, jak używać SQLite w programach C / C ++.

Instalacja

Zanim zaczniesz używać SQLite w naszych programach C / C ++, musisz upewnić się, że masz skonfigurowaną bibliotekę SQLite na komputerze. Możesz zapoznać się z rozdziałem Instalacja SQLite, aby zrozumieć proces instalacji.

Interfejsy API C / C ++

Poniżej znajdują się ważne procedury interfejsu C / C ++ SQLite, które mogą wystarczyć do pracy z bazą danych SQLite z poziomu programu C / C ++. Jeśli szukasz bardziej wyrafinowanej aplikacji, możesz zajrzeć do oficjalnej dokumentacji SQLite.

Sr.No.	API i opis
1	sqlite3_open(const char *filename, sqlite3 **ppDb) Ta procedura otwiera połączenie z plikiem bazy danych SQLite i zwraca obiekt połączenia z bazą danych, który ma być używany przez inne procedury SQLite. Jeśli argument filename ma wartość NULL lub ': memory:', sqlite3_open () utworzy bazę danych w pamięci w pamięci RAM, która będzie trwała tylko przez czas trwania sesji. Jeśli nazwa pliku nie jest równa NULL, sqlite3_open () próbuje otworzyć plik bazy danych przy użyciu jego wartości. Jeśli nie istnieje żaden plik o tej nazwie, sqlite3_open () otworzy nowy plik bazy danych o tej nazwie.
2	sqlite3_exec(sqlite3*, const char *sql, sqlite_callback, void *data, char **errmsg) Ta procedura zapewnia szybki i łatwy sposób wykonywania poleceń SQL udostępnianych przez argument sql, który może składać się z więcej niż jednego polecenia SQL. Tutaj pierwszy argument sqlite3 to otwarty obiekt bazy danych, sqlite_callback to wywołanie zwrotne, dla którego dane są pierwszym argumentem, a errmsg zostanie zwrócony w celu wychwycenia każdego błędu wywołanego przez procedurę. Funkcja SQLite3_exec () analizuje i wykonuje każde polecenie podane w sql argument, dopóki nie osiągnie końca ciągu lub napotka błąd.
3	sqlite3_close(sqlite3*) Ta procedura zamyka połączenie z bazą danych, które zostało wcześniej otwarte przez wywołanie funkcji sqlite3_open (). Wszystkie przygotowane zestawienia związane z połączeniem powinny zostać sfinalizowane przed zamknięciem połączenia. Jeśli pozostaną jakieś zapytania, które nie zostały sfinalizowane, sqlite3_close () zwróci SQLITE_BUSY z komunikatem o błędzie Nie można zamknąć z powodu niezakończonych instrukcji.

Połącz się z bazą danych

Poniższy segment kodu C pokazuje, jak połączyć się z istniejącą bazą danych. Jeśli baza danych nie istnieje, to zostanie utworzona i na koniec zostanie zwrócony obiekt bazy danych.

#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);
}

Teraz skompilujmy i uruchommy powyższy program, aby utworzyć naszą bazę danych test.dbw bieżącym katalogu. Możesz zmienić swoją ścieżkę zgodnie z wymaganiami.

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

Jeśli zamierzasz używać kodu źródłowego C ++, możesz skompilować swój kod w następujący sposób -

$g++ test.c -l sqlite3

Tutaj łączymy nasz program z biblioteką sqlite3, aby zapewnić wymagane funkcje programowi C. Spowoduje to utworzenie pliku bazy danych test.db w twoim katalogu i uzyskasz następujący wynik.

-rwxr-xr-x. 1 root root 7383 May 8 02:06 a.out
-rw-r--r--. 1 root root  323 May 8 02:05 test.c
-rw-r--r--. 1 root root    0 May 8 02:06 test.db

Utwórz tabelę

Poniższy segment kodu C zostanie użyty do stworzenia tabeli we wcześniej utworzonej bazie danych -

#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;

   /* Open database */
   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");
   }

   /* Create SQL statement */
   sql = "CREATE TABLE COMPANY("  \
      "ID INT PRIMARY KEY     NOT NULL," \
      "NAME           TEXT    NOT NULL," \
      "AGE            INT     NOT NULL," \
      "ADDRESS        CHAR(50)," \
      "SALARY         REAL );";

   /* Execute SQL statement */
   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;
}

Kiedy powyższy program zostanie skompilowany i wykonany, utworzy tabelę COMPANY w twoim test.db, a ostateczna lista pliku będzie wyglądać następująco -

-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

Operacja INSERT

Poniższy segment kodu C pokazuje, jak można tworzyć rekordy w tabeli COMPANY utworzonej w powyższym przykładzie -

#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;

   /* Open database */
   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");
   }

   /* Create SQL statement */
   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 );";

   /* Execute SQL statement */
   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;
}

Gdy powyższy program zostanie skompilowany i wykonany, utworzy podane rekordy w tabeli COMPANY i wyświetli następujące dwie linie -

Opened database successfully
Records created successfully

Wybierz operację

Zanim przejdziemy do rzeczywistego przykładu pobierania rekordów, przyjrzyjmy się niektórym szczegółom funkcji wywołania zwrotnego, której używamy w naszych przykładach. To wywołanie zwrotne umożliwia uzyskanie wyników z instrukcji SELECT. Ma następującą deklarację -

typedef int (*sqlite3_callback)(
   void*,    /* Data provided in the 4th argument of sqlite3_exec() */
   int,      /* The number of columns in row */
   char**,   /* An array of strings representing fields in the row */
   char**    /* An array of strings representing column names */
);

Jeśli powyższe wywołanie zwrotne zostanie podane w procedurze sqlite_exec () jako trzeci argument, SQLite wywoła tę funkcję zwrotną dla każdego rekordu przetwarzanego w każdej instrukcji SELECT wykonywanej w argumencie SQL.

Poniższy segment kodu C pokazuje, jak można pobrać i wyświetlić rekordy z tabeli COMPANY utworzonej w powyższym przykładzie -

#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";

   /* Open database */
   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");
   }

   /* Create SQL statement */
   sql = "SELECT * from COMPANY";

   /* Execute SQL statement */
   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;
}

Gdy powyższy program zostanie skompilowany i wykonany, da następujący wynik.

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

Operacja UPDATE

Poniższy segment kodu C pokazuje, jak możemy użyć instrukcji UPDATE do zaktualizowania dowolnego rekordu, a następnie pobrać i wyświetlić zaktualizowane rekordy z tabeli 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";

   /* Open database */
   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");
   }

   /* Create merged SQL statement */
   sql = "UPDATE COMPANY set SALARY = 25000.00 where ID=1; " \
         "SELECT * from COMPANY";

   /* Execute SQL statement */
   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;
}

Gdy powyższy program zostanie skompilowany i wykonany, da następujący wynik.

Opened database successfully
Callback function called: ID = 1
NAME = Paul
AGE = 32
ADDRESS = California
SALARY = 25000.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

Operacja USUŃ

Poniższy segment kodu C pokazuje, jak można użyć instrukcji DELETE do usunięcia dowolnego rekordu, a następnie pobrać i wyświetlić pozostałe rekordy z tabeli 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";

   /* Open database */
   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");
   }

   /* Create merged SQL statement */
   sql = "DELETE from COMPANY where ID=2; " \
         "SELECT * from COMPANY";

   /* Execute SQL statement */
   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;
}

Gdy powyższy program zostanie skompilowany i wykonany, da następujący wynik.

Opened database successfully
Callback function called: ID = 1
NAME = Paul
AGE = 32
ADDRESS = California
SALARY = 20000.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