Mysql Update wenn es nicht existiert insert

[Emrullah]

Hallo zusammen,

wollte bei meiner Datenbank ein update ausführen wenn eine Datei nicht existieren sollte, sollte sie mit insert eingefügt werden leider macht er bei mir weder ein update noch versucht er die Funktion insert.



[CODE lang="java" title="Update /Insert"]public void kontrolle(String[] Aboziel){
Integer.parseInt(Aboziel[3]+1);

Connection con;
con= Erstelle_verbindung();




try {

System.out.println("systeme.ABoziele.aboZielzahlen()"+Aboziel[3]);


String query = "update abos set FirmenID = ?,Heftname = ?,HeftID = ?,Ausgabe = ?,Jahr = ?,ABOZiel = ? ";
PreparedStatement preparedStmt=con.prepareStatement(query);

preparedStmt.setInt (1,Integer.parseInt(Aboziel[0]));
preparedStmt.setInt (3,Integer.parseInt(Aboziel[2]));
preparedStmt.setInt (4,Integer.parseInt(Aboziel[3]));
preparedStmt.setInt (5,Integer.parseInt(Aboziel[4]));
preparedStmt.setString(6,Aboziel[5]);
preparedStmt.setString(2,Aboziel[1]);

preparedStmt.executeUpdate();

System.out.println("systeme.ABoziele.kontrolle(aaaaaaaaa)-----" +Aboziel[0]+"--FirmenID---"
+Aboziel[2]+"---HeftID---"
+Aboziel[3]+"---Ausgaben---"
+Aboziel[4]+"---Jahr---"
+Aboziel[5]+"---ABOZiel---"
+Aboziel[1]+"--Heftname---");
System.out.println("systeme.ABoziele.kontrolle(query)"+query);
if(query == null){
System.out.println("systeme.ABoziele.kontrolle(null) ---"+Aboziel[3]);
Statement stmt = con.createStatement();
stmt.executeUpdate("INSERT INTO abos(FirmenID, Heftname, HeftID, Ausgabe, Jahr, ABOZiel) VALUES "

+ "('" + Integer.parseInt(Aboziel[0]) //MitarbeiterId
+ "','" + Aboziel[1] //DatenBanke // Abo = 1 // Anzeigen = 2 // EInzelhandel = 3
+ "','" + Integer.parseInt(Aboziel[2]) //Heftnamen
+ "','" + Integer.parseInt(Aboziel[3]) //FirmenID
+ "','" + Integer.parseInt(Aboziel[4])
+ "','" + Aboziel[5]+"')");


System.out.println("systeme.ABoziele.kontrolle(speichern)");
}



mySQL.schliesse_verbindung();


}catch(Exception e) {
System.out.println("firmen : Konnte keine Verbindung hergestellt werden");
e.printStackTrace();

}[/CODE]


danke um die schnelle Hilfe schonmal im Vorraus

 

[LimDul]

Diese Zeile sieht nach kompletten Unfug aus:

        Integer.parseInt(Aboziel[3]+1);

Die macht auf jeden Fall nichts sinvolles.

Das Query sieht auch "interessant" aus - sicher das da keine Where-Bedingung fehlt? Du aktualisiert damit alle Zeilen in der Tabelle.

                               if(query == null){

Diese Bedingung kann nie true werden Wie soll query jemals null sein? Du hast oben einen String erzeugt und damit ist der Wert ungleich null.

Du musst schon das Ergebnis des Aufrufes abfragen. Siehe https://docs.oracle.com/en/java/jav...va/sql/PreparedStatement.html#executeUpdate()

Returns:
either (1) the row count for SQL Data Manipulation Language (DML) statements or (2) 0 for SQL statements that return nothing

Das heißt, wenn du 0 kommt gab es in der Tabelle keine Zeilen und es wurde nichts aktualisiert. Das wirst du eher prüfen wollen.

Und das Insert-Statement sollte ebenfalls ein PreparedStatement sein, so öffnet das Tür und Scheunentor für eine SQL-Injection und ist nicht mal syntaktisch korrekt, weil da komplett umschließende einfache Hochkommas um die Values drum sind, anstelle um jeden einzelnen.

Und eine Bitte - halte dich an Java Code Konvention:
* Parameter und Variablen klein (Aboziel => aboziel)
* Methoden im CamelCase und mit Kleinbucstaben beginne: Erstelle_verbindung => erstelleVerbindung

Eine sinnvolle Einrückung (entweder einheitlich mit Leerzeichen oder Tabs) macht den Code auch deutlich lesbarer - so sieht er ziemlich wirr und dahingekackt aus

 

[Mart]

1. verwende Prepared Statements aus Sicherheits/ übersichtlichkeits gründen
2. da weder das eine noch das andere ausgeführt wird hast du wahrschleinich einen sql error der sollte irgendwie abrufbar über stmt sein ka wie die methode heißt da steht drin welcher error passiert ist
3. deine Ifs werden nie ausgeführt vllt

 

[Mart]

Und das Insert-Statement sollte ebenfalls ein PreparedStatement sein, so öffnet das Tür und Scheunentor für eine SQL-Injection und ist nicht mal syntaktisch korrekt, weil da komplett umschließende einfache Hochkommas um die Values drum sind, anstelle um jeden einzelnen.

so ein query sieht halt einfach shceiße aus, ein prepared statement sieht schicker aus und ist übersichtlicher

 

[Oneixee5]

MySQL kann INSERT und UPDATE in einem Statement durchführen, somit ist eine Verzweigung nicht notwendig.

INSERT INTO ados
    (firmenid, ...<andere Spaltennamen>...)
VALUES
    (?, ...<? pro Spalte>...)
ON DUPLICATE KEY UPDATE
    <Spalte für Update> = ?,
    <Spalte für Update> = ?,
    <Spalte für Update> = ?;

 

[Emrullah]

danke für die schnelle Antwort an alle hatte viel unsinniges noch drinnen da ich viel probiert hatte.

@Oneixee5 danke für deine schritt weiße die hab ich eingebunden aber leider tut er mir immer wieder doppelt alles abspeichern

public void speichern(String[] Aboziel){
        
        
        
        Connection con;
                       con= Erstelle_verbindung();
                
                        try {
                            
                    
                      
            Statement stmt = con.createStatement();
                        stmt.executeUpdate("INSERT INTO abos(FirmenID, HeftID, Ausgabe, Jahr, ABOZiel, Heftname) "
                                + "VALUES"
                        + "('"  + Integer.parseInt(Aboziel[0])                                      //MitarbeiterId
                        + "','" + Integer.parseInt(Aboziel[2])                                          //Heftnamen
                        + "','" + Integer.parseInt(Aboziel[3]+1)                     //FirmenID
                        + "','" + Integer.parseInt(Aboziel[4])
                        + "','" + Integer.parseInt(Aboziel[5])
                        + "','" + Aboziel[1]+"')"
                                + "ON Duplicate KEY UPDATE "
                        + "ABOZiel="+Integer.parseInt(Aboziel[5])); 
                        
                            
            mySQL.schliesse_verbindung();
            
            
        }catch(Exception e) {
            System.out.println("firmen : Konnte keine Verbindung hergestellt werden");
                e.printStackTrace();
                
        }
        
    }
    
}

weißt du wo genau der Fehler liegt.

 

[Mart]

du kannst nicht auf einen einzigartigen key prüfen wenn der key nicht einzigartig ist du hast weder unique noch primary key modifier

 

[Emrullah]

@Mart
danke für deine Antwort

hab jetzt mir Primary key und Unique key getestet aber es wird immer wieder doppelt angelegt.

hab das noch nie gemacht, kann niemanden fragen bzw. Tipps erfragen und kenn mich leider nicht aus.

könntest du mir einen ungefähren Beispiel auflisten.

danke für deine mühe.

 

[Mart]

"ABOZiel="+Integer.parseInt(Aboziel[5]))

