উদাহরণ সহ Spring JDBC এর মাধ্যমে ডেটাবেস অপারেশন (CRUD)

Spring JDBC এবং Database Integration - স্প্রিং (Spring) - Java Technologies

354

Spring JDBC স্প্রিং ফ্রেমওয়ার্কের একটি অংশ, যা ডেটাবেস অপারেশনগুলি (CRUD – Create, Read, Update, Delete) সহজ এবং কার্যকরীভাবে পরিচালনা করতে সহায়তা করে। এটি JDBC (Java Database Connectivity) ব্যবহারের উপর ভিত্তি করে তৈরি, তবে Spring JDBC তে প্রচলিত JDBC API ব্যবহার করার সময় অনেক জটিলতা হ্রাস পায় এবং কোড আরও পরিষ্কার, মডুলার এবং সহজ হয়ে ওঠে। স্প্রিং JDBC সহজ এবং নিরাপদভাবে ডেটাবেস অপারেশন পরিচালনার জন্য JdbcTemplate ক্লাস সরবরাহ করে।

এই টিউটোরিয়ালে, আমরা Spring JDBC ব্যবহার করে CRUD অপারেশন (ডেটাবেসে রেকর্ড তৈরি, পড়া, আপডেট এবং মুছা) সম্পাদন করব।

Spring JDBC এর প্রয়োজনীয়তা

  1. JdbcTemplate ব্যবহার করে ডেটাবেসের সঙ্গে ইন্টারঅ্যাকশন করা সহজ হয়।
  2. SQLException এর মতো চ্যালেঞ্জিং এক্সেপশন হ্যান্ডলিং সরলীকৃত হয়।
  3. Transaction management স্প্রিং ফ্রেমওয়ার্কে সহজভাবে করা যায়।
  4. কোডের cleanliness এবং modularity বৃদ্ধি পায়।
  5. SQL injection প্রতিরোধে সাহায্য করে।

Spring JDBC এর মাধ্যমে CRUD অপারেশন

স্প্রিং JDBC ব্যবহার করে ডেটাবেসের সঙ্গে ইন্টারঅ্যাক্ট করার জন্য JdbcTemplate ক্লাস একটি গুরুত্বপূর্ণ উপাদান। এটি ডেটাবেস থেকে তথ্য পড়া, নতুন তথ্য ইনসার্ট করা, পুরোনো তথ্য আপডেট করা এবং তথ্য মুছে ফেলা সহজ করে তোলে।

১. স্প্রিং JDBC কনফিগারেশন

প্রথমে, স্প্রিং কনফিগারেশন তৈরি করতে হবে যাতে DataSource, JdbcTemplate ইত্যাদি কনফিগার করা যায়।

স্প্রিং কনফিগারেশন উদাহরণ:

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.datasource.DriverManagerDataSource;
import javax.sql.DataSource;

@Configuration
public class AppConfig {

    @Bean
    public DataSource dataSource() {
        DriverManagerDataSource dataSource = new DriverManagerDataSource();
        dataSource.setDriverClassName("com.mysql.cj.jdbc.Driver");
        dataSource.setUrl("jdbc:mysql://localhost:3306/mydb");
        dataSource.setUsername("root");
        dataSource.setPassword("password");
        return dataSource;
    }

    @Bean
    public JdbcTemplate jdbcTemplate() {
        return new JdbcTemplate(dataSource());
    }
}

এখানে, DriverManagerDataSource ব্যবহার করে ডেটাবেসের কানেকশন তৈরি করা হয়েছে এবং JdbcTemplate তৈরি করা হয়েছে, যা ডেটাবেস অপারেশন পরিচালনা করবে।


২. CRUD অপারেশন উদাহরণ

স্প্রিং JDBC ব্যবহার করে আমরা CRUD (Create, Read, Update, Delete) অপারেশনগুলি সম্পাদন করতে পারি। নিচে প্রতিটি অপারেশনের উদাহরণ দেয়া হলো।

১. Create (Insert) Operation

import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Repository;

@Repository
public class EmployeeDAO {

    private final JdbcTemplate jdbcTemplate;

    public EmployeeDAO(JdbcTemplate jdbcTemplate) {
        this.jdbcTemplate = jdbcTemplate;
    }

    public int createEmployee(String name, int age, String department) {
        String sql = "INSERT INTO employees (name, age, department) VALUES (?, ?, ?)";
        return jdbcTemplate.update(sql, name, age, department);
    }
}

এখানে, JdbcTemplate.update() মেথড ব্যবহার করা হয়েছে INSERT অপারেশন চালানোর জন্য। এটি সফল হলে প্রভাবিত রেকর্ডের সংখ্যা রিটার্ন করে।

২. Read (Select) Operation

import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.RowMapper;
import org.springframework.stereotype.Repository;
import java.util.List;

@Repository
public class EmployeeDAO {

    private final JdbcTemplate jdbcTemplate;

