博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
Hibernate的ORM原理和实现
阅读量:5826 次
发布时间:2019-06-18

本文共 6464 字,大约阅读时间需要 21 分钟。

1.Hibernate和ORM

ORM的全称是Object Relational Mapping,即对象关系映射。它的实现思想就是将关系数据库中表的数据映射成为对象,以对象的形式展现,这样开发人员就可以把对数据库的操作转化为对这些对象的操作。因此它的目的是为了方便开发人员以面向对象的思想来实现对数据库的操作。

2.Hibernate是如何实现映射的

在使用Hibernate实现ORM功能的时候,主要的文件有:映射类(*.java)、映射文件(*.hbm.xml)以及数据库配置文件(*.properties或*.cfg.xml),它们各自的作用如下:

⑴映射类:它的作用是描述数据库表的结构,表中的字段在类中被描述成属性,将来就可以实现把表中的记录映射成为该类的对象。
⑵映射文件:它的作用是指定数据库表和映射类之间的关系,包括映射类和数据库表的对应关系、表字段和类属性类型的对应关系以及表字段和类属性名称的对应关系等。
⑶数据库配置文件:它的作用是指定与数据库连接时需要的连接信息,比如连接哪中数据库、登录用户名、登录密码以及连接字符串等。
在这三种主要的文件中,映射类为普通Java源文件、映射文件为XML格式、数据库配置文件为Properties格式或者是XML格式。想理解“映射”首先我们需要知道如何解析这三种文件,即解析XML格式文件、解析Properties格式文件和解析Java类文件。

⑴如何解析XML文件

解析XML的技术可以分为两类那就是SAX和DOM,这两种方式有各自的差别和优缺点。实现解析XML文件的功能很方便,我们可以通过下载第三方的一些工具包如xml-apis.jar和xercesImpl.jar等,也可以使用JDK自带的工具类DocumentBuilderFactory、
DocumentBuilder、Document、Element等等,大家可以通过API文挡查阅这些类的说明。通过这些类我们可以把XML文件的信息读入内存并通过类中的某些方法获取指定节点的名字、值、属性名、属性值这些信息。
⑵解析Properties文件
Properties文件一般采用“属性名=属性值”的形式描述信息。
如果配置文件采用Properties文件描述,我们就需要想办法解析这种类型的文件了。想解析Properties文件需要熟悉Properties这个类了,这个类有一些常用方法比如,load()加载指定文件并读取文件中的属性信息,PropertyNames()返回所有属性名,getProperty()返回指定属性名的属性值。通过解析Properties文件我们可以得到连接数据库必要的信息,然后通过底层JDBC技术与数据库建立连接。
⑶解析Java类文件
通过解析映射文件和数据库配置文件我们可以建立数据库的连接,可以得到映射类的名字、属性名、数据库表名、字段名以及类型等信息。要把数据库中表的数据映射成为对象,首先需要把表中的记录取出,然后将每个字段值给映射类对象的每个属性,这个赋值过程要调用对象中的set方法。
我们现在通过映射文件只知道类名和属性名,如何根据类名和属性名调用相应的set和get方法,是一个关键问题。在Java中有一种机制叫反射机制,使用这种机制我们可以得到类的信息,包括类只用的修饰符、方法、属性、继承的父类以及实现接口等信息。
反射机制相关的类有Class、Field、Method以及Constructor等。通过Class的getFields()、getMethods()和getConstructors()方法得到相应的属性、方法和构造方法。
通过Field类的getName()、getType()和getModifiers()方法得到相应的属性名、属性类型、属性修饰符信息。
通过Method类getReturnType()可以获取方法的返回类型,
invoke()方法可以根据给定的方法名和参数值执行对象中对应的方法。
我们可以首先通过以上方法获取类中的属性名,然后拼写成setXXX和getXXX方法名,最后根据方法名执行对应的方法,将数据库数据加载到对象中。

整理自 

