SQLite C/C++ প্রোগ্রামিং – sqlite3_open, exec, close, callback (বাংলা টিউটোরিয়াল)

SQLite C/C++ প্রোগ্রামিং – sqlite3_open, exec, close, callback (বাংলা টিউটোরিয়াল) Detail Page

SQLite-কে শুধু কমান্ড-লাইন নয়, আপনার নিজের সি বা সি++ প্রোগ্রামের ভিতরেও ব্যবহার করতে পারেন। এটি করার জন্য SQLite একটি সহজ C API সরবরাহ করে, যার মাধ্যমে আপনি ডাটাবেস ফাইল তৈরি, টেবিল তৈরি, ডেটা ইনসার্ট, আপডেট, ডিলিট এবং কোয়েরি করতে পারবেন। এই পর্বে আমরা ধাপে ধাপে শিখব কীভাবে একটি C প্রোগ্রামে SQLite লাইব্রেরি যুক্ত করতে হয়, প্রয়োজনীয় ফাংশনগুলো ব্যবহার করে ডাটাবেস অপারেশন চালাতে হয়, এবং callback ফাংশনের মাধ্যমে SELECT-এর ফলাফল হ্যান্ডেল করতে হয়।

পূর্বপ্রস্তুতি

আপনার সিস্টেমে SQLite3 লাইব্রেরি ইন্সটল থাকতে হবে। উবুন্টু/ডেবিয়ানে sudo apt install libsqlite3-dev, ফেডোরায় sudo dnf install sqlite-devel, উইন্ডোজে SQLite ডাউনলোড পেজ থেকে বাইনারি ও হেডার সংগ্রহ করুন।
C কম্পাইলার (gcc) বা C++ কম্পাইলার (g++) থাকতে হবে।
সাধারণ C প্রোগ্রামিং জ্ঞান (ফাংশন, পয়েন্টার) থাকলে বুঝতে সুবিধা হবে।

ইন্সটল চেক করতে:

bash

gcc --version
sqlite3 --version

১. C/C++ API মূল ফাংশন

SQLite C API-এর তিনটি প্রধান ফাংশন হলো:

sqlite3_open(const char *filename, sqlite3 **ppDb)
একটি ডাটাবেস ফাইল খোলে (বা তৈরি করে) এবং একটি ডাটাবেস সংযোগ অবজেক্ট রিটার্ন করে। ফাইলের নাম NULL বা ":memory:" দিলে ইন-মেমোরি ডাটাবেস তৈরি হবে, যা শুধুমাত্র সেশন চলাকালে স্থায়ী।
sqlite3_exec(sqlite3*, const char *sql, sqlite3_callback, void *data, char **errmsg)
এক বা একাধিক SQL স্টেটমেন্ট এক্সিকিউট করার সহজ উপায়। এর মাধ্যমে আমরা CREATE, INSERT, UPDATE, DELETE, SELECT ইত্যাদি চালাতে পারি। SELECT-এর ফলাফল পেতে তৃতীয় আর্গুমেন্টে একটি callback ফাংশন দিতে হয়, যা প্রতিটি রেকর্ডের জন্য ডাকা হবে। শেষ আর্গুমেন্ট error মেসেজ ধরে রাখে।
sqlite3_close(sqlite3*)
পূর্বে খোলা ডাটাবেস সংযোগ বন্ধ করে। বন্ধ করার আগে সমস্ত প্রস্তুতকৃত স্টেটমেন্ট ফাইনালাইজ করতে হবে, নয়তো SQLITE_BUSY রিটার্ন করবে।

২. ডাটাবেসে সংযোগ

নিচের কোডটি test.db নামে একটি ডাটাবেস খোলে (যদি না থাকে তবে তৈরি করে) এবং সফল হলে মেসেজ দেখিয়ে বন্ধ করে।

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

কম্পাইল ও চালান:

bash

gcc test.c -l sqlite3
./a.out

আউটপুট: Opened database successfully

এখন আপনার ডিরেক্টরিতে test.db ফাইল তৈরি হবে। -l sqlite3 ফ্ল্যাগ sqlite3 লাইব্রেরি লিঙ্ক করে। C++ হলে g++ ব্যবহার করুন, কমান্ড একই।

৩. টেবিল তৈরি

