Apache Commons DBUtils: controlador personalizado
Podemos crear nuestro propio controlador personalizado implementando la interfaz ResultSetHandler o extendiendo cualquiera de las implementaciones existentes de ResultSetHandler. En el ejemplo que se muestra a continuación, hemos creado un controlador personalizado, EmployeeHandler al extender la clase BeanHandler.
Para comprender los conceptos mencionados anteriormente relacionados con DBUtils, escribamos un ejemplo que ejecutará una consulta de lectura. Para escribir nuestro ejemplo, creemos una aplicación de muestra.
Paso | Descripción |
---|---|
1 | Actualice el archivo MainApp.java creado en el capítulo DBUtils - Primera aplicación . |
2 | Compile y ejecute la aplicación como se explica a continuación. |
A continuación se muestra el contenido de la Employee.java.
public class Employee {
private int id;
private int age;
private String first;
private String last;
private String name;
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;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
}
A continuación se muestra el contenido de la EmployeeHandler.java archivo.
import java.sql.ResultSet;
import java.sql.SQLException;
import org.apache.commons.dbutils.handlers.BeanHandler;
public class EmployeeHandler extends BeanHandler<Employee> {
public EmployeeHandler() {
super(Employee.class);
}
@Override
public Employee handle(ResultSet rs) throws SQLException {
Employee employee = super.handle(rs);
employee.setName(employee.getFirst() +", " + employee.getLast());
return employee;
}
}
A continuación se muestra el contenido de la MainApp.java archivo.
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();
DbUtils.loadDriver(JDBC_DRIVER);
conn = DriverManager.getConnection(DB_URL, USER, PASS);
EmployeeHandler employeeHandler = new EmployeeHandler();
try {
Employee emp = queryRunner.query(conn,
"SELECT * FROM employees WHERE first=?", employeeHandler, "Sumit");
//Display values
System.out.print("ID: " + emp.getId());
System.out.print(", Age: " + emp.getAge());
System.out.print(", Name: " + emp.getName());
} finally {
DbUtils.close(conn);
}
}
}
Una vez que haya terminado de crear los archivos fuente, ejecutemos la aplicación. Si todo está bien con su aplicación, imprimirá el siguiente mensaje.
ID: 103, Age: 28, Name: Sumit, Mittal