langkah koneksi database MySQL menggunakan Java
- sebelum melakukan koneksi
tahap ini adalah tahap yang harus di lakukan sebelum kita mulai menuliskan kode untuk koneksi database.
Sebelum membuat program / aplikasi yang menggunakan koneksi database, terlebih dahulu kita lakukan hal-hal berikut :
- siapkan driver untuk database yang kita gunakan
driver ini biasanya di sediakan oleh para pengembang database,
atau bias di dapatkan dengan contoh mengunjungi situs ini : http://dev.mysql.com/
- setelah driver nya kita dapatkan, maka langkah selanjutnya adalah setting classpath.
- Melakukan koneksi
Untuk melakukan koneksi ke database langkah-langkahnya yaitu :
=> load driver database
Untuk melakukan hal ini gunakan syntax berikut :
Class.forName(“com.mysql.jdbc.Driver”);// sesuaikan dengan driver databasenya.
=> koneksi dan panggil URL databasenya.
Setelah driver databasenya di tentukan, panggil URL databasenya :
Connection con=DriverManager.getConnection(url, user, password);
url : URL database
user : username database
password : password database
untuk mysql syntaknya dapat di ubah menjadi sebagai berikut
Connectioncon=DriverManager.getConnection (“jdbc:mysql:http://localhost/table_coba”, “root”,”blackonta”);
=> buat statement
Pada tahap ini buat query yang nantinya akan di eksekusi oleh database :
Stmt = conn.createStatement(); //step 4
=> eksekusi perintah ( biasanya berupa statement SQL)
Rs = stmt.executeQuery(“SELECT * FROM table02”);
=> proses hasil
Pada tahap ini hasil yang di dapat kita proses lebih lanjut, dapat langsung di tampilkan dengan system.out.println(); atau bias d tampilkan dengan menggunakan GRID untuk GUI interface
=> tutup koneksi
Setelah di dapatkan hasil yang di inginkan, tutup koneksinya :
Stmt.close();
Conn.close();
Contoh lengkap programnya :
import java.sql.*;
public class koneksiDB {
public static void main(String[] args) {
Connection conn = null;
Statement stmt = null;
ResultSet rs = null;
try {
Class.forName(“org.gjt.mm.mysql.Driver”); // Step 1
} catch (ClassNotFoundException cnfe) {
System.err.println(cnfe);
} catch (Exception E) {
E.printStackTrace();
} // end catch
try {
conn = DriverManager.getConnection(“jdbc:mysql://localhost/coba”,”root”,”black”);
stmt = conn.createStatement(); // step 4
rs = stmt.executeQuery(“SELECT * FROM tabel02″);
while (rs.next()) { // step 6
System.out.print(rs.getString(“Nomer”) + ” “);
System.out.print(rs.getString(“Judul”) + ” “);
System.out.print(rs.getString(“Pengarang”) + ” “);
System.out.print(rs.getString(“Penerbit”) + ” “);
System.out.print(rs.getString(“harga”) + ” “);
System.out.println(“Oke”);
} // while
stmt.close();
conn.close();
} catch(SQLException sqle) {
System.err.println(“SQLException : ” + sqle.getMessage());
} // end cacth
}
}
Contoh program insert dengan menggunakan java
Public class InsertTbl {
Public static void main(String[]args) {
InsertTbl insert = new Insert Tbl();
insert.hubunginTbl();
insert.insert();
}
Public void hubungin Tbl() {
try {
Class.forName(“org.gjt.mm.mysql.Driver”);
con = DriverManager.getConnection(“jdbc:mysql://localhost\dbTest?
user=root&password=kklc”);
System.out.println(“Connected”);
}
Catch(java.sql.SQLException err) {
System.out.println(“Error :”+err.getMessage());
}
}
Public void insert() {
Try {
String = “insert into tblUser(id, nama, password, email) values (1,”+”’nama’,’123r45’,’thamrin.dinus@gmail.com’)”;
Stat = con.createStatement();
stat.executeQuery(sql);
}
Catch(java.sql.SQLException err) {
System.out.println(“error : “+err.getMessage());
}
}
}
Contoh program select dengan menggunakan java
Public class SelectTbl {
Public static void main(String[]args) {
SelectTbl select = new SelectTbl();
Select hubungin Tbl();
Select.select();
}
Public void hubungin Tbl() {
try {
Class.forName(“org.gjt.mm.mysql.Driver”);
con = Drivermanager.getConnection(“jdbc:mysql://localhost\dbTest?
user = roor&password=kklc”);
System.out.println(“connected”);
}
catch(java.sql.SQLException err) {
System.out.println(“Error :”+err.getMessage());
}
Public void select() {
try {
String sql = “select * from userTbl”;
stat = con.createStatement();
rs = stat.ExecuteQuery();
while(rs.next()){
String nama = rs.getString(“nama”);
Srting password = rs.getString(“password”);
String email = rs.getString(“password”);
}
Catch(java.sql.SQLException err) {
System.out,println(“error :”+ err.getMessage());
}
java.sql.Connection con;
java.sql.Statement stat;
java.sql.ResultSet rs;
}