Wie kann man eine MySQL-Datenbank anlegen?

Im Beispiel wird eine MySQL Datenbank mit dem Namen TestDB auf localhost erzeugt. Hierzu werden nach dem Laden des JDBC-Treibers in einem statischen Block im Konstruktor nacheinander zwei Methoden aufgerufen und dann ein Shutdown Hook erzeugt, um eine eventuell noch geöffnete Datenbankverbindung zu schließen.

Die erste Methode createConnection() erzeugt die Verbindung zum Datenbank-Host, indem es ein Objekt vom Typ java.sql.Connection initialisiert. Hierzu wird die URL mit dem Argument rewriteBatchedStatements=true erzeugt. Es bewirkt, dass mehrere Datenbank-Anfragen in einem Netzwerk-Paket verwendet werden können und somit die Geschwindigkeit erheblich gesteigert werden kann.
Die erzeugte Verbindung wird verwendet, um in der Methode createDBStructure() die Datenbank anzulegen. Hierzu werden zunächst vier SQL-Queries als String erzeugt. Sie führen das eigentliche Anlegen der Datenbank auf der Ebene des DBMS durch.
Innerhalb eines try-catch-Blockes wird dann zunächst der auto-commit-Modus auf false gesetzt. Dies bewirkt, dass die Queries nicht einzeln ausgeführt, sondern in gruppierten Transaktionen gebündelt werden. Die Ausführung muss deshalb am Schluss mit connecion.commit() 'manuell' angestoßen werden. Vorher werden dem statement-Objekt die einzelnen Anweisungen duch die Methode addBatch() übergeben.

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;

public class CreateDB {

    private Connection connection;

    static {
        try {
            Class<?> c = Class.forName("com.mysql.jdbc.Driver");
            if (c != null) {
                System.out.println("JDBC-Treiber geladen");
            }
        } catch (ClassNotFoundException e) {
            System.err.println("Fehler beim Laden des JDBC-Treibers");
            System.exit(1);
        }
    }

    public CreateDB() {
        createConnection();
        createDBStructure();
        Thread shutDownHook = new Thread() {
            public void run() {
                System.out.println("Running shutdown hook");
                if(connection == null) System.out.println("Connedtion to database already closed");
                try {
                    if (connection != null && !connection.isClosed()) {
                        connection.close();
                        if (connection.isClosed())
                            System.out.println("Connection to database closed");
                    }
                } catch (SQLException e) {
                    System.err.println(
                            "Shutdown hook couldn't close database connection.");
                }
            }
        };
        Runtime.getRuntime().addShutdownHook(shutDownHook);
    }

    private void createConnection() {
        String url = "jdbc:mysql://localhost/?rewriteBatchedStatements=true";
        String user = "root";
        String pass = "";
        try {
            System.out.println("Creating DBConnection");
            connection = DriverManager.getConnection(url, user, pass);
        } catch (SQLException e) {
            System.err.println("Couldn't create DBConnection");
            System.exit(1);
        }
    }

    private boolean createDBStructure() {
        String dbName = "TestDB";

        String query0 = "CREATE DATABASE IF NOT EXISTS `" + dbName + "`";

        String query1 = "USE `" + dbName + "`";

        String query2 = "SET SQL_MODE='NO_AUTO_VALUE_ON_ZERO'; ";

        String query3 = "CREATE TABLE IF NOT EXISTS `Studenten` ("
                + "`Name` varchar(100) NOT NULL DEFAULT '', "
                + "`Vorname` varchar(100) NOT NULL DEFAULT '', "
                + "`ID` varchar(50) NOT NULL, " + "UNIQUE KEY `ID` (`ID`)"
                + ") ENGINE=MyISAM DEFAULT CHARSET=utf8 "
                + "DEFAULT COLLATE=utf8_german2_ci";

        Statement stmt = null;
        try {
            connection.setAutoCommit(false);
            stmt = connection.createStatement();
            stmt.addBatch(query0);
            stmt.addBatch(query1);
            stmt.addBatch(query2);
            stmt.addBatch(query3);
            stmt.executeBatch();
            connection.commit();
            stmt.close();
            connection.close();
            System.out.println("Database successfully created or just existing");
            return true;
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            try {
                if (stmt != null)
                    stmt.close();
                if (connection != null)
                    connection.close();
            } catch (SQLException e) {
            }
        }
        return false;
    }

    public static void main(String[] args) {
        new CreateDB();
    }
}