SQLite, C, CRUD 예제 첨삭

 

 

코드 테스트 못함

아픔

아마 맞을꺼임

아래 SQLite C Library 코드 이해하고, C++ 에서 사용하면 됨

 

1. Open

▶️ SQLite DB 연결

 

#include <stdio.h>

// sqlite3 라이브러리 추가
#include <sqlite3.h> 


int main(int argc, char* argv[]) {
	// DB 핸들로 사용
   sqlite3 *db;
   // 에러 메시지로 사용
   char *zErrMsg = 0;
   // sqlite3_open() 함수의 반환값을 저장할 때 사용
   int rc;

	// sqlite3_open() 으로 sqlite3 DB 연결
   rc = sqlite3_open("test.db", &db);

	// sqlite3 DB 연결 실패라면 에러 메시지를 띄우고 함수 종료
   if( rc ) 
   {
      fprintf(stderr, "Can't open database: %s\n", sqlite3_errmsg(db));
      return(0);
   } 
   // sqlite3 DB 연결 성공면 함수 정상 종료
   else 
   {
      fprintf(stderr, "Opened database successfully\n");
   }
   
   // sqlite3 DB 연결을 닫습니다.
   sqlite3_close(db);
}

 

 

 

2. Create 

▶️ 테이블 생성

 

#include <stdio.h>
#include <stdlib.h>
// sqlite3 라이브러리 추가
#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[]) {
	// DB 핸들로 사용
   sqlite3 *db;
   // 에러 메시지로 사용
   char *zErrMsg = 0;
   // sqlite3_open() 함수의 반환값을 저장할 때 사용
   int rc;
   // 쿼리문을 가르키는 포인터
   char *sql;

	// sqlite3_open() 으로 sqlite3 DB 연결
   rc = sqlite3_open("test.db", &db);
   
	// sqlite3 DB 연결 실패라면 에러 메시지를 띄우고 함수 종료
   if( rc ) 
   {
      fprintf(stderr, "Can't open database: %s\n", sqlite3_errmsg(db));
      return(0);
   } 
   // sqlite3 DB 연결 성공면 함수 정상 종료
   else 
   {
      fprintf(stdout, "Opened database successfully\n");
   }

   /* Create Table 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 */
   // sqlite3에 쿼리 실행 요청
   rc = sqlite3_exec(db, sql, callback, 0, &zErrMsg);
   
   // sqlite3 쿼리 실패하면 종료
   if( rc != SQLITE_OK )
   {
      fprintf(stderr, "SQL error: %s\n", zErrMsg);
      sqlite3_free(zErrMsg);
   } 
   // sqlite3 쿼리 성공하면 SQLITE_OK 반환 함수 정상 종료
   else 
   {
      fprintf(stdout, "Table created successfully\n");
   }
   sqlite3_close(db);
   return 0;
}

 

 

3. Create

▶️ 테이블에 데이터 추가

 

#include <stdio.h>
#include <stdlib.h>
// sqlite3 라이브러리 추가
#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[]) {
	// DB 핸들로 사용
   sqlite3 *db;
   // 에러 메시지로 사용
   char *zErrMsg = 0;
   // sqlite3_open() 함수의 반환값을 저장할 때 사용
   int rc;
   // 쿼리문을 가르키는 포인터
   char *sql;


	// sqlite3_open() 으로 sqlite3 DB 연결
   rc = sqlite3_open("test.db", &db);
   
	// sqlite3 DB 연결 실패라면 에러 메시지를 띄우고 함수 종료
   if( rc ) 
   {
      fprintf(stderr, "Can't open database: %s\n", sqlite3_errmsg(db));
      return(0);
   } 
   // sqlite3 DB 연결 성공면 함수 정상 종료
   else 
   {
      fprintf(stdout, "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 */
   // sqlite3에 쿼리 실행 요청
   rc = sqlite3_exec(db, sql, callback, 0, &zErrMsg);
   
   // sqlite3 쿼리 실패하면 종료
   if( rc != SQLITE_OK )
   {
      fprintf(stderr, "SQL error: %s\n", zErrMsg);
      sqlite3_free(zErrMsg);
   } 
   // sqlite3 쿼리 성공하면 SQLITE_OK 반환 함수 정상 종료
   else 
   {
      fprintf(stdout, "Table created successfully\n");
   }
   // sqlite3 DB 연결을 닫습니다.
   sqlite3_close(db);
   return 0;
}

 

 

4. Read

▶️ 테이블 데이터 읽어오기

 

#include <stdio.h>
#include <stdlib.h>
// sqlite3 라이브러리 추가
#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[]) {
	// DB 핸들로 사용
   sqlite3 *db;
   // 에러 메시지로 사용
   char *zErrMsg = 0;
   // sqlite3_open() 함수의 반환값을 저장할 때 사용
   int rc;
   // 쿼리문을 가르키는 포인터
   char *sql;

	// sqlite3_open() 으로 sqlite3 DB 연결
   rc = sqlite3_open("test.db", &db);
   
	// sqlite3 DB 연결 실패라면 에러 메시지를 띄우고 함수 종료
   if( rc ) 
   {
      fprintf(stderr, "Can't open database: %s\n", sqlite3_errmsg(db));
      return(0);
   } 
   // sqlite3 DB 연결 성공면 함수 정상 종료
   else 
   {
      fprintf(stdout, "Opened database successfully\n");
   }



   /* Execute SQL statement */
   // sqlite3에 쿼리 실행 요청
   rc = sqlite3_exec(db, sql, callback, 0, &zErrMsg);
   
   // sqlite3 쿼리 실패하면 종료
   if( rc != SQLITE_OK )
   {
      fprintf(stderr, "SQL error: %s\n", zErrMsg);
      sqlite3_free(zErrMsg);
   } 
   // sqlite3 쿼리 성공하면 SQLITE_OK 반환 함수 정상 종료
   else 
   {
      fprintf(stdout, "Table created successfully\n");
   }
   // sqlite3 DB 연결을 닫습니다.
   sqlite3_close(db);
   
   return 0;
}

 

 

