MySQL Class für Java Anwendungen

MySQL_Class sql = new MySQL_Class();
try {
    sql.mysqlConnect("user", "password", "localhost", "3306");
        Object[][] result = sql.mysqlArray("select * from table");
        for(int i=0; i<result.length; i  ) {
            for(int j=0; j<result[i].length; j  ) {
                System.out.println(result[i][j]);
            }
        }
    sql.mysqlDisconnect();
} catch(SQLException e) {
    System.out.println(e.toString());
}

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import java.sql.Statement;
import javax.swing.JTable;
 
    /**
     * MySQL Verbindungsklasse
     * @author Christian Blechert
     * @since 2008
     */
 
public class MySQL_Class {
    
// Attribute fuer externe Klassen
    private Connection connection = null;
    private Statement statement = null;
    private ResultSet result = null;
        private ResultSetMetaData meta = null;
 
    /**
     * Verbindung zum MySQL Server aufbauen
     * @param user Benutzername
     * @param pass Password zum Benutzernamen
     * @param host Name/IP Adresse des MySQL Servers
     * @param port Port auf den der Server horcht. Default: 3306
     * @throws java.sql.SQLException
     */
        public void mysqlConnect(String user, String pass, String host, String port) throws Exception {
            if(this.connection!=null) this.mysqlDisconnect();
            String conn = "jdbc:mysql://" host ":" port;
            
            Class.forName("com.mysql.jdbc.Driver").newInstance();
            this.connection = DriverManager.getConnection(conn, user, pass);
            this.statement = this.connection.createStatement();
        }
        
    /**
     * Trennt die Verbindung
     * Gibt bei Erfolg true zurueck
     * @throws java.sql.SQLException
     */
        public boolean mysqlDisconnect() throws SQLException {
            if(this.connection!=null) {
                if(this.result!=null)  {  this.result.close(); this.result=null; }
                if(this.statement!=null) { this.statement.close(); this.statement=null; }
                this.connection.close(); this.connection=null;
                return true;
            }
            return false;
        }
    
    /**
     * Auswaehlen einer Datenbank
     * @param db Datenbankname
     * @throws java.sql.SQLException
     */
        public void mysqlSelectDB(String db) throws SQLException {
            this.statement.execute("use `" db "`");
        }
        
    /**
     * Absenden eines MySQL Statements
     * @param query SQL Statement
     * @return Das ResultSet zu dem Statement
     * @throws java.sql.SQLException
     */
        public ResultSet mysqlQuery(String query) throws SQLException {
            this.result = this.statement.executeQuery(query);
            this.meta = this.result.getMetaData();
            return this.result;
        }
        
    /**
     * Absenden eines MySQL Updates
     * Zum veraendern und neu Erstellen von Daten
     * @param query MySQL Statement
     * @throws java.sql.SQLException
     */
        public void mysqlUpdate(String query) throws SQLException {
            this.statement.executeUpdate(query);
        }
        
    /**
     * Liefert das Result eines MySQL Statements als Array zurueck
     * @param query MySQL Statement
     * @return Result als Array
     * @throws java.sql.SQLException
     */
        public Object[][] mysqlArray(String query) throws SQLException {
            ResultSet res = this.mysqlQuery(query); int i=0;
            Object[][] result;
            try {
                result = new String[this.mysqlGetRows()][this.mysqlGetFields()];
            } catch(Exception e) {
                return null;
            }
            while(res.next()) {
                if(Runtime.getRuntime().freeMemory()<1000000) {
                    res.close();
                    res = null;
                    return null;
                }
                for(int j=0; j<this.mysqlGetFields(); j  ) {
                    result[i][j] = res.getString(j 1);
                } i  ;
            }
            return result;
        }
        
    /**
     * Daten aus einem JTable bei veraenderung in eine MySQL Datenbank schreiben
     * @param newValue neuer Wert der veraenderten Zelle
     * @param oldValue alter Wert der veranderten Zelle
     * @param x X-Koordinate der Zelle
     * @param y Y-Koordinate der Zelle
     * @param object Object des JTable
     * @throws java.sql.SQLException
     */
        public void updateJTable(Object newValue, Object oldValue, int x, int y, JTable object) throws SQLException {
            if(!newValue.equals(oldValue)) {
                String[] fn = this.mysqlGetFN();
                String query = "update `" this.mysqlGetTable(y 1) "` set `" fn[y] "` = '" newValue.toString() "' where";
                for(int i=0; i<this.mysqlGetFields(); i  ) {
                    if(i>0) query  = " and";
                    if(i==y) {
                        if(oldValue==null) {
                            query  = " `"   fn[i] "` is NULL";                        
                        } else {
                            query  = " `"   fn[i] "`='" oldValue "'";                        
                        }
                    } else {
                        if(object.getValueAt(x, i)==null) {
                            query  = " `"   fn[i] "` is NULL";
                        } else {
                            query  = " `"   fn[i] "`='" object.getValueAt(x, i) "'";
                        }
                    }
                }
                this.mysqlUpdate(query);
            }
        }
        
