Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- package be.pxl.student;
- import java.sql.*;
- import java.util.ArrayList;
- import java.util.List;
- public class DBConnection {
- private static String url = "jdbc:mysql://localhost/studentDB?serverTimezone=UTC";
- private static String user = "root";
- private static String password = "";
- private Connection con = null;
- public static void main(String[] args) {
- DBConnection connection = new DBConnection();
- connection.createConnection();
- connection.selectQuery().forEach(b -> System.out.println(b.getAlcohol()));
- Beer beerUpdate = new Beer();
- beerUpdate.setName("Jupiler420");
- beerUpdate.setPrice(6969.0);
- beerUpdate.setAlcohol(420.69);
- beerUpdate.setId(4);
- connection.updateBeer(beerUpdate);
- //connection.deleteBeer(5);
- Beer newBeer = new Beer();
- newBeer.setName("NewBeer");
- newBeer.setPrice(4395.532);
- newBeer.setAlcohol(532.235);
- connection.insertBeer(newBeer);
- }
- private void insertBeer(Beer newBeer) {
- try {
- String insert = "INSERT INTO Beers (name, alcohol, price) VALUES (?, ?, ?)";
- PreparedStatement statement = con.prepareStatement(insert);
- statement.setString(1, newBeer.getName());
- statement.setDouble(2, newBeer.getAlcohol());
- statement.setDouble(3, newBeer.getPrice());
- statement.execute();
- } catch (SQLException e) {
- e.printStackTrace();
- }
- }
- private void deleteBeer(int beerToDeleteId) {
- try {
- String delete = "DELETE FROM Beers WHERE id = ?";
- PreparedStatement statement = con.prepareStatement(delete);
- statement.setInt(1, beerToDeleteId);
- statement.execute();
- } catch (SQLException e) {
- e.printStackTrace();
- }
- }
- private void updateBeer(Beer beerUpdate) {
- try {
- String update = "UPDATE beers set alcohol = ?, price = ?, name = ? WHERE id = ?;";
- PreparedStatement statement = con.prepareStatement(update);
- statement.setDouble(1, beerUpdate.getAlcohol());
- statement.setDouble(2, beerUpdate.getPrice());
- statement.setString(3, beerUpdate.getName());
- statement.setInt(4, beerUpdate.getId());
- statement.executeUpdate();
- } catch (SQLException e) {
- e.printStackTrace();
- }
- }
- private List<Beer> selectQuery() {
- List<Beer> beerList = new ArrayList<>();
- try {
- Statement statement = con.createStatement();
- ResultSet resultSet = statement.executeQuery("SELECT * FROM Beers");
- while (resultSet.next()) {
- Integer id = resultSet.getInt("Id");
- String name = resultSet.getString("Name");
- Double alcohol = resultSet.getDouble("Alcohol");
- Double price = resultSet.getDouble("Price");
- //System.out.printf("%s %s %s %n", name, alcohol, price);
- beerList.add(new Beer(id, name, alcohol, price));
- }
- } catch (SQLException e) {
- e.printStackTrace();
- }
- return beerList;
- }
- private void createConnection() {
- try {
- con = DriverManager.getConnection(url, user, password);
- } catch (SQLException e) {
- e.printStackTrace();
- }
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement