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ö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ügt:
	public void updateDatabase(String whatever) throws SQLException {
		s = conn.createStatement();
		s.executeUpdate(whatever);
	}

	// Methode, die die Anzahl der Datensätze der Tabelle zurückgibt:
	public int getRowCount(String table) throws SQLException {
		s = conn.createStatement();
		ResultSet rs = s.executeQuery("Select * From " + table);
		rs.last();
		return rs.getRow();
	}

}