একটি callback ফাংশন ডিফাইন করে sqlite3_exec-এর মাধ্যমে CREATE TABLE চালাই।

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

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

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

কম্পাইল ও চালালে test.db-তে COMPANY টেবিল তৈরি হবে। callback ফাংশন এখানে শুধু প্রিন্ট করবে (যদি কোনো আউটপুট থাকে), কিন্তু CREATE TABLE কোনো রেকর্ড রিটার্ন করে না, তাই callback ডাকা হবে না।

৪. INSERT অপারেশন

একাধিক INSERT একত্রে চালানো যায়, সেমিকোলন দিয়ে পৃথক করে।

#include <stdio.h>
#include <stdlib.h>
#include <sqlite3.h>

static int callback(void *NotUsed, int argc, char **argv, char **azColName) {
   for(int 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);
   }

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

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

এটি COMPANY টেবিলে চারটি রেকর্ড যোগ করবে।

৫. SELECT অপারেশন ও callback ফাংশন

SELECT স্টেটমেন্টের ফলাফল পেতে callback ফাংশন ব্যবহার বাধ্যতামূলক। SQLite প্রতিটি রেকর্ডের জন্য এই callback কল করে। নিচের উদাহরণে আমরা SELECT * FROM COMPANY চালাই এবং প্রতিটি সারির কলাম ও মান প্রিন্ট করি।

#include <stdio.h>
#include <stdlib.h>
#include <sqlite3.h>

static int callback(void *data, int argc, char **argv, char **azColName) {
   fprintf(stderr, "%s: ", (const char*)data);
   for(int 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);
   }

   sql = "SELECT * from COMPANY";
   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;
}

আউটপুট:

text

Callback function called: ID = 1
NAME = Paul
AGE = 32
ADDRESS = California
SALARY = 20000.0
...

callback ফাংশনের প্যারামিটার:

void *data: user-defined ডাটা, যা sqlite3_exec-এর চতুর্থ আর্গুমেন্ট থেকে আসে।
int argc: ওই সারিতে কলাম সংখ্যা।
char **argv: কলামগুলোর মান (স্ট্রিং)।
char **azColName: কলামগুলোর নাম।

callback ফাংশন 0 রিটার্ন করলে পরবর্তী সারির জন্য আবার ডাকা হয়; অশূন্য রিটার্ন করলে প্রক্রিয়া বন্ধ হয়।

৬. UPDATE ও DELETE অপারেশন

আপডেট ও ডিলিট অপারেশনও sqlite3_exec দিয়েই সম্পন্ন হয়। নিচের উদাহরণে UPDATE এবং সাথে সাথে SELECT দেখানো হয়েছে।

// UPDATE
sql = "UPDATE COMPANY set SALARY = 25000.00 where ID=1; "
      "SELECT * from COMPANY";
rc = sqlite3_exec(db, sql, callback, (void*)data, &zErrMsg);

// DELETE
sql = "DELETE from COMPANY where ID=2; "
      "SELECT * from COMPANY";
rc = sqlite3_exec(db, sql, callback, (void*)data, &zErrMsg);

একই কাঠামো ব্যবহার করে আপনি জটিল SQL চালাতে পারবেন। error হ্যান্ডেলিং-এ sqlite3_free(zErrMsg) করতে ভুলবেন না, নাহলে মেমরি লিক হতে পারে।

৭. ডিরেক্টরি স্ট্রাকচার ও ফাইল

আপনার প্রজেক্ট ফোল্ডারে নিম্নোক্ত ফাইলগুলো থাকবে:

text

project-folder/
├── test.c        (C সোর্স ফাইল)
├── a.out         (কম্পাইল্ড এক্সিকিউটেবল)
└── test.db       (SQLite ডাটাবেস ফাইল)

প্রয়োজনীয় প্যাকেজ:

উবুন্টু/ডেবিয়ান: libsqlite3-dev
ফেডোরা: sqlite-devel
উইন্ডোজ: SQLite ডাউনলোড থেকে sqlite3.h, sqlite3.dll, sqlite3.def সংগ্রহ করে MinGW বা Visual Studio প্রজেক্টে সংযুক্ত করুন।

কম্পাইল কমান্ড: gcc -o myapp test.c -lsqlite3

