Java : Koneksi ke Database Menggunakan MySQL

Last Updated on 8 years ago by Mas Herdi

Kali ini saya akan membahas tutorial untuk menyambungkan aplikasi ini dengan database MySQL. Yang dibahas di sini adalah hal-hal dasar, seperti menyambungkan aplikasi ke database MySQL java.sql.Connection, mengeksekusi query menggunakan Statement dan menampilkan hasilnya menggunakan ResultSet. Tutorial ini dibuat menggunakan NetBeans IDE, untuk mencoba jangan lupa terlebih dahulu men-copy-kan MySQL Driver yang dapat diunduh di sini, ke dalam folder project Anda.

/**
*
*@authorHerdi Naufal
*/

import java.sql.SQLException;
import java.util.Properties;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
import java.sql.Connection;
import static java.lang.System.*;
public class Database {
    public static void main(String[] args){
            //Memanggil program dengan menspesifikasikan url database, username dan password
            new DB().connectDB("jdbc:mysql://localhost:3306/gangguan","root","");
        }
}

class DB{
        public void connectDB(String db_url, String db_username, String db_password){
                    try {
                        //Membuat sambungan ke database
                        Connection sambungan = null;

                        //instantiasi Driver
                        Class.forName("com.mysql.jdbc.Driver").newInstance();

                        //Membuat ResultSet untuk menampung hasil
                        ResultSet rs;

                        //Membuat Statement untuk mengeksekusi query
                        Statement stmt;

                        //Query String
                        String query = "select * from gangguan";

                        //Connection Properties, menspesifikasikan username dan password
                        Properties connectionProps = new Properties();
                        connectionProps.put("user", db_username);
                        connectionProps.put("password", db_password);

                        sambungan = DriverManager.getConnection(db_url,connectionProps);
                        stmt = sambungan.createStatement();
                        rs = stmt.executeQuery(query);

                        if(!sambungan.isClosed())
                        {
                            out.println("Connected");
                        }
                        out.println("Hasil eksekusi : " + query + " adalah");
                        while(rs.next())
                        {
                            out.println(""+rs.getString("alamat") +" "+rs.getString("pelanggan")+" ");
                        }

                }
                catch(Exception e)
                {
                    if(e.equals(new SQLException()))
                    {
                        SQLException eSQL = (SQLException)e;
                        out.println(eSQL.getMessage());
                        eSQL.getErrorCode();

                    }

                }

     }
}
 

Test Running