executeQuery()
メソッドに以下のコードを追加します。
public static void executeQuery() {
// ここにコードを記述します
Connection connection = null;
Statement stmt = null;
ResultSet rs = null;
try{
// ここにコードを記述します
Class.forName("com.mysql.jdbc.Driver");
String url = "jdbc:mysql://localhost:3306/edusys";
String username = "root";
String password = "";
connection = DriverManager.getConnection(url, username, password);
Scanner scanner = new Scanner(System.in);
System.out.println("照会するテーブルを入力してください:");
System.out.println("1. student");
System.out.println("2. course");
System.out.println("3. instructor");
int option = scanner.nextInt();
String sql = "";
switch (option) {
case 1:
sql = "SELECT ID, name, dept_name FROM student";
break;
case 2:
sql = "SELECT course_id, title, dept_name FROM course";
break;
case 3:
sql = "SELECT ID, name, dept_name FROM instructor";
break;
default:
System.out.println("無効なオプション");
}
stmt = connection.createStatement();
rs = stmt.executeQuery(sql);
while (rs.next()) {
String column1 = rs.getString(1);
String column2 = rs.getString(2);
String column3 = rs.getString(3);
System.out.println(column1 + "\t" + column2 + "\t" + column3);
}
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (SQLException e) {
e.printStackTrace();
} catch (Exception e) {
e.printStackTrace();
} finally{
try {
if(rs!= null)rs.close();
if(stmt!= null)stmt.close();
if(connection!= null)connection.close();
} catch (SQLException e) {
e.printStackTrace();
} catch (Exception e) {
e.printStackTrace();
}
}
}
このコードは MySQL データベースに接続し、ユーザに照会するテーブルを選択させ、適切な SQL 照会を実行し、結果をコンソールに表示します。