Statement

Statement là một trong ba loại interace thực thi câu lệnh truy vấn SQL trong JDBC API
Statement có hiệu năng thấp nhất trong 3 loại interface truy vấn SQL của JDBC
Statement thường được sử dụng để thực hiện các câu truy vấn SQL tĩnh, dùng một lần, các câu SQL DDL (Data Denifition Lanaguge) như tạo, sửa, xóa table.

Ví dụ với Statement trong JDBC.

Tạo cơ sở tài liệu demo-jdbc như hình dưới :

CREATE SCHEMA `demo-jdbc` ;

( Xem lại : Cài đặt và thông số kỹ thuật MySQL )

Hướng dẫn Java JDBC, Ví dụ với Statement trong JDBC

Bạn đang đọc: Hướng dẫn Java JDBC, Ví dụ với Statement trong JDBC – STACKJAVA

Bây giờ mình sẽ viết 1 chương trình Java liên kết tới database demo-jdbc

Tạo 1 table ‘user_info’ với 3 column (id, name, address) trong đó id kiểu int là primary key và tự tăng; name và address kiểu varchar
Thêm, sửa, xóa, truy vấn với table ‘user_info’ đã tạo ở trên.

Để liên kết với MySQL bằng Java tất cả chúng ta cần tải về jdbc tương ứng cho MySQL
Các bạn hoàn toàn có thể tải về thư viện jdbc cho MySQL tại đây mysql-connector-java-6.0.6.jar
Hoặc sử dụng maven :



    mysql
    mysql-connector-java
    6.0.6

Ở đây mình dùng maven ( nếu bạn nào chưa biết maven thì nên khám phá luôn vì nó được dùng nhiều và khá quan trọng khi đi làm )
Tạo table user_info

package stackjava.com.demojdbc.statement;

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

public class CreateTable {
  public static void main(String[] args) throws SQLException, ClassNotFoundException {
    Class.forName("com.mysql.jdbc.Driver");
    Connection con = DriverManager.getConnection("jdbc:mysql://localhost:3306/demo-jdbc", "root", "admin1234");
    Statement stmt = con.createStatement();
    String sql = "CREATE TABLE user_info (" +
        "  id int(11) NOT NULL AUTO_INCREMENT," +
        "  name varchar(45) DEFAULT NULL," +
        "  address varchar(255) DEFAULT NULL," +
        "  PRIMARY KEY (id)" +
        ")";
    stmt.execute(sql);
    con.close();
    System.out.println("Created!");
  }
}

jdbc statement create table

Thêm 2 bản ghi vào table user_inf ( id tự tăng nên tất cả chúng ta không cần thêm nó vào câu lệnh INSERT )

package stackjava.com.demojdbc.statement;

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

public class InsertRow {
  public static void main(String[] args) throws SQLException, ClassNotFoundException {
    Class.forName("com.mysql.cj.jdbc.Driver");
    Connection con = DriverManager.getConnection("jdbc:mysql://localhost:3306/demo-jdbc", "root", "admin1234");
    Statement stmt = con.createStatement();
    String sql1 = "INSERT INTO user_info (name, address) VALUES ('Harry', 'England');";
    String sql2 = "INSERT INTO user_info (name, address) VALUES ('Batman', 'USA');";
    stmt.executeUpdate(sql1);
    stmt.executeUpdate(sql2);
    con.close();
    System.out.println("Inserted!");
  }
}

jdbc statement insert row

Update bản ghi ( row ) có address = “ England ” thành “ VietNam ”

package stackjava.com.demojdbc.statement;

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

public class UpdateRow {
  public static void main(String[] args) throws SQLException, ClassNotFoundException {
    Class.forName("com.mysql.cj.jdbc.Driver");
    Connection con = DriverManager.getConnection("jdbc:mysql://localhost:3306/demo-jdbc", "root", "admin1234");
    Statement stmt = con.createStatement();
    String sql = "UPDATE user_info SET address = 'VietNam' WHERE address = 'England';";
    stmt.executeUpdate(sql);
    con.close();
    System.out.println("Updated!");
  }
}

jdbc statement update row

Xóa bản ghi có address = “ USA ”

package stackjava.com.demojdbc.statement;

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

public class DeleteRow {
  public static void main(String[] args) throws SQLException, ClassNotFoundException {
    Class.forName("com.mysql.cj.jdbc.Driver");
    Connection con = DriverManager.getConnection("jdbc:mysql://localhost:3306/demo-jdbc", "root", "admin1234");
    Statement stmt = con.createStatement();
    String sql = "DELETE FROM user_info WHERE address = 'USA';";
    stmt.executeUpdate(sql);
    con.close();
    System.out.println("DELETED!");
  }
}

jdbc statement delete row

Xem thêm: 10 Java Framework cho Java Developer chất

Câu lệnh select toàn bộ những bản ghi trong table user_info :

package stackjava.com.demojdbc.statement;

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

public class SelectRow {
  public static void main(String[] args) throws SQLException, ClassNotFoundException {
    Class.forName("com.mysql.cj.jdbc.Driver");
    Connection con = DriverManager.getConnection("jdbc:mysql://localhost:3306/demo-jdbc", "root", "admin1234");
    Statement stmt = con.createStatement();
    String sql = "SELECT * FROM user_info;";
    ResultSet rs = stmt.executeQuery(sql);
    while (rs.next())
      System.out.println(rs.getInt(1) + "  " + rs.getString(2) + "  " + rs.getString(3));
    
    con.close();
    System.out.println("Done!");
  }
}

Kết quả :

jdbc statement select