Java项目中使用Hibernate处理数据

CREATE TABLE ORDERS( 
        ID VARCHAR NOT NULL PRIMARY KEY, 
        ORDER_DATE TIMESTAMP NOT NULL, 
        PRICE_TOTAL DOUBLE NOT NULL) 
CREATE TABLE PRODUCTS( 
        ID VARCHAR NOT NULL PRIMARY KEY, 
        NAME VARCHAR NOT NULL, 
        PRICE DOUBLE NOT NULL, 
        AMOUNT INTEGER NOT NULL) 
CREATE TABLE ORDER_ITEMS( 
        ID VARCHAR NOT NULL PRIMARY KEY, 
        ORDER_ID VARCHAR NOT NULL, 
        PRODUCT_ID VARCHAR NOT NULL, 
        AMOUNT INTEGER NOT NULL, 
        PRICE DOUBLE NOT NULL) 

package test.hibernate; 

public class Product { 
    private String id; 
    private String name; 
    private double price; 
    private int amount; 
     
    public String getId() { 
        return id; 
    } 
    public void setId(String string) { 
        id = string; 
    } 

    // 默认的构造函数及其他  
    // 为了简洁起见，getter/setter方法没有显示 
    // ... 
} 

public String toString() { 
    return  
     "[Product] " + name + "(" + id + 
     ") price=" + price + " amount=" + amount; 
} 

package test.hibernate; 
import java.util.Date; 
import java.util.HashSet; 
import java.util.Set; 
public class Order { 
    private String id; 
    private Date date; 
    private double priceTotal; 
    private Set orderItems = new HashSet(); 
     
    // 自动设置该Order的创建时间 
    public Order() { 
        this.date = new Date(); 
    } 
    public String getId() { 
        return id; 
    } 
    public void setId(String string) { 
        id = string; 
    } 
    // 为了简洁起见，其他getter/setter方法没有显示 
    // ... 
} 

package test.hibernate; 
public class OrderItem { 
    /** 
    * 创建有效的订单项。自动设置订单项的价格，并更正产品的库存可用量 
    *  
    * @param order 该订单项属于的订单 
    * @param product 该订单项为哪种产品而创建 
    * @param amount  
    */ 
    public OrderItem(Order order,  
                     Product product,  
                     int amount) { 
                      
        this.order = order; 
        this.product = product; 
        this.amount = amount; 
        product.setAmount(product.getAmount() - amount); 
        this.price = product.getPrice() * amount;         
    } 
    // 还需要默认的构造函数来保证Hibernate工作 
    /** 
    * 空构造函数遵循JavaBeans约定  
    * 
    */ 
    public OrderItem() { 
        // 空的默认构造函数 
    } 
    // 字段 
    private String id; 
    private Product product; 
    private Order order; 
    private String productId; 
    private String orderId; 
    private double price; 
    private int amount; 
     
    public String getId() { 
        return id; 
    } 
    public String getProductId() { 
        return product.getId(); 
    } 
    public String getOrderId() { 
        return order.getId(); 
    } 
    // 其他getter/setter方法没有显示 
    // ... 
    file://显示该订单项的方便方式 
    public String toString() { 
        return  
          "[OrderItem] id=" + id + " amount=" +  
          amount + " price=" + price + "(" +  
          product + ")"; 
    } 
} 

/** 
* 添加一项产品到订单中。产品自动成为一个订单项。  
* priceTotal被自动更新。 
*  
* @param p 添加到该订单的产品 
* @param amount 添加的产品量 
*/ 
public void addProduct(Product p,  
                       int amount) { 
   OrderItem orderItem = new OrderItem(this,  
                         p, amount); 
                          
   this.priceTotal = this.priceTotal  
                     + p.getPrice() * amount; 
                      
   this.orderItems.add(orderItem); 
} 

package test; 
import net.sf.hibernate.Session; 
import net.sf.hibernate.SessionFactory; 
import net.sf.hibernate.Transaction; 
import net.sf.hibernate.cfg.Configuration; 
import test.hibernate.Product; 
// 用法： 
// java test.InsertProduct name amount price 
public class InsertProduct { 
    public static void main(String[] args)  
                        throws Exception { 
        // 1. 创建Product对象 
        Product p = new Product(); 
        p.setName(args[0]); 
        p.setAmount(Integer.parseInt(args[1])); 
        p.setPrice(Double.parseDouble(args[2])); 
        // 2. 启动Hibernate 
        Configuration cfg = new Configuration() 
                         .addClass(Product.class); 
        SessionFactory sf = cfg.buildSessionFactory(); 
        // 3. 打开Session 
        Session sess = sf.openSession(); 
        // 4. 保存Product，关闭Session 
        Transaction t = sess.beginTransaction(); 
        sess.save(p); 
        t.commit(); 
        sess.close(); 
    } 
} 