৮. গুরুত্বপূর্ণ টিপস

কলব্যাক ছাড়া SELECT: কেবলমাত্র INSERT/UPDATE/DELETE-র জন্য callback NULL দেওয়া যায়; SELECT-র জন্য callback দিতেই হবে। যদি callback না দেন, তবে SELECT-এর ফলাফল পাবেন না, কিন্তু প্রোগ্রাম চলবে।
মেমরি ম্যানেজমেন্ট: sqlite3_exec-এ error পেলে zErrMsg কে sqlite3_free() দিয়ে ফ্রি করতে হবে।
প্রিপেয়ার্ড স্টেটমেন্ট: প্যারামিটারাইজড কোয়েরির জন্য sqlite3_prepare_v2, sqlite3_bind_*, sqlite3_step ব্যবহার করতে পারেন, যা SQL Injection প্রতিরোধ করে। আমরা শুধু প্রাথমিক API কভার করেছি।
স্ট্রিং কনক্যাটেনেশন: C-তে SQL স্ট্রিং বানাতে "..." ও "..." পাশাপাশি লিখে জোড়া যায় (উপরের উদাহরণের মতো), এটি কম্পাইল টাইমে এক হয়ে যায়।
একাধিক কমান্ড: সেমিকোলন দিয়ে একাধিক SQL কমান্ড একসাথে চালানো যায়, যেমন INSERT একাধিক। তবে প্রতিটি স্টেটমেন্টের সাফল্য আলাদা; একটি ব্যর্থ হলে sqlite3_exec থেমে যাবে।
রিটার্ন কোড চেক: সবসময় rc != SQLITE_OK চেক করে error হ্যান্ডেল করুন। SQLITE_OK-র মান 0।

৯. সম্পূর্ণ অনুশীলন

উপরের কোডগুলো একটি ফাইলে ক্রমান্বয়ে লিখে পরীক্ষা করে দেখতে পারেন। নিচে একটি পূর্ণাঙ্গ প্রোগ্রামের স্কেলিটন দেওয়া হলো যা টেবিল তৈরি, ডেটা ঢোকানো, সিলেক্ট, আপডেট ও ডিলিট করে:

#include <stdio.h>
#include <sqlite3.h>

static int callback(void *data, int argc, char **argv, char **azColName) {
    for (int i = 0; i < argc; i++) {
        printf("%s = %s\n", azColName[i], argv[i] ? argv[i] : "NULL");
    }
    printf("\n");
    return 0;
}

int main() {
    sqlite3 *db;
    char *errMsg = 0;
    int rc = sqlite3_open("test.db", &db);
    if (rc) {
        fprintf(stderr, "Can't open database: %s\n", sqlite3_errmsg(db));
        return 1;
    }

    // Create table
    const char *sql_create = "CREATE TABLE IF NOT EXISTS COMPANY(...);";
    rc = sqlite3_exec(db, sql_create, NULL, 0, &errMsg);
    // Handle error...

    // Insert
    const char *sql_insert = "INSERT INTO COMPANY ...";
    rc = sqlite3_exec(db, sql_insert, NULL, 0, &errMsg);

    // Select
    const char *sql_select = "SELECT * FROM COMPANY;";
    rc = sqlite3_exec(db, sql_select, callback, 0, &errMsg);

    sqlite3_close(db);
    return 0;
}

পরবর্তী পর্বে

আমরা শিখব SQLite জাভা প্রোগ্রামিং – জাভা প্রোগ্রামে JDBC বা Android-এ SQLite ব্যবহারের পদ্ধতি।

লেখকের কথা: C/C++ দিয়ে SQLite-কে নিজের অ্যাপ্লিকেশনে জুড়ে দেওয়া এখন আর কঠিন নয়। বাংলায় এই টিউটোরিয়াল সিরিজ এগিয়ে নিতে আপনার মূল্যবান মতামত ও শেয়ার আমাদের উৎসাহিত করে। পোস্টটি ভালো লাগলে বন্ধুদের জানাতে ভুলবেন না! সম্পূর্ণ সিরিজের আপডেট পেতে ToLearnTeam.com সাবস্ক্রাইব করুন। কোনো প্রশ্ন থাকলে কমেন্টে জানান – আমরা উত্তর দিতে প্রস্তুত!