1. Berikut adalah contoh sederhana operasi databases di java terdiri dari masuk, hapus, ubah dan tampilkan, program ini masih jauh dari kesempurnaan silahkan coba untuk merombak dan menambahkan. Contoh program dibuat dengan compiler Neatbeans 6.7.1 dan database mysql.
1. Contoh program java
package database;
import java.sql.*;
import java.io.*;
/**
*
* @author NRT_REYCON
*/
public class Main {
/**
* @param args the command line arguments
*/
public static void main(String[] args) {
// TODO code application logic here
int n = 0; String lagi =”y”;
BufferedReader in = new BufferedReader(new InputStreamReader(System.in));
do{
System.out.println(“ =====Silahkan Pilih Menu===== “);
System.out.println(“ Tugas OOP 2 Koneksi Database “);
System.out.println(“| 1. Input Data Pegawai |”);
System.out.println(“| 2. Ubah Data Pegawai |”);
System.out.println(“| 3. Hapus Data Pegawai |”);
System.out.println(“| 4. Lihat Data Pegawai |”);
System.out.println(“+————————————–+”);
try {
System.out.print(“Pilih : “); n = Integer.parseInt(in.readLine());
}catch (Exception e) { }
switch (n) {
case 1 : System.out.println(satu(n)) ;break;
case 2 : System.out.println(dua(n)) ;break;
case 3 : System.out.println(tiga(n)) ;break;
case 4 : System.out.println(empat(n)) ;break;
default : System.out.println(kacau(n));break;
}
try {
System.out.print(“Lagi ? Y / y : “); lagi = in.readLine();
}catch (Exception e) { }
}while (lagi.equals(“Y”) || lagi.equals(“y”)); }
static String satu(int nn)
{ String hasil=”";
BufferedReader data = new BufferedReader (new InputStreamReader(System.in));
String nip;
String nama;
String umur;
String alamat;
String user=”root”;
String pwd=”admin”;
String host=”localhost”;
String db=”latihan_bab6″;
String urlValues=”";
try{
System.out.println(“ini adalah contoh program input database”);
System.out.println(“Nip :”);
nip = data.readLine();
System.out.println(“Nama :”);
nama=data.readLine();
System.out.println(“Umur :”);
umur=data.readLine();
System.out.println(“Alamat :”);
alamat=data.readLine();
Class.forName(“com.mysql.jdbc.Driver”);
urlValues=”jdbc:mysql://”+ host +”/”+db +”?user=” + user +”&password=”+ pwd;
Connection conn = DriverManager.getConnection(urlValues);
PreparedStatement pStatement = null;
String sql =”insert into pegawai values (?,?,?,?)”;
pStatement = conn.prepareStatement(sql);
pStatement.setString(1, nip);
pStatement.setString(2, nama);
pStatement.setString(3, umur);
pStatement.setString(4, alamat);
int intTambah= pStatement.executeUpdate();
if (intTambah>0)
System.out.println(“Penambahan data berhasil”);
else
System.out.println(“Penambahan data gagal”);
pStatement.close();
conn.close();
}
catch(ClassNotFoundException e) {
System.out.println(“jdbc.Driver tidak ditemukan”);
}
catch (SQLException e){
System.out.println(“koneksi gagal ” + e.toString());
}
catch (Exception e){}
return hasil;
}
static String dua(int nn)
{ String hasil=”";
BufferedReader data = new BufferedReader (new InputStreamReader(System.in));
String nip;
String nama;
String umur;
String alamat;
String user=”root”;
String pwd=”admin”;
String host=”localhost”;
String db=”latihan_bab6″;
String urlValues=”";
try{
System.out.println(“ini adalah contoh program ubah database”);
System.out.println(“Nip pegawai yang akan di ubah :”);
nip = data.readLine();
System.out.println(“Nama :”);
nama=data.readLine();
System.out.println(“Umur :”);
umur=data.readLine();
System.out.println(“Alamat :”);
alamat=data.readLine();
Class.forName(“com.mysql.jdbc.Driver”);
urlValues=”jdbc:mysql://”+ host +”/”+db +”?user=” + user +”&password=”+ pwd;
Connection conn = DriverManager.getConnection(urlValues);
PreparedStatement pStatement = null;
String sql =” UPDATE pegawai SET nama=?, umur=?, alamat=? WHERE nip=? “;
pStatement = conn.prepareStatement(sql);
pStatement.setString(1, nama);
pStatement.setString(2, umur);
pStatement.setString(3, alamat);
pStatement.setString(4, nip);
int intTambah= pStatement.executeUpdate();
if (intTambah>0)
System.out.println(“Penambahan data berhasil”);
else
System.out.println(“Penambahan data gagal”);
pStatement.close();
conn.close();
}
catch(ClassNotFoundException e) {
System.out.println(“jdbc.Driver tidak ditemukan”);
}
catch (SQLException e){
System.out.println(“koneksi gagal ” + e.toString());
}
catch (Exception e){}
return hasil;
}
static String tiga(int nn)
{ String hasil=”";
BufferedReader data = new BufferedReader (new InputStreamReader(System.in));
String nip;
String nama;
String umur;
String alamat;
String user=”root”;
String pwd=”admin”;
String host=”localhost”;
String db=”latihan_bab6″;
String urlValues=”";
try{
System.out.println(“ini adalah contoh program hapus database”);
System.out.println(“Nip pegawai yang akan di hapus :”);
nip = data.readLine();
Class.forName(“com.mysql.jdbc.Driver”);
urlValues=”jdbc:mysql://”+ host +”/”+db +”?user=” + user +”&password=”+ pwd;
Connection conn = DriverManager.getConnection(urlValues);
PreparedStatement pStatement = null;
String sql =”delete from pegawai where nip=?”;
pStatement = conn.prepareStatement(sql);
pStatement.setString(1, nip);
int intTambah= pStatement.executeUpdate();
if (intTambah>0)
System.out.println(“Penghapusan data berhasil”);
else
System.out.println(“data tidak di temukan”);
pStatement.close();
conn.close();
}
catch(ClassNotFoundException e) {
System.out.println(“jdbc.Driver tidak ditemukan”);
}
catch (SQLException e){
System.out.println(“koneksi gagal ” + e.toString());
}
catch (Exception e){}
return hasil;
}
static String empat(int nn)
{ String hasil=”";
String user=”root”;
String pwd=”admin”;
String host=”localhost”;
String db=”latihan_bab6″;
String urlValues=”";
System.out.println(“ini adalah contoh program input database”);
try {
int no=0;
Class.forName(“com.mysql.jdbc.Driver”);
urlValues=”jdbc:mysql://”+ host +”/”+db +”?user=” + user +”&password=”+ pwd;
Connection conn = DriverManager.getConnection(urlValues);
Statement st=conn.createStatement();
ResultSet rs=st.executeQuery(“Select * from pegawai”);
while (rs.next()){
no=no+1;
System.out.println(no+”)”);
System.out.println(“NIP : “+ rs.getString(“nip”));
System.out.println(“Nama : “+ rs.getString(“nama”));
System.out.println(“Umur : “+ rs.getString(“umur”));
System.out.println(“Alamat : “+ rs.getString(“alamat”));
st.close();
conn.close();
}
}
catch(ClassNotFoundException e) {
System.out.println(“jdbc.Driver tidak ditemukan”);
}
catch (SQLException e){
System.out.println(“koneksi gagal ” + e.toString());
}
return hasil;
}
static String kacau(int nn)
{
String hasil=”";
hasil=”tak ada pilihan nati di tambah”;
return hasil;
}
}
2. Untuk databasebya bisa di download disini dan di export ke database yg mw di gunakan.
Untuk memperoleh programnya bisa di download dari sini
1. Program
2. Databases-nya
