Apache Commons DBUtils - Verwenden von DataSource

Bisher haben wir bei der Verwendung von QueryRunner ein Verbindungsobjekt verwendet. Wir können die Datenquelle auch scheinbar nahtlos verwenden. Das folgende Beispiel zeigt, wie ein Datensatz mithilfe der Abfrage "Lesen" mithilfe von QueryRunner und der Datenquelle gelesen wird. Wir werden einen Datensatz aus der Mitarbeitertabelle lesen.

Syntax

QueryRunner queryRunner = new QueryRunner( dataSource );
Employee emp = queryRunner.query("SELECT * FROM employees WHERE first=?", resultHandler, "Sumit");

Wo,

• dataSource - DataSource-Objekt konfiguriert.

• resultHandler - ResultSetHandler-Objekt, um die Ergebnismenge dem Employee-Objekt zuzuordnen.

• queryRunner - QueryRunner-Objekt zum Lesen des Mitarbeiterobjekts aus der Datenbank.

Um die oben genannten Konzepte in Bezug auf DBUtils zu verstehen, schreiben wir ein Beispiel, in dem eine Leseabfrage ausgeführt wird. Um unser Beispiel zu schreiben, erstellen wir eine Beispielanwendung.

Schritt	Beschreibung
1	Aktualisieren Sie die Datei MainApp.java, die unter Kapitel DBUtils - Erste Anwendung erstellt wurde .
2	Kompilieren Sie die Anwendung und führen Sie sie wie unten erläutert aus.

Es folgt der Inhalt der 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;
   }
}

Es folgt der Inhalt der CustomDatasource.java.

import javax.sql.DataSource;
import org.apache.commons.dbcp2.BasicDataSource;

public class CustomDataSource {
   // 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";
   private static DataSource datasource;
   private static final BasicDataSource basicDataSource;

   static {
      basicDataSource = new BasicDataSource();
      basicDataSource.setDriverClassName(JDBC_DRIVER);
      basicDataSource.setUsername(USER);
      basicDataSource.setPassword(PASS);
      basicDataSource.setUrl(DB_URL);
   }

   public static DataSource getInstance() {
      return basicDataSource;
   }
}

Es folgt der Inhalt der MainApp.java Datei.

import java.sql.SQLException;

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

public class MainApp {
   public static void main(String[] args) throws SQLException {    
      
      DbUtils.loadDriver(JDBC_DRIVER);
      QueryRunner run = new QueryRunner(CustomDataSource.getInstance());
      ResultSetHandler<Employee> resultHandler = new BeanHandler<Employee>(Employee.class);

      Employee emp = queryRunner.query("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());
   }
}

Wenn Sie mit dem Erstellen der Quelldateien fertig sind, lassen Sie uns die Anwendung ausführen. Wenn mit Ihrer Anwendung alles in Ordnung ist, wird die folgende Meldung gedruckt.

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