Cara koneksi java dengan data base mysql beserta CRUD (Read/select, Insert, Update, dan Delete)

Pertama, kita pastikan sudah menginstall aplikasi xampp, dan telah membuat data base. Disini database yang saya buat bernama “javadbc”. Dan jangan lupa membuat table baru, saya beri nama "identitas" yang berisi 2 kolom yaitu nama dan nim. saya hanya memberikan sedikit gambar, mungkin teman-teman juga sudah sangat faham cara menggunakan aplikasi xampp.

Lalu pada aplikasi Netbeans kita buat kelas koneksi, dan jangan lupa tambahkan library MySQL JDBC Driver, dengan klik kanan pada library >> add library.

Setelah itu kita buka kelas koneksi yang telah kita buat tadi, juga perlu kita import berikut ini :

package TUGAS6;

import java.io.*;

import java.sql.*;

kedua, pada kelas koneksi isikan jdbc driver, url, user, pass, dan lain-lain. Gunanya agar bisa di akses seluruh yang ada pada kelas ini.

public class koneksi {

    static final String JDBC_DRIVER = "com.mysql.jdbc.Driver";

    static final String url = "jdbc:mysql://localhost/javadbc";

    static final String user = "root";

    static final String pass = "";

    static InputStreamReader inputStreamReader = new InputStreamReader(System.in);

    static BufferedReader input = new BufferedReader(inputStreamReader);

    public static Connection con;

    public static Statement stm;

    static ResultSet rs;

}

Kita buat method bernama insertIdentitas, yang kita gunakan sebagai proses insert data ke dalam data base, meliputi inputan nama dan nim. 

static void insertIdentitas() {

        try {

           

            // ambil input dari user

            System.out.println("\n=============================");

            System.out.println("Insert ");

            System.out.println("NIM: ");

            int nim = Integer.parseInt(input.readLine().trim());

            System.out.println("Nama: ");

            String nama = input.readLine().trim();

            // query simpan

            String sql = "INSERT INTO identitas (nim, nama) VALUE('%s', '%s')";

            sql = String.format(sql, nim, nama);

            // simpan

            stm.execute(sql);

            System.out.println("Data Berhasil di Tambah ");

        } catch (Exception e) {

            System.err.println("\nInsert gagal" + e.getMessage());

        }

    }

Method yang kedua bernama updateIdentitas, yang kita gunakan untuk memproses update data yang ada pada database. Nanti kita menginputkan nim yang sudah ada dalam database(yang akan kita update), lalu menginputkan nama baru yang akan kita masukkan dalam data tersebut.

static void updateIdentitas() {

        try {

            System.out.println("=============================");

            System.out.println("Update");

            // ambil input dari user

            System.out.println("nim yang mau diedit: ");

            int nim = Integer.parseInt(input.readLine());

            System.out.println("nama baru: ");

            String nama = input.readLine().trim();

          

            // query update

            String sql = "UPDATE identitas SET nama='%s' WHERE nim=%d";

            sql = String.format(sql, nama, nim);

            // update data

            stm.execute(sql);

        System.out.println("Data Berhasil di Update ");

        } catch (Exception e) {

            System.err.println("update gagal" + e.getMessage());

        }

    }

 

Yang ke tiga kita buat method deleteIdentitas, yang kita gunakan untuk memproses delete data dalam database yang ada. Dalam proses delete ini kita hanya menginputkan nim saja.

static void deleteIdentitas() {

        try {

            System.out.println("=============================");

            System.out.println("Delete");

            // ambil input dari user

            System.out.println("nim yg mau di hapus: ");

            int nim = Integer.parseInt(input.readLine());

           

            // buat query hapus

            String sql = String.format("DELETE FROM identitas WHERE nim=%d", nim);

            // hapus data

            stm.execute(sql);

           

            System.out.println("Data telah terhapus...");

        } catch (Exception e) {

            System.err.println("delete gagal" + e.getMessage());

        }

    }

}

Dan yang terakhir adalah pada main, kita disini menuliskan koding untuk proses koneksi dan read data.

Sedangkan  insert, update, dan delete yang kita panggil dari method yang telah kita buat.

public static void main(String[] args) throws SQLException {

        try {

            con = DriverManager.getConnection(url, user, pass);

            stm = con.createStatement();

            System.out.println("koneksi berhasil;");

           

        } catch (Exception e) {

            System.err.println("koneksi gagal" + e.getMessage());

        }

       

//READ/SELECT 

       

    ResultSet rs = stm.executeQuery("SELECT * FROM identitas");

    System.out.println("\nData Identitas ");

    while (rs.next()){

       

        int nim=rs.getInt("nim");

        String nama=rs.getString("nama");

        System.out.format(nama +" "+nim+"\n ");

    }

    //stm.close();

    insertIdentitas();

    updateIdentitas();

    deleteIdentitas();

    }

berikut adalah hasil outputnya :

 semoga bermanfaat.. :)