ডেটাবেস থেকে ডেটা পড়া এবং লেখা

MuleSoft এ ডেটাবেস ইন্টিগ্রেশন খুবই শক্তিশালী এবং সহজ। মিউলফ্লো (Mule Flow) ব্যবহার করে আপনি বিভিন্ন ডেটাবেস যেমন MySQL, PostgreSQL, Oracle, SQL Server ইত্যাদি থেকে ডেটা পড়তে এবং ডেটা লিখতে পারবেন। মিউলসফটে ডেটাবেস ইন্টিগ্রেশনের জন্য প্রধানত Database Connector ব্যবহার করা হয়।

এই গাইডে আমরা দেখব কিভাবে মিউলফ্লো ব্যবহার করে ডেটাবেস থেকে ডেটা পড়া এবং লিখা যায়।

১. Database Connector ইনস্টল করা

প্রথমে Database Connector ইনস্টল করতে হবে যা ডেটাবেসের সাথে সংযোগ স্থাপন করবে।

Steps:

1. Anypoint Studio ওপেন করুন।
2. Mule Palette থেকে Database Connector টেনে মিউলফ্লো তে ড্র্যাগ করুন।
3. এখন আপনি ডেটাবেসের সাথে সংযোগ স্থাপন করার জন্য কনফিগারেশন সেট করতে পারেন। এটি করার জন্য Database Config নির্বাচন করুন এবং ডেটাবেসের সংযোগ সেটিংস দিন (যেমন JDBC URL, ব্যবহারকারী নাম, পাসওয়ার্ড ইত্যাদি)।

২. ডেটাবেস থেকে ডেটা পড়া (Select Query)

এখন দেখব কিভাবে SQL Select Query ব্যবহার করে ডেটাবেস থেকে ডেটা পড়া যায়।

উদাহরণ: MySQL থেকে ডেটা পড়া

1. Database Config কনফিগারেশন:
   • JDBC URL: jdbc:mysql://localhost:3306/mydb
   • ইউজারনেম: root
   • পাসওয়ার্ড: password
2. SQL Select Query:
   • আপনি Database Select কম্পোনেন্ট ব্যবহার করবেন SQL SELECT কোয়েরি চালানোর জন্য।

<?xml version="1.0" encoding="UTF-8"?>
<mule xmlns:db="http://www.mulesoft.org/schema/mule/db"
      xmlns="http://www.mulesoft.org/schema/mule/core"
      xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
      xsi:schemaLocation="http://www.mulesoft.org/schema/mule/db http://www.mulesoft.org/schema/mule/db/current/mule-db.xsd
                          http://www.mulesoft.org/schema/mule/core http://www.mulesoft.org/schema/mule/core/current/mule-core.xsd">
    
    <flow name="readFromDatabaseFlow">
        <!-- Database Connector Configuration -->
        <db:config name="MySQL_Database_Config" doc:name="Database Config">
            <db:generic-connection url="jdbc:mysql://localhost:3306/mydb" driverClassName="com.mysql.cj.jdbc.Driver" user="root" password="password"/>
        </db:config>
        
        <!-- Execute SQL Select Query to fetch data -->
        <db:select doc:name="Database Select">
            <db:sql>SELECT * FROM users</db:sql>
            <db:output-metadata>
                <db:output-metadata> 
                    <db:column name="id" />
                    <db:column name="name" />
                    <db:column name="email" />
                </db:output-metadata>
            </db:output-metadata>
        </db:select>
        
        <!-- Logger to output the fetched data -->
        <logger level="INFO" doc:name="Logger" message="Fetched Data: #[payload]" />
    </flow>
</mule>

কোড ব্যাখ্যা:

• Database Config: এখানে আমরা MySQL ডেটাবেসের সংযোগ সেট করেছি।
• db:select: এই কম্পোনেন্টটি SQL Select Query চালাতে ব্যবহৃত হয়। কোয়েরি SELECT * FROM users ডেটাবেসের users টেবিল থেকে সব রেকর্ড নির্বাচন করবে।
• db:output-metadata: এখানে আমরা কলাম নাম ডিফাইন করেছি যা রিকোয়েস্টের আউটপুট হিসেবে পাওয়া যাবে।
• logger: ফেচ করা ডেটা কনসোলে প্রিন্ট করবে।

৩. ডেটাবেসে ডেটা লেখা (Insert Query)

এখন দেখব কিভাবে SQL Insert Query ব্যবহার করে ডেটাবেসে নতুন ডেটা লেখা যায়।

উদাহরণ: MySQL এ নতুন ডেটা লেখা

