Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import java.sql.Connection;
- import java.sql.DriverManager;
- import java.sql.ResultSet;
- import java.sql.SQLException;
- import java.sql.Statement;
- public class MySQL {
- private static Connection con;
- public MySQL(String Host, String Port, String Database, String Username, String Password) {
- if (isConnected()) { System.out.println("Die Verbindung zu MySQL wurde schon Hergestellt!"); return; }
- try {
- con = DriverManager.getConnection("jdbc:mysql://" + Host + ":" + Port + "/" + Database, Username, Password);
- } catch (SQLException e) { e.printStackTrace(); }
- }
- public static boolean isConnected() { return (con == null ? false : true); }
- public static void disconnect() {
- if (isConnected()) {
- try {
- con.close();
- } catch (SQLException e) { e.printStackTrace(); }
- } else { System.out.println("Es gibt keine Verbindung zu einer MySQL Datenbank!"); }
- }
- public static void update(String qry) {
- try {
- Statement statement = con.createStatement();
- statement.executeUpdate(qry);
- statement.close();
- } catch (SQLException e) { e.printStackTrace(); }
- }
- public static ResultSet query(String qry) {
- ResultSet resultSet = null;
- try {
- Statement statement = con.createStatement();
- resultSet = statement.executeQuery(qry);
- } catch (SQLException e) {
- e.printStackTrace();
- }
- return resultSet;
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement