CQL (Cassandra Query Language) হলো Apache Cassandra ডেটাবেসে ডেটা পরিচালনা করার জন্য ব্যবহৃত একটি উচ্চ স্তরের কুয়েরি ভাষা। CQL মূলত SQL এর মতো দেখতে হলেও, এটি Cassandra এর ডিস্ট্রিবিউটেড আর্কিটেকচারের জন্য বিশেষভাবে ডিজাইন করা হয়েছে। CQL ব্যবহার করে ডেটা টেবিল থেকে SELECT, INSERT, UPDATE, এবং DELETE করা যায়।
এখানে আমরা CQL এর মাধ্যমে ডেটা কুয়েরি করার কিছু প্রধান কমান্ড এবং তাদের ব্যবহার দেখব।
1. SELECT (ডেটা নির্বাচন করা)
SELECT কমান্ড ব্যবহার করে Cassandra টেবিল থেকে ডেটা নির্বাচন করা হয়। CQL-এ SELECT কুয়েরি ব্যবহার করে আমরা টেবিলের কলামগুলির মান বের করতে পারি।
Syntax:
SELECT <columns> FROM <keyspace_name>.<table_name> WHERE <conditions>;
- : আপনি যে কলামগুলো দেখতে চান, সেগুলি উল্লেখ করতে পারেন। যদি সমস্ত কলাম দেখতে চান, তবে
*ব্যবহার করুন। - <keyspace_name>: Keyspace এর নাম।
- <table_name>: টেবিলের নাম।
- : WHERE ক্লজ ব্যবহার করে আপনি কন্ডিশন নির্ধারণ করতে পারেন।
উদাহরণ:
SELECT * FROM ecommerce.users WHERE age > 25;
এটি users টেবিল থেকে সমস্ত তথ্য নির্বাচন করবে যেখানে age ২৫ এর বেশি।
উদাহরণ 2: নির্দিষ্ট কলাম নির্বাচন করা:
SELECT username, email FROM ecommerce.users WHERE user_id = 12345;
এটি users টেবিল থেকে user_id = 12345 এর জন্য username এবং email কলামগুলি নির্বাচন করবে।
2. INSERT (ডেটা ইনসার্ট করা)
INSERT INTO কমান্ড ব্যবহার করে Cassandra টেবিলে নতুন ডেটা যোগ করা হয়। Cassandra তে ডেটা ইনসার্ট করার সময়, প্রতিটি কলামের মান সঠিকভাবে প্রদান করা হয়।
Syntax:
INSERT INTO <keyspace_name>.<table_name> (<columns>) VALUES (<values>);
- : আপনি যে কলামগুলিতে ডেটা ইনসার্ট করতে চান।
- : সেই কলামগুলির জন্য মান।
উদাহরণ:
INSERT INTO ecommerce.users (user_id, username, email, age)
VALUES (uuid(), 'john_doe', 'john.doe@example.com', 30);
এটি users টেবিলে একটি নতুন রেকর্ড ইনসার্ট করবে, যেখানে user_id একটি নতুন UUID হবে, এবং অন্যান্য কলামগুলিতে যথাক্রমে username, email, এবং age দেওয়া হবে।
3. UPDATE (ডেটা আপডেট করা)
UPDATE কমান্ড ব্যবহার করে Cassandra-তে বিদ্যমান রেকর্ডের ডেটা আপডেট করা হয়। Cassandra তে UPDATE সাধারণত PRIMARY KEY এর ভিত্তিতে হয়।
Syntax:
UPDATE <keyspace_name>.<table_name> SET <column1> = <value1>, <column2> = <value2> WHERE <primary_key_condition>;
- <primary_key_condition>: এটি PRIMARY KEY এর ভিত্তিতে ডেটা নির্ধারণ করে।
উদাহরণ:
UPDATE ecommerce.users SET age = 31 WHERE user_id = 12345;
এটি users টেবিলে user_id = 12345 এর জন্য age কলামের মান ৩১ এ আপডেট করবে।
4. DELETE (ডেটা মুছে ফেলা)
DELETE কমান্ড ব্যবহার করে Cassandra-তে কোনো রেকর্ড মুছে ফেলা হয়। Cassandra তে DELETE করার সময় আপনাকে অবশ্যই PRIMARY KEY নির্ধারণ করতে হবে, কারণ এটি ডেটা মুছতে সঠিক রো চিহ্নিত করতে সহায়তা করে।
Syntax:
DELETE FROM <keyspace_name>.<table_name> WHERE <primary_key_condition>;
উদাহরণ:
DELETE FROM ecommerce.users WHERE user_id = 12345;
এটি users টেবিল থেকে user_id = 12345 এর জন্য রেকর্ড মুছে ফেলবে।
5. CQL ব্যবহার করার সময় কিছু গুরুত্বপূর্ণ বিষয়
- WHERE ক্লজ: WHERE ক্লজ ব্যবহার করে আপনি ডেটা অনুসন্ধান বা ফিল্টার করতে পারেন। তবে, Cassandra তে শুধুমাত্র Partition Key এর উপর ভিত্তি করে WHERE ক্লজ ব্যবহার করা যেতে পারে। যদি আপনি Clustering Key বা অন্যান্য কলামের উপর ভিত্তি করে ফিল্টার করতে চান, তবে তা Secondary Index ব্যবহার করে করতে হবে।
- Primary Key: Cassandra-তে ডেটা Primary Key ব্যবহার করে পার্টিশন করা হয়। আপনি যে কলামটিকে Primary Key হিসেবে নির্বাচন করেন, সেটি ক্লাস্টারের মধ্যে ডেটাকে পৃথক করবে।
- Batch Operations: Cassandra তে একাধিক INSERT, UPDATE, বা DELETE কমান্ড একসাথে চালানোর জন্য BATCH কমান্ড ব্যবহার করা হয়।
6. Batch Operation উদাহরণ
BATCH কমান্ড ব্যবহার করে একাধিক ডেটা একসাথে ইনসার্ট বা আপডেট করা যায়। এটি ডেটার দ্রুত আপডেট নিশ্চিত করতে সহায়তা করে।
উদাহরণ:
BEGIN BATCH
INSERT INTO ecommerce.users (user_id, username, email, age) VALUES (uuid(), 'alice_smith', 'alice@example.com', 25);
INSERT INTO ecommerce.users (user_id, username, email, age) VALUES (uuid(), 'bob_jones', 'bob@example.com', 29);
APPLY BATCH;
এটি একসাথে দুটি ইনসার্ট অপারেশন করবে এবং দুটি রেকর্ড একসাথে টেবিলে ইনসার্ট হবে।
সারাংশ
CQL (Cassandra Query Language) Cassandra ডেটাবেসের মধ্যে ডেটা পরিচালনার জন্য ব্যবহৃত একটি শক্তিশালী ভাষা। SELECT, INSERT, UPDATE, এবং DELETE কমান্ডের মাধ্যমে Cassandra তে ডেটা নির্বাচন, ইনসার্ট, আপডেট, এবং ডিলিট করা যায়। CQL ব্যবহার করে ডেটাবেসের বিভিন্ন কার্যক্রম পরিচালনা করা সম্ভব, যা Cassandra এর স্কেলেবিলিটি এবং উচ্চ পারফরম্যান্স সুবিধা নিশ্চিত করে।
Read more
