Java with MySQL-Tạo Model

Trong Java, Model thường được sử dụng để tương tác với cơ sở dữ liệu. Để tạo Model cho ứng dụng Java kết nối với MySQL, ta cần sử dụng JDBC để thao tác với cơ sở dữ liệu.

Bước 1: Tạo đối tượng Connection để kết nối với cơ sở dữ liệu MySQL.

String databaseName = "mydatabase";
String username = "myusername";
String password = "mypassword";
String url = "jdbc:mysql://localhost/" + databaseName;

Connection connection = DriverManager.getConnection(url, username, password);

Bước 2: Tạo các class đại diện cho các bảng trong cơ sở dữ liệu MySQL.

public class User {
    private int id;
    private String username;
    private String password;

    public User(int id, String username, String password) {
        this.id = id;
        this.username = username;
        this.password = password;
    }

    // Getters và setters
}

Bước 3: Tạo các phương thức để thao tác với cơ sở dữ liệu MySQL, bao gồm tìm kiếm, thêm mới, cập nhật và xóa bản ghi.

public class UserDao {
    private Connection connection;

    public UserDao(Connection connection) {
        this.connection = connection;
    }

    public User findById(int id) throws SQLException {
        PreparedStatement statement = connection.prepareStatement("SELECT * FROM users WHERE id = ?");
        statement.setInt(1, id);
        ResultSet resultSet = statement.executeQuery();
        if (resultSet.next()) {
            String username = resultSet.getString("username");
            String password = resultSet.getString("password");
            return new User(id, username, password);
        } else {
            return null;
        }
    }

    public void create(User user) throws SQLException {
        PreparedStatement statement = connection.prepareStatement("INSERT INTO users (username, password) VALUES (?, ?)");
        statement.setString(1, user.getUsername());
        statement.setString(2, user.getPassword());
        statement.executeUpdate();
    }

    public void update(User user) throws SQLException {
        PreparedStatement statement = connection.prepareStatement("UPDATE users SET username = ?, password = ? WHERE id = ?");
        statement.setString(1, user.getUsername());
        statement.setString(2, user.getPassword());
        statement.setInt(3, user.getId());
        statement.executeUpdate();
    }

    public void delete(int id) throws SQLException {
        PreparedStatement statement = connection.prepareStatement("DELETE FROM users WHERE id = ?");
        statement.setInt(1, id);
        statement.executeUpdate();
    }
}

Lưu ý: Khi sử dụng JDBC để tương tác với cơ sở dữ liệu MySQL, ta cần xử lý các exception như SQLException để đảm bảo ứng dụng Java của bạn chạy một cách ổn định và đáng tin cậy.