Nov 23, 2003 9:05:50 AM net.sf.hibernate.cfg.Environment ＜clinit＞ 
INFO: Hibernate 2.0.3 
Nov 23, 2003 9:05:50 AM net.sf.hibernate.cfg.Environment ＜clinit＞ 
INFO: hibernate.properties not found 
Nov 23, 2003 9:05:50 AM net.sf.hibernate.cfg.Environment ＜clinit＞ 
INFO: using CGLIB reflection optimizer 
Nov 23, 2003 9:05:50 AM net.sf.hibernate.cfg.Environment ＜clinit＞ 
INFO: JVM proxy support: true 
Nov 23, 2003 9:05:50 AM net.sf.hibernate.cfg.Configuration addClass 
INFO: Mapping resource: test/hibernate/Product.hbm.xml 
Exception in thread "main" net.sf.hibernate.MappingException:  
Resource: test/hibernate/Product.hbm.xml not found 
    at net.sf.hibernate.cfg.Configuration.addClass(Configuration.java:285) 
    at test.FindProductByName.main(FindProductByName.java:24) 

INFO: hibernate.properties not found and 
Resource: test/hibernate/Product.hbm.xml not found.

hibernate.connection.username=sa 
hibernate.connection.password= 
hibernate.connection.url=jdbc:hsqldb:/home/davor/hibernate/orders 
hibernate.connection.driver_class=org.hsqldb.jdbcDriver 
hibernate.dialect=net.sf.hibernate.dialect.HSQLDialect 

＜?xml version="1.0" encoding="UTF-8"?＞ 
＜!DOCTYPE hibernate-mapping 
    PUBLIC "-//Hibernate/Hibernate Mapping DTD//EN" 
    "http://hibernate.sourceforge.net/hibernate-mapping-2.0.dtd"＞ 
     
＜hibernate-mapping＞ 
    ＜class name="test.hibernate.Product"  
           table="products"＞ 
               
        ＜id name="id" type="string"  
            unsaved-value="null"＞ 
            ＜column name="id" sql-type="char(32)"  
                    not-null="true"/＞ 
            ＜generator class="uuid.hex"/＞ 
        ＜/id＞ 
        ＜property name="name"＞ 
            ＜column name="name" sql-type="char(255)"  
                    not-null="true"/＞ 
        ＜/property＞ 
        ＜property name="price"＞ 
            ＜column name="price" sql-type="double"  
                    not-null="true"/＞ 
        ＜/property＞ 
        ＜property name="amount"＞ 
            ＜column name="amount" sql-type="integer"  
                    not-null="true"/＞ 
        ＜/property＞         
    ＜/class＞ 
＜/hibernate-mapping＞ 

ID                              |NAME  |PRICE |AMOUNT | 
40288081f907f42900f907f448460001|Milk  |1.99  |100    | 

package test; 
import java.util.List; 
import net.sf.hibernate.Hibernate; 
import net.sf.hibernate.Session; 
import net.sf.hibernate.SessionFactory; 
import net.sf.hibernate.cfg.Configuration; 
import test.hibernate.Product; 
// 用法： 
// java test.FindProductByName name 
public class FindProductByName { 
    public static void main(String[] args) throws Exception { 
        // 执行的查询 
        String query = 
            "select product from product " 
            + "in class test.hibernate.Product " 
            + "where product.name=:name"; 
        // 搜索的内容 
        String name = args[0]; 
        // 初始化 
        Configuration cfg = new Configuration() 
                           .addClass(Product.class); 
        SessionFactory sf = cfg.buildSessionFactory(); 
        // 打开会话 
        Session sess = sf.openSession(); 
         
        // 搜索并返回 
        List list = sess.find(query, name,  
                              Hibernate.STRING); 
        if (list.size() == 0) { 
            System.out.println("No products named "  
                               + name); 
            System.exit(0); 
        } 
        Product p = (Product) list.get(0); 
        sess.close(); 
        System.out.println("Found product: " + p); 
    } 
}

double percentage = Double.parseDouble(args[0])/100; 
sess = sf.openSession(); 
Transaction t = sess.beginTransaction(); 
// 列表包含产品 
Iterator iter = list.iterator(); 
while (iter.hasNext()) { 
    Product p = (Product) iter.next();             
    p.setPrice(p.getPrice() * (1 + percentage)); 
    sess.saveOrUpdate(p);       
} 
t.commit(); 
sess.close(); 