3.模拟Hibernate加载配置文件并映射到实体类的过程

 

(1)创建实体类

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
/**
 
* 示例实体对象
 
* 对应学生表
 
*/
public 
class 
Student {
 
    
private 
int 
id;
    
private 
String name;
    
private 
String score;
    
public 
int 
getId() {
        
return 
id;
    
}
    
public 
void 
setId(
int 
id) {
        
this
.id = id;
    
}
    
public 
String getName() {
        
return 
name;
    
}
    
public 
void 
setName(String name) {
        
this
.name = name;
    
}
    
public 
String getScore() {
        
return 
score;
    
}
    
public 
void 
setScore(String score) {
        
this
.score = score;
    
}
}

  

(2)模拟解析hbm.xml和数据库配置文件,并且创建Session

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
import 
java.io.IOException;
import 
java.lang.reflect.Method;
import 
java.sql.Connection;
import 
java.sql.DriverManager;
import 
java.sql.PreparedStatement;
import 
java.util.HashMap;
import 
java.util.List;
import 
java.util.Map;
import 
org.jdom.Document;
import 
org.jdom.Element;
import 
org.jdom.JDOMException;
import 
org.jdom.input.SAXBuilder;
import 
org.jdom.xpath.XPath;
 
/**
 
* 模拟Session类实现
 
*/
public 
class 
Session {
     
    
/**
     
* 模拟Stument.hbm.xml文件的内容
     
* 这里没有解析hbm.xml
     
*/
    
private 
Map<String ,String > hbmInfo = 
new 
HashMap<String ,String >();
     
    
//存放数据库连接配置
    
private 
Map<String, String> conConfig = 
new 
HashMap<String, String>();
 
    
//实体的get方法集合
    
String methodNames[];
     
    
public 
Session(){
        
/**
         
* 初始化实体,具体的实现应该是读取hbm.xml文件解析字段
         
*/
        
hbmInfo.put(
"id"
"id"
); 
        
hbmInfo.put(
"name"
"name"
); 
        
hbmInfo.put(
"password"
"password"
); 
        
methodNames = 
new 
String[hbmInfo.size()]; 
    
}
 
    
/**
     
* 创建数据库连接
     
* @return
     
* @throws IOException
     
* @throws JDOMException
     
*/
    
public 
Connection initConn() 
throws 
Exception{
        
SAXBuilder sb = 
new 
SAXBuilder(); 
        
Document doc = sb.build(
this
.getClass().getClassLoader().getResourceAsStream(
"hibernate.cfg.xml"
)); 
        
Element root = doc.getRootElement(); 
        
List list = XPath.selectNodes(root, 
"/hibernate-configuration/property"
); 
 
        
for 
(
int 
i = 
0
; i < list.size(); i++) {             
           
Element property = (Element) list.get(i); 
           
String name = property.getAttributeValue(
"name"
); 
           
String value = property.getText();          
           
conConfig.put(name, value);          
          
}
         
      
//根据配置文件获得数据库连接
        
Class.forName(conConfig.get(
"driver"
)); 
        
Connection con = DriverManager.getConnection(conConfig.get(
"url"
),conConfig.get(
"username"
),conConfig.get(
"password"
));
        
return 
con; 
    
}
     
    
/**
     
* 持久化对象
     
* @param student
     
*/
    
public 
void 
save(Student student) {
         
         
String sql = getSaveStatement(); 
         
System.out.println(sql); 
       
         
try 
{
            
//获得连接
            
Connection con = initConn();
            
//创建jdbc执行语句
            
PreparedStatement state =  (PreparedStatement) con.prepareStatement(sql); 
             
            
for
(
int 
i=
0
;i<methodNames.length;i++) { 
 
                
//得到每一个方法的对象 
                
Method method = student.getClass().getMethod(methodNames[i]); 
 
                
//得到他的返回类型 
                
Class cla = method.getReturnType(); 
 
                
//根据返回类型来设置插入数据库中的每个属性值。 
                
if
(cla.getName().equals(
"java.lang.String"
)) { 
                    
String returnValue = (String)method.invoke(student); 
                    
state.setString(i+
1
, returnValue); 
                
                
else 
if
(cla.getName().equals(
"int"
)) { 
                    
Integer returnValue = (Integer) method.invoke(student); 
                    
state.setInt(i+
1
, returnValue); 
                
}                       
            
 
            
state.executeUpdate(); 
            
state.close(); 
            
con.close(); 
        
catch 
(Exception e) {
            
e.printStackTrace();
        
    
}
     
     
    
private 
String getSaveStatement(){
        
//strColumn代表数据库中表中的属性列。并将其连接起来。 
        
String strColumn = 
""
        
int 
index=
0
        
for
(String key :hbmInfo.keySet()) 
        
            
strColumn +=key+
","
            
String v = hbmInfo.get(key); 
 
            
//获得属性的get方法,需要将属性第一个字母大写如:getId()
            
v = 
"get" 
+ Character.toUpperCase(v.charAt(
0
)) + v.substring(
1
); 
            
methodNames[index] = v;
            
index++; 
        
        
strColumn  = strColumn.substring(
0
, strColumn.length()-
1
); 
 
        
//拼接参数占位符,即:(?, ?, ?)
        
String strValue = 
""
        
for
(
int 
i=
0
;i<hbmInfo.size();i++) 
            
strValue +=
"?,"
;       
        
strValue = strValue.substring(
0
,strValue.length()-
1
); 
 
        
String sql = 
"insert into " 
+ hbmInfo.get(
"tableName"
) +
"(" 
+ strColumn + 
")" 
" values (" 
+ strValue + 
")"
;  
        
return 
sql; 
    
     
}

(3)测试持久化

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
public 
class 
Test {
 
    
/**
     
* 测试持久化
     
* 数据库语句:
     
* DROP TABLE IF EXISTS `tb_student`; 
     
* CREATE TABLE tb_student (
     
* `id` int(10) NOT NULL DEFAULT 0 ,
     
* `name` varchar(50) DEFAULT NULL ,
     
* `score` int(11) DEFAULT 0 ,
     
* PRIMARY KEY (`id`)
     
* )ENGINE=MyISAM  DEFAULT CHARSET=utf8;
     
*/
    
public 
void 
main(){
        
Student student=
new 
Student();
        
student.setId(
100
);
        
student.setName(
"Tom"
);
        
student.setScore(
"99"
);
        
//获得Session对象
        
Session session=
new 
Session();
        
//执行持久化操作
        
session.save(student);
    
}
     
}

  

 

本文转自邴越博客园博客,原文链接:http://www.cnblogs.com/binyue/p/3966322.html,如需转载请自行联系原作者

你可能感兴趣的文章
KVM脚本批量添加删除虚拟机
查看>>
oracle学习笔记-第三篇
查看>>
我的友情链接
查看>>
centos 6.8 安装 pure-ftpd-1.0.43,采用MariaDB作为用户数据库
查看>>
C#利用Socket实现C/S模式通信
查看>>
logback + log4jdbc-log4j2 输出 jpa sql 参数实际value
查看>>
pxe整合dnsmasq
查看>>
Linux下L2TP ***客户端的配置
查看>>
SQL Server 排名函数
查看>>
Linux(Red Hat Linux 9)中关于程序的存放目录
查看>>
iptables详解(二)
查看>>
xenserver 虚机磁盘突破2TB限制
查看>>
ps抠树
查看>>
编辑php.ini配置文件
查看>>
Visual Studio 2017对xp的支持
查看>>
fadingEdge
查看>>
hello world
查看>>
php 文件操作
查看>>
Python开发(基础):列表List
查看>>
支付宝SDK官方下载-移动端、服务端各个平台通用
查看>>