Hibernate的基本使用以及配置c3p0连接池

看价的后台基本也就那样了,水平有限,一开始没做功能划分,想到什么写什么,好在注释还是有的,虽然没有模块化,起码没一个类写几百行,要修修补补还是可以的。写了几段sql实在没耐心了,还是用框架吧,下面先来背背书。

Hibernate是一个开放源代码的对象关系映射框架,它对JDBC进行了非常轻量级的对象封装,使得Java程序员可以随心所欲的使用对象编程思维来操纵数据库。

配置Hibernate

导入jar包(是的,我不会用maven),在项目目录下建一个hibernate.cfg.xml文件,编辑如下

1
2
3
4
5
6
7
8
9
10
11
12
<hibernate-configuration>  
<session-factory >
<property name="hibernate.connection.driver_class">com.mysql.jdbc.Driver</property>
<property name="hibernate.connection.url">jdbc:mysql://localhost:3306/dbname</property>
<property name="hibernate.connection.username">root</property>
<property name="hibernate.connection.password">password</property>
<property name="hibernate.dialect">org.hibernate.dialect.MySQLDialect</property>
<property name="hibernate.show_sql">true</property>
<property name="hibernate.format_sql">true</property>
<mapping resource="com/bjpowernode/hibernate/User.hbm.xml"/>
</session-factory>
</hibernate-configuration>

注意其中的数据库名字、用户名、密码,mapping标签就是标记User这个model类,User.hbm.xml这个映射文件也要自己编辑。

编辑映射文件

比如现在有个User类,有以下属性

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
//id
private int id;
//clientID
private String clientID;
//用户名
private String username;
//密码
private String password;
//手机号码
private String phoneNumber;
//设备Token
private String deviceToken;
//添加商品的一些信息
private String itemID_AddDetails;
//创建时间
private Date createTime;
private String loginTime;

新建一个User.hbm.xml文件,编辑如下

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
<?xml version="1.0"?>
<!DOCTYPE hibernate-mapping PUBLIC
"-//Hibernate/Hibernate Mapping DTD 3.0//EN"
"http://hibernate.sourceforge.net/hibernate-mapping-3.0.dtd">
<hibernate-mapping>
<class name="com.sephilex.model.User">
<id name="id">
<generator class="identity"/>
</id>
<property name="username"/>
<property name="password"/>
<property name="deviceToken"/>
<property name="clientID"/>
<property name="createTime"/>
<property name="itemID_AddDetails"/>
<property name="phoneNumber"/>
<property name="loginTime"/>
</class>
</hibernate-mapping>

测试

  • 生成表
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
package com.sephilex.hibernateTest;  

import org.hibernate.cfg.Configuration;
import org.hibernate.tool.hbm2ddl.SchemaExport;

/**
* 将hbm生成ddl
* @author Administrator
*
*/
public class ExportDB {

public static void main(String[] args) {

//默认读取hibernate.cfg.xml文件
Configuration cfg = new Configuration().configure();

SchemaExport export = new SchemaExport(cfg);
export.create(true, true);
}
}

不过这一步一般都不用做,因为项目的数据库表一般都设置好了。

  • 写入数据
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
package com.sephilex.hibernate;  

import java.util.Date;

import org.hibernate.Session;
import org.hibernate.SessionFactory;
import org.hibernate.cfg.Configuration;

public class Client {

public static void main(String[] args) {

//读取hibernate.cfg.xml文件
Configuration cfg = new Configuration().configure();

//建立SessionFactory
SessionFactory factory = cfg.buildSessionFactory();

//取得session
Session session = null;
try {
session = factory.openSession();
//开启事务
session.beginTransaction();
User user = new User();
user.setName("张三");
user.setPassword("123");
user.setCreateTime(new Date());
user.setExpireTime(new Date());

//保存User对象
session.save(user);

//提交事务
session.getTransaction().commit();
}catch(Exception e) {
e.printStackTrace();
//回滚事务
session.getTransaction().rollback();
}finally {
if (session != null) {
if (session.isOpen()) {
//关闭session
session.close();
}
}
}
}
}

增删改查

先封装一些对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
import org.hibernate.Session;  
import org.hibernate.SessionFactory;
import org.hibernate.cfg.Configuration;