＜?xml version="1.0" encoding="UTF-8"?＞ 
＜!DOCTYPE hibernate-mapping 
    PUBLIC "-//Hibernate/Hibernate Mapping DTD//EN" 
    "http://hibernate.sourceforge.net/hibernate-mapping-2.0.dtd"＞ 
＜hibernate-mapping＞ 
    ＜class name="test.hibernate.Order" table="orders"＞ 
        ＜id name="id" type="string" unsaved-value="null" ＞ 
            ＜column name="id" sql-type="char(32)" not-null="true"/＞ 
            ＜generator class="uuid.hex"/＞ 
        ＜/id＞ 
        ＜property name="date"＞ 
         ＜column name="order_date"  
                 sql-type="datetime" not-null="true"/＞ 
        ＜/property＞ 
        ＜property name="priceTotal"＞ 
        ＜column name="price_total"  
                sql-type="double" not-null="true"/＞ 
        ＜/property＞ 
         
        ＜set name="orderItems" table="order_items" inverse="true"  cascade="all"＞ 
            ＜key column="order_id" /＞ 
            ＜one-to-many class="test.hibernate.OrderItem" /＞ 
        ＜/set＞ 
         
    ＜/class＞ 
＜/hibernate-mapping＞ 

＜?xml version="1.0" encoding="UTF-8"?＞ 
＜!DOCTYPE hibernate-mapping 
    PUBLIC "-//Hibernate/Hibernate Mapping DTD//EN" 
    "http://hibernate.sourceforge.net/hibernate-mapping-2.0.dtd"＞ 
＜hibernate-mapping＞ 
    ＜class name="test.hibernate.OrderItem"  
             table="order_items"＞ 
        ＜id name="id" type="string" unsaved-value="null" ＞ 
            ＜column name="id" sql-type="char(32)"  
                       not-null="true"/＞ 
            ＜generator class="uuid.hex"/＞ 
        ＜/id＞ 
        ＜property name="orderId" insert="false"  
                     update="false"＞ 
            ＜column name="order_id" sql-type="char(32)"  
                       not-null="true"/＞ 
        ＜/property＞ 
        ＜property name="productId" insert="false"  
                     update="false"＞ 
            ＜column name="product_id" sql-type="char(32)"  
                       not-null="true"/＞ 
        ＜/property＞ 
        ＜property name="amount"＞ 
            ＜column name="amount" sql-type="int"  
                       not-null="true"/＞ 
        ＜/property＞ 
        ＜property name="price"＞ 
            ＜column name="price" sql-type="double"  
                       not-null="true"/＞ 
        ＜/property＞ 
        ＜many-to-one name="order"  
                 class="test.hibernate.Order"  
                 column="order_id" /＞ 
        ＜many-to-one name="product"  
                 class="test.hibernate.Product"  
                 cascade="save-update"  
                 column="product_id"/＞ 
    ＜/class＞ 
＜/hibernate-mapping＞ 

// ... 
Configuration cfg = new Configuration() 
                    .addClass(Product.class) 
                    .addClass(Order.class) 
                    .addClass(OrderItem.class); 
// ... 
Order order = new Order(); 
order.addProduct(milk, 3); 
order.addProduct(coffee, 5); 
// ... 
sess = sf.openSession(); 
Transaction t = sess.beginTransaction(); 
sess.save(order); 
t.commit(); 
sess.close(); 
System.out.println(order); 
// ... 

// ... 
String query = "select o from o " 
    + "in class test.hibernate.Order " 
    + "where o.priceTotal ＞ :priceTotalLower " 
    + "and o.priceTotal ＜ :priceTotalUpper"; 
// ...                 
Query q = sess.createQuery(query); 
q.setDouble("priceTotalLower",  
             Double.parseDouble(args[0])); 
q.setDouble("priceTotalUpper",  
             Double.parseDouble(args[1])); 
List list = q.list(); 
// ... 
sess.close(); 
// ... 

// ... 
String query = "select o from o " 
    + "in class test.hibernate.Order " 
    + "where o.priceTotal ＞ :priceTotalLower " 
    + "and o.priceTotal ＜ :priceTotalUpper"; 
Transaction tx = sess.beginTransaction(); 
sess.delete(query,  
    new Object[]{new Double(args[0]),  
                 new Double(args[1])},  
    new Type[]{Hibernate.DOUBLE,  
               Hibernate.DOUBLE} 
           );        
tx.commit(); 
sess.close();