Apache Commons DBUtils - Query di aggiornamento

Il seguente esempio dimostrerà come aggiornare un record utilizzando la query di aggiornamento con l'aiuto di DBUtils. Aggiorneremo un record nella tabella dei dipendenti.

Sintassi

La sintassi per la query di aggiornamento è la seguente:

String updateQuery = "UPDATE employees SET age=? WHERE id=?";
int updatedRecords = queryRunner.update(conn, updateQuery, 33,104);

Dove,

• updateQuery - Aggiorna query con segnaposto.

• queryRunner - Oggetto QueryRunner per aggiornare l'oggetto dipendente nel database.

Per comprendere i concetti sopra menzionati relativi a DBUtils, scriviamo un esempio che eseguirà una query di aggiornamento. Per scrivere il nostro esempio, creiamo un'applicazione di esempio.

Passo	Descrizione
1	Aggiorna il file MainApp.java creato nel capitolo DBUtils - Prima applicazione .
2	Compilare ed eseguire l'applicazione come spiegato di seguito.

Di seguito è riportato il contenuto del file 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;
   }
}

Di seguito è riportato il contenuto del file MainApp.java file.

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

import org.apache.commons.dbutils.DbUtils;
import org.apache.commons.dbutils.QueryRunner;

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);
      try {
         int updatedRecords = queryRunner.update(conn,
            "UPDATE employees SET age=? WHERE id=?", 33,104);
         System.out.println(updatedRecords + " record(s) updated.");
      } finally {
         DbUtils.close(conn);
      }
   }
}

Una volta che hai finito di creare i file sorgente, eseguiamo l'applicazione. Se tutto va bene con la tua applicazione, stamperà il seguente messaggio:

1 record(s) updated.