JDBC / sql 쿼리 적용 / Statement

Statement

Statement stat=conn.createStatement();

  1. executeUpdate / Create, Update, Delete

String sql = "insert into logininfo(id,pw) values ('admin1','admin')";
int result = stat.executeUpdate(sql); 
System.out.println(result);

  2. executeQuery / ResultSet / Read

sql = "select * FROM logininfo";
ResultSet rs = null;
rs=stat.executeQuery(sql);

while(rs.next()) {
    String id =rs.getString("id");
    String pw =rs.getString("pw");
    System.out.println(id+" "+pw);
}
rs.close();

 

전체 코드

Connection conn = null;

try{
    Class.forName("com.mysql.jdbc.Driver");
    String url ="jdbc:mysql://localhost:3306/hellojdbc?serverTimezone=UTC";
    conn = DriverManager.getConnection(url, "root", "root");
    System.out.println("연결 성공");

    Statement stat=conn.createStatement();
    
    String sql = "insert into logininfo(id,pw) values"
            + "('admin1','admin')";

    int result = stat.executeUpdate(sql); 
    System.out.println(result);
    
    sql = "select * FROM logininfo";
    ResultSet rs = null;
    rs=stat.executeQuery(sql);

    while(rs.next()) {
        String id =rs.getString("id");
        String pw =rs.getString("pw");
        System.out.println(id+" "+pw);
    }
    rs.close();  
}
catch(ClassNotFoundException e){
    System.out.println(e+"드라이버 로딩 실패");
}
catch(SQLException e){
    System.out.println("에러: " + e);
}
finally{
    try{
        if( conn != null && !conn.isClosed()){
            conn.close();
        }
    }
    catch( SQLException e){
        e.printStackTrace();
    }
}