Java – データベースで主キーの重複チェックを行う方法

<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
    <version>8.0.26</version> <!-- バージョンは適宜変更してください -->
</dependency>

import java.sql.Connection; // JDBC接続用
import java.sql.DriverManager; // ドライバマネージャ
import java.sql.PreparedStatement; // プリペアドステートメント
import java.sql.ResultSet; // 結果セット
import java.sql.SQLException; // SQL例外
public class App {
    public static void main(String[] args) {
        String url = "jdbc:mysql://localhost:3306/your_database"; // データベースURL
        String user = "your_username"; // ユーザー名
        String password = "your_password"; // パスワード
        String primaryKeyValue = "12345"; // チェックする主キーの値
        try {
            // データベースに接続
            Connection connection = DriverManager.getConnection(url, user, password);
            // 主キーの重複チェック用SQL
            String sql = "SELECT COUNT(*) FROM your_table WHERE primary_key_column = ?";
            PreparedStatement preparedStatement = connection.prepareStatement(sql);
            preparedStatement.setString(1, primaryKeyValue); // 主キーの値を設定
            // クエリを実行
            ResultSet resultSet = preparedStatement.executeQuery();
            if (resultSet.next()) {
                int count = resultSet.getInt(1); // 結果セットからカウントを取得
                if (count > 0) {
                    System.out.println("主キーの重複が見つかりました。"); // 重複がある場合
                } else {
                    System.out.println("主キーは一意です。"); // 重複がない場合
                }
            }
            // リソースをクローズ
            resultSet.close();
            preparedStatement.close();
            connection.close();
        } catch (SQLException e) {
            e.printStackTrace(); // エラーメッセージを表示
        }
    }
}

主キーは一意です。

CREATE TABLE users (
    user_id INT PRIMARY KEY,
    user_name VARCHAR(100) NOT NULL
);

import java.sql.Connection; // JDBC接続用
import java.sql.DriverManager; // ドライバマネージャ
import java.sql.PreparedStatement; // プリペアドステートメント
import java.sql.ResultSet; // 結果セット
import java.sql.SQLException; // SQL例外
import java.util.Scanner; // ユーザー入力用
public class App {
    public static void main(String[] args) {
        String url = "jdbc:mysql://localhost:3306/your_database"; // データベースURL
        String user = "your_username"; // ユーザー名
        String password = "your_password"; // パスワード
        Scanner scanner = new Scanner(System.in); // スキャナーの初期化
        System.out.print("チェックするユーザーIDを入力してください: ");
        int userId = scanner.nextInt(); // ユーザーからの入力を取得
        try {
            // データベースに接続
            Connection connection = DriverManager.getConnection(url, user, password);
            // 主キーの重複チェック用SQL
            String sql = "SELECT COUNT(*) FROM users WHERE user_id = ?";
            PreparedStatement preparedStatement = connection.prepareStatement(sql);
            preparedStatement.setInt(1, userId); // ユーザーIDを設定
            // クエリを実行
            ResultSet resultSet = preparedStatement.executeQuery();
            if (resultSet.next()) {
                int count = resultSet.getInt(1); // 結果セットからカウントを取得
                if (count > 0) {
                    System.out.println("ユーザーID " + userId + " は既に存在します。"); // 重複がある場合
                } else {
                    System.out.println("ユーザーID " + userId + " は一意です。"); // 重複がない場合
                }
            }
            // リソースをクローズ
            resultSet.close();
            preparedStatement.close();
            connection.close();
        } catch (SQLException e) {
            e.printStackTrace(); // エラーメッセージを表示
        } finally {
            scanner.close(); // スキャナーをクローズ
        }
    }
}

チェックするユーザーIDを入力してください: 1
ユーザーID 1 は既に存在します。