Spring+quartz删除超时订单的测试

- 日理万妓 2022-06-14 10:23 170阅读 0赞

建立一张简单的表：myorder（order是保留字不能做数据库表名），字段：id,和date（下订单的时间）

status(是否支付的状态)，uid（外键，关联下订单的人）。

applicationContext.xml文件：

<?xml version="1.0" encoding="UTF-8"?>
    <beans
    	xmlns="http://www.springframework.org/schema/beans"
    	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    	xmlns:p="http://www.springframework.org/schema/p"
    	xsi:schemaLocation="http://www.springframework.org/schema/beans
    	http://www.springframework.org/schema/beans/spring-beans-3.1.xsd">
    
    <bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">
       <property name="driverClassName" value="com.mysql.jdbc.Driver"/>
    	    <property name="url" value="jdbc:mysql://localhost:3306/message"/>
    	    <property name="username" value="root"/>
    	    <property name="password" value="123456"/>
    	     
    	<property name="initialSize" value="3"/>
    	 
    	 <property name="maxActive" value="500"/>
     
    	<property name="maxIdle" value="2"/>
    	
    	<property name="minIdle" value="1"/>
    	</bean>
    
    <bean id="sessionFactory" class="org.springframework.orm.hibernate4.LocalSessionFactoryBean">
    <property name="dataSource" ref="dataSource"></property>
    <property name="mappingResources">
    <list>
       <value>domain/Order.hbm.xml</value>
    </list>
    </property>
     <property name="hibernateProperties">
    	    <value>
    	        	hibernate.dialect=org.hibernate.dialect.MySQLDialect
    	        	hibernate.hbm2ddl.auto=update
    				hibernate.show_sql=true
    				hibernate.format_sql=false	      
    	  </value>
        </property>
    </bean>
    <bean id="test" class="imp.OrderImp">
     <property name="sessionFactory" ref="sessionFactory">
    </property>
    </bean>
    
    <bean id="methodInvokingJobDetail" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
    <property name="targetObject">
    <ref bean="test"/>
    </property>
    <property name="targetMethod">
    <value>addOrder</value>
    </property>
    </bean>
    <bean id="methodInvokingJobDetail2" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
    <property name="targetObject">
    <ref bean="test"/>
    </property>
    <property name="targetMethod">
    <value>delete</value>
    </property>
    </bean>
    
    <bean id="cronTrigger" class="org.springframework.scheduling.quartz.CronTriggerBean">
    <property name="jobDetail" ref="methodInvokingJobDetail"></property>
    
           <property name="cronExpression">
               <value>0 * 08-21 * * ?</value>
           </property>
    </bean>
    <bean id="cronTrigger2" class="org.springframework.scheduling.quartz.CronTriggerBean">
    <property name="jobDetail" ref="methodInvokingJobDetail2"></property>
    
           <property name="cronExpression">
               <value>0 * 08-21 * * ?</value>
           </property>
    </bean>
     <bean lazy-init="false"
        class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
           
           <property name="triggers">
               <list>
                  <ref local="cronTrigger" />
                  <ref local="cronTrigger2"/>
               </list>
           </property>
        </bean>
    </beans>

imp:

package imp;
    
    import java.text.SimpleDateFormat;
    import java.util.Date;
    import java.util.List;
    
    import org.hibernate.Query;
    import org.hibernate.Session;
    import org.hibernate.SessionFactory;
    import org.hibernate.Transaction;
    
    import domain.Order;
    
    import interfa.OrderInter;
    
    public class OrderImp implements OrderInter {
    private SessionFactory sessionFactory;
    public void setSessionFactory(SessionFactory sessionFactory) {
    	this.sessionFactory = sessionFactory;
    }
    	public void addOrder() {
    		// TODO Auto-generated method stub
    		Session s=sessionFactory.openSession();
    		Transaction t=s.beginTransaction();
    		Order order=new Order(new Date());
    		s.save(order);
    		System.out.println("加一条订单");
    		t.commit();
    		s.close();
    	}
    	public void delete() {
    		// TODO Auto-generated method stub
    		Session s=sessionFactory.openSession();
    		Transaction t=s.beginTransaction();
    		List<Order> list=s.createQuery("from Order order by id desc").list();
    		for(int i=0;i<list.size();i++){
    			Date date=new Date();
    			if((date.getTime()-list.get(i).getDate().getTime())/1000>3*60){
    				 Query query=s.createQuery("delete from Order where id="+list.get(i).getId()+"");
    				 query.executeUpdate();
    				 System.out.println("删除一条存在3分钟的订单");
    				t.commit();
    			} 
    			else{
    				System.out.println("没有可删除的订单");
    			}
    		
    			}
    		}
    	}

test

package test;
    
    import org.springframework.context.ApplicationContext;
    import org.springframework.context.support.ClassPathXmlApplicationContext;
    
    import interfa.OrderInter;
    
    public class Test {
    public static void main(String[] args) {
    	ApplicationContext applicationContext= new ClassPathXmlApplicationContext("applicationContext.xml");
    	System.out.println("begin ");
    }
    }

这样就每隔一分钟添加一条数据库，删除一条未支付时间超过三分钟的订单：

![Center][]

[Center]: /images/20220614/2cbc18174bc142b68624b4a2dbcf850e.png