Tutorial Membuat Koneksi Database dengan Java Netbeans

Tutorial membuat koneksi database pada bahasa pemrograman java - Pada tutorial kali ini kita akan belajar membuat koneksi database  beserta contoh pengambilan record. Pertama silahkan buat sebuah database dengan nama db_barang. dan buat  1 (satu) buah tabel dengan nama "daftarbarang".

Source Code

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import javax.swing.JOptionPane;

public class ConnectionManager {

    private Connection con_m= null;

    public ConnectionManager(){
        try {
            String driver = "org.postgresql.Driver";
            String database = "db_barang";
            String url = "jdbc:postgresql://localhost:5432/"+ database;
            String username = "postgres";
            String password = "postgres";
            
            Class.forName(driver);
            con_m = DriverManager.getConnection(url, username, password);
            System.out.println("Connection Success !!!");
        } catch (ClassNotFoundException ex) {
            System.out.println("Class Not Found\n"+ex.toString());
        } catch (SQLException ex) {
            System.out.println("ERROR SQL\n"+ex.toString());
        }
    }

    public Connection getConnection() {
        return con_m;
    }
 
}

Bagi kalian yang menggunakan database selain PostgreSQL, silahkan ubah driver dan url pastikan juga kalian sudah melakukan import library databasenya.

Buat sebuah class dengan nama "Barang", class Barang ini saya sebuat sebagai entity class yang berisikan variabel dan method setter dan getter.

Source Code

import java.io.Serializable;

public class Barang implements Serializable{

    private long sequenceindex;
    private String kodebarang, namabarang;
    private short jumlah;
    private double harga;

    public long getSequenceindex() {
        return sequenceindex;
    }

    public void setSequenceindex(long sequenceindex) {
        this.sequenceindex = sequenceindex;
    }
    public String getNamabarang() {
        return namabarang;
    }

    public void setNamabarang(String namabarang) {
        this.namabarang = namabarang;
    }

    public String getKodebarang() {
        return kodebarang;
    }

    public void setKodebarang(String kodebarang) {
        this.kodebarang = kodebarang;
    }

    public short getJumlah() {
        return jumlah;
    }

    public void setJumlah(short jumlah) {
        this.jumlah = jumlah;
    }

    public double getHarga() {
        return harga;
    }

    public void setHarga(double harga) {
        this.harga = harga;
    }

}

Buatlah sebuah interface dengan nama IBarang.

Source Code

import java.sql.SQLException;
import java.util.List;

public interface IBarang {

    public List<barang> getAllData() throws SQLException;

}

Buatlah sebuah class dengan nama BarangSQL. Class BarangSQL merupakan implements dari IBarang.

Source Code

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.List;

public class BarangSQL implements IBarang {

    private Connection con_m = new ConnectionManager().getConnection();

    public List<barang> getAllData() throws SQLException{
        String query = "SELECT * FROM daftarbarang";
        Statement st = null;
        ResultSet rs = null;
        List<barang> list = new ArrayList<>();
        try {
            st = con.createStatement();
            rs = st.executeQuery(query);
            while(rs.next()){
                Barang obj = new Barang();
                obj.setSequenceindex(rs.getLong("sequenceindex");
                obj.setKodebarang(rs.getString("kodebarang");
                obj.setNamabarang(rs.getString("namabarang");
                obj.setJumlah(rs.getShort("jumlah");
                obj.setHarga(rs.getDouble("harga");
                list.add(obj)
            }
            return list;
        }catch(SQLException ex){
            ex.printStackTrace();
        }finally{
            if(st!=null){
                st.close();
            }
            if(rs!=null){
                rs.close();
            }
            if(con!=null){
                con.close();
            }
        }
    }
}

Untuk melakukan test pengambilan data tersebut, buatlah class dengan nama TestBarang.

Source Code

import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;

public class TestBarang {

    private void getBarang(){
        try {
            IBarang sql = new BarangSQL();
            List<barang> barang = sql.getAllData();
            for(Barang brg : barang){
                System.out.println("Kode Barang : "+brg.getKodebarang);
                System.out.println("Nama Barang : "+brg.getNamabarang);
                System.out.println("Jumlah      : "+brg.getJumlah);
                System.out.println("Harga       : "+brg.getHarga);
                System.out.println();
            }
        } catch (SQLException ex) {
            ex.getMessage();
        }
    }

    public static void main(String[] args){
        TestBarang obj = new TestBarang();
        obj.getBarang();
    }

}

Penjelasan lebih lengkap mengenai source code diatas, akan kami bahas pada artikel berikutnya.

Sekian tutorial membuat koneksi database pada pemrograman java. Silahkan tinggalkan komentar anda.

Subscribe to receive free email updates: