Java mit mysql verbinden

Guten Tag,

ich möchte gerne wissen wie ich mein Java programm mit Mysql verbinden kann. Ich habe vieles durchgelesen und nicht verstanden.

Ich bin gerade dabei etwas zu programmieren und komme nicht weiter. Und zwar hat mein Programm das Objekt z.B kunde. Der Kunde hat viele attribute wie z.B adresse, plz und geburtsdatum. Wie kann ich beim start des programms die daten auslesen und in einen HashSet Kunde speichern ?

Mit freundlichen Grüßen

Master147

Hier kann ich mein code zum speichern und laden in text dateien zeigen.

public void auftragLaden() 
    {
        try(FileInputStream fops = new FileInputStream("Auftraege"); ObjectInputStream oos = new ObjectInputStream(fops))
        {
            System.out.println(auftrag = (HashSet<Auftrag>) oos.readObject())  ;
        }
        catch (IOException e) 
        {
            
        } 
        catch (ClassNotFoundException e)
        {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
    
    public void auftragSpeichern()
    {
        try(FileOutputStream fops = new FileOutputStream("Auftraege"); ObjectOutputStream oos = new ObjectOutputStream(fops))
        {
                oos.writeObject(auftrag);
        }
        catch(Exception e)
        {
            e.printStackTrace();
        }
    }

Muss ich dafür etwas installieren, da das Import java.sql nicht erkannt wird bei mir.

Zitat von Mogly1

Heyho, also ich habe mir das damals so geschrieben.

Bin jetzt kein Experte in Java, also evtl. geht es cleaner :D. (geht es ja fast immer)

MySQL klasse:

Spoiler anzeigen

Java

package Mysql; // anpassen

import java.sql.*;

public class mysql {
    
    private static String url = "jdbc:mysql://Ip/DatenBank"; //Serverip und Datenbank auswählen
    private static String user = "root";
    private static String pass = "password";
    private static Connection con = null;

    public static void main(String[] args){
        
    }
    
    public static void close()// schließt die Mysql Conenction con und setzt sie wieder auf null (falls es nicht geht, gibt es ein Mysql fehler aus)
    {
        try {
            if(!con.isClosed())
            {
                con.close();
                con = null;
                System.out.println("Database closed");
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
    
    public static PreparedStatement prepareStatement(String s)
    {
        try {
            return con.prepareStatement(s);
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
            return null;
        }
    }
    
    public static Statement createStatement()
    {
        try {
            return con.createStatement();
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
            return null;
        }
    }
    
    public static boolean open() //Öffnet eine verbindun, falls keiner existiert. dafür nutzen fir die Conenction con variable.
    {
        if(con != null)return true;
        try {
            con = DriverManager.getConnection(url, user, pass);
            System.out.println("Database connected");
        }
        catch (SQLException e) {
            System.out.println(e.getMessage());
            return false;
        }
        return true;
    }
}

Alles anzeigen

Dann kannst du in deinem Programm das ganz einfach nutzen wie hier z.B.:

Spoiler anzeigen

Java

package Mysql;

import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class programm {

    public static void main(String[] args){
        auftragLaden();
    }
    
    public static void auftragLaden()
    {
        if(!mysql.open())return;
        try
        {
            Statement stm = mysql.createStatement();
            String query = "SELECT * FROM Tabelle";
            
            ResultSet rs = stm.executeQuery(query);
            while(rs.next()){
                //rs.getInt("SpaltenName aus der Tabelle"), achte gleich auf die werte ob Int, String, boolean
                System.out.println(rs.getInt("ID") + " " +
                        rs.getString("Name")); //Bsp.
            }
            
            mysql.close();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
    
    public static void auftragSpeichern()
    {
        if(!mysql.open())return;
        try
        {
            String query = "UPDATE Tabelle SET Thema = ? WHERE ID = ?";  
            PreparedStatement ps = mysql.prepareStatement(query);
            
            // ps.setString(a,b) a = welches Fragezeichen aus der query fängt bei 1. b = der wert für das Fragezeichen geht auch setString und co.
            ps.setInt(1, 99);
            ps.setInt(2, 4); //beispiele
            
            ps.executeUpdate();
            System.out.println("Mysql Updated");
            mysql.close();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
    
    public static void auftragErstellen()
    {
        if(!mysql.open())return;
        try
        {
            String query = "INSERT INTO Tabelle (Regel, Thema) VALUES (?, ?)";  
            PreparedStatement ps = mysql.prepareStatement(query);
            
            // ps.setString(a,b) a = welches Fragezeichen aus der query fängt bei 1. b = der wert für das Fragezeichen 
            ps.setString(1, "Nicht bei Rot fahren");
            ps.setInt(2, 108); //beispiele
            
            ps.executeUpdate();
            System.out.println("Mysql Insert");
            
            mysql.close();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
    
}

Alles anzeigen

kleiner eklärung dazu:

Spoiler anzeigen

Code

Erkärung noch evtl. weil du meintest nciht verstanden:

Verbindung aufbauen tuhen wir hiermit:

    private static String url = "jdbc:mysql://Ip/DatenBank"; //Serverip und Datenbank auswählen
    private static String user = "root";
    private static String pass = "password";
    private static Connection con = null;
    
    try {
            con = DriverManager.getConnection(url, user, pass);
            System.out.println("Database connected");
    }
    catch (SQLException e) {
            System.out.println(e.getMessage());
            return false;
    }
    
wichtig ist immer,w enn wir mit mysql fertig sind die conenction weider zuschließen.
dafür nutzen wir dann

    con.close();
    
mit 
    co.prepareStatement(query);
    
    können wir noch die ? ersetzen und somit mit unseren values füllen
    
und am ende

    con.createStatement();
    
    damit erstellen wir einfach eine feste query abfrage
    
    
    
ich habe das als Klasse ausgelagert, damit man leichtere übersicht hat und man es noch als Object anpassen kann für verschiedene Datenbanken...

Alles anzeigen

Alles anzeigen

Ich nutze auch Eclipse nur nutze ich ein Macbook deshalb kann ich keine JDBC Driver fürn Mac finden. Hat vielleicht jemand eine Idee ?