`我创建了一个名为“animal”的 Hibernate 项目，其中使用 Hibernate 查询语言 (HQL) 与 SQL Server 数据库建立连接。在该项目中，我将代码组织到包中，其中包括“DAO”，其中包含两个类：“interfaceDAO”和“animalDAO”。后一个类实现了“interfaceDAO”中定义的方法。
在“animalDAO”中，我实现了几个管理动物数据的功能，包括：
全选：检索所有动物记录。 按 ID 选择：按 ID 获取特定动物。 插入：添加新的动物记录。 更新：修改现有动物记录。 删除：从数据库中删除动物记录。 为了促进数据库连接，我创建了一个“hibernate.cfg.xml”配置文件。此外，我还开发了一个“hibernateUtil.java”类来创建一个“SessionFactory”，这是管理 Hibernate 会话的关键组件。
最后，我在“test”包中创建了一个主测试类“testAnimal.java”。这个类允许我执行我在“animalDAO”类中定义的函数。尽管成功连接到数据库并显示菜单，但错误消息仍然存在。`
animalDAO class
package DAO;
import java.util.ArrayList;
import java.util.List;
import javax.persistence.Query;
import org.hibernate.Session;
import org.hibernate.SessionFactory;
import org.hibernate.Transaction;
import model.animal;
import util.hibernateUtil;
public class animalDAO implements interfaceDAO<animal> {
@Override
public List<animal> sellectAll() {
List<animal> list = new ArrayList();
try {
SessionFactory sf = hibernateUtil.getSessionFactory();
if (sf != null) {
// open & begin transaction
Session s = sf.openSession();
Transaction trans = s.beginTransaction();
// transaction
String hql = "from animal";
Query q = s.createQuery(hql);
list = q.getResultList();
// comit & close transaction
trans.commit();
sf.close();
}
} catch (Exception e) {
e.printStackTrace();
}
return list;
}
@Override
public animal selectByID(animal t) {
List<animal> list = new ArrayList<>();
try {
SessionFactory sf = hibernateUtil.getSessionFactory();
if (sf != null) {
Session s = sf.openSession();
Transaction trans = s.beginTransaction();
String hql = "from animal a where a.id=:id";
Query q = s.createQuery(hql);
q.setParameter("id", t.getId());
list = q.getResultList();
trans.commit();
sf.close();
}
} catch (Exception e) {
e.printStackTrace();
}
if (list.size() > 0) {
return list.get(0);
}else {
return null;
}
}
@Override
public boolean insert(animal t) {
boolean result = false;
try {
SessionFactory sf = hibernateUtil.getSessionFactory();
if (sf != null) {
Session s = sf.openSession();
Transaction trans = s.beginTransaction();
// save: chỉ lưu khi chưa tồn tại
// s.save(t);
//saveOrUpdate: thêm mới khi chưa tồn tại, cập nhật dữ liệu khi đã tồn tại
s.saveOrUpdate(t);
trans.commit();
sf.close();
return true;
}
} catch (Exception e) {
e.printStackTrace();
}
return false;
}
@Override
public boolean update(animal t) {
boolean result = false;
try {
SessionFactory sf = hibernateUtil.getSessionFactory();
if (sf != null) {
Session s = sf.openSession();
Transaction trans = s.beginTransaction();
// save: chỉ lưu khi chưa tồn tại
// s.save(t);
//saveOrUpdate: thêm mới khi chưa tồn tại, cập nhật dữ liệu khi đã tồn tại
s.saveOrUpdate(t);
trans.commit();
sf.close();
return true;
}
} catch (Exception e) {
e.printStackTrace();
}
return false;
}
@Override
public boolean delete(animal t) {
try (SessionFactory sf = hibernateUtil.getSessionFactory()) {
if (sf != null) {
try(Session s = sf.openSession()){
Transaction trans = s.beginTransaction();
s.delete(t);
trans.commit();
sf.close();
}
}
} catch (Exception e) {
e.printStackTrace();
return false;
}
return true;
}
}
hibernateUtil.java
package util;
import org.hibernate.SessionFactory;
import org.hibernate.cfg.Configuration;
public class hibernateUtil {
private static final SessionFactory sessionFactory = buildSessionFactory();
private static SessionFactory buildSessionFactory() {
try {
return new Configuration().configure().buildSessionFactory();
} catch (Exception e) {
System.out.println("Error");
return null;
}
}
public static SessionFactory getSessionFactory() {
return sessionFactory;
}
public static void shutdown() {
getSessionFactory().close();
}
}
hibernate.cfg.xml
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE hibernate-configuration PUBLIC
"-//Hibernate/Hibernate Configuration DTD 3.0//EN"
"http://www.hibernate.org/dtd/hibernate-configuration-3.0.dtd">
<hibernate-configuration>
<session-factory>
<property name="hibernate.dialect">org.hibernate.dialect.SQLServerDialect</property>
<property name="hibernate.connection.driver_class">com.microsoft.sqlserver.jdbc.SQLServerDriver</property>
<property name="hibernate.connection.url">jdbc:sqlserver://localhost:1433;DatabaseName=animal;encrypt=false;</property>
<property name="hibernate.connection.username">sa</property>
<property name="hibernate.connection.password">123456789Thien_Phu</property>
<property name="hibernate.hbm2ddl.auto">update</property>
<property name="show_sql">true</property>
<mapping class="model.animal"/>
</session-factory>
</hibernate-configuration>
testAnimal.java class
package test;
import java.sql.Date;
import java.util.List;
import java.util.Scanner;
import org.hibernate.Session;
import org.hibernate.SessionFactory;
import org.hibernate.Transaction;
import DAO.animalDAO;
import model.animal;
import util.hibernateUtil;
public class testAnimal {
@SuppressWarnings("deprecation")
public static void main(String[] args) {
Scanner sc = new Scanner(System.in);
SessionFactory sf = hibernateUtil.getSessionFactory();
int choice = 0;
do {
System.out.println("============================== \r\n"
+ "1. Select All \r\n"
+ "2. Select by id \r\n"
+ "3. Insert \r\n"
+ "4. Update \r\n"
+ "5. Delete \r\n");
choice = sc.nextInt();
sc.nextLine();
switch (choice) {
case 0:
System.out.println("exit!");
break;
case 1:
if (sf != null) {
Session s = sf.openSession();
Transaction trans = s.beginTransaction();
animalDAO ad = new animalDAO();
List<animal> list = ad.sellectAll();
for (animal a : list) {
System.out.println(a);
}
trans.commit();
sf.close();
}
break;
case 2:
if (sf != null) {
Session s = sf.openSession();
Transaction trans = s.beginTransaction();
animalDAO ad = new animalDAO();
System.out.println("Enter ID: ");
int id = sc.nextInt();
animal a = new animal();
a.setId(id);
animal result = ad.selectByID(a);
System.out.println(result);
trans.commit();
sf.close();
}
break;
case 3:
if (sf != null) {
Session s = sf.openSession();
Transaction trans = s.beginTransaction();
animalDAO ad = new animalDAO();
System.out.println("Enter animal name: ");
String name = sc.nextLine();
System.out.println("Enter animal date of birth [yyyy MM dd]: ");
int year = sc.nextInt();
int month = sc.nextInt();
int day = sc.nextInt();
sc.nextLine();
Date dob = new Date(year - 1900, month - 1, day);
System.out.println("Enter sex/gender [true / false]: ");
boolean sex = sc.nextBoolean();
animal a1 = new animal(name, dob, sex);
ad.insert(a1);
trans.commit();
sf.close();
}
break;
case 4:
if (sf != null) {
Session s = sf.openSession();
Transaction trans = s.beginTransaction();
animalDAO ad = new animalDAO();
System.out.println("enter new name for animal: ");
String name = sc.nextLine();
System.out.println("Enter new date of birth for animal [xxxx xx xx]: ");
int year = sc.nextInt();
int month = sc.nextInt();
int day = sc.nextInt();
sc.nextLine();
Date dob = new Date(year - 1900, month - 1, day);
System.out.println("enter new sex/gender [true / false]: ");
boolean sex = sc.nextBoolean();
System.out.println("Enter ID: ");
int id = sc.nextInt();
animal a2 = new animal(name, dob, sex);
a2.setId(id);
ad.update(a2);
trans.commit();
sf.close();
}
break;
case 5:
if (sf != null) {
Session s = sf.openSession();
Transaction trans = s.beginTransaction();
animalDAO ad = new animalDAO();
System.out.println("Enter ID: ");
int id = sc.nextInt();
animal a3 = new animal(id);
a3.setId(id);
ad.delete(a3);
trans.commit();
sf.close();
}
break;
default:
break;
}
} while (choice != 0);
}
}
Error log
Sep 06, 2023 9:04:46 AM org.hibernate.Version logVersion
INFO: HHH000412: Hibernate ORM core version 5.6.15.Final
Sep 06, 2023 9:04:46 AM org.hibernate.annotations.common.reflection.java.JavaReflectionManager <clinit>
INFO: HCANN000001: Hibernate Commons Annotations {5.1.2.Final}
Sep 06, 2023 9:04:47 AM org.hibernate.engine.jdbc.connections.internal.DriverManagerConnectionProviderImpl configure
WARN: HHH10001002: Using Hibernate built-in connection pool (not for production use!)
Sep 06, 2023 9:04:47 AM org.hibernate.engine.jdbc.connections.internal.DriverManagerConnectionProviderImpl buildCreator
INFO: HHH10001005: using driver [com.microsoft.sqlserver.jdbc.SQLServerDriver] at URL [jdbc:sqlserver://localhost:1433;DatabaseName=animal;encrypt=false;]
Sep 06, 2023 9:04:47 AM org.hibernate.engine.jdbc.connections.internal.DriverManagerConnectionProviderImpl buildCreator
INFO: HHH10001001: Connection properties: {password=****, user=sa}
Sep 06, 2023 9:04:47 AM org.hibernate.engine.jdbc.connections.internal.DriverManagerConnectionProviderImpl buildCreator
INFO: HHH10001003: Autocommit mode: false
Sep 06, 2023 9:04:47 AM org.hibernate.engine.jdbc.connections.internal.DriverManagerConnectionProviderImpl$PooledConnections <init>
INFO: HHH000115: Hibernate connection pool size: 20 (min=1)
Sep 06, 2023 9:04:47 AM org.hibernate.dialect.Dialect <init>
INFO: HHH000400: Using dialect: org.hibernate.dialect.SQLServerDialect
Sep 06, 2023 9:04:47 AM org.hibernate.resource.transaction.backend.jdbc.internal.DdlTransactionIsolatorNonJtaImpl getIsolatedConnection
INFO: HHH10001501: Connection obtained from JdbcConnectionAccess [org.hibernate.engine.jdbc.env.internal.JdbcEnvironmentInitiator$ConnectionProviderJdbcConnectionAccess@3b8ec001] for (non-JTA) DDL execution was not in auto-commit mode; the Connection 'local transaction' will be committed and the Connection will be set into auto-commit mode.
Sep 06, 2023 9:04:48 AM org.hibernate.engine.transaction.jta.platform.internal.JtaPlatformInitiator initiateService
INFO: HHH000490: Using JtaPlatform implementation: [org.hibernate.engine.transaction.jta.platform.internal.NoJtaPlatform]
==============================
1. Select All
2. Select by id
3. Insert
4. Update
5. Delete
1
Hibernate: select animal0_.id as id1_0_, animal0_.dateOfBirth as dateofbi2_0_, animal0_.name as name3_0_, animal0_.sex as sex4_0_ from animal animal0_
Sep 06, 2023 9:04:50 AM org.hibernate.engine.jdbc.connections.internal.DriverManagerConnectionProviderImpl$PoolState stop
INFO: HHH10001008: Cleaning up connection pool [jdbc:sqlserver://localhost:1433;DatabaseName=animal;encrypt=false;]
Sep 06, 2023 9:04:50 AM org.hibernate.engine.jdbc.connections.internal.DriverManagerConnectionProviderImpl$PooledConnections close
ERROR: Connection leak detected: there are 1 unclosed connections upon shutting down pool jdbc:sqlserver://localhost:1433;DatabaseName=animal;encrypt=false;
Sep 06, 2023 9:04:50 AM org.hibernate.engine.jdbc.connections.internal.DriverManagerConnectionProviderImpl validateConnectionsReturned
ERROR: Connection leak detected: there are 1 unclosed connections!
animal [id=1, name=cat, dateOfBirth=null, sex=false]
animal [id=2, name=fish, dateOfBirth=2003-04-05, sex=true]
animal [id=6, name=carrovet, dateOfBirth=2003-12-02, sex=false]
Exception in thread "main" org.hibernate.TransactionException: Unable to commit against JDBC Connection
at org.hibernate.resource.jdbc.internal.AbstractLogicalConnectionImplementor.commit(AbstractLogicalConnectionImplementor.java:92)
at org.hibernate.resource.transaction.backend.jdbc.internal.JdbcResourceLocalTransactionCoordinatorImpl$TransactionDriverControlImpl.commit(JdbcResourceLocalTransactionCoordinatorImpl.java:282)
at org.hibernate.engine.transaction.internal.TransactionImpl.commit(TransactionImpl.java:101)
at test.testAnimal.main(testAnimal.java:49)
Caused by: com.microsoft.sqlserver.jdbc.SQLServerException: The connection is closed.
at com.microsoft.sqlserver.jdbc.SQLServerException.makeFromDriverError(SQLServerException.java:231)
at com.microsoft.sqlserver.jdbc.SQLServerConnection.checkClosed(SQLServerConnection.java:1728)
at com.microsoft.sqlserver.jdbc.SQLServerConnection.commit(SQLServerConnection.java:4451)
at com.microsoft.sqlserver.jdbc.SQLServerConnection.commit(SQLServerConnection.java:4432)
at org.hibernate.resource.jdbc.internal.AbstractLogicalConnectionImplementor.commit(AbstractLogicalConnectionImplementor.java:86)
... 3 more
in the error log it said Exception in thread "main" org.hibernate.TransactionException: Unable to commit against JDBC Connection I try may way check all the jdbc connection but still not work我尝试改变测试类中的一些主要内容， 我在循环之外创建一个 SessionFactory do while 然后在任何情况下我都会打开一个新会话并开始一个新事务 在这种情况下也提交并关闭
case 1:
if (sf != null) {
Session s = sf.openSession();
Transaction trans = s.beginTransaction();
animalDAO ad = new animalDAO();
List<animal> list = ad.sellectAll();
for (animal a : list) {
System.out.println(a);
}
trans.commit();
sf.close();
}
break;
case 2:
if (sf != null) {
Session s = sf.openSession();
Transaction trans = s.beginTransaction();
animalDAO ad = new animalDAO();
System.out.println("Enter ID: ");
int id = sc.nextInt();
animal a = new animal();
a.setId(id);
animal result = ad.selectByID(a);
System.out.println(result);
trans.commit();
sf.close();
}
break;
case 3:
if (sf != null) {
Session s = sf.openSession();
Transaction trans = s.beginTransaction();
animalDAO ad = new animalDAO();
System.out.println("Enter animal name: ");
String name = sc.nextLine();
System.out.println("Enter animal date of birth [yyyy MM dd]: ");
int year = sc.nextInt();
int month = sc.nextInt();
int day = sc.nextInt();
sc.nextLine();
Date dob = new Date(year - 1900, month - 1, day);
System.out.println("Enter sex/gender [true / false]: ");
boolean sex = sc.nextBoolean();
animal a1 = new animal(name, dob, sex);
ad.insert(a1);
trans.commit();
sf.close();
}
break;
但似乎这样不行
我已经知道错误在哪里了
所以基于animalDAO类的错误 所有方法 selectAll、selectByID、insert、update 和 delete 我忘记用 try...catch 括起来，这是检查方法是否出错的非常重要的步骤 所以我把所有的方法都包围在try...catch里之后，项目就可以正常运行了
这是animalDAO类的更新
package DAO;
import java.util.ArrayList;
import java.util.List;
import javax.persistence.Query;
import org.hibernate.Session;
import org.hibernate.SessionFactory;
import org.hibernate.Transaction;
import model.animal;
import util.hibernateUtil;
public class animalDAO implements interfaceDAO<animal> {
// this is previous method code
// @Override
// public List<animal> sellectAll() {
// List<animal> list = new ArrayList();
// try {
// SessionFactory sf = hibernateUtil.getSessionFactory();
// if (sf != null) {
// // open & begin transaction
// Session s = sf.openSession();
// Transaction trans = s.beginTransaction();
//
// // transaction
// String hql = "from animal";
// Query q = s.createQuery(hql);
// list = q.getResultList();
//
// // commit & close transaction
// trans.commit();
// sf.close();
// }
// } catch (Exception e) {
// e.printStackTrace();
// }
// return list;
// }
//
// @Override
// public animal selectByID(animal t) {
// List<animal> list = new ArrayList<>();
//
// try {
// SessionFactory sf = hibernateUtil.getSessionFactory();
// if (sf != null) {
// Session s = sf.openSession();
// Transaction trans = s.beginTransaction();
//
// String hql = "from animal a where a.id=:id";
// Query q = s.createQuery(hql);
// q.setParameter("id", t.getId());
// list = q.getResultList();
//
// trans.commit();
// sf.close();
// }
// } catch (Exception e) {
// e.printStackTrace();
// }
//
// if (list.size() > 0) {
// return list.get(0);
// }else {
// return null;
// }
// }
//
//
// @Override
// public boolean insert(animal t) {
// boolean result = false;
//
// try {
// SessionFactory sf = hibernateUtil.getSessionFactory();
// if (sf != null) {
// Session s = sf.openSession();
// Transaction trans = s.beginTransaction();
//
// // save: chỉ lưu khi chưa tồn tại
//// s.save(t);
//
// //saveOrUpdate: thêm mới khi chưa tồn tại, cập nhật dữ liệu khi đã tồn tại
// s.saveOrUpdate(t);
//
// trans.commit();
// sf.close();
//
// return true;
// }
//
//
// } catch (Exception e) {
// e.printStackTrace();
// }
// return false;
// }
//
// @Override
// public boolean update(animal t) {
// boolean result = false;
//
// try {
// SessionFactory sf = hibernateUtil.getSessionFactory();
// if (sf != null) {
// Session s = sf.openSession();
// Transaction trans = s.beginTransaction();
//
// // save: chỉ lưu khi chưa tồn tại
//// s.save(t);
//
// //saveOrUpdate: thêm mới khi chưa tồn tại, cập nhật dữ liệu khi đã tồn tại
// s.saveOrUpdate(t);
//
// trans.commit();
// sf.close();
//
// return true;
// }
//
//
// } catch (Exception e) {
// e.printStackTrace();
// }
// return false;
// }
//
// @Override
// public boolean delete(animal t) {
// try (SessionFactory sf = hibernateUtil.getSessionFactory()) {
// if (sf != null) {
// try(Session s = sf.openSession()){
//
// Transaction trans = s.beginTransaction();
//
// s.delete(t);
//
// trans.commit();
// sf.close();
// }
// }
// } catch (Exception e) {
// e.printStackTrace();
// return false;
// }
// return true;
// }
// this is new code after update
@Override
public List<animal> sellectAll() {
List<animal> list = new ArrayList();
SessionFactory sf = hibernateUtil.getSessionFactory();
if (sf != null) {
try(Session s = sf.openSession();) {
Transaction trans = s.beginTransaction();
// transaction
String hql = "from animal";
Query q = s.createQuery(hql);
list = q.getResultList();
trans.commit();
} catch (Exception e) {
sf.close();
e.printStackTrace();
}
}
return list;
}
@Override
public animal selectByID(animal t) {
List<animal> list = new ArrayList<>();
SessionFactory sf = hibernateUtil.getSessionFactory();
if (sf != null) {
try(Session s = sf.openSession();) {
Transaction trans = s.beginTransaction();
String hql = "from animal a where a.id=:id";
Query q = s.createQuery(hql);
q.setParameter("id", t.getId());
list = q.getResultList();
trans.commit();
} catch (Exception e) {
sf.close();
e.printStackTrace();
}
}
if (list.size() > 0) {
return list.get(0);
}else {
return null;
}
}
@Override
public boolean insert(animal t) {
boolean result = false;
SessionFactory sf = hibernateUtil.getSessionFactory();
if (sf != null) {
try(Session s = sf.openSession();) {
Transaction trans = s.beginTransaction();
s.saveOrUpdate(t);
trans.commit();
} catch (Exception e) {
sf.close();
e.printStackTrace();
return true;
}
}
return false;
}
@Override
public boolean update(animal t) {
boolean result = false;
SessionFactory sf = hibernateUtil.getSessionFactory();
if (sf != null) {
try(Session s = sf.openSession();) {
Transaction trans = s.beginTransaction();
s.saveOrUpdate(t);
trans.commit();
} catch (Exception e) {
sf.close();
e.printStackTrace();
return true;
}
}
return false;
}
@Override
public boolean delete(animal t) {
try (SessionFactory sf = hibernateUtil.getSessionFactory()) {
if (sf != null) {
try(Session s = sf.openSession()){
Transaction trans = s.beginTransaction();
s.delete(t);
trans.commit();
sf.close();
}
}
} catch (Exception e) {
e.printStackTrace();
return false;
}
return true;
}
}
所以错误已修复，谢谢