JavaでexecuteQuery()を使ったデータ操作ができない理由と解決法

はじめに (対象読者・この記事でわかること)

この記事は、Javaでデータベースを操作する際にJDBCを利用しているプログラマー、特に初心者から中級者の方を対象としています。特に、executeQuery()メソッドを使おうとして「Can not issue data manipulation statements with executeQuery()」というエラーに遭遇した経験がある方に特に役立つ内容です。

この記事を読むことで、なぜこのエラーが発生するのか、その根本的な原因を理解できるようになります。また、正しいデータベース操作の方法として、SELECT文以外のINSERT、UPDATE、DELETE文にはexecuteUpdate()メソッドを使うべき理由と具体的な使い方を学べます。さらに、実際のプログラム例を通して、エラーを回避した正実装方法を習得できます。

前提知識

この記事を読み進める上で、以下の知識があるとスムーズです。前提となる知識1: Java言語の基本的な知識前提となる知識2: データベースの基本的な概念とSQL文の知識前提となる知識3: JDBCの基本的な使い方

JDBCにおけるクエリ実行メソッドの基本

Javaプログラムからデータベースを操作する際、JDBC（Java Database Connectivity）APIを使用します。JDBCでは、StatementやPreparedStatementオブジェクトのexecuteQuery()やexecuteUpdate()といったメソッドを使ってSQL文を実行します。

executeQuery()メソッドは、SELECT文のように結果セットを返すクエリを実行するために設計されています。一方、executeUpdate()メソッドはINSERT、UPDATE、DELETEのようにデータベースの状態を変更するクエリ、またはDDL文（CREATE TABLEなど）を実行するために設計されています。

この2つのメソッドの使い分けは、JDBCの基本的なルールですが、多くの開発者がこのルールを理解せずにexecuteQuery()を使おうとして「Can not issue data manipulation statements with executeQuery()」エラーに遭遇します。このエラーは、データ操作文（INSERT、UPDATE、DELETE）を実行しようとしているのに、結果セットを返すexecuteQuery()メソッドを使おとした際に発生します。

このエラーはJDBCドライバによってスローされ、データベースへの不正な操作を防ぐためのものです。しかし、このエラーの根本原因を理解していないと、適切な解決策を見つけることができません。

正しいデータベース操作方法

Javaからデータベースを操作する際には、実行するSQL文の種類に応じて適切なメソッドを選択する必要があります。ここでは、SELECT文以外のデータ操作文（INSERT、UPDATE、DELETE）を実行する正しい方法について詳しく解説します。

executeUpdate()メソッドの使い方

INSERT、UPDATE、DELETE文を実行するには、StatementまたはPreparedStatementオブジェクトのexecuteUpdate()メソッドを使用します。このメソッドは、データベースに影響を与えた行数を整数値で返します。

以下に、executeUpdate()メソッドを使用したINSERT文の実行例を示します：

