声明事务管理（数据库连接池）
1.dao
1 package com.zhidi.dao;
2
3 import java.sql.Connection;
4 import java.sql.PreparedStatement;
5 import java.sql.ResultSet;
6 import java.sql.SQLException;
7
8 import javax.sql.DataSource;
9
10 import org.hibernate.Session;
11 import org.hibernate.SessionFactory;
12 import org.springframework.beans.factory.annotation.Autowired;
13 import org.springframework.stereotype.Repository;
14
15 import com.zhidi.entity.Emp;
16
17 @Repository
18 public class EmpDao {
19 @Autowired
20 private DataSource dataSource;
21 @Autowired
22 private SessionFactory sessionFactory;
23
24 public void query() {
25 try {
26 Connection connection = dataSource.getConnection();
27 PreparedStatement statement = connection.prepareStatement("select * from emp");
28 ResultSet set = statement.executeQuery();
29 while (set.next()) {
30 String name = set.getString("ename");
31 System.out.println(name);
32 }
33 } catch (SQLException e) {
34 e.printStackTrace();
35 }
36 }
37
38 public void get(Integer id) {
39 Session session = sessionFactory.getCurrentSession();
40 session.beginTransaction();
41 session.get(Emp.class, id);
42 session.getTransaction().commit();
43 }
44
45 public Emp getById(Integer id)
46 {
47 Session session = sessionFactory.getCurrentSession();
48 Emp emp=(Emp)session.get(Emp.class, id);
49 return emp;
50 }
51
52 public void delete(Integer id)
53 {
54 Session session = sessionFactory.getCurrentSession();
55 Emp emp= getById(id);
56 session.delete(emp);
57
58 }
59 }
2.entity
1 package com.zhidi.entity;
2
3 import java.util.Date;
4
5 import javax.persistence.Entity;
6 import javax.persistence.GeneratedValue;
7 import javax.persistence.GenerationType;
8 import javax.persistence.Id;
9 import javax.persistence.Table;
10 import javax.persistence.Temporal;
11 import javax.persistence.TemporalType;
12
13 @Entity
14 @Table(name = "emp")
15 public class Emp {
16 @Id
17 @GeneratedValue(strategy = GenerationType.AUTO)
18 private Integer empno;
19 private String ename;
20 @Temporal(TemporalType.DATE)
21 private Date hiredate;
22
23 public Integer getEmpno() {
24 return empno;
25 }
26
27 public void setEmpno(Integer empno) {
28 this.empno = empno;
29 }
30
31 public String getEname() {
32 return ename;
33 }
34
35 public void setEname(String ename) {
36 this.ename = ename;
37 }
38
39 public Date getHiredate() {
40 return hiredate;
41 }
42
43 public void setHiredate(Date hierdate) {
44 this.hiredate = hierdate;
45 }
46
47 }
3.service
1 package com.zhidi.service;
2
3 import org.springframework.beans.factory.annotation.Autowired;
4 import org.springframework.stereotype.Service;
5 import org.springframework.transaction.annotation.Propagation;
6 import org.springframework.transaction.annotation.Transactional;
7
8 import com.zhidi.dao.EmpDao;
9 import com.zhidi.entity.Emp;
10 @Transactional
11 @Service
12 public class EmpService {
13 @Autowired
14 private EmpDao empDao;
15 @Transactional(propagation=Propagation.SUPPORTS,readOnly=true)
16 public Emp getById(Integer id)
17 {
18 return empDao.getById(id);
19 }
20
21 public void deleteById(Integer id)
22 {
23 empDao.delete(id);
24 }
25
26 }
4.test
1 package com.zhidi.test;
2
3 import org.springframework.context.ApplicationContext;
4 import org.springframework.context.support.ClassPathXmlApplicationContext;
5
6 import com.zhidi.dao.EmpDao;
7
8 public class TestEmp {
9
10 public static void main(String[] args) {
11 @SuppressWarnings("resource")
12 ApplicationContext context = new ClassPathXmlApplicationContext("applicationContext.xml");
13 EmpDao empDao = context.getBean(EmpDao.class);
14 empDao.query();
15
16 empDao.get(7965);
17 }
18 }
1 package com.zhidi.test;
2
3 import org.springframework.context.ApplicationContext;
4 import org.springframework.context.support.ClassPathXmlApplicationContext;
5
6 import com.zhidi.entity.Emp;
7 import com.zhidi.service.EmpService;
8
9 public class TestTx {
10
11 public static void main(String[] args) {
12 @SuppressWarnings("resource")
13 ApplicationContext context =new ClassPathXmlApplicationContext("applicationContext.xml");
14 EmpService service=context.getBean(EmpService.class);
15 Emp emp=service.getById(7959);
16 System.out.println(emp.getEname());
17
18 service.deleteById(7951);
19
20 }
21
22 }
5.applicationContext.xml
1 <?xml version="1.0" encoding="UTF-8"?>
2 <beans xmlns="http://www.springframework.org/schema/beans"
3 xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:aop="http://www.springframework.org/schema/aop"
4 xmlns:context="http://www.springframework.org/schema/context" xmlns:tx="http://www.springframework.org/schema/tx"
5 xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
6 http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.3.xsd
7 http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-4.3.xsd
8 http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-4.3.xsd">
9
10 <!-- 打开配置 -->
11 <!-- <context:component-scan base-package="com.zhidi" /> -->
12 <context:property-placeholder location="jdpc.properties" />
13 <!-- 将c3p0交给Spring的IOC容器管理 -->
14 <bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
15 <!-- 必要的配置 -->
16 <property name="driverClass" value="${jdpc.driverClass}" />
17 <property name="jdbcUrl" value="${jdpc.url}" />
18 <property name="user" value="${jdpc.userName}" />
19 <property name="password" value="${jdpc.password}" />
20 <!-- 初始化连接数 -->
21 <property name="initialPoolSize" value="3" />
22 <!-- 最大连接数 -->
23 <property name="maxPoolSize" value="10" />
24 <!-- 最小连接数 -->
25 <property name="minPoolSize" value="1"></property>
26 <!-- 最大的连接时间8小时 -->
27 <property name="maxConnectionAge" value="28800"></property>
28 <!-- 需要防止8小时陷阱，需要设置时间小于8小时 -->
29 <!-- 设置为6小时 -->
30 <property name="maxIdleTime" value="21600"></property>
31 </bean>
32
33 <!-- 将LocalSessionFactoryBean交给Spring的IOC容器管理 -->
34 <bean id="sessionFactory"
35 class="org.springframework.orm.hibernate4.LocalSessionFactoryBean">
36 <!-- 将c3p0的数据源注入到SessionFactory -->
37 <property name="dataSource" ref="dataSource"></property>
38 <!-- 指定hibernate的配置信息 -->
39 <property name="hibernateProperties">
40 <props>
41 <prop key="hibernate.dialect">org.hibernate.dialect.MySQL5Dialect</prop>
42 <prop key="hibernate.show_sql">true</prop>
43 <prop key="hibernate.format_sql">true</prop>
44 <!-- 删掉或者把 thread改为org.springframework.orm.hibernate4.SpringSessionContext-->
45 <prop key="hibernate.current_session_context_class">org.springframework.orm.hibernate4.SpringSessionContext</prop>
46 </props>
47 </property>
48 <!-- 指定扫描@entity的实体类 -->
49 <property name="packagesToScan" value="com.zhidi.entity" />
50 </bean>
51
52 <!-- 定义hibernate的事务管理 -->
53 <bean id="transactionManager"
54 class="org.springframework.orm.hibernate4.HibernateTransactionManager">
55 <!-- 将sessionFactory注入事务管理器中 -->
56 <property name="sessionFactory" ref="sessionFactory" />
57 </bean>
58 <!-- 开启事务管理的配置 -->
59 <tx:annotation-driven transaction-manager="transactionManager"/>
60
61 <!-- 配置事务管理 -->
62 <!-- <tx:advice id="txAdvice" transaction-manager="transactionManager">
63 为不同的目标方法指定不同的事务属性
64 <tx:attributes>
65 name指定该事务属性对应的方法 propagation指事务的传播特性 read-only只读
66 <tx:method name="add*" propagation="REQUIRED" />
67 <tx:method name="save*" propagation="REQUIRED" />
68 <tx:method name="delete*" propagation="REQUIRED" />
69 <tx:method name="modeif*" propagation="REQUIRED" />
70 <tx:method name="update*" propagation="REQUIRED" />
71 <tx:method name="get*" propagation="SUPPORTS" read-only="true" />
72 <tx:method name="query*" propagation="SUPPORTS" read-only="true" />
73 <tx:method name="search*" propagation="SUPPORTS" read-only="true" />
74 <tx:method name="*" propagation="SUPPORTS" read-only="true" />
75 </tx:attributes>
76 </tx:advice> -->
77
78 <!-- 定义事务处理的AOP切面 -->
79 <aop:config>
80 <aop:advisor advice-ref="txAdvice"
81 pointcut="execution(* com.zhidi.service..*.*(..))" />
82 </aop:config>
83
84 </beans>
6.properties
1 jdpc.driverClass=com.mysql.jdbc.Driver 2 jdpc.url=jdbc:mysql://localhost:3306/db_hibernate 3 jdpc.userName=root 4 jdpc.password=775297
1 ### direct log messages to stdout ###
2 log4j.appender.stdout=org.apache.log4j.ConsoleAppender
3 log4j.appender.stdout.Target=System.out
4 log4j.appender.stdout.layout=org.apache.log4j.PatternLayout
5 log4j.appender.stdout.layout.ConversionPattern=%d{ABSOLUTE} %5p %c{1}:%L - %m%n
6
7 ### direct messages to file hibernate.log ###
8 #log4j.appender.file=org.apache.log4j.FileAppender
9 #log4j.appender.file.File=hibernate.log
10 #log4j.appender.file.layout=org.apache.log4j.PatternLayout
11 #log4j.appender.file.layout.ConversionPattern=%d{ABSOLUTE} %5p %c{1}:%L - %m%n
12
13 ### set log levels - for more verbose logging change ‘info‘ to ‘debug‘ ###
14
15 log4j.rootLogger=warn, stdout
16
17 #log4j.logger.org.hibernate=info
18 log4j.logger.org.hibernate=debug
19
20 ### log HQL query parser activity
21 #log4j.logger.org.hibernate.hql.ast.AST=debug
22
23 ### log just the SQL
24 #log4j.logger.org.hibernate.SQL=debug
25
26 ### log JDBC bind parameters ###
27 log4j.logger.org.hibernate.type=info
28 #log4j.logger.org.hibernate.type=debug
29
30 ### log schema export/update ###
31 log4j.logger.org.hibernate.tool.hbm2ddl=debug
32
33 ### log HQL parse trees
34 #log4j.logger.org.hibernate.hql=debug
35
36 ### log cache activity ###
37 #log4j.logger.org.hibernate.cache=debug
38
39 ### log transaction activity
40 #log4j.logger.org.hibernate.transaction=debug
41
42 ### log JDBC resource acquisition
43 #log4j.logger.org.hibernate.jdbc=debug
44
45 ### enable the following line if you want to track down connection ###
46 ### leakages when using DriverManagerConnectionProvider ###
47 #log4j.logger.org.hibernate.connection.DriverManagerConnectionProvider=trace
时间： 2024-10-26 17:36:27