    /**
     * Verfuegbare MySQL Datenbanken als Array auslesen
     * @return Array mit den Datenbanknamen
     * @throws java.sql.SQLException
     */
        public String[] mysqlGetDBs() throws SQLException {
            this.mysqlQuery("show databases");
            String[] Array = new String[this.mysqlGetRows()];
            int i=0;
 
            while(this.result.next()) {
                Array[i] = this.result.getString(1); i  ;
            }
            return Array;
        }
        
    /**
     * Liefert alle Tabellen der aktuell ausgewaehlten Datenbank
     * @return Array mit den Tabellennamen
     * @throws java.sql.SQLException
     */
        public String[] mysqlGetTables() throws SQLException {
            this.mysqlQuery("show tables");
            String[] Array = new String[this.mysqlGetRows()];
            int i=0;
 
            while(this.result.next()) {
                Array[i] = this.result.getString(1); i  ;
            }
            return Array;
        }
        
    /**
     * Liefert den Tabellennamen einer Spalte aus dem aktuellen ResultSet
     * @param column Spaltennummer
     * @return Tabellennamen
     * @throws java.sql.SQLException
     */
        public String mysqlGetTable(int column) throws SQLException {
            return this.meta.getTableName(column);
        }
        
    /**
     * Liefert den Benutzernamen mit dem man am MySQL Server angemeldet ist
     * @return Benutzername
     * @throws java.sql.SQLException
     */
        public String mysqlGetUser() throws SQLException {
            String user = this.connection.getMetaData().getUserName();
            user = user.substring(0, user.indexOf("@"));
            return user;
        }
        
    /**
     * Liefert den Hostnamen des MySQL Servers
     * @return Hostname
     * @throws java.sql.SQLException
     */
        public String mysqlGetHost() throws SQLException {
            String host = this.connection.getMetaData().getURL();
            host = host.substring(host.indexOf("//") 2);
            return host;
        }
        
    /**
     * Liefert alle Feldnamen des Aktuellen ResultSets
     * @return Array mit den Feldnamen
     * @throws java.sql.SQLException
     */
        public String[] mysqlGetFN() throws SQLException {
            String[] fns = new String[this.mysqlGetFields()];
            for(int i=0; i<this.mysqlGetFields(); i  ) {
                fns[i] = this.meta.getColumnName(i 1);
            }
            return fns;
        }
        
    /**
     * Liefert die Feldnamen der angegebenen Tabelle
     * @param table Name der Tabelle
     * @return Array mit den Feldnamen
     * @throws java.sql.SQLException
     */
        public String[] mysqlGetFNfrom(String table) throws SQLException {
            this.mysqlQuery("desc `" table "`");
            String[] Array = new String[this.mysqlGetRows()];
            int i=0;
 
            while(this.result.next()) {
                Array[i] = this.result.getString(1); i  ;
            }
            return Array;
        }
        
    /**
     * Liefert naechsten Datensatz
     * @param col Spalte
     * @return Inhalt der Spalte als String
     * @throws java.sql.SQLException
     */
        public String mysqlGetNext(int col) throws SQLException {
            this.result.next();
            return this.result.getString(col);
        }
        
    /**
     * Anzahl der Datensaetze des ResultSets
     * @return Anzahl der Datensaetze
     * @throws java.sql.SQLException
     */
        public int mysqlGetRows() throws SQLException {
            this.result.last(); int rows = this.result.getRow(); this.result.beforeFirst();
            return rows;
        }
        
    /**
     * Anzahl der Spalten des ResultSets
     * @return Anzahl der Spalten
     * @throws java.sql.SQLException
     */
        public int mysqlGetFields() throws SQLException {
            return this.meta.getColumnCount();
        }
        
    /**
     * Gibt das aktuelle ResultSet zurueck
     * @return ResultSet
     */
        public ResultSet mysqlGetResult() {
            return this.result;
        }
        
    /**
     * Liefert die MetaData des aktuellen ResultSets zurueck
     * @return ResultSetMetaData
     */ 
        public ResultSetMetaData mysqlGetMeta() {
            return this.meta;
        }
        
    /**
     * Setzt ein neues ResultSet
     * @param res ResultSet
     * @throws java.sql.SQLException
     */
        public void mysqlSetResult(ResultSet res) throws SQLException {
            this.result = res;
            this.meta = res.getMetaData();
        }
        
}