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".

/**
 *
 * @author Akira
 */
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.

import java.io.Serializable;

/**
 *
 * @author user
 */
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.

import java.sql.SQLException;
import java.util.List;
/**
 *
 * @author Akira
 */

public interface IBarang {

    public List getAllData() throws SQLException;

}

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

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.List;
/**
 *
 * @author Akira
 */

public class BarangSQL implements IBarang {

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

    public List getAllData() throws SQLException{
        String query = "SELECT * FROM daftarbarang";
        Statement st = null;
        ResultSet rs = null;
        List 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.

import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;
/**
 *
 * @author Akira
 */

public class TestBarang {

    private void getBarang(){
        try {
            IBarang sql = new BarangSQL();
            List 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.