Membuat Database Otomatis

import    java.awt.*;
import    java.awt.event.*;
import    javax.swing.*;
import    java.sql.*;

public    class Database
{
public Database()
{
try
{
int    DBInt    =    0;
Class.forName(“org.gjt.mm.mysql.Driver”);
Connection    connection    =    DriverManager.getConnection(
“jdbc:mysql://localhost/mysql”,”root”,”indra”);
Statement    statement    =    connection.createStatement();
String    showDB    =    “SHOW DATABASES”;
ResultSet    rs    =    statement.executeQuery(showDB);
rs.last();
int    n    =    rs.getRow();
String    DB[]    =    new    String[n];
rs.beforeFirst();
int    p    =    0;
while(rs.next())
{
DB[p]    =    rs.getString(1);
if(“kampus”.equals(DB[p]))
DBInt    =    1;
p++;
}

if(DBInt == 1)
{
int    flag    =    1;
flag    =    JOptionPane.showConfirmDialog(null,”Database kampus”+
” sudah ada,\nApakah anda ingin me-replacenya dengan data”+
“base yang baru?”,”Pertanyaan”,JOptionPane.YES_NO_OPTION);
if(flag == 0)
{
String    dropDB    =    “DROP DABASE IF EXISTS kampus”;
statement.executeUpdate(dropDB);
JOptionPane.showMessageDialog(null,”Database yang lama “+
“telah dihapus”,”Pemeberitahuan”,
JOptionPane.INFORMATION_MESSAGE);
buatDatabase();
}
else
{
JOptionPane.showMessageDialog(null,”Database kampus tidak ja”+
“di buat”,”Pemberitahuan”,
JOptionPane.INFORMATION_MESSAGE);
}
DBInt    =    0;
}
else
{
int    flag    =    1;
flag    =    JOptionPane.showConfirmDialog(null,”Database kampus”+
” belum ada,\nApakah anda ingin membuatnya?”,”Pertanyaan”,
JOptionPane.YES_NO_OPTION);
if(flag == 0)
{
buatDatabase();
}
else
{
JOptionPane.showMessageDialog(null,”Database kampus tidak ja”+
“di buat”,”Pemberitahuan”,
JOptionPane.INFORMATION_MESSAGE);
}
}
statement.close();
connection.close();
}
catch(Exception e)
{
JOptionPane.showMessageDialog(null,”Error”,”Error”,
JOptionPane.ERROR_MESSAGE);
}
}

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

public void buatDatabase()
{
try
{
Class.forName(“org.gjt.mm.mysql.Driver”);
Connection    connection    =    DriverManager.getConnection(
“jdbc:mysql://localhost/mysql”,”root”,”indra”);
Statement    statement    =    connection.createStatement();
String    kampusDB    =    “CREATE DATABASE kampus”;
statement.executeUpdate(kampusDB);
String    useDB    =    “USE kampus”;
statement.executeUpdate(useDB);
statement.executeUpdate(“FLUSH PRIVILEGES”);
String    mhsTbl    =    “CREATE TABLE mahasiswa (nim VARCHAR(10) PRIMA”+
“RY KEY, nama VARCHAR(100) NOT NULL);”;
statement.executeUpdate(mhsTbl);
JOptionPane.showMessageDialog(null,”Database kampus beserta tablenya”+
” sudah berhasil dibuat”,”Pemeberitahuan”,
JOptionPane.INFORMATION_MESSAGE);
statement.close();
connection.close();
}
catch(Exception e)
{
JOptionPane.showMessageDialog(null,”Error pada fungsi buatDatabase”,
“Error”,JOptionPane.ERROR_MESSAGE);
}
}
}