C/C++를 사용한 데이터베이스 연결

<시간/>

이 섹션에서는 C/C++ 프로그램에서 SQLite를 사용하는 방법을 배웁니다.

설치

C/C++ 프로그램에서 SQLite 사용을 시작하기 전에 머신에 SQLite 라이브러리가 설정되어 있는지 확인해야 합니다. SQLite 설치 장을 확인하여 설치 과정을 이해할 수 있습니다.

C/C++ 인터페이스 API

다음은 중요한 C/C++ SQLite 인터페이스 루틴으로, C/C++ 프로그램에서 SQLite 데이터베이스를 사용하는 데 필요한 요구 사항을 충족할 수 있습니다. 보다 정교한 애플리케이션을 찾고 있다면 SQLite 공식 문서를 살펴볼 수 있습니다.

일련 번호	API 및 설명
1	sqlite3_open(const char filename, sqlite3 ppDb) 이 루틴은 SQLite 데이터베이스 파일에 대한 연결을 열고 다른 SQLite 루틴에서 사용할 데이터베이스 연결 개체를 반환합니다. 파일 이름* 인수가 NULL 또는 ':memory:'인 경우 sqlite3_open()은 세션 기간 동안만 지속되는 메모리 내 데이터베이스를 RAM에 생성합니다. 파일 이름이 NULL이 아닌 경우 sqlite3_open()은 해당 값을 사용하여 데이터베이스 파일을 열려고 시도합니다. 해당 이름의 파일이 없으면 sqlite3_open()은 해당 이름으로 새 데이터베이스 파일을 엽니다.
2	sqlite3_exec(sqlite3, const char sql, sqlite_callback, void data, char *errmsg) 이 루틴은 하나 이상의 SQL 명령으로 구성될 수 있는 sql 인수가 제공하는 SQL 명령을 실행하는 빠르고 쉬운 방법을 제공합니다. 여기에서 첫 번째 인수 sqlite3은 열린 데이터베이스 개체이고 sqlite_callback은 데이터가 첫 번째 인수이고 루틴에서 발생한 오류를 캡처하기 위해 errmsg가 반환되는 콜백입니다. SQLite3_exec() 루틴은 문자열 끝에 도달하거나 오류가 발생할 때까지 sql 인수에 제공된 모든 명령을 구문 분석하고 실행합니다.
3	sqlite3_close(sqlite3*) 이 루틴은 sqlite3_open() 호출에 의해 이전에 열린 데이터베이스 연결을 닫습니다. 연결과 관련된 모든 준비된 명령문은 연결을 닫기 전에 완료되어야 합니다. 완료되지 않은 쿼리가 남아 있으면 sqlite3_close()는 완료되지 않은 명령문으로 인해 닫을 수 없다는 오류 메시지와 함께 SQLITE_BUSY를 반환합니다.

데이터베이스에 연결

다음 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 코드 세그먼트는 이전에 생성된 데이터베이스에 테이블을 생성하는 데 사용됩니다 -

예시 코드

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

출력(데이터베이스 파일 상태 확인):

-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

삽입 작업

다음 C 코드 세그먼트는 위의 예에서 생성된 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;
   /* 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;
}

출력

Opened database successfully
Records created successfully

작업 선택

레코드를 가져오는 실제 예제를 진행하기 전에 예제에서 사용하는 콜백 함수에 대한 세부 정보를 살펴보겠습니다. 이 콜백은 SELECT 문에서 결과를 얻는 방법을 제공합니다. 다음 선언이 있습니다. –

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 */
);

위의 콜백이 sqlite_exec() 루틴에서 세 번째 인수로 제공되면 SQLite는 SQL 인수 내에서 실행되는 각 SELECT 문에서 처리되는 각 레코드에 대해 이 콜백 함수를 호출합니다.

다음 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";
   /* 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;
}

출력

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