package DataBase;

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

public class DbConnection {
    private Statement st;
    private ResultSet rs;

    public DbConnection() {
        try {
            String url = "jdbc:mysql://localhost:3306/Shop";
            String username = "root";
            String password = "localhost";
            Connection con = DriverManager.getConnection(url,username,password);
            st = con.createStatement();
            } catch (Exception ex) {
        }
    }

    public void getProducts() throws Exception {
        String query = "select * from product";
        rs = st.executeQuery(query);

        while(rs.next()){
            String product = rs.getString("naam");
            int prijs = rs.getInt("prijs");
            System.out.println(product+":"+prijs);
        }

    }

    public void updateTable(String query) throws Exception {

        try{
            st.executeUpdate(query);
        }
        catch (Exception e){
            System.out.println(e);
        }

    }


}