    public EmployeeDAO(JdbcTemplate jdbcTemplate) {
        this.jdbcTemplate = jdbcTemplate;
    }

    public List<Employee> getAllEmployees() {
        String sql = "SELECT * FROM employees";
        return jdbcTemplate.query(sql, new EmployeeRowMapper());
    }

    // RowMapper implementation for mapping SQL result to Employee object
    private static class EmployeeRowMapper implements RowMapper<Employee> {
        @Override
        public Employee mapRow(java.sql.ResultSet rs, int rowNum) throws java.sql.SQLException {
            Employee employee = new Employee();
            employee.setId(rs.getInt("id"));
            employee.setName(rs.getString("name"));
            employee.setAge(rs.getInt("age"));
            employee.setDepartment(rs.getString("department"));
            return employee;
        }
    }
}

এখানে, jdbcTemplate.query() মেথড ব্যবহার করে SELECT অপারেশন করা হয়েছে এবং RowMapper ইন্টারফেস ব্যবহার করে SQL রেজাল্টকে Employee অবজেক্টে ম্যাপ করা হয়েছে।

৩. Update Operation

import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Repository;

@Repository
public class EmployeeDAO {

    private final JdbcTemplate jdbcTemplate;

    public EmployeeDAO(JdbcTemplate jdbcTemplate) {
        this.jdbcTemplate = jdbcTemplate;
    }

    public int updateEmployeeDepartment(int id, String newDepartment) {
        String sql = "UPDATE employees SET department = ? WHERE id = ?";
        return jdbcTemplate.update(sql, newDepartment, id);
    }
}

এখানে, JdbcTemplate.update() মেথড ব্যবহার করে UPDATE অপারেশন করা হয়েছে।

৪. Delete Operation

import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Repository;

@Repository
public class EmployeeDAO {

    private final JdbcTemplate jdbcTemplate;

    public EmployeeDAO(JdbcTemplate jdbcTemplate) {
        this.jdbcTemplate = jdbcTemplate;
    }

    public int deleteEmployee(int id) {
        String sql = "DELETE FROM employees WHERE id = ?";
        return jdbcTemplate.update(sql, id);
    }
}

এখানে, JdbcTemplate.update() মেথড ব্যবহার করে DELETE অপারেশন করা হয়েছে, যা নির্দিষ্ট id এর রেকর্ড মুছে দেয়।


৩. Main Method বা Service Layer দিয়ে পরীক্ষা করা

স্প্রিং অ্যাপ্লিকেশন চালানোর জন্য আপনি একটি Main মেথড বা Service Layer ব্যবহার করতে পারেন।

উদাহরণ: Service Layer

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.List;

@Service
public class EmployeeService {

    private final EmployeeDAO employeeDAO;

    @Autowired
    public EmployeeService(EmployeeDAO employeeDAO) {
        this.employeeDAO = employeeDAO;
    }

    public void performCRUDOperations() {
        // Create operation
        employeeDAO.createEmployee("John", 30, "IT");

        // Read operation
        List<Employee> employees = employeeDAO.getAllEmployees();
        employees.forEach(employee -> System.out.println(employee));

        // Update operation
        employeeDAO.updateEmployeeDepartment(1, "HR");

        // Delete operation
        employeeDAO.deleteEmployee(1);
    }
}

Main Application:

import org.springframework.context.annotation.AnnotationConfigApplicationContext;

public class MainApp {
    public static void main(String[] args) {
        AnnotationConfigApplicationContext context = new AnnotationConfigApplicationContext(AppConfig.class);
        EmployeeService employeeService = context.getBean(EmployeeService.class);
        employeeService.performCRUDOperations();
        context.close();
    }
}

এখানে, EmployeeService ক্লাসের মাধ্যমে CRUD অপারেশনগুলি পরীক্ষিত হয়েছে। এটি ডেটাবেসে ডেটা তৈরি, পড়া, আপডেট এবং মুছতে সক্ষম।

সারাংশ

স্প্রিং JDBC হল একটি শক্তিশালী টুল যা ডেটাবেস অপারেশনগুলিকে সহজ এবং নিরাপদ করে তোলে। JdbcTemplate এর মাধ্যমে আপনি খুব সহজে CRUD (Create, Read, Update, Delete) অপারেশন সম্পাদন করতে পারেন। এটি SQLException এর মতো সমস্যা সমাধান করতে সাহায্য করে এবং ডেটাবেস কোডকে আরও পরিষ্কার এবং সহজ করে তোলে।

স্প্রিং JDBC ব্যবহার করে ডেটাবেস অপারেশন সম্পাদন করতে হলে, আপনার স্প্রিং কনফিগারেশন সঠিকভাবে তৈরি করতে হবে এবং JdbcTemplate ব্যবহার করে আপনার SQL কুয়েরি চালাতে হবে।

Content added By
Promotion

Are you sure to start over?

Loading...