<?xml version="1.0" encoding="UTF-8"?>
<mule xmlns:db="http://www.mulesoft.org/schema/mule/db"
      xmlns="http://www.mulesoft.org/schema/mule/core"
      xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
      xsi:schemaLocation="http://www.mulesoft.org/schema/mule/db http://www.mulesoft.org/schema/mule/db/current/mule-db.xsd
                          http://www.mulesoft.org/schema/mule/core http://www.mulesoft.org/schema/mule/core/current/mule-core.xsd">
    
    <flow name="insertIntoDatabaseFlow">
        <!-- Database Connector Configuration -->
        <db:config name="MySQL_Database_Config" doc:name="Database Config">
            <db:generic-connection url="jdbc:mysql://localhost:3306/mydb" driverClassName="com.mysql.cj.jdbc.Driver" user="root" password="password"/>
        </db:config>
        
        <!-- Insert data into the 'users' table -->
        <db:insert doc:name="Database Insert">
            <db:sql>INSERT INTO users (name, email) VALUES ('John Doe', 'john.doe@example.com')</db:sql>
        </db:insert>
        
        <!-- Logger to confirm insertion -->
        <logger level="INFO" doc:name="Logger" message="Data Inserted Successfully" />
    </flow>
</mule>

কোড ব্যাখ্যা:

• db:insert: এখানে INSERT INTO users (name, email) SQL কোয়েরি ব্যবহার করা হয়েছে যাতে নতুন ইউজার name এবং email ফিল্ডে ডেটা ইনসার্ট করা যায়।
• logger: ইনসার্ট করা ডেটা সফলভাবে করা হয়েছে কিনা তা কনসোলে লগ করবে।

৪. ডেটাবেস থেকে ডেটা আপডেট করা (Update Query)

ডেটাবেসে বিদ্যমান রেকর্ড আপডেট করতে SQL Update Query ব্যবহার করা হয়।

উদাহরণ: MySQL এ ডেটা আপডেট করা

<?xml version="1.0" encoding="UTF-8"?>
<mule xmlns:db="http://www.mulesoft.org/schema/mule/db"
      xmlns="http://www.mulesoft.org/schema/mule/core"
      xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
      xsi:schemaLocation="http://www.mulesoft.org/schema/mule/db http://www.mulesoft.org/schema/mule/db/current/mule-db.xsd
                          http://www.mulesoft.org/schema/mule/core http://www.mulesoft.org/schema/mule/core/current/mule-core.xsd">
    
    <flow name="updateDatabaseFlow">
        <!-- Database Connector Configuration -->
        <db:config name="MySQL_Database_Config" doc:name="Database Config">
            <db:generic-connection url="jdbc:mysql://localhost:3306/mydb" driverClassName="com.mysql.cj.jdbc.Driver" user="root" password="password"/>
        </db:config>
        
        <!-- Update data in the 'users' table -->
        <db:update doc:name="Database Update">
            <db:sql>UPDATE users SET name = 'Jane Doe' WHERE id = 1</db:sql>
        </db:update>
        
        <!-- Logger to confirm update -->
        <logger level="INFO" doc:name="Logger" message="Data Updated Successfully" />
    </flow>
</mule>

কোড ব্যাখ্যা:

• db:update: এখানে UPDATE users SET name = 'Jane Doe' WHERE id = 1 SQL কোয়েরি ব্যবহার করা হয়েছে যা id = 1 ইউজারের নাম পরিবর্তন করবে।
• logger: ডেটা আপডেট সফল হলে কনসোলে একটি বার্তা দেখাবে।

৫. ডেটাবেস থেকে ডেটা মুছা (Delete Query)

ডেটাবেসে রেকর্ড মুছে ফেলতে SQL Delete Query ব্যবহার করা হয়।

উদাহরণ: MySQL থেকে ডেটা মুছা

<?xml version="1.0" encoding="UTF-8"?>
<mule xmlns:db="http://www.mulesoft.org/schema/mule/db"
      xmlns="http://www.mulesoft.org/schema/mule/core"
      xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
      xsi:schemaLocation="http://www.mulesoft.org/schema/mule/db http://www.mulesoft.org/schema/mule/db/current/mule-db.xsd
                          http://www.mulesoft.org/schema/mule/core http://www.mulesoft.org/schema/mule/core/current/mule-core.xsd">
    
    <flow name="deleteFromDatabaseFlow">
        <!-- Database Connector Configuration -->
        <db:config name="MySQL_Database_Config" doc:name="Database Config">
            <db:generic-connection url="jdbc:mysql://localhost:3306/mydb" driverClassName="com.mysql.cj.jdbc.Driver" user="root" password="password"/>
        </db:config>
        
        <!-- Delete data from the 'users' table -->
        <db:delete doc:name="Database Delete">
            <db:sql>DELETE FROM users WHERE id = 2</db:sql>
        </db:delete>
        
        <!-- Logger to confirm deletion -->
        <logger level="INFO" doc:name="Logger" message="Data Deleted Successfully"