package dbzugriffuebungpflanzen;

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

//Diese Klasse wird immer erstellt, 
//wenn der Datenprovider für SQL Server einen vom Server generierten Fehler entdeckt.
import java.sql.SQLException;
import java.sql.Statement;
import java.util.logging.Level;
import java.util.logging.Logger;

import javax.swing.JTextArea;
import javax.swing.JTextField;



/**
 *
 * @author ME
 */
public class DBZugriff {
// Objekt der Klasse Connection

    private Connection verbindung;

// DB-Daten (Tabellenname, DB-Server ... für url)
// Zugangsdaten (Parameter für Methode verbindung)
    private String url = "jdbc:mysql://localhost:3306/db_pflanzen";

//Statement createStatement() throws SQLException Liefert ein Statement-Objekt, um SQL-Anweisungen zur Datenbank zu schicken
    private Statement statement = null;
    private ResultSet rs = null;

    int count = 0;

    
    public int count() {

        try {

            rs = statement.executeQuery("SELECT count(*) FROM db_pflanzen.pflanzen");
            System.out.println(rs);
            rs.next();
            count = rs.getInt(1);

        } catch (SQLException ex) {
            Logger.getLogger(DBZugriff.class.getName()).log(Level.SEVERE, null, ex);
        }
        return count;
    }

    public String irgendwasAusgeben() {
        String a = "";
        try {

	  // Resultset nur bei SELECT-Abfrage nötig
            // Ergebnis der Abfrage wird als "ResultSet"gespeichert
            rs = statement.executeQuery("SELECT * FROM db_pflanzen.pflanzen WHERE artikelNr = 12");

// so lange rs.next() true ist, gibt es noch weitere Datensätze anzuzeigen
            while (rs.next()) {
                a = rs.getString("name");

            }
        } catch (SQLException ex) {
            Logger.getLogger(DBZugriff.class.getName()).log(Level.SEVERE, null, ex);
        }
        return a;
    }

  public void holeDaten(JTextArea taErgebnisliste){
{

        try {
            
            rs = statement.executeQuery("SELECT * FROM db_pflanzen.pflanzen");
            
            while (rs.next())
            {
                int artikelNr = rs.getInt("artikelNr");
                double preis = rs.getDouble("Preis");
                String name = rs.getString("Name");
                String sorte = rs.getString("Sorte");
                String farbe = rs.getString("farbe");
                //System.out.println(rs);
                // \t 	horizontaler Tabulator 
                taErgebnisliste.append(name+"\t");
                // \n Zeilenumbruch
                taErgebnisliste.append(sorte+"\n");
                //taErgebnisliste.append(farbe+"\t");
                
                
                }
        } catch (SQLException ex) {
            Logger.getLogger(DBZugriff.class.getName()).log(Level.SEVERE, null, ex);
        }


}
}
  
  
  
    // hier methoden einfügen
    
    
    public void VerbindungHerstellen() {

        String user = "root";
        String passwort = "";
        try {
            this.verbindung = DriverManager.getConnection(this.url, user, passwort);
            statement = verbindung.createStatement();

        } catch (SQLException ex) {
            Logger.getLogger(DBZugriff.class.getName()).log(Level.SEVERE, null, ex);
        }
        System.out.println("DbZugriff initialisiert");

    }

    void first() {
        throw new UnsupportedOperationException("Not supported yet."); //To change body of generated methods, choose Tools | Templates.
    }
}