import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
public class MySQL_Anbindung{
//Dieses Unterprogramm wird für Update und Insert Befehle verwendet
public void Datenbank_Insert_Update_Zugriff(String sql){
try {
//es wird einen Verbindungsbrücke geschaffen damit das Programm mit der Datenbank Komunizieren kann
Class.forName( "com.mysql.jdbc.Driver" );
//Hier wird die Verbindung festgelegt
Connection con = DriverManager.getConnection( "jdbc:mysql://127.0.0.1:3306/Datenbankname", "Benutzer", "Passwort" );
Statement stmt = con.createStatement();
stmt.executeUpdate(sql);
stmt.close();
con.close();
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (SQLException e) {
e.printStackTrace();
}
}
//Dieses Unterprogramm wird für Select zugriffe verwendet
public ResultSet Datenbank_Select_Zugriff(String sql)
{
try {
//es wird einen Verbindungsbrücke geschaffen damit das Programm mit der Datenbank Komunizieren kann
Class.forName( "com.mysql.jdbc.Driver" );
//Hier wird die Verbindung festgelegt
Connection con = DriverManager.getConnection( "jdbc:mysql://127.0.0.1:3306/Datenbankname", "Benutzer", "Passwort" );
Statement stmt = con.createStatement();
ResultSet rs1;
rs1 = stmt.executeQuery(sql);
return rs1;
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (SQLException e) {
e.printStackTrace();
}
return null;
}
}
