package datenbanken;

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

public class Datenbanken {

    public static void main(String[] args) {

        String host = "jdbc:derby://localhost:1527/Produkte";
        String username = "mitarbeiter1";
        String password = "xyz";
        try {
            Connection verbindung = DriverManager.getConnection(host, username, password);
            Statement befehl = verbindung.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_UPDATABLE);
            String SQL = "SELECT * FROM Produkte WHERE Artikelnummer = 1001";
            ResultSet rs = befehl.executeQuery(SQL);
            rs.next( );
            int ar = rs.getInt("Artikelnummer");
            System.out.println("Artikelnummer: "+ar);
            String pr = rs.getString("Produkttyp");
            System.out.println("Produkttyp: "+pr);
            int preis = rs.getInt("Preis");
            System.out.println("Preis: "+preis);
            int anz = rs.getInt("Anzahl");
            System.out.println("Anzahl: "+anz);
            rs.updateInt("Anzahl",anz+2);
            rs.updateRow();
        }
        catch ( SQLException err ) {
            System.out.println( err.getMessage( ) );
        }
    }
}