我正在开发一个简单的示例应用程序，它使用 Hibernate 来实现在数据库表上执行一些CRUD操作的 DAO。
我的应用程序运行良好，但我怀疑这可能与我在使用 Java 方面的角色差距有关。
在我的应用程序架构中，我有一个名为HibernateDAO的接口，其中我只声明了我将拥有的 CRUD 方法，这个：
package org.andrea.myH8.myH8HelloWorld;
public interface HibernateDAO {
// Operazione di CREATE:
public Integer addEmployee(String fname, String lname, int salary);
// Operazione di READ:
public void listEmployees();
// Operazione di UPDATE:
public void updateEmployee(Integer EmployeeID, int salary);
// Operazione di DELETE:
public void deleteEmployee(Integer EmployeeID);
}
然后我有实现previous接口的具体类，这个类被命名为HibernateDAOImpl，这个：
package org.andrea.myH8.myH8HelloWorld;
import java.util.List;
import java.util.Date;
import java.util.Iterator;
import org.hibernate.HibernateException;
import org.hibernate.Session;
import org.hibernate.Transaction;
import org.hibernate.SessionFactory;
import org.hibernate.cfg.Configuration;
import org.hibernate.service.ServiceRegistry;
import org.hibernate.service.ServiceRegistryBuilder;
// Classe principale contenente il metodo main():
public class HibernateDAOImpl implements HibernateDAO {
// Factory per la creazione delle sessioni di Hibernate:
private static SessionFactory factory;
/** Registratore di servizzi che contiene, gestisce e fornisce l'accesso
* ai servizzi registrati:
*/
private static ServiceRegistry serviceRegistry;
public HibernateDAOImpl() {
try {
/** Un'istanza di Configuration consente all'applicazione di specificare le
* proprietà ed il documento di mapping tra oggetti da persistere e dabelle
* che devono essere utilizzati durante la creazione di una SessionFactory
*/
Configuration configuration = new Configuration();
/** Per la configurazione di Hibernate utilizza le proprietà specificate nel
* file XML di configurazione avente nome standard hibernate.cfg.xml:
*/
configuration.configure();
/** ServiceRegistry crea un'istanza di ServiceRegistry (il registratore di servizzi)
* alla quale vengono applicati un gruppo di settaggi contenuti dentro le proprietà
* dell'oggetto configuration.
* Infine il registratore di Service creato viene costruito in base a tutte le
* impostazioni specificate.
*/
serviceRegistry = new ServiceRegistryBuilder().applySettings(configuration.getProperties()).buildServiceRegistry();
/** Crea l'istanza della SessionFactory usando le proprietà ed i mapping
* definiti in questa configurazione
*/
factory = configuration.buildSessionFactory(serviceRegistry);
} catch (Throwable ex) { // Se viene sollevata un'eccezione la gestisce
System.err.println("Failed to create sessionFactory object." + ex);
throw new ExceptionInInitializerError(ex);
}
}
/** Metodo relativo all'operazione CREATE di un record nella tabella EMPLOYEE:
*
* @param fname nome
* @param lname cognome
* @param salary salario
* @return l'identificativo intero univoco che rappresenta l'impiegato
*/
public Integer addEmployee(String fname, String lname, int salary) {
// Crea e mette nella connection pool la connessione JDBC:
Session session = factory.openSession();
Transaction tx = null; // Rappresenta una transazione
Integer employeeID = null; // Identificativo univoco impiegato
try {
// Inizia un'unità di lavoro e ritorna la transazione ad essa associata:
tx = session.beginTransaction();
// Crea un nuovo oggetto Employee:
Employee employee = new Employee(fname, lname, salary);
/** Persiste l'istanza transiente data ed in primo luogo gli assegna
* un identificatore univoco autogenerato
*/
employeeID = (Integer) session.save(employee);
tx.commit(); // Esegue la commit della transazione
} catch (HibernateException e) { // Se viene sollevata un'eccezione:
if (tx != null) // Se la transazione non è nulla
tx.rollback(); // Esegue la rollback e riporta alla situazione iniziale
e.printStackTrace();
} finally { // Alla fine:
// Chiude la sessione rilasciando la connessione JDBC e facendo il cleanup:
session.close();
}
return employeeID;
}
/* Metodo usato per elencare tutti i record presenti nella tabella EMPLOYEE: */
public void listEmployees() {
// Crea e mette nella connection pool la connessione JDBC:
Session session = factory.openSession();
Transaction tx = null; // Rappresenta una transazione
try {
// Inizia un'unità di lavoro e ritorna la transazione ad essa associata:
tx = session.beginTransaction();
/** Crea la query usando una stringa HQL per ottenere tutti i record
* ed ottiene la lista di tutti i record rappresentati ognuno da un
* oggetto Employee
*/
List employees = session.createQuery("FROM Employee").list();
// Stampa i valori delle proprietà di ogni oggett nella lista:
for (Iterator iterator = employees.iterator(); iterator.hasNext();) {
Employee employee = (Employee) iterator.next();
System.out.print("First Name: " + employee.getFirstName());
System.out.print(" Last Name: " + employee.getLastName());
System.out.println(" Salary: " + employee.getSalary());
}
tx.commit(); // Esegue la commit della transazione
} catch (HibernateException e) { // Se viene sollevata un'eccezione:
if (tx != null) // Se la transazione non è nulla
tx.rollback(); // Esegue la rollback e riporta alla situazione iniziale
e.printStackTrace();
} finally { // Alla fine:
// Chiude la sessione rilasciando la connessione JDBC e facendo il cleanup:
session.close();
}
}
/** Metodo che aggiorna il salario di un impiegato
*
* @param EmployeeID l'ID univoco che identifica il record nella tabella EMPLOYEE
* @param salary il nuovo salario dell'impiegato rappresentato dal record
*/
public void updateEmployee(Integer EmployeeID, int salary) {
// Crea e mette nella connection pool la connessione JDBC:
Session session = factory.openSession();
Transaction tx = null; // Rappresenta una transazione
try {
// Inizia un'unità di lavoro e ritorna la transazione ad essa associata:
tx = session.beginTransaction();
/**
* Ritorna l'istanza persistita sul database della classe fornita come
* parametro di input avente l'identificatore fornito come parametro
* di input. Se non esiste un tale oggetto persistito nel database
* allora ritorna null.
*/
Employee employee = (Employee) session.get(Employee.class,
EmployeeID);
employee.setSalary(salary); // Setta il nuovo valore del salario
session.update(employee); // Esegue l'update di tale oggetto
tx.commit(); // Esegue la commit della transazione
} catch (HibernateException e) { // Se viene sollevata un'eccezione:
if (tx != null) // Se la transazione non è nulla
tx.rollback(); // Esegue la rollback e riporta alla situazione iniziale
e.printStackTrace();
} finally { // Alla fine:
// Chiude la sessione rilasciando la connessione JDBC e facendo il cleanup:
session.close();
}
}
/** Metodo che elimina un record dalla tabella EMPOLYEE
*
* @param EmployeeID l'ID univoco che identifica il record nella tabella EMPLOYEE
*/
public void deleteEmployee(Integer EmployeeID) {
// Crea e mette nella connection pool la connessione JDBC:
Session session = factory.openSession();
Transaction tx = null; // Rappresenta una transazione
try {
// Inizia un'unità di lavoro e ritorna la transazione ad essa associata:
tx = session.beginTransaction();
/**
* Ritorna l'istanza persistita sul database della classe fornita come
* parametro di input avente l'identificatore fornito come parametro
* di input. Se non esiste un tale oggetto persistito nel database
* allora ritorna null.
*/
Employee employee = (Employee) session.get(Employee.class,
EmployeeID);
session.delete(employee); // Rimuove l'oggetto dalla tabella del database:
tx.commit(); // Esegue la commit della transazione
} catch (HibernateException e) { // Se viene sollevata un'eccezione:
if (tx != null) // Se la transazione non è nulla
tx.rollback(); // Esegue la rollback e riporta alla situazione iniziale
e.printStackTrace();
} finally { // Alla fine:
// Chiude la sessione rilasciando la connessione JDBC e facendo il cleanup:
session.close();
}
}
}
好的，省略实体类 Person，最后一个类是MainApp类，它包含我用来测试这个类如何工作的 main() 方法：
包 org.andrea.myH8.myH8HelloWorld；
公共类 MainApp {
public static void main(String[] args) {
// Creo una nuova istanza dell'oggetto DAO per interagire con il database:
HibernateDAO ME = new HibernateDAOImpl();
System.out.println("CREAZIONE DEI RECORD:");
// Inserisce 3 record nella tabella EMPLOYEE sul DB:
Integer empID1 = ME.addEmployee("Zara", "Ali", 1000);
Integer empID2 = ME.addEmployee("Daisy", "Das", 5000);
Integer empID3 = ME.addEmployee("John", "Paul", 10000);
// Elenca tutti i record della tabella EMPLOYEE:
System.out.println("ELENCA TUTTI I RECORD:");
ME.listEmployees();
// Update del record avente id corrispondente al valore della variabile empID1
System.out.println("Update del record avente id corrispondente al valore: " + empID1);
ME.updateEmployee(empID1, 5000);
/* Elimina dalla tabella EMPLOYEE il record avente id corrispondente al valore
* della variabile empID2 */
System.out.println("Eliminazione del record avente id corrispondente al valore: " + empID2);
ME.deleteEmployee(empID2);
// Elenca tutti i record della tabella EMPLOYEE:
System.out.println("ELENCA TUTTI I RECORD:");
ME.listEmployees();
}
}
现在我对最后一个类有疑问......在这个类的main()方法中，我将我的 DAO 对象声明为接口类型（HibernateDAO），但我必须使用实现此接口的具体类型（ HibernateDAOImpl ）来构造它， 这样：
HibernateDAO ME = new HibernateDAOImpl();
我会知道这是否是我必须使用的最佳实践，或者是否存在一些更好的方式来说 Java 将其创建为 HibernateDAO 类型，然后自动检测到我只有一个实现并使用它的 Java。
你能给我解释一下这件事吗？
肿瘤坏死因子
安德烈亚