OOP LANJUT PEMROSESAN DATABASE MENGGUNAKAN JDBC Niko Ibrahim, MIT Universitas Kristen Maranatha
Tujuan
Memahami Koneksi dan Pemrosesan Basis Data di Java Memahami JDBC Menggunakan MySQL pada program Java
Materi
Pengenalan library JDBC Diagram pengaksesan database melalui JDBC Step-by-step Setting JDBC untuk MySQL Cara Melakukan Query (SELECT) Cara Memproses Hasil Query Cara Update/Insert/Delete
1st Thing 1st: Siapkan MySQL
Jalankan MySQL server + Apache server (melalui XAMPP Control Panel) Masuk ke phpMyAdmin: http://localhost/phpmyadmin/ Di dalam phpMyAdmin, import the “movieSQL.sql” script Browse table “movie”, yang isinya adalah sbb:
Pengenalan: JDBC Library
JDBC — Java Database Connectivity — adalah suatu feature di Java yang memungkinkan kita untuk melakukan:
Library JDBC terdiri atas class-class yang berguna untuk setiap tasks di dalam pemrosesan database, misalnya class untuk:
Koneksi ke hampir semua sistem RDBMS yang ada saat ini, Eksekusi perintah SQL, dan Memproses hasil perintah SQL melalui program Java
Membuat koneksi ke database Membuat statement menggunakan SQL Mengeksekusi query SQL (statement) di dalam database Menampilkan records yang dihasilkan
Semua class-class JDBC adalah bagian dari java.sql package.
Bagaimana program Java mengakses database melalui JDBC?
Program
JDBC
driver mysql
MYSQL
driver oracle
ORACLE
driver sybase
SYBASE
JDBC Driver: Apa itu & Bagaimana mendapatkannya?
First Thing First: Setting Up a Driver
Sebelum Anda dapat menulis program Java yang mengakses database melalui JDBC, pertama-tama Anda harus meng-instal sebuah Driver yang menghubungkan class-class di dalam Java’s database API dengan database yang akan digunakan.
Untuk setiap database yang ada di pasaran saat ini, hampir semuanya memiliki driver JDBC-nya. Biasanya driver ini dapat didownload secara gratis melalui website perusahaan database masing-masing. Driver ini seringkali disebut juga sebagai “connector”.
Setting up MySQL JDBC Driver
Database connector is a driver provided by your database vendor. Database connectors are designed to work exclusively with a specific type of database. You have to obtain the JDBC connector for the database you’re using from the company that makes the database server you’re using. For example, you can get a JDBC connector for MySQL from the MySQL Web site at www.mysql.com . Along with the driver, you get detailed instructions on how to set it up.
Step-by-step for: MySQL JDBC driver Download Driver dan Setting Environment 1.
2.
Download driver JBDC MySQL dari website berikut: www.mysql.com/products/connector lalu unzip file tsb. Driver JDBC untuk MySQL dinamakan: MySQL Connector/J. Setelah Anda mendownloadnya, unzip file tsb ke suatu folder, misalnya: “c:\MySQL”
Tambahkan file driver yang berekstensi “.jar” ke dalam variabel “ClassPath” Misalnya *): c:\mysql\mysql-connector-java-3.1.10-bin.jar
atau C:\mysql\mysql-connector-java-5.0.7\mysql-connector-java-5.0.7-bin.jar *) tergantung lokasi dan versi driver yang digunakan
That’s all you have to do. You can now connect to MySQL from a Java program.
6 Langkah Koneksi & Akses Database 1. 2. 3. 4. 5. 6.
Memanggil Driver JDBC Mendefinisikan URL untuk Koneksi Basis Data & Melakukan Koneksi tsb Membuat Objek Statement Melakukan Query/Update Memproses Hasil Menutup Koneksi
1. Memanggil Driver JDBC
Sebelum kita dapat menggunakan JDBC untuk mengakses database SQL, kita harus melakukan koneksi terlebih dahulu. Langkah pertama dalam melakukan koneksi adalah: registrasi driver Caranya adalah dengan menggunakan method “forName” dari kelas “Class” Misalnya untuk meregistrasi connector MySQL, gunakan perintah berikut: Class.forName("com.mysql.jdbc.Driver"); Note that the forName method throws ClassNotFoundException, so you have to enclose this statement in a try/catch block that catches ClassNotFoundException. try { Class.forName("com.mysql.jdbc.Driver"); } catch (ClassNotFoundException){ // error handling }
2. Mendefinisikan URL dan Melakukan Koneksi
Setelah melalukan registrasi driver class tsb, kita dapat memanggil method getConnection untuk membuka koneksi ke database. Method ini membutuhkan 3 parameter String:the database URL, the user name, and a password. Contoh: String url = "jdbc:mysql://localhost/movies"; String user = "root"; String pw = ""; Connection conn = DriverManager.getConnection(url, user, pw); Note that the getConnection method throws SQLException, so you need to enclose it in a try/catch block statement that catches this exception.
Note: You can find these classes — and the other classes for working with SQL databases — in the java.sql package. As a result, you have to include an import statement that specifies this package in any program that uses JDBC. import java.sql package;
3. Membuat Objek Statement
Kita memerlukan objek Statement untuk melakukan query dan objek ini dapat dibuat dari objek Connection. Sintaks kode: Statement st = conn.createStatement(); Statement: The Statement interface contains the methods necessary to send
statements to the database for execution and return the results.
Use the executeQuery method to execute a select statement, or Use the executeUpdate method to execute an insert, update, or delete statement.
Putting it all together (Step 1 to 3)
Berikut ini adalah sebuah method yang me-return objek Connection yang berfungsi sebagai penghubung ke database MySQL:
private static Connection getConnection(){ Connection con = null; try{ Class.forName("com.mysql.jdbc.Driver "); String url = "jdbc:mysql://localhost/movies"; String user = "root"; String pw = " "; con = DriverManager.getConnection(url, user, pw); } catch (ClassNotFoundException e){ System.out.println(e.getMessage()); System.exit(0); } catch (SQLException e){ System.out.println(e.getMessage()); System.exit(0); } return con; }
4. Melakukan Query atau Update
Setelah kita memiliki objek Statement, kita dapat menggunakannya untuk mengirimkan query dan mengeksekusinya dengan method executeQuery yang menghasilkan objek bertipe ResultSet. ResultSet: The ResultSet interface represents rows returned from a query. It provides methods you can use to move from row to row and to get the data for a column.
Contoh: String query = "SELECT id, title FROM movie";
ResultSet rs = st.executeQuery(query);
Note: Apabila ingin melakukan update/insert/delete, gunakan
st.executeUpdate(query)
5a. Memproses Hasil Query
Untuk memproses hasil query, kita gunakan objek resultSet karena hasil query disimpan dalam objek ini. Method yang sering digunakan: next dan getString Contoh pemrosesan hasil query: while (rs.next()){ System.out.println(rs.getString(1) + " " + rs.getString(2)); }
Kode di atas akan menampilkan semua baris hasil query yang masing-masing menampilkan data kolom pertama dan kedua.
Memproses hasil query (cont.) Navigating through the result set
The ResultSet object returned by the executeQuery statement contains all the rows that are retrieved by the select statement. You can only access one of those rows at a time. You can use the methods shown in the table to move the cursor through a result set. Method Description void close() Closes the result set void last()
Moves the cursor to the last row
int getRow()
Gets the current row number
boolean next()
Moves to the next row
For example, the following snippet shows how you can structure code that processes each row in a result set: while(rows.next()) { // process the current row }
All you have to do is replace the comment with statements that retrieve data from the result set and process it, as described in the next section.
Memproses hasil query (cont.) Example: Navigating the result set // Already done: // ResultSet rs = st.executeQuery(select); try { while (rs.next()){ String title = movies.getString("Title"); int year = movies.getInt("Year"); double price = movies.getDouble("Price"); String msg = title + " " + year + " " + price; System.out.println(msg); } } catch (SQLException e){ System.out.println(e.getMessage()); }
Memproses hasil query (cont.) Getting data from the result set
The following table lists the methods of the ResultSet interface you can use to retrieve data from the current row. As you can see, each of these methods comes in two versions:
One specifies the column by name, the other by index number. If you know the index number, using it to access the column values is more efficient than using the column names.
Method
Description
boolean getBoolean(String columnName)
Gets the value of the specified column as a boolean
boolean getBoolean(int columnIndex)
Gets the value of the specified column as a boolean
Date getDate(String columnName)
Gets the value of the specified column as a Date
Date getDate(int columnIndex)
Gets the value of the specified column as a Date
double getDouble(String columnName)
Gets the value of the specified column as a double
double getDouble(int columnIndex)
Gets the value of the specified column as a double
int getInt(String columnName)
Gets the value of the specified column as a int
int getInt(int columnIndex)
Gets the value of the specified column as a int
String getString(String columnName)
Gets the value of the specified column as a String
String getString(int columnIndex)
Gets the value of the specified column as a String
5b. Untuk Proses Update/Insert/Delete
Setelah mengerti bagaimana menampilkan data, maka kita perlu mengerti bagaimana menambah/menghapus/mengupdate data ke tabel. Untuk melakukan hal tersebut, kita menggunakan method executeUpdate("perintah sql untuk insert / update / delete");
Method tersebut akan menghasilkan nilai integer yang merupakan jumlah baris yang dipengaruhi oleh proses update tersebut. int i = st.executeUpdate( "delete from movie where id = ' 2' ");
5b. Untuk Proses Insert/Update/Delete (cont...)
Untuk proses updating tabel, kita bisa juga menggunakan objek PreparedStatement: Untuk mengeksekusi PreparedStatement, kita gunakan method executeUpdate() Berikut contoh penggunaannya: PreparedStatement st = conn.prepareStatement ("INSERT INTO movie VALUES (?,?,?)"); st.setString(1, "Passion of The Christ"); st.setInt(2, 2004); st.setDouble(3, 22.5); int i = st.executeUpdate(); .... ....
st.close();
6. Menutup Koneksi
Sebelum menutup koneksi basis data, kita juga perlu melepaskan objek ResultSet yang ada dengan kode berikut: st.close(); Untuk menutup koneksi ke basis data, kita tuliskan sbb: conn.close();
Exercise 1. 2. 3.
ListMovies.java: aplikasi console Swing & JDBC: Address Book NetBeans & DB tutorial: Contact Application
Exercise 1: ListMovies.java 1st Thing 1st: Siapkan MySQL
Jalankan MySQL server + Apache server (melalui XAMPP Control Panel) Masuk ke phpMyAdmin: http://localhost/phpmyadmin/ Di dalam phpMyAdmin, import the “movieSQL.sql” script Browse table “movie”, yang isinya adalah sbb:
Exercise 1: ListMovies.java Open & Run Console Application: “ListMovies.java”
See the full code in “ListMovies.java” When you run the code, the following appears in the console:
1946: 1965: 1974: 1975: 1977: 1987: 1989: 1995: 1997: 2001:
It’s a Wonderful Life ($16.45) The Great Race ($14.25) Young Frankenstein ($18.65) The Return of the Pink Panther ($13.15) Star Wars ($19.75) The Princess Bride ($18.65) Glory ($16.45) Apollo 13 ($20.85) The Game ($16.45) The Lord of the Rings: The Fellowship of the Ring ($21.95)
Exercise 2: Swing & JDBC Address book (Lihat file PDF yang diberikan)
Tutorial membuat address book menggunakan Swing dan JDBC Buat project “java application” baru
Nama Project: AddressBookDemoDB Uncheck “create main class”
Buat database & user:
Buat user baru di MYSQL: (apabila perlu)
Userid: niko Password: niko
Jalankan script yan berfungsi:
membuat MySQL database: addressbook Membuat Table: Person
create table Person ( id integer, name varchar(30), address varchar(30), phone integer, email varchar(50) )
Ada 3 files berikut di dalam project:
PersonInfo: class JavaBeans berisi atribut dan method untuk Person PersonDAO: class yang menyediakan pengaksesan database untuk objek Person AddressBookForm: user interface untuk mengelola Person
A final word for JDBC
Berikut cuplikan dokumentasi dari MySQL Connector/J: “Although JDBC is useful by itself, we would hope that if you are not familiar with JDBC that after reading the first few sections of this manual, that you would avoid using naked JDBC for all but the most trivial problems and consider using one of the popular persistence frameworks such as Hibernate, Spring's JDBC templates or Ibatis SQL Maps to do the majority of repetitive work and heavier lifting that is sometimes required with JDBC.” Produk Persistence Framework yang paling populer digunakan saat ini adalah Hibernate dan Oracle TopLink. Framework ini dinamakan JPA (Java Persisitence API) yang merupakan bagian standar dari Java Enterprise Edition (J2EE)
That’s all for today, folks!
Selamat, Anda telah menyelesaikan sebuah topik penting di Java yaitu pengaksesan Database. Setelah mengikuti kuliah ini, Anda diharapkan mampu:
Memahami penggunaan JDBC Melakukan koneksi ke MySQL Melakukan pemrosesan database Mengetahui framework penyimpanan data (persistence) yang lebih canggih dari JDBC yaitu JPA
