Antarmuka QueryRunner

Itu org.apache.commons.dbutils.QueryRunnerkelas adalah kelas pusat di perpustakaan DBUtils. Ini mengeksekusi kueri SQL dengan strategi yang dapat dimasukkan untuk menangani ResultSets. Kelas ini aman untuk thread.

Deklarasi Kelas

Berikut adalah deklarasi untuk kelas org.apache.commons.dbutils.QueryRunner -

public class QueryRunner
   extends AbstractQueryRunner

Pemakaian

Step 1 - Buat objek koneksi.
Step 2 - Gunakan metode objek QueryRunner untuk membuat operasi database.

Contoh

Contoh berikut akan mendemonstrasikan cara membaca record menggunakan kelas QueryRunner. Kami akan membaca salah satu catatan yang tersedia di Tabel karyawan.

Sintaksis

ResultSetHandler<Employee> resultHandler = new BeanHandler<Employee>(Employee.class);
Employee emp = 
   queryRunner.query(conn, "SELECT * FROM employees WHERE first=?", resultHandler, "Sumit");

Dimana,

resultHandler - Objek ResultSetHandler untuk memetakan hasil yang disetel ke objek Karyawan.
queryRunner - Objek QueryRunner untuk membaca objek karyawan dari database.

Untuk memahami konsep yang disebutkan di atas terkait dengan DBUtils, mari kita tulis contoh yang akan menjalankan kueri baca. Untuk menulis contoh kita, mari kita buat aplikasi contoh.

Langkah	Deskripsi
1	Perbarui file MainApp.java yang dibuat di bawah bab DBUtils - Aplikasi Pertama .
2	Kompilasi dan jalankan aplikasi seperti yang dijelaskan di bawah ini.

Berikut ini adalah konten dari Employee.java.

public class Employee {
   private int id;
   private int age;
   private String first;
   private String last;
   public int getId() {
      return id;
   }
   public void setId(int id) {
      this.id = id;
   }
   public int getAge() {
      return age;
   }
   public void setAge(int age) {
      this.age = age;
   }
   public String getFirst() {
      return first;
   }
   public void setFirst(String first) {
      this.first = first;
   }
   public String getLast() {
      return last;
   }
   public void setLast(String last) {
      this.last = last;
   }
}

Berikut ini adalah konten dari MainApp.java mengajukan.

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;

import org.apache.commons.dbutils.DbUtils;
import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.ResultSetHandler;
import org.apache.commons.dbutils.handlers.BeanHandler;

public class MainApp {
   // JDBC driver name and database URL
   static final String JDBC_DRIVER = "com.mysql.jdbc.Driver";  
   static final String DB_URL = "jdbc:mysql://localhost:3306/emp";

   //  Database credentials
   static final String USER = "root";
   static final String PASS = "admin";

   public static void main(String[] args) throws SQLException {
      Connection conn = null;
      QueryRunner queryRunner = new QueryRunner();
      
      //Step 1: Register JDBC driver
      DbUtils.loadDriver(JDBC_DRIVER);

      //Step 2: Open a connection
      System.out.println("Connecting to database...");
      conn = DriverManager.getConnection(DB_URL, USER, PASS);

      //Step 3: Create a ResultSet Handler to handle Employee Beans
      ResultSetHandler<Employee> resultHandler = new BeanHandler<Employee>(Employee.class);

      try {
         Employee emp = queryRunner.query(conn,
            "SELECT * FROM employees WHERE id=?", resultHandler, 103);
         //Display values
         System.out.print("ID: " + emp.getId());
         System.out.print(", Age: " + emp.getAge());
         System.out.print(", First: " + emp.getFirst());
         System.out.println(", Last: " + emp.getLast());
      } finally {
         DbUtils.close(conn);
      }        
   }
}

Setelah Anda selesai membuat file sumber, biarkan kami menjalankan aplikasinya. Jika semuanya baik-baik saja dengan aplikasi Anda, itu akan mencetak pesan berikut.

ID: 103, Age: 28, First: Sumit, Last: Mittal