Java SQLException Nedir? SQLException Hatası ve Çözümü

Java programlama dilinde sıkça karşılaşılan hatalardan biri olan SQLException, veritabanı işlemleri sırasında meydana gelen bir hata türüdür. Bu makalede, SQLException hatasının ne anlama geldiğini, neden oluştuğunu ve bu hatayı çözmek için alınabilecek önlemleri detaylı bir şekilde inceleyeceğiz.

1. SQLException Nedir?

SQLException, Java veritabanı programlamasında meydana gelen bir exception türüdür. Bu hata, SQL sorgularının çalışma sırasında veya veritabanı bağlantısı sırasında bir problem olduğunda ortaya çıkar. Örneğin, geçersiz bir SQL sorgusu, veritabanına bağlantı sorunları veya tablo eksikliği gibi durumlar bu hatayı tetikleyebilir.

2. Nedenleri ve Senaryolar

2.1. Geçersiz SQL Sorgusu:

try {
    Connection connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/exampledb", "user", "password");
    Statement statement = connection.createStatement();
    ResultSet resultSet = statement.executeQuery("SELECT * FROM nonexistingtable"); // SQLException
    while (resultSet.next()) {
        // Veri işleme
    }
    resultSet.close();
    statement.close();
    connection.close();
} catch (SQLException e) {
    e.printStackTrace();
}

Bu örnekte, nonexistingtable adlı tablo bulunamadığı için SQLException hatası meydana gelir.

2.2. Veritabanına Bağlantı Sorunları:

try {
    Connection connection = DriverManager.getConnection("jdbc:mysql://nonexistenthost:3306/exampledb", "user", "password"); // SQLException
    Statement statement = connection.createStatement();
    ResultSet resultSet = statement.executeQuery("SELECT * FROM existingtable");
    while (resultSet.next()) {
        // Veri işleme
    }
    resultSet.close();
    statement.close();
    connection.close();
} catch (SQLException e) {
    e.printStackTrace();
}

Bu örnekte, veritabanına bağlantı sırasında nonexistenthost adlı host bulunamadığı için SQLException hatası meydana gelir.

3. Çözümler ve Örnekler

3.1. SQL Sorgularını Kontrol Etme:

try {
    Connection connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/exampledb", "user", "password");
    Statement statement = connection.createStatement();
    ResultSet resultSet = statement.executeQuery("SELECT * FROM existingtable"); // Geçerli SQL sorgusu
    while (resultSet.next()) {
        // Veri işleme
    }
    resultSet.close();
    statement.close();
    connection.close();
} catch (SQLException e) {
    e.printStackTrace();
}

Bu örnekte, existingtable adlı var olan bir tablo üzerinde geçerli bir SQL sorgusu kullanıldığı için SQLException hatası önlenmiş olur.

3.2. Bağlantı Sorunlarını İzleme:

try {
    Connection connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/exampledb", "user", "password");
    if (connection.isValid(5)) { // 5 saniye içinde geçerliliği kontrol et
        Statement statement = connection.createStatement();
        ResultSet resultSet = statement.executeQuery("SELECT * FROM existingtable");
        while (resultSet.next()) {
            // Veri işleme
        }
        resultSet.close();
        statement.close();
        connection.close();
    } else {
        System.out.println("Veritabanı bağlantısı geçersiz.");
    }
} catch (SQLException e) {
    e.printStackTrace();
}

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;

public class PreparedStatementExample {
    public static void main(String[] args) {
        String name = "John";
        int age = 25;

        try {
            Connection connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/exampledb", "user", "password");
            
            // Hatalı SQL sorgusu (parametre eksik)
            String sql = "INSERT INTO users (name, age) VALUES (?)";
            PreparedStatement preparedStatement = connection.prepareStatement(sql);
            preparedStatement.setString(1, name);
            preparedStatement.setInt(2, age);  // SQLException
            preparedStatement.executeUpdate();

            preparedStatement.close();
            connection.close();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

Bu örnekte, INSERT INTO users (name, age) VALUES (?) SQL sorgusunda beklenen iki parametreden sadece biri (name) sağlandığı için SQLException hatası ortaya çıkar.

Detaylar ve Çözümler:

1. Parametre Sayısını ve Sıralamasını Kontrol Etme:
   • PreparedStatement kullanılıyorsa, SQL sorgusundaki parametre sayısı ve sıralamasını doğru belirtmek önemlidir.
   • Örnekte, setInt(2, age); yerine setInt(1, age); kullanılmalıdır.

Örnek 4: Transaction ve SQLException

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;

public class TransactionExample {
    public static void main(String[] args) {
        try {
            Connection connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/exampledb", "user", "password");
            
            // Otomatik commit modunu kapat
            connection.setAutoCommit(false);

            // Hatalı SQL sorgusu (tablo adı yanlış)
            Statement statement = connection.createStatement();
            statement.executeUpdate("INSERT INTO users (name, age) VALUES ('Alice', 30)");  // SQLException
            statement.executeUpdate("INSERT INTO nonexistenttable (col1, col2) VALUES ('Value1', 'Value2')");
            
            // Commit işlemi
            connection.commit();

            statement.close();
            connection.close();
        } catch (SQLException e) {
            e.printStackTrace();
            // Hata durumunda rollback işlemi
            connection.rollback();
        }
    }
}