public class HibernateUtils {
/*
*读取Hibernate.cfg.xml文件
*/
private static SessionFactory factory;

static {
try {
//读取hibernate.cfg.xml文件
Configuration cfg = new Configuration().configure();

//建立SessionFactory
factory = cfg.buildSessionFactory();
}catch(Exception e) {
e.printStackTrace();
}
}
/*
*打开Session
*/

public static Session getSession() {
return factory.openSession();
}
/*
*关闭Session
*/

public static void closeSession(Session session) {
if (session != null) {
if (session.isOpen()) {
session.close();
}
}
}

public static SessionFactory getSessionFactory() {
return factory;
}
}

增删改查

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
import java.util.Date;  

import org.hibernate.Session;

import com.sephilex.hibernate.HibernateUtils;

import com.sephlex.hibernate.User;

import junit.framework.TestCase;

public class TestHibernate {
/*
* 增加User
*/
public void testSave() {

Session session = null;
try {
session = HibernateUtils.getSession();
session.beginTransaction();

User user = new User();
user.setName("李四");
user.setPassword("123");
user.setCreateTime(new Date());
user.setExpireTime(new Date());
session.save(user);
session.getTransaction().commit();
}catch(Exception e) {
e.printStackTrace();
session.getTransaction().rollback();
}finally {
HibernateUtils.closeSession(session);
}
}
/**
* 删除
*/
public void testDel(){
Session session = null;
try {
session = HibernateUtils.getSession();
session.beginTransaction();

User user=(User)session.load(User.class, "4028989545a244640145a24466300001");

session.delete(user);
session.getTransaction().commit();
}catch(Exception e) {
e.printStackTrace();
session.getTransaction().rollback();
}finally {
HibernateUtils.closeSession(session);
}
}

/**
* 修改
*/
public void testUpdate(){
Session session = null;
try {
session = HibernateUtils.getSession();
session.beginTransaction();

User user=(User)session.load(User.class, "4028989545a243ca0145a243cbf80001");
user.setName("王五");
session.update(user);
session.getTransaction().commit();
}catch(Exception e) {
e.printStackTrace();
session.getTransaction().rollback();
}finally {
HibernateUtils.closeSession(session);
}
}

/**
* 查询
*/
public void testLoad(){
Session session = null;
try {
session = HibernateUtils.getSession();
session.beginTransaction();

User user=(User)session.load(User.class, "4028989545a243ca0145a243cbf80001");
System.out.println(user.getName());
System.out.println(user.getId());
System.out.println(user.getPassword());
System.out.println(user.getClass());
System.out.println(user.getCreateTime());
System.out.println(user.getExpireTime());
session.getTransaction().commit();
}catch(Exception e) {
e.printStackTrace();
session.getTransaction().rollback();
}finally {
HibernateUtils.closeSession(session);
}
}
}

配置c3p0连接池

假装有用户,假装有并发
配置如下:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
<!-- c3po配置-->
<property name="hibernate.connection.provider_class">org.hibernate.connection.C3P0ConnectionProvider</property>
<!-- 最大连接数 -->
<property name="hibernate.c3p0.max_size">20</property>
<!-- 最小连接数 -->
<property name="hibernate.c3p0.min_size">5</property>
<property name="hibernate.c3p0.timeout">300</property>
<property name="automaticTestTable">Test</property>
<property name="hibernate.c3p0.max_statements">100</property>
<property name="hibernate.c3p0.idle_test_period">120</property>
<property name="hibernate.c3p0.acquire_increment">1</property>
<property name="c3p0.testConnectionOnCheckout">true</property>
<!-- 每次都验证连接是否可用 -->
<property name="hibernate.c3p0.validate">true</property>
<property name="c3p0.idleConnectionTestPeriod">18000</property>
<property name="c3p0.maxIdleTime">25000</property>
<property name="c3p0.idle_test_period">120</property>
<!-- 结束-->

本文标题:Hibernate的基本使用以及配置c3p0连接池

文章作者:Sephilex

发布时间:2016年11月13日 - 20:11

最后更新:2019年12月13日 - 21:12

原始链接:https://sephilex.com/2016/11/13/Hibernate的基本使用以及配置c3p0连接池/

许可协议: 署名-非商业性使用-禁止演绎 4.0 国际 转载请保留原文链接及作者。

坚持原创技术分享,您的支持将鼓励我继续创作!