Advertisement
Guest User

elias

a guest
Feb 25th, 2019
95
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 3.47 KB | None | 0 0
  1. package be.pxl.student;
  2.  
  3. import java.sql.*;
  4. import java.util.ArrayList;
  5. import java.util.List;
  6.  
  7. public class DBConnection {
  8. private static String url = "jdbc:mysql://localhost/studentDB?serverTimezone=UTC";
  9. private static String user = "root";
  10. private static String password = "";
  11. private Connection con = null;
  12.  
  13. public static void main(String[] args) {
  14. DBConnection connection = new DBConnection();
  15. connection.createConnection();
  16. connection.selectQuery().forEach(b -> System.out.println(b.getAlcohol()));
  17.  
  18. Beer beerUpdate = new Beer();
  19. beerUpdate.setName("Jupiler420");
  20. beerUpdate.setPrice(6969.0);
  21. beerUpdate.setAlcohol(420.69);
  22. beerUpdate.setId(4);
  23.  
  24. connection.updateBeer(beerUpdate);
  25.  
  26. //connection.deleteBeer(5);
  27. Beer newBeer = new Beer();
  28. newBeer.setName("NewBeer");
  29. newBeer.setPrice(4395.532);
  30. newBeer.setAlcohol(532.235);
  31.  
  32. connection.insertBeer(newBeer);
  33. }
  34.  
  35. private void insertBeer(Beer newBeer) {
  36. try {
  37. String insert = "INSERT INTO Beers (name, alcohol, price) VALUES (?, ?, ?)";
  38. PreparedStatement statement = con.prepareStatement(insert);
  39. statement.setString(1, newBeer.getName());
  40. statement.setDouble(2, newBeer.getAlcohol());
  41. statement.setDouble(3, newBeer.getPrice());
  42. statement.execute();
  43. } catch (SQLException e) {
  44. e.printStackTrace();
  45. }
  46. }
  47.  
  48. private void deleteBeer(int beerToDeleteId) {
  49. try {
  50. String delete = "DELETE FROM Beers WHERE id = ?";
  51. PreparedStatement statement = con.prepareStatement(delete);
  52. statement.setInt(1, beerToDeleteId);
  53. statement.execute();
  54. } catch (SQLException e) {
  55. e.printStackTrace();
  56. }
  57. }
  58.  
  59. private void updateBeer(Beer beerUpdate) {
  60. try {
  61. String update = "UPDATE beers set alcohol = ?, price = ?, name = ? WHERE id = ?;";
  62. PreparedStatement statement = con.prepareStatement(update);
  63.  
  64. statement.setDouble(1, beerUpdate.getAlcohol());
  65. statement.setDouble(2, beerUpdate.getPrice());
  66. statement.setString(3, beerUpdate.getName());
  67. statement.setInt(4, beerUpdate.getId());
  68. statement.executeUpdate();
  69. } catch (SQLException e) {
  70. e.printStackTrace();
  71. }
  72. }
  73.  
  74. private List<Beer> selectQuery() {
  75. List<Beer> beerList = new ArrayList<>();
  76. try {
  77. Statement statement = con.createStatement();
  78. ResultSet resultSet = statement.executeQuery("SELECT * FROM Beers");
  79. while (resultSet.next()) {
  80. Integer id = resultSet.getInt("Id");
  81. String name = resultSet.getString("Name");
  82. Double alcohol = resultSet.getDouble("Alcohol");
  83. Double price = resultSet.getDouble("Price");
  84. //System.out.printf("%s %s %s %n", name, alcohol, price);
  85. beerList.add(new Beer(id, name, alcohol, price));
  86. }
  87. } catch (SQLException e) {
  88. e.printStackTrace();
  89. }
  90.  
  91. return beerList;
  92. }
  93.  
  94. private void createConnection() {
  95. try {
  96. con = DriverManager.getConnection(url, user, password);
  97. } catch (SQLException e) {
  98. e.printStackTrace();
  99. }
  100. }
  101. }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement