OPERASI CRUD PADA JAVA
CRUD adalah singkatan dari Create, Read, Update, dan Delete. Proses ini sangat
berkaitan dengan pengambilan atau transaksi data dari atau ke database. Hal ini menjadi
krusial apabila berhubungan dengan sistem informasi perusahaan karena data yang
diproses biasanya merupakan data transaksi.
Bagi Java Developer, operasi CRUD biasanya menjadi pillar untuk mempelajari
proses pengelolaan data menggunakan Java dan tentu saja MySQL database. CRUD bisa
diibaratkan sebagai jalur atau koneksi yang menghubungkan antara bahasa
pemrograman Java dengan MySQL.
Lebih jelasnya, berikut ini ulasan operasi CRUD beserta contohnya:
• Create (C) merupakan proses pembuatan data baru. Proses ini biasanya
dilakukan ketika mendaftar pada sebuah halaman website. Data yang
dimasukkan akan disimpan di dalam database menggunakan operasi Create.
• Read (R) merupakan proses pengambilan data dari database. Proses ini biasanya
terjadi ketika melakukan proses login di halaman aplikasi tertentu. Saat klik
tombol “Login” maka aplikasi akan menjalankan proses “Read” untuk melakukan
verifikasi akun yang di gunakan. Contoh operasi yang lebih sederhana yaitu
ketika mengakses sebuah aplikasi, saat itu pula proses Read berjalan. Hasil dari
operasi ini adalah tampilan halaman aplikasi yang terlihat.
• Update (U) adalah proses mengubah data yang berada di dalam database. Contoh
proses ini ketika mengubah data di dalam aplikasi. Saat klik “Ubah”, aplikasi akan
mengirimkan proses Update ke dalam database. Kemudian database meresponnya
dengan mengubah data lama menjadi data baru yang ditambahkan.
• Delete (D) adalah proses untuk menghapus data yang ada di database. Proses ini
mirip dengan Update, bedanya, proses Delete akan mengubah data yang ada di
database menjadi ‘tidak ada’.
Cara Menghubungkan Java dengan MySQL?
Menghubungkan Java dengan MySQL dibutuhkan JDBC (Java Data Base
Connectivity). JDBC bertugas menyediakan koneksi ke database, sehingga kita bisa
mengakses dan mengelola datanya dari program Java.
Ada beberapa istilah yang harus dipahami dalam JDBC:
• DriverManager: sebuah class yang mengelola dirver;
• Driver: interface yang menangani komunikasi dengan database.
• Connection: interface yang menyediakan method untuk menghubungi
database;
• Statement: inteface untuk mengeksekusi query;
• ResultSet: interface untuk menampung data hasil query.
Langkah-langkah menghubungkan Java dengan MySQL:
1. Impor package [Link].*;
2. Daftarkan driver atau pilih driver yang akan digunakan;
3. Buat Sebuah Koneksi;
4. Exsekusi sebuah Query;
5. Tutup koneksi dan selesai.
Program Java dan MySQL
Silahkan buat proyek Java Application di Netbeans.
Berikan nama: belajar-java-mysql.
Sebelum mulai coding, siapkan dulu databasenya.
Buka browser, ketikkan localhost/phpMyAdmin. Kemudian tekan enter, sehingga
akan muncul tampilan seperti berikut:
Silahkan buat database baru bernama perpustakaan, seperti pada gambar berikut:
Setelah itu buat tabel bernama buku.
Pada menu SQL, ketikkan query berikut ini:
CREATE TABLE buku (
id_buku INT NOT NULL AUTO_INCREMENT ,
judul VARCHAR(45) NOT NULL ,
pengarang VARCHAR(45) NOT NULL ,
PRIMARY KEY (id_buku)
);
Setelah itu coba isi dengan beberapa data.
INSERT INTO buku (judul, pengarang)
VALUES
('Belajar Pemrograman Java dari Nol', 'Andi Lau),
('Pemrograman Java Menggunakan Linux', 'Andi Lau)
Selanjutnya kita akan mencoba menghubungkan program yang sudah kita buat
dengan database perpustakaan. Berikut kode programnya:
package [Link];
// import bumbu-bumbu yang diperlukan
import [Link];
import [Link];
import [Link];
import [Link];
// bisa juga diimpor sekaligus seperti ini:
// import [Link].*
public class BelajarJavaMysql {
// Menyiapkan paramter JDBC untuk koneksi ke datbase
static final String JDBC_DRIVER = "[Link]";
static final String DB_URL = "jdbc:mysql://localhost/perpustakaan";
static final String USER = "root";
static final String PASS = "kopi";
// Menyiapkan objek yang diperlukan untuk mengelola database
static Connection conn;
static Statement stmt;
static ResultSet rs;
public static void main(String[] args) {
// Melakukan koneksi ke database
// harus dibungkus dalam blok try/catch
try {
// register driver yang akan dipakai
[Link](JDBC_DRIVER);
// buat koneksi ke database
conn = [Link](DB_URL, USER, PASS);
// buat objek statement
stmt = [Link]();
// buat query ke database
String sql = "SELECT * FROM buku";
// eksekusi query dan simpan hasilnya di obj ResultSet
rs = [Link](sql);
// tampilkan hasil query
while([Link]()){
[Link]("ID Buku: " + [Link]("id_buku"));
[Link]("Judul: " + [Link]("judul"));
[Link]("Pengarang: " +
[Link]("pengarang"));
}
[Link]();
[Link]();
} catch (Exception e) {
[Link]();
}
Program masih belum dapat dieksekusi, karena library MySQL JDBC Driver belum
kita tambahkan ke dalam proyek. Jika tetap dieksekusi, maka akan muncul error
ClassNotFoundException: [Link].
Selanjutnya, untuk menambahkan library MySQL JDBC Driver , klik kanan
pada Libraries, lalu pilih Add Library dan MySQL JDBC Driver:
Tekan Shift+F6 atau klik kanan–>Run File.
Kita telah berhasil menghubungkan program Java dengan database MySQL dan
menampilkan datanya. Namun untuk penjelasan kode program yang lebih detail
sebagai berikut:
Pertama dimulai dari mengimpor
// import bumbu-bumbu yang diperlukan
import [Link];
import [Link];
import [Link];
import [Link];
Kode di atas maksudnya adalah mengimpor class dan interface yang dibutuhkan.
Bisa juga disingkat seperti ini:
import [Link].*;
Setelah mengimpor, selanjutnya siapkan dulu sebuah konstanta untuk parameter yang
akan digunakan saat membuat koneksi ke database.
// Menyiapkan paramter JDBC untuk koneksi ke datbase
static final String JDBC_DRIVER = "[Link]";
static final String DB_URL = "jdbc:mysql://localhost/perpustakaan";
static final String USER = "root";
static final String PASS = "kopi";
DB_URL menyatakan URL server database dan database yang akan digunakan.
Lalu USER untuk username databasenya dan PASS untuk password.
Jika tidak pakai password, kosongkan saja nilai PASS.
static final String PASS = "";
Sebelum mulai membuat koneksi ke server, harus menentukan dulu driver yang akan
digunakan.
// register driver yang akan digunakan
[Link](JDBC_DRIVER);
Dalam contoh tersebut, digunakan driver "[Link]" untuk
database MySQL.
Sedangkan untuk database yang lain, beda lagi drivernya.
• MySQL
Driver: [Link],
URL: jdbc:mysql://hostname/databaseName;
• ORACLE
Driver: [Link],
URL jdbc:oracle:thin:@hostname:portNumber:databaseName;
• DB2
Driver: [Link].DB2Driver,
URL: jdbc:db2:hostname:portNumber/databaseName
• Sybase
Driver: [Link],
URL: jdbc:sybase:Tds:hostname:portNumber/databaseName
Setelah memilih driver, selanjutnya lakukan koneksi ke database dengan parameter
yang sudah dibuat.
// buat koneksi ke database
conn = [Link](DB_URL, USER, PASS);
Kalau koneksinya gagal, biasanya akan terjadi SQLException.
Selanjutnya kita membutuhkan objek Statement untuk mengeksekusi Query MySQL.
// buat objek statement
stmt = [Link]();
Setelah itu, buat sebuah Query, eksekusi, dan hasilnya akan disimpan ke dalam
objek rs (ResultSet).
// buat query ke database
String sql = "SELECT * FROM buku";
// eksekusi query dan simpan hasilnya di obj ResultSet
rs = [Link](sql);
Method executeQuery() akan menghasilkan nilai kembalian berupa
objek ResultSet. Method ini biasanya digunakan untuk mengambil data dari
database.
Selain itu ada juga method untuk eksekusi query simpan, update, batch, dsb.
Tips: Tekan tobol Ctrl + Spasi saat menulis kode untuk melihatnya.
Setelah mendapatkan data dari database MySQL, selanjutnya kita bisa tampilkan
dengan perulangan.
// tampilkan hasil query
while([Link]()){
[Link]("ID Buku: " + [Link]("id_buku"));
[Link]("Judul: " + [Link]("judul"));
[Link]("Pengarang: " + [Link]("pengarang"));
}
Perulangan tersebut akan mengulang sebanyak isi tabelnya, atau dengan kata lain
“Ulangi selama rs masih punya isi”.
Cara mengambil nilai dari objek rs menggunakan method get* dengan parameter
nama kolom di tabel database.
Contoh mau ambil id buku yang bertipe Integer:
int idBuku = [Link]("id_buku");
Jika ingin mengambil dengan tipe String tinggal diganti methodnya:
String idBuku = [Link]("id_buku");
Pastikan paramternya sama persis dengan nama kolom di database. Jika di database
pakai huruf kapital, ya ikuti pakai huruf kapital.
Terakhir tutup Statement dan koneksi dengan kode berikut.
[Link]();
[Link]();
Membuat Program CRUD Java dan MySQL
Program CRUD adalah program yang mampu melakukan operasi Create, Read, Update,
dan Delete. Suatu program dasar untuk memahami pemrograman database.
Silahkan buat Class baru di dalam proyek yang tadi dengan nama JavaCRUD. Isi Class
tersebut dengan fungsi-fungsi atau method untuk melakukan CRUD. Impor library
yang dibutuhkan:
import [Link];
import [Link];
import [Link];
import [Link];
import [Link];
import [Link];
Class BuffereReader dan InputStreamReader dibutuhkan untuk mengambil
input dari keyboard. Seteleh itu, siapkan parameter, variabel, dan objek yang
dibutuhkan.
static final String JDBC_DRIVER = "[Link]";
static final String DB_URL = "jdbc:mysql://localhost/perpustakaan";
static final String USER = "root";
static final String PASS = "kopi";
static Connection conn;
static Statement stmt;
static ResultSet rs;
static InputStreamReader inputStreamReader = new
InputStreamReader([Link]);
static BufferedReader input = new BufferedReader(inputStreamReader);
Selanjutnya membuat method main() yang merupakan entri point dari sebuah
program.
Di dalam method ini kita akan melakukan perulangan selama terkoneksi dengan
database dan perulangannya akan berhenti setelah user memilih menu keluar.
public static void main(String[] args) {
try {
// register driver
[Link](JDBC_DRIVER);
conn = [Link](DB_URL, USER, PASS);
stmt = [Link]();
while (![Link]()) {
showMenu();
}
[Link]();
[Link]();
} catch (Exception e) {
[Link]();
}
Perhatikan, di sana ada pemanggilan fungsi atau method showMenu(). Berarti harus
dibuat:
static void showMenu() {
[Link]("\n========= MENU UTAMA =========");
[Link]("1. Insert Data");
[Link]("2. Show Data");
[Link]("3. Edit Data");
[Link]("4. Delete Data");
[Link]("0. Keluar");
[Link]("");
[Link]("PILIHAN> ");
try {
int pilihan = [Link]([Link]());
switch (pilihan) {
case 0:
[Link](0);
break;
case 1:
insertBuku();
break;
case 2:
showData();
break;
case 3:
updateBuku();
break;
case 4:
deleteBuku();
break;
default:
[Link]("Pilihan salah!");
}
} catch (Exception e) {
[Link]();
}
}
Di dalam method tersebut, digunakan logika percabangan switch/case untuk
pemilihan menu. Perhatikan lagi, di sana ada pemanggilan method insertBuku(),
showData(), updateBuku(), dan deleteBuku() di masing-masing pilihan menu.
Selanjutnya adalah membuat keempat method tersebut dengan memulai dari
method showData():
static void showData() {
String sql = "SELECT * FROM buku";
try {
rs = [Link](sql);
[Link]("+--------------------------------+");
[Link]("| DATA BUKU DI PERPUSTAKAAN |");
[Link]("+--------------------------------+");
while ([Link]()) {
int idBuku = [Link]("id_buku");
String judul = [Link]("judul");
String pengarang = [Link]("pengarang");
[Link]([Link]("%d. %s -- (%s)", idBuku,
judul, pengarang));
}
} catch (Exception e) {
[Link]();
}
}
Method show data hanya berfungsi untuk menampilkan data hasil dari database.
Gunakan fungsi [Link]() untuk memudahkan penggabungan string.
Setelah itu, buat method insertBuku():
static void insertBuku() {
try {
// ambil input dari user
[Link]("Judul: ");
String judul = [Link]().trim();
[Link]("Pengarang: ");
String pengarang = [Link]().trim();
// query simpan
String sql = "INSERT INTO buku (judul, pengarang) VALUE('%s',
'%s')";
sql = [Link](sql, judul, pengarang);
// simpan buku
[Link](sql);
} catch (Exception e) {
[Link]();
}
}
Untuk melakukan query simpan, gunakan method execute(). Method ini akan
mengembalikan nilai boolean: true bila query berhasil dan false bila gagal.
Selanjutnya membuat method updateBuku():
static void updateBuku() {
try {
// ambil input dari user
[Link]("ID yang mau diedit: ");
int idBuku = [Link]([Link]());
[Link]("Judul: ");
String judul = [Link]().trim();
[Link]("Pengarang: ");
String pengarang = [Link]().trim();
// query update
String sql = "UPDATE buku SET judul='%s', pengarang='%s' WHERE
id_buku=%d";
sql = [Link](sql, judul, pengarang, idBuku);
// update data buku
[Link](sql);
} catch (Exception e) {
[Link]();
}
}
Terakhir membuat method deleteBuku():
static void deleteBuku() {
try {
// ambil input dari user
[Link]("ID yang mau dihapus: ");
int idBuku = [Link]([Link]());
// buat query hapus
String sql = [Link]("DELETE FROM buku WHERE id_buku=%d",
idBuku);
// hapus data
[Link](sql);
[Link]("Data telah terhapus...");
} catch (Exception e) {
[Link]();
}
}
Kode lengkapnya akan menjadi seperti ini:
package [Link];
import [Link];
import [Link];
import [Link];
import [Link];
import [Link];
import [Link];
public class JavaCRUD {
static final String JDBC_DRIVER = "[Link]";
static final String DB_URL = "jdbc:mysql://localhost/perpustakaan";
static final String USER = "root";
static final String PASS = "kopi";
static Connection conn;
static Statement stmt;
static ResultSet rs;
static InputStreamReader inputStreamReader = new
InputStreamReader([Link]);
static BufferedReader input = new BufferedReader(inputStreamReader);
/**
* @param args the command line arguments
*/
public static void main(String[] args) {
try {
// register driver
[Link](JDBC_DRIVER);
conn = [Link](DB_URL, USER, PASS);
stmt = [Link]();
while (![Link]()) {
showMenu();
}
[Link]();
[Link]();
} catch (Exception e) {
[Link]();
}
static void showMenu() {
[Link]("\n========= MENU UTAMA =========");
[Link]("1. Insert Data");
[Link]("2. Show Data");
[Link]("3. Edit Data");
[Link]("4. Delete Data");
[Link]("0. Keluar");
[Link]("");
[Link]("PILIHAN> ");
try {
int pilihan = [Link]([Link]());
switch (pilihan) {
case 0:
[Link](0);
break;
case 1:
insertBuku();
break;
case 2:
showData();
break;
case 3:
updateBuku();
break;
case 4:
deleteBuku();
break;
default:
[Link]("Pilihan salah!");
}
} catch (Exception e) {
[Link]();
}
}
static void showData() {
String sql = "SELECT * FROM buku";
try {
rs = [Link](sql);
[Link]("+--------------------------------+");
[Link]("| DATA BUKU DI PERPUSTAKAAN |");
[Link]("+--------------------------------+");
while ([Link]()) {
int idBuku = [Link]("id_buku");
String judul = [Link]("judul");
String pengarang = [Link]("pengarang");
[Link]([Link]("%d. %s -- (%s)", idBuku,
judul, pengarang));
}
} catch (Exception e) {
[Link]();
}
static void insertBuku() {
try {
// ambil input dari user
[Link]("Judul: ");
String judul = [Link]().trim();
[Link]("Pengarang: ");
String pengarang = [Link]().trim();
// query simpan
String sql = "INSERT INTO buku (judul, pengarang) VALUE('%s',
'%s')";
sql = [Link](sql, judul, pengarang);
// simpan buku
[Link](sql);
} catch (Exception e) {
[Link]();
}
static void updateBuku() {
try {
// ambil input dari user
[Link]("ID yang mau diedit: ");
int idBuku = [Link]([Link]());
[Link]("Judul: ");
String judul = [Link]().trim();
[Link]("Pengarang: ");
String pengarang = [Link]().trim();
// query update
String sql = "UPDATE buku SET judul='%s', pengarang='%s' WHERE
id_buku=%d";
sql = [Link](sql, judul, pengarang, idBuku);
// update data buku
[Link](sql);
} catch (Exception e) {
[Link]();
}
}
static void deleteBuku() {
try {
// ambil input dari user
[Link]("ID yang mau dihapus: ");
int idBuku = [Link]([Link]());
// buat query hapus
String sql = [Link]("DELETE FROM buku WHERE id_buku=%d",
idBuku);
// hapus data
[Link](sql);
[Link]("Data telah terhapus...");
} catch (Exception e) {
[Link]();
}
}
}
Cobalah untuk mengeksekusi dan analisis sendiri hasinya 😄…