Java

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

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

        try (Connection conn = DriverManager.getConnection(url, user, password);
             Statement stmt = conn.createStatement()) {

            // INSERT文の実行
            String sql = "INSERT INTO users (name, email) VALUES ('山田太郎', 'yamada@example.com')";
            int affectedRows = stmt.executeUpdate(sql);

            System.out.println("挿入された行数: " + affectedRows);

        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

同様に、UPDATE文とDELETE文もexecuteUpdate()メソッドで実行します：

Java

// UPDATE文の実行
String updateSql = "UPDATE users SET email = 'new.email@example.com' WHERE id = 1";
int updatedRows = stmt.executeUpdate(updateSql);
System.out.println("更新された行数: " + updatedRows);

// DELETE文の実行
String deleteSql = "DELETE FROM users WHERE id = 1";
int deletedRows = stmt.executeUpdate(deleteSql);
System.out.println("削除された行数: " + deletedRows);

PreparedStatementを使用した安全なデータ操作

PreparedStatementを使用すると、SQLインジェクション攻撃を防ぎ、パラメータ化クエリを簡単に実装できます。以下に、PreparedStatementを使用したINSERT文の例を示します：

Java

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

public class PreparedInsertExample {
    public static void main(String[] args) {
        String url = "jdbc:mysql://localhost:3306/mydatabase";
        String user = "username";
        String password = "password";

        try (Connection conn = DriverManager.getConnection(url, user, password)) {

            // PreparedStatementの作成
            String sql = "INSERT INTO users (name, email) VALUES (?, ?)";
            try (PreparedStatement pstmt = conn.prepareStatement(sql)) {

                // パラメータの設定
                pstmt.setString(1, "鈴木一郎");
                pstmt.setString(2, "suzuki@example.com");

                // クエリの実行
                int affectedRows = pstmt.executeUpdate();
                System.out.println("挿入された行数: " + affectedRows);
            }

        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

execute()メソッドによる汎用的なクエリ実行

execute()メソッドは、任意のSQL文を実行するための汎用的なメソッドです。このメソッドは、SELECT文を実行した場合は結果セットを返し、それ以外の文を実行した場合は影響を受けた行数を返します。以下にexecute()メソッドの使用例を示します：

Java

// SELECT文の実行
String selectSql = "SELECT * FROM users WHERE id = 1";
boolean isResultSet = stmt.execute(selectSql);
if (isResultSet) {
    // SELECT文が実行された場合の処理
    ResultSet rs = stmt.getResultSet();
    while (rs.next()) {
        System.out.println("ID: " + rs.getInt("id"));
        System.out.println("名前: " + rs.getString("name"));
        System.out.println("メール: " + rs.getString("email"));
    }
} else {
    // SELECT文以外が実行された場合の処理
    int affectedRows = stmt.getUpdateCount();
    System.out.println("影響を受けた行数: " + affectedRows);
}

ハマった点やエラー解決

「Can not issue data manipulation statements with executeQuery()」エラーの原因

このエラーは、データ操作文（INSERT、UPDATE、DELETE）を実行しようとしているのに、結果セットを返すexecuteQuery()メソッドを使おとした際に発生します。具体的な例を見てみましょう：

Java

// 誤った例：INSERT文にexecuteQuery()を使用
String insertSql = "INSERT INTO users (name, email) VALUES ('田中花子', 'tanaka@example.com')";
ResultSet rs = stmt.executeQuery(insertSql);  // ここでエラーが発生

上記のコードでは、INSERT文を実行しようとしているのにexecuteQuery()メソッドを使用しているため、「Can not issue data manipulation statements with executeQuery()」エラーが発生します。

解決策

このエラーを解決するには、executeQuery()メソッドの代わりにexecuteUpdate()メソッドを使用します。以下に修正したコードを示します：

Java

// 正しい例：INSERT文にexecuteUpdate()を使用
String insertSql = "INSERT INTO users (name, email) VALUES ('田中花子', 'tanaka@example.com')";
int affectedRows = stmt.executeUpdate(insertSql);  // 正しく実行される
System.out.println("挿入された行数: " + affectedRows);

同様に、UPDATE文とDELETE文にもexecuteUpdate()メソッドを使用する必要があります：

Java

// UPDATE文の正しい実行方法
String updateSql = "UPDATE users SET email = 'updated.email@example.com' WHERE id = 1";
int updatedRows = stmt.executeUpdate(updateSql);
System.out.println("更新された行数: " + updatedRows);

// DELETE文の正しい実行方法
String deleteSql = "DELETE FROM users WHERE id = 1";
int deletedRows = stmt.executeUpdate(deleteSql);
System.out.println("削除された行数: " + deletedRows);

その他のよくある間違い

executeQuery()とexecuteUpdate()の使い分け以外にも、JDBCを使用する際によくある間違いがあります：

接続のクローズ漏れ: データベース接続やStatement、ResultSetを適切にクローズしないと、リソースがリークします。try-with-resources構文を使用すると、自動的にクローズされるため安全です。
例外処理の不足: データベース操作では例外が発生しやすいため、適切な例外処理が必要です。try-catchブロックで例外を捕捉し、適切なエラーメッセージを表示するようにしましょう。
トランザクションの管理: 複数のデータベース操作を一つの単位として扱う場合、トランザクションを適切に管理する必要があります。conn.setAutoCommit(false)で自動コミットを無効にし、すべての操作が成功した後にconn.commit()を呼び出します。

まとめ

本記事では、Javaプログラミングで発生する「Can not issue data manipulation statements with executeQuery()」エラーの原因と解決方法について解説しました。

executeQuery()メソッドはSELECT文専用で、INSERT、UPDATE、DELETE文にはexecuteUpdate()メソッドを使用する必要がある
PreparedStatementを使用すると、SQLインジェクション攻撃を防ぎつつ安全にデータ操作ができる
execute()メソッドは任意のSQL文を実行できる汎用的なメソッドだが、返り値の型を確認して適切に処理する必要がある

この記事を通して、JDBCを使用したデータベース操作における基本的なルールを理解し、エラーを回避した安全なプログラミングができるようになったことでしょう。これからは、実行するSQL文の種類に応じてexecuteQuery()、executeUpdate()、execute()のいずれを使用すべきかを意識してプログラミングに取り組んでください。

参考資料

参考にした記事、ドキュメント、書籍などがあれば、必ず記載しましょう。

JavaでexecuteQuery()を使ったデータ操作ができない理由と解決法🔧