Java サーブレットにおけるデータベース接続管理のトラブルシューティング

2024-04-07

Java サーブレットにおけるデータベース接続管理のベストプラクティス

Java サーブレットでデータベース接続を管理するには、いくつかの方法があります。それぞれの方法には長所と短所があり、プロジェクトの要件に基づいて最適な方法を選択する必要があります。

方法

DriverManager

これは最も基本的な方法であり、JDBC API を直接使用してデータベース接続を管理します。コードはシンプルですが、接続プーリングなどの機能がないため、スケーラビリティやパフォーマンスに問題が生じる可能性があります。

データソース

JNDI (Java Naming and Directory Interface) を使用して、データベース接続情報を管理します。DriverManager よりも柔軟性が高く、接続プーリングなどの機能を利用できます。

コンテナ管理接続 (CMC)

Servlet 3.0 以降で導入された機能で、コンテナがデータベース接続を管理します。開発者は接続プーリングなどの設定を意識することなく、データベース接続を利用できます。

JPA (Java Persistence API)

オブジェクト指向のフレームワークで、データベースとのマッピングを抽象化します。複雑な SQL クエリを記述することなく、エンティティオブジェクトを操作できます。

各方法の長所と短所

方法	長所	短所
DriverManager	シンプル	スケーラビリティやパフォーマンスに問題が生じる可能性がある
データソース	柔軟性が高い	設定が複雑になる可能性がある
CMC	設定が簡単	コンテナに依存する
JPA	オブジェクト指向	習得に時間がかかる

ベストプラクティス

接続プーリングを使用する
トランザクション管理を行う
PreparedStatement を使用する
接続を閉じる

補足

上記の方法は一般的な方法であり、プロジェクトの要件に合わせてさまざまなライブラリやフレームワークを使用することができます。

DriverManager

import java.sql.*;

public class DriverManagerExample {

    public static void main(String[] args) throws SQLException {
        // データベース接続情報
        String url = "jdbc:mysql://localhost:3306/mydb";
        String user = "root";
        String password = "password";

        // データベース接続
        Connection connection = DriverManager.getConnection(url, user, password);

        // SQL ステートメント
        Statement statement = connection.createStatement();
        String sql = "SELECT * FROM users";

        // SQL クエリ実行
        ResultSet resultSet = statement.executeQuery(sql);

        // 結果処理
        while (resultSet.next()) {
            System.out.println(resultSet.getString("name"));
        }

        // 接続クローズ
        resultSet.close();
        statement.close();
        connection.close();
    }
}

データソース

import java.sql.*;
import javax.naming.*;

public class DataSourceExample {

    public static void main(String[] args) throws SQLException, NamingException {
        // JNDI コンテキスト
        Context context = new InitialContext();

        // データソース取得
        DataSource dataSource = (DataSource) context.lookup("java:comp/env/jdbc/mydb");

        // データベース接続
        Connection connection = dataSource.getConnection();

        // SQL ステートメント
        Statement statement = connection.createStatement();
        String sql = "SELECT * FROM users";

        // SQL クエリ実行
        ResultSet resultSet = statement.executeQuery(sql);

        // 結果処理
        while (resultSet.next()) {
            System.out.println(resultSet.getString("name"));
        }

        // 接続クローズ
        resultSet.close();
        statement.close();
        connection.close();
    }
}

コンテナ管理接続 (CMC)

import javax.annotation.Resource;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

@WebServlet("/cmc")
public class CMCExample extends HttpServlet {

    @Resource(name = "jdbc/mydb")
    private DataSource dataSource;

    @Override
    protected void doGet(HttpServletRequest request, HttpServletResponse response) throws IOException {
        try (Connection connection = dataSource.getConnection();
             Statement statement = connection.createStatement();
             ResultSet resultSet = statement.executeQuery("SELECT * FROM users")) {

            // 結果処理
            while (resultSet.next()) {
                response.getWriter().println(resultSet.getString("name"));
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

JPA

import javax.persistence.*;

@Entity
public class User {

    @Id
    @GeneratedValue
    private Long id;
    private String name;

    // ...
}

public class JPAExample {

    public static void main(String[] args) {
        EntityManagerFactory emf = Persistence.createEntityManagerFactory("mydb");
        EntityManager em = emf.createEntityManager();

        // エンティティの作成
        User user = new User();
        user.setName("John Doe");

        // エンティティの保存
        em.getTransaction().begin();
        em.persist(user);
        em.getTransaction().commit();

        // エンティティの検索
        User foundUser = em.find(User.class, user.getId());

        // エンティティの削除
        em.getTransaction().begin();
        em.remove(foundUser);
        em.getTransaction().commit();

        em.close();
        emf.close();
    }
}