Java.sql.Connection
Sebelum kita mengelola database pada MySQL kita perlu membuat terlebih dahulu sebuah koneksi yang dalam java dekenal dengan java.sql.Connection. tapi sebelumnya kita harus menentukan sebuah driver setiap DBMS yang akan kita gunakan. karena kita menggunakan DBMS MySQL, maka kita harus membuat instansiasi dari Driver milik MySQL. dan masalahnya, java tidak menyediakan driver untuk MySQL, sehingga kita harus mendownload driver MySQL dari situs resmi MySQL. tapi tenang saja, karena kita pake Netbeans, semuanya telah tersedia.
Setelah itu d RUN, jika berhasil akan muncul tulisan "koneksi berhasil", namun jika tidak akan muncul tulisan "Koneksi gagal". bila kegagalan terjadi kita dapat melihat bagian mana yang terjadi kesalahan tersebut, dn terus mecobanya sampai dengan berhasil.
setelah selesai lalu eksekusi/RUN.
Kedua ini kita akan melakukan eksekusi perintah UPDATE :
Ketiga ini kita akan melakukan eksekusi perintah DELETE :
setelah itu buat sebuah class untuk koneksi (jika anda belum tahu cara membuat koneksi, silahkan lihat kembali tutorial MySQL dan Netbeans bagian 1) :
01 | import com.mysql.jdbc.Driver; |
02 | import java.sql.Connection; |
03 | import java.sql.DriverManager; |
04 | import java.sql.SQLException; |
05 |
06 | public class Koneksi { |
07 |
08 | private static Connection koneksi; |
09 |
10 | public static Connection getConnection() throws SQLException { |
11 | if (koneksi == null) { |
12 | // panggil Driver MySQL |
13 | new Driver(); |
14 | // buat koneksi |
15 | koneksi = DriverManager.getConnection("jdbc:mysql://localhost:3306/netbeans", "username", "password"); |
16 | } |
17 | return koneksi; |
18 | } |
19 |
20 | public static void main(String args[]) { |
21 | try { |
22 | getConnection(); |
23 | System.out.println("Koneksi Berhasil"); |
24 | } catch (SQLException ex) { |
25 | System.err.println("Koneksi Gagal"); |
26 | } |
27 | } |
28 | } |
Java.sql.Statement
Pertama ini kita akan melakukan eksekusi perintah INSERT :
01 | import java.sql.SQLException; |
02 | import java.sql.Statement; |
03 |
04 | public class InsertRecord { |
05 |
06 | public static void main(String args[]) throws SQLException { |
07 | Statement statement = Koneksi.getConnection().createStatement(); |
08 | statement.executeUpdate("INSERT INTO MAHASISWA " + |
09 | "VALUES (" + |
10 | "'10106031','Eko Kurnaiwan Khannedy','1988-12-29'" + |
11 | ");"); |
12 |
13 | statement.close(); |
14 | } |
15 | } |
Kedua ini kita akan melakukan eksekusi perintah UPDATE :
01 | import java.sql.SQLException; |
02 | import java.sql.Statement; |
03 |
04 | public class UpdateRecord { |
05 |
06 | public static void main(String args[]) throws SQLException { |
07 | Statement statement = Koneksi.getConnection().createStatement(); |
08 | statement.executeUpdate("UPDATE MAHASISWA " + |
09 | "SET " + |
10 | "NAMA = 'Nesia Oktiana' ," + |
11 | "TANGGAL_LAHIR = '1988-10-04' " + |
12 | "WHERE " + |
13 | "NIM = '10106031';"); |
14 | statement.close(); |
15 | } |
16 | } |
Ketiga ini kita akan melakukan eksekusi perintah DELETE :
01 | import java.sql.SQLException; |
02 | import java.sql.Statement; |
03 |
04 | public class DeleteRecord { |
05 |
06 | public static void main(String args[]) throws SQLException { |
07 | Statement statment = Koneksi.getConnection().createStatement(); |
08 | statment.executeUpdate("DELETE FROM MAHASISWA " + |
09 | "WHERE NIM = '10106031';"); |
10 | statment.close(); |
11 | } |
12 | } |
Di atas adalah cara kita membuat koneksi serta perintah eksekusi |
Tidak ada komentar:
Posting Komentar