55 lines
1.5 KiB
Java
55 lines
1.5 KiB
Java
|
package package1;
|
|||
|
|
|
|||
|
|
import java.sql.Connection;
|
|||
|
|
import java.sql.Statement;
|
|||
|
|
import java.sql.SQLException;
|
|||
|
|
import java.sql.ResultSet;
|
|||
|
|
import com.mysql.jdbc.jdbc2.optional.MysqlDataSource;
|
|||
|
|
|
|||
|
|
// Diese Klasse ist f<>r die Verbindung zur Datenbank
|
|||
|
|
public class MySQLConnector {
|
|||
|
|
|
|||
|
|
private MysqlDataSource ds;
|
|||
|
|
private Connection conn;
|
|||
|
|
private Statement s;
|
|||
|
|
|
|||
|
|
// Erstellen des Konstruktors mit den richtigen Daten:
|
|||
|
|
public MySQLConnector(String user, String pw, String server, String db) {
|
|||
|
|
ds = new MysqlDataSource();
|
|||
|
|
ds.setUser(user);
|
|||
|
|
ds.setPassword(pw);
|
|||
|
|
ds.setServerName(server);
|
|||
|
|
ds.setDatabaseName(db);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public void connect() throws SQLException { // Methode, die die Verbindung zur Datenbank herstellt
|
|||
|
|
conn = ds.getConnection();
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public void disconnect() throws SQLException { // Methode, die die Verbindung zur Datenbank aufl<66>st
|
|||
|
|
s.close();
|
|||
|
|
conn.close();
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// Methode, die den eingegebenen SQL Befehl auf die Datenbank anwendet:
|
|||
|
|
public ResultSet executeQuery(String query) throws SQLException {
|
|||
|
|
s = conn.createStatement();
|
|||
|
|
ResultSet rs = s.executeQuery(query);
|
|||
|
|
return rs;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// Methode, das einen neuen Datensatz in die Datenbank einf<6E>gt:
|
|||
|
|
public void updateDatabase(String whatever) throws SQLException {
|
|||
|
|
s = conn.createStatement();
|
|||
|
|
s.executeUpdate(whatever);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// Methode, die die Anzahl der Datens<6E>tze der Tabelle zur<75>ckgibt:
|
|||
|
|
public int getRowCount(String table) throws SQLException {
|
|||
|
|
s = conn.createStatement();
|
|||
|
|
ResultSet rs = s.executeQuery("Select * From " + table);
|
|||
|
|
rs.last();
|
|||
|
|
return rs.getRow();
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
}
|