Hibernate 连接 MySQL 数据库实战示例

核心配置集中在 hibernate.cfg.xml 中，这里需要指定驱动、URL、方言以及日志输出等属性。

<?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.connection.driver_class">com.mysql.jdbc.Driver</property>
        <!-- 数据库连接 URL -->
        <property name="hibernate.connection.url">jdbc:mysql://192.168.25.152/test</property>
        <!-- 数据库用户名与密码（请根据实际情况修改） -->
        <property name="hibernate.connection.username">your_username</property>
        <property name="hibernate.connection.password">your_password</property>
        <!-- SQL 方言 -->
        <property name="hibernate.dialect">org.hibernate.dialect.MySQLDialect</property>
        <!-- 是否显示 SQL 语句 -->
        <property name="show_sql">true</property>
    </session-factory>
</hibernate-configuration>

3. 实体类映射 user.hbm.xml

接下来定义对象与表的映射关系，这里使用 XML 方式映射 TestDb 类。

<?xml version="1.0"?>
<!DOCTYPE hibernate-mapping PUBLIC
        "-//Hibernate/Hibernate Mapping DTD 3.0//EN"
        "http://www.hibernate.org/dtd/hibernate-mapping-3.0.dtd">
<hibernate-mapping package="com">
    <class name="TestDb" table="test">
        <id name="id" column="id">
            <generator class="native"/>
        </id>
        <property name="username" column="username"/>
    </class>
</hibernate-mapping>

4. 实体类 TestDb.java

对应数据库字段的 Java 类，注意字段类型与数据库类型的匹配。

package com;

public class TestDb {
    private Long id;
    private String username;

    public Long getId() {
        return id;
    }

    public void setId(Long id) {
        this.id = id;
    }

    public String getUsername() {
        return username;
    }

    public void setUsername(String myname) {
        this.username = myname;
    }
}

5. 测试与操作逻辑

在实际操作中，我们需要管理 Session 和 Transaction 的生命周期。下面的测试类展示了遍历、加载、更新和插入的基本用法。

package com;

import java.util.List;
import org.hibernate.Query;
import org.hibernate.Session;
import org.hibernate.SessionFactory;
import org.hibernate.Transaction;
import org.hibernate.cfg.Configuration;

public class Test {

    // 初始化 SessionFactory 和 Session
    static SessionFactory sessionFactory;
    static Session session;
    static Transaction tx;

    private static void init() {
        sessionFactory = new Configuration().configure().buildSessionFactory();
        session = sessionFactory.openSession();
        tx = session.beginTransaction();
    }

    private static void close() {
        if (tx != null) tx.commit();
        if (session != null) session.close();
        if (sessionFactory != null) sessionFactory.close();
    }

    // 遍历查询
    public static void all() {
        Query q = session.createQuery("select c.id, c.username from TestDb as c");
        List l = q.list();
        for (int i = 0; i < l.size(); i++) {
            Object[] row = (Object[]) l.get(i);
            Long id = (Long) row[0];
            String name = (String) row[1];
            System.out.println(id + " " + name);
        }
    }

    // 读取单条记录
    public static void load() {
        TestDb obj = (TestDb) session.load(TestDb.class, new Long(2));
        System.out.println(obj.getUsername());
    }

    // 更新操作
    public static void update() {
        TestDb obj = (TestDb) session.load(TestDb.class, new Long(2));
        obj.setUsername("cg");
        // 注意：此处需提交事务才能生效
    }

    // 插入操作
    public static void insert() {
        TestDb user = new TestDb();
        user.setUsername("sb");
        session.save(user);
    }

    public static void main(String[] args) {
        init();
        // 演示更新操作
        update();
        close();
    }
}

6. 注意事项

1. 资源释放：务必在 finally 块或 close() 方法中关闭 Session 和 SessionFactory，避免连接泄露。
2. 事务管理：修改数据前开启事务，操作完成后提交，否则更改不会持久化。
3. 版本兼容性：示例基于较旧的 Hibernate 3.x 语法，若使用 Hibernate 5+ 建议改用注解方式 (@Entity, @Table) 配合 JPA 标准。