hier hast du keine Hochkommatas dh es wird IRGENDWAS gemahct deswegen musst du es mit prepared statements machen weil keiner solche Statements lesen kann

 

[Emrullah]

@Mart
danke für deine Antwort hab es rum probiert zum Schluss hab ich es mit einem Count gemacht wenn er und eine if schleife

und die String array hab ich rausgenommen und alles einzeln eingefügt.
so funktioniert es jetzt wie ich es wollte.

    public void kontrolle(int FirmenID,String Heftname,int HeftID,int Ausgabe,int Jahr,int Aboziele){
        
        
        Connection con;
                       con= mySQL.Aboziel_Erstelle_verbindung();
        
        
        int count =0;
                      
                        try {
                            
                      System.out.println("systeme.ABoziele.aboZielzahlen()");
                      
            
                            Statement stat = con.createStatement();
                                    ResultSet rs=stat.executeQuery("Select Count(ID),ID From abos Where "
                                                                        +" FirmenID ='"+ FirmenID
                                                                        +"'AND Heftname='"+ Heftname
                                                                        +"'AND Jahr='"+ Jahr
                                                                        +"'AND Ausgabe='"+Ausgabe+"'");
                                    
                                    if (rs.next())
                                    count =rs.getInt(1);
                                    int ID = rs.getInt(2);
                                    
                                    if(count!=0)
                                    {
                                        System.out.println("systeme.ABoziele.kontrolle(update)");
                                    String UpdateQuery  = "update abos set ABOZiel = ? Where ID =?";
                                    
                                    PreparedStatement preparedStmt2 = con.prepareStatement(UpdateQuery);
                                    preparedStmt2.setInt(1, Aboziele);                     
                                    preparedStmt2.setInt(2, ID);
                                    preparedStmt2.executeUpdate();
                                                }
                                    else{
                                        System.out.println("systeme.ABoziele.kontrolle(insert)");
                                        stat.executeUpdate("INSERT INTO abos(FirmenID, HeftID, Ausgabe, Jahr, ABOZiel, Heftname) "
                                            + "VALUES"
                                    + "('"  + FirmenID                          //FIrmenID
                                    + "','" + HeftID                          //HeftID
                                    + "','" + Ausgabe                           //Ausgabenummer
                                    + "','" + Jahr                              //Jahr
                                    + "','" + Aboziele                           //Aboziel
                                    + "','" + Heftname +"')");                 //Heftname
                                    }
                    
            mySQL.schliesse_verbindung();
            
            
        }catch(Exception e) {
            System.out.println("firmen : Konnte keine Verbindung hergestellt werden");
                e.printStackTrace();
                
        }

danke für eure Hilfe und den ganzen Tipps

Ps. ich weiß ich muss mein Programm etwas ordentlicher gestalten mit Beschriftung und Aufteilung

 

[Mart]

Ps. ich weiß ich muss mein Programm etwas ordentlicher gestalten mit Beschriftung und Aufteilung

nicht unbedingt, die namensgebung ist ok soweit

methoden in java schreibt man eher nicht wie schliesse_verbindung()
sondern mit camelCase dh -> schliesseVerbindung()

ist halt vkonvention in PL SQL , ABAP oder java static final konstanten schreibt man mit unterstrich

zweitens '" + Heftname +"' hier hängst du hinten und vorne anführungs zeichen an

was ist wenn ich jetzt böse bin und den string hef't übergebe

dann wirft die SQL datenbank einen fehler weil

'hef't');

-> unerwartetes Zeichen "t"

weil ich den string zerschossen habe

wenn ich noch böser bin

über gebe ich
hef';DELETE * FROM abos:

dann steht bei dir das statement bis statement...hef';DELETE * FROM abos;'
jetzt schmiert die datenbank bei dem letzten ' ab aber das delete from wird dennoch ausgeführt

falls es dich interessiert -> SQL injection

um es zu verhindern immer prepared Statements verwenden -> hast du erst einmal

 

[Emrullah]

@Mart

was ist genau der unterschied zwischen einem normalten Statements und einem PreparedStatment.
könntest du es mir erklären
ich danke schonmal im vorraus

 

[Mart]

executeQuery("Select Count(ID),ID From abos Where "
                                                                        +" FirmenID ='"+ FirmenID
                                                                        +"'AND Heftname='"+ Heftname
                                                                        +"'AND Jahr='"+ Jahr
                                                                        +"'AND Ausgabe='"+Ausgabe+"'");

das ist ein Normales Statement -> es wird so in die Datenbank übergeben und nacheinander interpretiert
wenn jemand wie oben beschrieben "blöde" string werte eingibt kann man den String so setzen und dann einfach alles zerschießen => shclecht

ein prepared statement ist zb

prepareStatement( "INSERT name INTO myTable VALUE ?")
=> hier ist plötzlich ein frage zeichen wieso?

prepared auf deutsch heißt "vorbereitet" = > der string wird oben übergeben und von der Datenbank übersetzt ( falls fehlerhaft schmierts da ab)
der befehl liegt dann genau so vor in der Datenbank => kann nicht mehr durch "blöde strings" manipuliert werden

das fragezeichen ist ein Platzhalter das musst du selber googlen

da der befehl vorliegt auf der datenbank kannst du sagen
=> auf das prepared statement setz den wert "bob" ein => datenbank nimmt den fertigen befehl und setzt fürs fragezeichen bob ein
=> jetzt übergibst du "bob2" => datenbank machts wieder ohne wieder zu übersetzen und zu parsen => ist jaschon passiert

du bist sicherer da keine manipulation mehr möglich ist + das einsetzen der fragezeichen ist einfach nach 5 min googlen
+ du bist ungefähr um faktor 10 shcneller wenn du 1mio befehle als prepared statements vs normale statements benutzt

FÜR test code brauchst du keine prepared statements aber alles was in "Produktion" kommt sollte mindestens prepared statement sein

 

[Oneixee5]

Ein Count ohne Group By? Das ist nicht OK, es funktioniert vielleicht im Moment ... Auch die HeftID fehlt da irgendwie.
Zeig doch mal das DML der Tabelle, also den Bedehl "create table abos ..." oder wenigsten "desc abos". Offensichtlich benötigst du einen zusammengesetzten Primärschlüssel oder UNIQUE KEY.
Vermutlich muss das so aussehen:

INSERT INTO abos
    (FirmenID, HeftID, Ausgabe, Jahr, ABOZiel, Heftname)
VALUES
    (?,?,?,?,?,?)
ON DUPLICATE KEY UPDATE
    ABOZiel = ?;

Es würde bestimmt auch helfen den Quellcode ordentlich zu formatieren. Eine IDE kann das auch für dich machen.

 

[Mart]

INSERT INTO abos
    (FirmenID, HeftID, Ausgabe, Jahr, ABOZiel, Heftname)
VALUES
    (?,?,?,?,?,?)
ON DUPLICATE KEY UPDATE
    ABOZiel = ?;

soweit iser ja noch nicht