src/main/java/sbp/io/Main.java - MyIOExample - pchelkin_g/homework6

src/main/java/sbp/io/Main.java
58 строк3 KB
pchelking
MyIOExample
24 дек 2025, 14:39
24 дек 2025, 14:391a97abd
package sbp.io;

import org.h2.jdbcx.JdbcDataSource;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

//взаимодействия с реляционной БД (CRUD операции)
public class Main {
    public static void main(String[] args) {
        JdbcDataSource ds = new JdbcDataSource();
        ds.setUrl("jdbc:h2:./person");
        ds.setUser("sa");
        ds.setPassword("sa");

        try (Connection connection = ds.getConnection()) {
            //CREATE TABLE, DROP, ALTER, TRUNCATE
            connection.createStatement().execute("CREATE TABLE IF NOT EXISTS person (id long primary key auto_increment, name varchar(50), city varchar(50), age integer)");
            //INSERT, UPDATE, DELETE
            connection.createStatement().execute("INSERT INTO person (name, city, age) VALUES ('mask ealon', 'austin',54)");
            connection.createStatement().execute("INSERT INTO person (name, city, age) VALUES ('altman samuel', 'sant francisco',42)");
            connection.createStatement().execute("INSERT INTO person (name, city, age) VALUES ('till peter', 'sant francisco',60)");
//            ResultSet  rs = connection.createStatement().executeQuery("SELECT count(*) FROM person");
            PreparedStatement preparedStatement = connection.prepareStatement("DELETE FROM person WHERE id = ?");
            preparedStatement.setLong(1, 3L);
            preparedStatement.execute();

            PreparedStatement preparedStatement1 = connection.prepareStatement("UPDATE person SET name = ?, city = ?, age = ? WHERE id = ?");
            preparedStatement1.setString(1, "xxxx");
            preparedStatement1.setString(2, "xxxx");
            preparedStatement1.setInt(3,100);
            preparedStatement1.setLong(4,2L);
            preparedStatement1.execute();

            ResultSet  rs = connection.createStatement().executeQuery("SELECT id, name, city, age FROM person");

            while (rs.next()) {
                long  id = rs.getLong("id");
                String name = rs.getString("name");
                String city = rs.getString("city");
                int age = rs.getInt("age");

                Person person = Person.builder()
                        .withId(id)
                        .withName(name)
                        .withCity(city)
                        .withAge(age)
                        .build();
                System.out.println(person);
            }
            System.out.println("SUCCESS");
        } catch (SQLException e) {
            System.out.println("ERROR");
        }
    }
}