import java.sql.*;
public class Datenbank {
private String url;
private String benutzer;
private String passwort;
Connection verbinde;
Statement stmt;
Produkt p;
public Datenbank(){
this.url = "jdbc:mysql://localhost/kuehlschranksystem";
this.benutzer = "root";
this.passwort = "";
}
public void Datenbank_speichern(Produkt p){
try {
stmt = verbinde.createStatement();
String pr_name = p.getPr_name();
String pr_beschreibung = p.getPr_beschreibung();
double pr_preis = p.getPr_preis();
double pr_menge = p.getPr_menge();
int pr_barcode = p.getPr_barcode();
String pr_gruppe = p.getPr_gruppe();
stmt.executeUpdate("INSERT INTO produkt_tab (pr_name,pr_beschreibung,pr_preis,pr_menge,pr_barcode,pr_gruppe) VALUES('" + pr_name + "' , '" + pr_beschreibung + "' , '" + null + "' , '" + pr_preis + "' , '" + pr_menge + "' , '" + pr_barcode + "' , '" + pr_gruppe + "')");
ResultSet rs = stmt.executeQuery("SELECT * FROM produkt");
while (rs.next()) {
System.out.println("Produkt: " + rs.getString("name"));
}
}
catch (SQLException exc) {
System.err.println(exc.getMessage());
}
}
public Produkt Datenbank_ausgabe(){
try{
stmt = verbinde.createStatement();
ResultSet erg = stmt.executeQuery("SELECT * FROM produkt_tab");
while (erg.next()) {
p = Produkt.erstelleProdukt(erg.getString("pr_name"), erg.getString("pr_beschreibung"),
null, erg.getDouble("pr_preis"), erg.getInt("pr_menge"), erg.getInt("pr_barcode"),
erg.getString("pr_gruppe"));
Produktliste.hinzuProduktliste(p);
Produktliste.ausgabeProduktliste();
}
}
catch (SQLException exc) {
System.err.println(exc.getMessage());
}
return p;
}
public void zuDatenbank_verbinden(){
try{
Class.forName("com.mysql.jdbc.Driver");
}
catch (ClassNotFoundException exc){
System.err.println("Treiber nicht gefunden!" + exc.getMessage());
System.exit(-1);
}
try{
verbinde = DriverManager.getConnection(getUrl(), getBenutzer(), getPasswort());
}
catch (SQLException exc) {
System.err.println(exc.getMessage());
}
}
public String getUrl() {
return url;
}
public void setUrl(String url) {
this.url = url;
}
public String getBenutzer() {
return benutzer;
}
public void setBenutzer(String benutzer) {
this.benutzer = benutzer;
}
public String getPasswort() {
return passwort;
}
public void setPasswort(String passwort) {
this.passwort = passwort;
}
}