DB/SQLite3
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;
}Contents
소중한 공감 감사합니다