5. Update

▶️  테이블 데이터 수정

 

#include <stdio.h>
#include <stdlib.h>
// sqlite3 라이브러리 추가
#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[]) {
	// DB 핸들로 사용
   sqlite3 *db;
   // 에러 메시지로 사용
   char *zErrMsg = 0;
   // sqlite3_open() 함수의 반환값을 저장할 때 사용
   int rc;
   // 쿼리문을 가르키는 포인터
   char *sql;

	// sqlite3_open() 으로 sqlite3 DB 연결
   rc = sqlite3_open("test.db", &db);
   
	// sqlite3 DB 연결 실패라면 에러 메시지를 띄우고 함수 종료
   if( rc ) 
   {
      fprintf(stderr, "Can't open database: %s\n", sqlite3_errmsg(db));
      return(0);
   } 
   // sqlite3 DB 연결 성공면 함수 정상 종료
   else 
   {
      fprintf(stdout, "Opened database successfully\n");
   }


   /* Create merged SQL statement */
   // 테이블 데이터 수정 쿼리 준비 + 수정 후 조회
   sql = "UPDATE COMPANY set SALARY = 25000.00 where ID=1; " \
         "SELECT * from COMPANY";

  /* Execute SQL statement */
   // sqlite3에 쿼리 실행 요청
   rc = sqlite3_exec(db, sql, callback, 0, &zErrMsg);
   
   // sqlite3 쿼리 실패하면 종료
   if( rc != SQLITE_OK )
   {
      fprintf(stderr, "SQL error: %s\n", zErrMsg);
      sqlite3_free(zErrMsg);
   } 
   // sqlite3 쿼리 성공하면 SQLITE_OK 반환 함수 정상 종료
   else 
   {
      fprintf(stdout, "Table created successfully\n");
   }
   // sqlite3 DB 연결을 닫습니다.
   sqlite3_close(db);
   
   return 0;
}

 

 

6. Delete

▶️ 테이블 데이터 삭제

 

#include <stdio.h>
#include <stdlib.h>
// sqlite3 라이브러리 추가
#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[]) {
	// DB 핸들로 사용
   sqlite3 *db;
   // 에러 메시지로 사용
   char *zErrMsg = 0;
   // sqlite3_open() 함수의 반환값을 저장할 때 사용
   int rc;
   // 쿼리문을 가르키는 포인터
   char *sql;

	// sqlite3_open() 으로 sqlite3 DB 연결
   rc = sqlite3_open("test.db", &db);
   
	// sqlite3 DB 연결 실패라면 에러 메시지를 띄우고 함수 종료
   if( rc ) 
   {
      fprintf(stderr, "Can't open database: %s\n", sqlite3_errmsg(db));
      return(0);
   } 
   // sqlite3 DB 연결 성공면 함수 정상 종료
   else 
   {
      fprintf(stdout, "Opened database successfully\n");
   }
   

   /* Create merged SQL statement */
   // 테이블 데이터 삭제 쿼리 준비 + 테이블 데이터 조회
   sql = "DELETE from COMPANY where ID=2; " \
         "SELECT * from COMPANY";


   /* Execute SQL statement */
   // sqlite3에 쿼리 실행 요청
   rc = sqlite3_exec(db, sql, callback, 0, &zErrMsg);
   
   // sqlite3 쿼리 실패하면 종료
   if( rc != SQLITE_OK )
   {
      fprintf(stderr, "SQL error: %s\n", zErrMsg);
      sqlite3_free(zErrMsg);
   } 
   // sqlite3 쿼리 성공하면 SQLITE_OK 반환 함수 정상 종료
   else 
   {
      fprintf(stdout, "Table created successfully\n");
   }
   // sqlite3 DB 연결을 닫습니다.
   sqlite3_close(db);
   
   return 0;
}